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

Stuff

This commit is contained in:
Simon Grätzer 2017-02-27 13:16:40 +01:00
parent 92d705ce76
commit 9e9b1fd0c5
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
arangod/Pregel/Algos/PageRank.cpp
View File

@ -65,7 +65,7 @@ struct PRComputation : public VertexComputation<float, float, float> {
*ptr = 0.85 * sum + 0.15 / context()->vertexCount();
}
float diff = fabs(copy - *ptr);
aggregate(kConvergence, diff);
aggregate<float>(kConvergence, diff);
RangeIterator<Edge<float>> edges = getEdges();
float val = *ptr / edges.size();

5
arangod/Pregel/Worker.cpp
View File

@ -353,6 +353,7 @@ void Worker<V, E, M>::_startProcessing() {
i++;
} while (start != total);
TRI_ASSERT(_runningThreads == i);
LOG_TOPIC(INFO, Logger::PREGEL) << "Using " << i << " Threads";
}
template <typename V, typename E, typename M>
@ -378,8 +379,10 @@ bool Worker<V, E, M>::_processVertices(
if (_config.asynchronousMode()) {
outCache->sendToNextGSS(_requestedNextGSS);
outCache->setLocalCacheNextGSS(_writeCacheNextGSS);
TRI_ASSERT(outCache->sendCountNextGSS() == 0);
}
TRI_ASSERT(outCache->sendCount() == 0);
AggregatorHandler workerAggregator(_algorithm.get());
// TODO look if we can avoid instantiating this
std::unique_ptr<VertexComputation<V, E, M>> vertexComputation(