diff options
| author | Adam Ierymenko <adam.ierymenko@gmail.com> | 2013-07-20 18:24:56 -0400 |
|---|---|---|
| committer | Adam Ierymenko <adam.ierymenko@gmail.com> | 2013-07-20 18:24:56 -0400 |
| commit | b8e9a79d009411525c99b886b7af41bb4c650669 (patch) | |
| tree | 64f905c620571a2085b88a3a440b3e6538d70ddc /node/NodeConfig.cpp | |
| parent | e4e517e9c3ba16076b231d082a179aad8e892d6c (diff) | |
| download | infinitytier-b8e9a79d009411525c99b886b7af41bb4c650669.tar.gz infinitytier-b8e9a79d009411525c99b886b7af41bb4c650669.zip | |
docs
Diffstat (limited to 'node/NodeConfig.cpp')
| -rw-r--r-- | node/NodeConfig.cpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/node/NodeConfig.cpp b/node/NodeConfig.cpp index 21ed5188..849d73fc 100644 --- a/node/NodeConfig.cpp +++ b/node/NodeConfig.cpp @@ -219,12 +219,17 @@ bool NodeConfig::decodeControlMessagePacket(const void *key,const void *data,uns void NodeConfig::_CBcontrolPacketHandler(UdpSocket *sock,void *arg,const InetAddress &remoteAddr,const void *data,unsigned int len) { NodeConfig *nc = (NodeConfig *)arg; + const RuntimeEnvironment *_r = nc->_r; + try { unsigned long convId = 0; std::vector<std::string> commands; - if (!decodeControlMessagePacket(nc->_controlSocketKey,data,len,convId,commands)) + if (!decodeControlMessagePacket(nc->_controlSocketKey,data,len,convId,commands)) { + TRACE("control bus packet from %s failed decode, discarded",remoteAddr.toString().c_str()); return; + } + TRACE("control bus packet from %s, contains %d commands",remoteAddr.toString().c_str(),(int)commands.size()); for(std::vector<std::string>::iterator c(commands.begin());c!=commands.end();++c) { std::vector< Buffer<ZT_NODECONFIG_MAX_PACKET_SIZE> > resultPackets(encodeControlMessage(nc->_controlSocketKey,convId,nc->execute(c->c_str()))); |