Searched refs:mutationBytes (Results 1 – 5 of 5) sorted by relevance
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/ |
| H A D | MasterProxyServer.actor.cpp | 54 Counter mutationBytes; member
68 …itBatchIn("CommitBatchIn", cc), commitBatchOut("CommitBatchOut", cc), mutationBytes("MutationBytes… in ProxyStats()
662 state int mutationBytes = 0; in commitBatch() local
682 mutationBytes += m.expectedSize(); in commitBatch()
853 self->stats.mutationBytes += mutationBytes; in commitBatch()
|
| H A D | TLogServer.actor.cpp | 265 SpilledData(Version version, IDiskQueue::location start, uint32_t length, uint32_t mutationBytes) in SpilledData()
266 : version(version), start(start), length(length), mutationBytes(mutationBytes) { in SpilledData()
271 serializer(ar, version, start, length, mutationBytes); in serialize()
277 uint32_t mutationBytes = 0; member
1348 uint32_t mutationBytes = 0; in tLogPeekMessages() local
1356 if (mutationBytes >= SERVER_KNOBS->DESIRED_TOTAL_BYTES) { in tLogPeekMessages()
1367 mutationBytes += sd.mutationBytes; in tLogPeekMessages()
|
| H A D | VersionedBTree.actor.cpp | 2235 state int mutationBytes = 0; variable
2249 while(mutationBytes < mutationBytesTarget) {
2291 mutationBytes += (last->first.first.size() + last->second.get().size());
2317 mutationBytes += (kv.key.size() + kv.value.size());
2325 if(mutationBytes >= std::min(mutationBytesTarget, (int)20e6) || g_random->random01() < .002) {
2335 …mutation bytes, %lu key changes, %lld key bytes, %lld value bytes\n", mutationBytes, written.size(…
|
| H A D | storageserver.actor.cpp | 445 mutationBytes; // Like bytesInput but without MVCC accounting member
466 mutationBytes("MutationBytes", cc), in Counters()
2584 state int mutationBytes = 0; in update() local
2590 mutationBytes += pUpdate->mutations[mutationNum].totalSize(); in update()
2592 if(mutationBytes > SERVER_KNOBS->DESIRED_UPDATE_BYTES) { in update()
2593 mutationBytes = 0; in update()
2603 if(mutationBytes > SERVER_KNOBS->DESIRED_UPDATE_BYTES) { in update()
2604 mutationBytes = 0; in update()
2637 mutationBytes += msg.totalSize(); in update()
2638 data->counters.mutationBytes += msg.totalSize(); in update()
|
| H A D | Status.actor.cpp | 1421 StatusCounter mutations, mutationBytes, txnConflicts, txnStartOut, txnCommitOutSuccess; in workloadStatusFetcher() local
1425 mutationBytes.updateValues( StatusCounter(ps.getValue("MutationBytes")) ); in workloadStatusFetcher()
1432 bytesObj["written"] = mutationBytes.getStatus(); in workloadStatusFetcher()
|