diff options
author | Vaclav Petricek <VaclavPetricek@LiveNation.com> | 2014-06-17 00:33:49 +0400 |
---|---|---|
committer | Vaclav Petricek <VaclavPetricek@LiveNation.com> | 2014-06-17 00:33:49 +0400 |
commit | 45206326209890997be98d0cafeb39430ead7cb6 (patch) | |
tree | ba8e13e0589197f1fb72058024a5fded9b461703 /cluster | |
parent | 9200cb737aabb919c564d72753961f9447f44891 (diff) |
report which node we are waiting for
Diffstat (limited to 'cluster')
-rw-r--r-- | cluster/spanning_tree.cc | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/cluster/spanning_tree.cc b/cluster/spanning_tree.cc index e325f2df..4bc0d842 100644 --- a/cluster/spanning_tree.cc +++ b/cluster/spanning_tree.cc @@ -254,6 +254,16 @@ int main(int argc, char* argv[]) { if (partial_nodeset.filled != total) //Need to wait for more connections { partial_nodesets[nonce] = partial_nodeset; + for(size_t i=0; i<total; i++) + { + if(partial_nodeset.nodes[i].client_ip == (uint32_t)-1) + { + cout << "nonce " << nonce + << " still waiting for " << (total - partial_nodeset.filled) + << " nodes out of " << total << " for example node " << i << endl; + break; + } + } } else {//Time to make the spanning tree |