Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/moses-smt/vowpal_wabbit.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVaclav Petricek <VaclavPetricek@LiveNation.com>2014-06-17 00:33:49 +0400
committerVaclav Petricek <VaclavPetricek@LiveNation.com>2014-06-17 00:33:49 +0400
commit45206326209890997be98d0cafeb39430ead7cb6 (patch)
treeba8e13e0589197f1fb72058024a5fded9b461703 /cluster
parent9200cb737aabb919c564d72753961f9447f44891 (diff)
report which node we are waiting for
Diffstat (limited to 'cluster')
-rw-r--r--cluster/spanning_tree.cc10
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