wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

clang-format

This commit is contained in:
Evan Tschannen 2021-03-19 13:17:39 -07:00
parent 78e81e514a
commit e1ebe2f487
3 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
fdbrpc/sim2.actor.cpp
View File

@ -2100,7 +2100,7 @@ public:
fprintf(randLog,
"T %f %f %d %s %" PRId64 "\n",
this->time,
this->actualTime,
this->actualTime,
int(deterministicRandom()->peek() % 10000),
t.machine ? t.machine->name : "none",
t.stable);

6
fdbserver/CommitProxyServer.actor.cpp
View File

@ -1062,7 +1062,8 @@ ACTOR Future<Void> postResolution(CommitBatchContext* self) {
state const Optional<UID>& debugID = self->debugID;
state Span span("MP:postResolution"_loc, self->span.context);
TEST(pProxyCommitData->latestLocalCommitBatchLogging.get() < localBatchNumber - 1); // Queuing post-resolution commit processing
TEST(pProxyCommitData->latestLocalCommitBatchLogging.get() <
localBatchNumber - 1); // Queuing post-resolution commit processing
wait(pProxyCommitData->latestLocalCommitBatchLogging.whenAtLeast(localBatchNumber - 1));
wait(yield(TaskPriority::ProxyCommitYield1));
@ -1275,7 +1276,8 @@ ACTOR Future<Void> reply(CommitBatchContext* self) {
// self->committedVersion by reporting commit version first before updating self->committedVersion. Otherwise, a
// client may get a commit version that the master is not aware of, and next GRV request may get a version less than
// self->committedVersion.
TEST(pProxyCommitData->committedVersion.get() > self->commitVersion); // A later version was reported committed first
TEST(pProxyCommitData->committedVersion.get() >
self->commitVersion); // A later version was reported committed first
if (self->commitVersion >= pProxyCommitData->committedVersion.get()) {
wait(pProxyCommitData->master.reportLiveCommittedVersion.getReply(
ReportRawCommittedVersionRequest(self->commitVersion,

10
fdbserver/DiskQueue.actor.cpp
View File

@ -882,7 +882,8 @@ public:
uint8_t const* begin = contents.begin();
uint8_t const* end = contents.end();
TEST(contents.size() && pushedPageCount()); // More than one push between commits
TEST(contents.size() >= 4 && pushedPageCount() && backPage().remainingCapacity() < 4); // Push right at the end of a page, possibly splitting size
TEST(contents.size() >= 4 && pushedPageCount() &&
backPage().remainingCapacity() < 4); // Push right at the end of a page, possibly splitting size
while (begin != end) {
if (!pushedPageCount() || !backPage().remainingCapacity())
addEmptyPage();
@ -1009,8 +1010,8 @@ public:
.detail("LastPoppedSeq", lastPoppedSeq)
.detail("PoppedSeq", poppedSeq)
.detail("NextPageSeq", nextPageSeq)
.detail("File0Size", rawQueue->files[0].size)
.detail("File1Size", rawQueue->files[1].size)
.detail("File0Size", rawQueue->files[0].size)
.detail("File1Size", rawQueue->files[1].size)
.detail("PoppedCommitted",
rawQueue->dbg_file0BeginSeq + rawQueue->files[0].popped + rawQueue->files[1].popped)
.detail("File0Name", rawQueue->files[0].dbgFilename);
@ -1363,7 +1364,8 @@ private:
// The fully durable popped point is self->lastPoppedSeq; tell the raw queue that.
int f;
int64_t p;
TEST(self->lastPoppedSeq / sizeof(Page) != self->poppedSeq / sizeof(Page)); // DiskQueue: Recovery popped position not fully durable
TEST(self->lastPoppedSeq / sizeof(Page) !=
self->poppedSeq / sizeof(Page)); // DiskQueue: Recovery popped position not fully durable
self->findPhysicalLocation(self->lastPoppedSeq, &f, &p, "lastPoppedSeq");
wait(self->rawQueue->setPoppedPage(f, p, pageFloor(self->lastPoppedSeq)));