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

Format fix

This commit is contained in:
Jingyu Zhou 2021-09-30 13:13:48 -07:00 committed by Dan Lambright
parent ff75d22ce8
commit ad64ee9858
2 changed files with 4 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
fdbserver/ApplyMetadataMutation.cpp
View File

@ -201,12 +201,6 @@ private:
// TraceEvent("checkSetServerKeysPrefix");
if (toCommit) {
{
TraceEvent("SendingPrivateMutation", dbgid)
.detail("M", m)
.detail("Server", serverKeysDecodeServer(m.param1))
.detail("TagKey", serverTagKeyFor(serverKeysDecodeServer(m.param1)));
}
Tag tag = decodeServerTagValue(
txnStateStore->readValue(serverTagKeyFor(serverKeysDecodeServer(m.param1))).get().get());
MutationRef privatized = m;

9
fdbserver/Resolver.actor.cpp
View File

@ -454,8 +454,8 @@ ACTOR Future<Void> processCompleteTransactionStateRequest(TransactionStateResolv
} // loop
auto lockedKey = pContext->pTxnStateStore->readValue(databaseLockedKey).get();
//pContext->pCommitData->locked = lockedKey.present() && lockedKey.get().size();
//pContext->pCommitData->metadataVersion = pContext->pTxnStateStore->readValue(metadataVersionKey).get();
// pContext->pCommitData->locked = lockedKey.present() && lockedKey.get().size();
// pContext->pCommitData->metadataVersion = pContext->pTxnStateStore->readValue(metadataVersionKey).get();
pContext->pTxnStateStore->enableSnapshot();
@ -487,7 +487,7 @@ ACTOR Future<Void> processTransactionStateRequestPart(TransactionStateResolveCon
}
pContext->receivedSequences.insert(request.sequence);
//ASSERT(!pContext->pResolverData->validState.isSet());
// ASSERT(!pContext->pResolverData->validState.isSet());
for (auto& kv : request.data) {
pContext->pTxnStateStore->set(kv, &request.arena);
@ -531,8 +531,7 @@ ACTOR Future<Void> resolverCore(ResolverInterface resolver,
state Future<Void> onError =
transformError(actorCollection(addActor.getFuture()), broken_promise(), master_resolver_failed());
self->logSystem = ILogSystem::fromServerDBInfo(resolver.id(), db->get(), false, addActor);
self->logAdapter =
new LogSystemDiskQueueAdapter(self->logSystem, Reference<AsyncVar<PeekTxsInfo>>(), 1, false);
self->logAdapter = new LogSystemDiskQueueAdapter(self->logSystem, Reference<AsyncVar<PeekTxsInfo>>(), 1, false);
self->txnStateStore = keyValueStoreLogSystem(self->logAdapter, resolver.id(), 2e9, true, true, true);
// wait for txnStateStore recovery