Skip to content

Commit afeef45

Browse files
authored
TeamScale cleanup for TLogServer.actor.cpp (#12406)
1 parent 6bfe9da commit afeef45

File tree

1 file changed

+13
-8
lines changed

1 file changed

+13
-8
lines changed

fdbserver/TLogServer.actor.cpp

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -510,15 +510,16 @@ struct LogData : NonCopyable, public ReferenceCounted<LogData> {
510510
// If persistentDataVersion != persistentDurableDataVersion,
511511
// then spilling is happening from persistentDurableDataVersion to persistentDataVersion.
512512
// Data less than persistentDataDurableVersion is spilled on disk (or fully popped from the TLog);
513-
VersionMetricHandle persistentDataVersion,
514-
persistentDataDurableVersion; // The last version number in the portion of the log (written|durable) to
515-
// persistentData
513+
VersionMetricHandle persistentDataVersion;
514+
VersionMetricHandle persistentDataDurableVersion; // The last version number in the portion of the log
515+
// (written|durable) to persistentData
516516
NotifiedVersion version;
517517
NotifiedVersion queueCommittedVersion; // The disk queue has committed up until the queueCommittedVersion version.
518518
Version queueCommittingVersion;
519519
Version knownCommittedVersion; // The maximum version that a proxy has told us that is committed (all TLogs have
520520
// ack'd a commit for this version).
521-
Version durableKnownCommittedVersion, minKnownCommittedVersion;
521+
Version durableKnownCommittedVersion;
522+
Version minKnownCommittedVersion;
522523
Version queuePoppedVersion; // The disk queue has been popped up until the location which represents this version.
523524
Version minPoppedTagVersion;
524525
Tag minPoppedTag; // The tag that makes tLog hold its data and cause tLog's disk queue increasing.
@@ -580,8 +581,10 @@ struct LogData : NonCopyable, public ReferenceCounted<LogData> {
580581
Future<Void> removed;
581582
PromiseStream<Future<Void>> addActor;
582583
TLogData* tLogData;
583-
Promise<Void> recoveryComplete, committingQueue;
584-
Version unrecoveredBefore, recoveredAt;
584+
Promise<Void> recoveryComplete;
585+
Promise<Void> committingQueue;
586+
Version unrecoveredBefore;
587+
Version recoveredAt;
585588
Version recoveryTxnVersion;
586589

587590
struct PeekTrackerData {
@@ -631,7 +634,8 @@ struct LogData : NonCopyable, public ReferenceCounted<LogData> {
631634
Tag remoteTag;
632635
bool isPrimary;
633636
int logRouterTags;
634-
Version logRouterPoppedVersion, logRouterPopToVersion;
637+
Version logRouterPoppedVersion;
638+
Version logRouterPopToVersion;
635639
int8_t locality;
636640
UID recruitmentID;
637641
TLogSpillType logSpillType;
@@ -799,8 +803,9 @@ void TLogQueue::forgetBefore(Version upToVersion, Reference<LogData> logData) {
799803
// Keep only the given and all subsequent version numbers
800804
// Find the first version >= upTo
801805
auto v = logData->versionLocation.lower_bound(upToVersion);
802-
if (v == logData->versionLocation.begin())
806+
if (v == logData->versionLocation.begin()) {
803807
return;
808+
}
804809

805810
if (v == logData->versionLocation.end()) {
806811
v = logData->versionLocation.lastItem();

0 commit comments

Comments
 (0)