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

Small fix

This commit is contained in:
Simon Grätzer 2017-02-24 11:22:16 +01:00
parent 32200b24d2
commit 19d3dfc601
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
arangod/Pregel/OutgoingCache.cpp
View File

@ -81,6 +81,10 @@ void ArrayOutCache<M>::appendMessage(prgl_shard_t shard, std::string const& key,
template <typename M>
void ArrayOutCache<M>::flushMessages() {
if (this->_containedMessages == 0) {
return;
}
// LOG_TOPIC(INFO, Logger::PREGEL) << "Beginning to send messages to other
// machines";
uint64_t gss = this->_config->globalSuperstep();
@ -189,6 +193,10 @@ void CombiningOutCache<M>::appendMessage(prgl_shard_t shard,
template <typename M>
void CombiningOutCache<M>::flushMessages() {
if (this->_containedMessages == 0) {
return;
}
// LOG_TOPIC(INFO, Logger::PREGEL) << "Beginning to send messages to other
// machines";
uint64_t gss = this->_config->globalSuperstep();