Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Some stuff

This commit is contained in:
Simon Grätzer 2017-02-22 18:56:35 +01:00
parent 41bc0da58e
commit 3565469ebf
3 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
arangod/Pregel/Conductor.cpp
View File

@ -288,6 +288,7 @@ VPackBuilder Conductor::finishedWorkerStep(VPackSlice const& data) {
LOG_TOPIC(INFO, Logger::PREGEL) LOG_TOPIC(INFO, Logger::PREGEL)
<< "Finished gss " << _globalSuperstep << " in " << "Finished gss " << _globalSuperstep << " in "
<< (TRI_microtime() - _computationStartTimeSecs) << "s"; << (TRI_microtime() - _computationStartTimeSecs) << "s";
_statistics.debugOutput();
_globalSuperstep++; _globalSuperstep++;
// don't block the response for workers waiting on this callback // don't block the response for workers waiting on this callback

9
arangod/Pregel/Statistics.h
View File

@ -111,6 +111,15 @@ struct StatsManager {
return send == received; return send == received;
} }
void debugOutput() {
uint64_t send = 0, received = 0;
for (auto const& pair : _serverStats) {
send += pair.second.sendCount;
received += pair.second.receivedCount;
}
LOG_TOPIC(INFO, Logger::PREGEL) << send << " - " << received << " : " << send - received;
}
/// tests if active count is greater 0 /// tests if active count is greater 0
bool executionFinished() { bool executionFinished() {
for (auto const& pair : _activeStats) { for (auto const& pair : _activeStats) {

10
arangod/Pregel/Worker.cpp
View File

@ -423,17 +423,17 @@ bool Worker<V, E, M>::_processVertices(
MessageStats stats; MessageStats stats;
stats.sendCount = outCache->sendCount(); stats.sendCount = outCache->sendCount();
stats.superstepRuntimeSecs = TRI_microtime() - start; stats.superstepRuntimeSecs = TRI_microtime() - start;
if (t > 0.005) {
LOG_TOPIC(INFO, Logger::PREGEL) << "Total " << stats.superstepRuntimeSecs
<< " s merge took " << t << " s";
}
inCache->clear(); inCache->clear();
outCache->clear(); outCache->clear();
bool lastThread = false; bool lastThread = false;
{ // only one thread at a time { // only one thread at a time
MUTEX_LOCKER(guard, _threadMutex); MUTEX_LOCKER(guard, _threadMutex);
if (t > 0.005) {
LOG_TOPIC(INFO, Logger::PREGEL) << "Total " << stats.superstepRuntimeSecs
<< " s merge took " << t << " s";
}
// merge the thread local stats and aggregators // merge the thread local stats and aggregators
_workerAggregators->aggregateValues(workerAggregator); _workerAggregators->aggregateValues(workerAggregator);
_messageStats.accumulate(stats); _messageStats.accumulate(stats);