MCPcopy Create free account
hub / github.com/apple/foundationdb / completeSourceFetch

Method completeSourceFetch

fdbserver/DataDistributionQueue.actor.cpp:1061–1073  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1059 }
1060
1061 void completeSourceFetch(const RelocateData& results) {
1062 ASSERT(fetchingSourcesQueue.count(results));
1063
1064 // logRelocation( results, "GotSourceServers" );
1065
1066 fetchingSourcesQueue.erase(results);
1067 queueMap.insert(results.keys, results);
1068 for (int i = 0; i < results.src.size(); i++) {
1069 queue[results.src[i]].insert(results);
1070 }
1071 updateLastAsSource(results.src);
1072 serverCounter.increaseForTeam(results.src, results.reason, ServerCounter::CountType::QueuedSource);
1073 }
1074
1075 void logRelocation(const RelocateData& rd, const char* title) {
1076 std::string busyString;

Callers 1

Calls 5

increaseForTeamMethod · 0.80
countMethod · 0.65
eraseMethod · 0.45
insertMethod · 0.45
sizeMethod · 0.45

Tested by

no test coverage detected