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

more logging

This commit is contained in:
Evan Tschannen 2021-03-18 18:50:18 -07:00
parent 74025fa8e0
commit cc66466ef3
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
fdbserver/DiskQueue.actor.cpp
View File

@ -122,7 +122,9 @@ private:
ACTOR static Future<Void> waitAndSync(SyncQueue* self) {
wait(self->outstanding.front());
self->outstanding.pop_front();
TraceEvent("FileSyncStart").detail("Name", self->file->getFilename());
wait(self->file->sync());
TraceEvent("FileSyncEnd").detail("Name", self->file->getFilename());
return Void();
}
};
@ -479,9 +481,9 @@ public:
self->updatePopped(poppedPages * sizeof(Page));
/*TraceEvent("RDQCommitEnd", self->dbgid).detail("DeltaPopped", poppedPages*sizeof(Page)).detail("PoppedCommitted", self->dbg_file0BeginSeq + self->files[0].popped + self->files[1].popped)
TraceEvent("RDQCommitEnd", self->dbgid).detail("DeltaPopped", poppedPages*sizeof(Page)).detail("PoppedCommitted", self->dbg_file0BeginSeq + self->files[0].popped + self->files[1].popped)
.detail("File0Size", self->files[0].size).detail("File1Size", self->files[1].size)
.detail("File0Name", self->files[0].dbgFilename).detail("SyncedFiles", syncFiles.size());*/
.detail("File0Name", self->files[0].dbgFilename).detail("SyncedFiles", syncFiles.size());
committed.send(Void());
} catch (Error& e) {
@ -964,10 +966,10 @@ public:
warnAlwaysForMemory = false;
}
/*TraceEvent("DQCommit", dbgid).detail("Pages", pushedPageCount()).detail("LastPoppedSeq", lastPoppedSeq).detail("PoppedSeq", poppedSeq).detail("NextPageSeq", nextPageSeq)
TraceEvent("DQCommit", dbgid).detail("Pages", pushedPageCount()).detail("LastPoppedSeq", lastPoppedSeq).detail("PoppedSeq", poppedSeq).detail("NextPageSeq", nextPageSeq)
.detail("RawFile0Size", rawQueue->files[0].size).detail("RawFile1Size",
rawQueue->files[1].size).detail("WritingPos", rawQueue->writingPos) .detail("RawFile0Name",
rawQueue->files[0].dbgFilename);*/
rawQueue->files[0].dbgFilename);
lastCommittedSeq = backPage().endSeq();
auto f = rawQueue->pushAndCommit(

2
fdbserver/TLogServer.actor.cpp
View File

@ -760,7 +760,7 @@ void TLogQueue::push(T const& qe, Reference<LogData> logData) {
const IDiskQueue::location startloc = queue->getNextPushLocation();
// FIXME: push shouldn't return anything. We should call getNextPushLocation() again.
const IDiskQueue::location endloc = queue->push(wr.toValue());
//TraceEvent("TLogQueueVersionWritten", dbgid).detail("Size", wr.getLength() - sizeof(uint32_t) - sizeof(uint8_t)).detail("Loc", loc);
TraceEvent("TLogQueueVersionWritten", dbgid).detail("Size", wr.getLength() - sizeof(uint32_t) - sizeof(uint8_t)).detail("Start", startloc).detail("End", endloc).detail("Ver", qe.version);
logData->versionLocation[qe.version] = std::make_pair(startloc, endloc);
}