summaryrefslogtreecommitdiff
path: root/node
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2017-01-30 16:15:47 -0800
committerAdam Ierymenko <adam.ierymenko@gmail.com>2017-01-30 16:15:47 -0800
commitf9ad80aa13705102c060bf6b16e62bb2bc3edfff (patch)
treee036e1449cb0a37f5374ff1aa434dd4a044b453f /node
parented31cb76d6c8e632456a554b79e05df0593b5e9c (diff)
downloadinfinitytier-f9ad80aa13705102c060bf6b16e62bb2bc3edfff.tar.gz
infinitytier-f9ad80aa13705102c060bf6b16e62bb2bc3edfff.zip
.
Diffstat (limited to 'node')
-rw-r--r--node/Cluster.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/node/Cluster.cpp b/node/Cluster.cpp
index b9359dc6..5537782e 100644
--- a/node/Cluster.cpp
+++ b/node/Cluster.cpp
@@ -476,7 +476,8 @@ void Cluster::handleIncomingStateMessage(const void *msg,unsigned int len)
if (network) {
// Copy into a Packet just to conform to Network API. Eventually
// will want to refactor.
- network->handleConfigChunk(0,Address(),Packet(dmsg),ptr);
+ printf("<< CLUSTER_MESSAGE_NETWORK_CONFIG %.16llx\n",dmsg.at<uint64_t>(ptr));
+ network->handleConfigChunk(0,Address(),Buffer<ZT_PROTO_MAX_PACKET_LENGTH>(dmsg),ptr);
}
} break;
}
@@ -511,6 +512,7 @@ void Cluster::broadcastNetworkConfigChunk(const void *chunk,unsigned int len)
Mutex::Lock _l2(_members[*mid].lock);
_send(*mid,CLUSTER_MESSAGE_NETWORK_CONFIG,chunk,len);
}
+ printf(">> CLUSTER_MESSAGE_NETWORK_CONFIG\n");
}
void Cluster::sendViaCluster(const Address &fromPeerAddress,const Address &toPeerAddress,const void *data,unsigned int len,bool unite)