summaryrefslogtreecommitdiff
path: root/node/IncomingPacket.cpp
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2015-01-05 11:47:22 -0800
committerAdam Ierymenko <adam.ierymenko@gmail.com>2015-01-05 11:47:22 -0800
commit56cfe1d603104784ec40d94d8ac689391ef2e0eb (patch)
tree2a62a6b94e2a0702f3ecb373cbc4b9d5d2870a2d /node/IncomingPacket.cpp
parent95e303d6f316e4a929d119a4255c79cca5a8a6e6 (diff)
downloadinfinitytier-56cfe1d603104784ec40d94d8ac689391ef2e0eb.tar.gz
infinitytier-56cfe1d603104784ec40d94d8ac689391ef2e0eb.zip
Strip out old Service code, add new service message type.
Diffstat (limited to 'node/IncomingPacket.cpp')
-rw-r--r--node/IncomingPacket.cpp60
1 files changed, 0 insertions, 60 deletions
diff --git a/node/IncomingPacket.cpp b/node/IncomingPacket.cpp
index c8197eb6..93be95ec 100644
--- a/node/IncomingPacket.cpp
+++ b/node/IncomingPacket.cpp
@@ -39,7 +39,6 @@
#include "Switch.hpp"
#include "Peer.hpp"
#include "NodeConfig.hpp"
-#include "Service.hpp"
#include "SoftwareUpdater.hpp"
namespace ZeroTier {
@@ -85,7 +84,6 @@ bool IncomingPacket::tryDecode(const RuntimeEnvironment *RR)
case Packet::VERB_MULTICAST_LIKE: return _doMULTICAST_LIKE(RR,peer);
case Packet::VERB_NETWORK_MEMBERSHIP_CERTIFICATE: return _doNETWORK_MEMBERSHIP_CERTIFICATE(RR,peer);
case Packet::VERB_NETWORK_CONFIG_REQUEST: return _doNETWORK_CONFIG_REQUEST(RR,peer);
- case Packet::VERB_NETWORK_CONFIG_REFRESH: return _doNETWORK_CONFIG_REFRESH(RR,peer);
case Packet::VERB_MULTICAST_GATHER: return _doMULTICAST_GATHER(RR,peer);
case Packet::VERB_MULTICAST_FRAME: return _doMULTICAST_FRAME(RR,peer);
}
@@ -714,43 +712,6 @@ bool IncomingPacket::_doNETWORK_CONFIG_REQUEST(const RuntimeEnvironment *RR,cons
{
try {
uint64_t nwid = at<uint64_t>(ZT_PROTO_VERB_NETWORK_CONFIG_REQUEST_IDX_NETWORK_ID);
-
-#ifndef __WINDOWS__
- if (RR->netconfService) {
- char tmp[128];
- unsigned int dictLen = at<uint16_t>(ZT_PROTO_VERB_NETWORK_CONFIG_REQUEST_IDX_DICT_LEN);
-
- Dictionary request;
- if (dictLen)
- request["meta"] = std::string((const char *)field(ZT_PROTO_VERB_NETWORK_CONFIG_REQUEST_IDX_DICT,dictLen),dictLen);
- request["type"] = "netconf-request";
- request["peerId"] = peer->identity().toString(false);
- Utils::snprintf(tmp,sizeof(tmp),"%.16llx",(unsigned long long)nwid);
- request["nwid"] = tmp;
- Utils::snprintf(tmp,sizeof(tmp),"%.16llx",(unsigned long long)packetId());
- request["requestId"] = tmp;
- if (!hops())
- request["from"] = _remoteAddress.toString();
- //TRACE("to netconf:\n%s",request.toString().c_str());
- RR->netconfService->send(request);
- } else {
-#endif // !__WINDOWS__
-
- // Send unsupported operation if there is no netconf service
- // configured on this node (or if this is a Windows machine,
- // which doesn't support that at all).
- Packet outp(source(),RR->identity.address(),Packet::VERB_ERROR);
- outp.append((unsigned char)Packet::VERB_NETWORK_CONFIG_REQUEST);
- outp.append(packetId());
- outp.append((unsigned char)Packet::ERROR_UNSUPPORTED_OPERATION);
- outp.append(nwid);
- outp.armor(peer->key(),true);
- _fromSock->send(_remoteAddress,outp.data(),outp.size());
-
-#ifndef __WINDOWS__
- }
-#endif // !__WINDOWS__
-
peer->received(RR,_fromSock,_remoteAddress,hops(),packetId(),Packet::VERB_NETWORK_CONFIG_REQUEST,0,Packet::VERB_NOP,Utils::now());
} catch (std::exception &exc) {
TRACE("dropped NETWORK_CONFIG_REQUEST from %s(%s): unexpected exception: %s",source().toString().c_str(),_remoteAddress.toString().c_str(),exc.what());
@@ -760,27 +721,6 @@ bool IncomingPacket::_doNETWORK_CONFIG_REQUEST(const RuntimeEnvironment *RR,cons
return true;
}
-bool IncomingPacket::_doNETWORK_CONFIG_REFRESH(const RuntimeEnvironment *RR,const SharedPtr<Peer> &peer)
-{
- try {
- unsigned int ptr = ZT_PACKET_IDX_PAYLOAD;
- while ((ptr + sizeof(uint64_t)) <= size()) {
- uint64_t nwid = at<uint64_t>(ptr); ptr += sizeof(uint64_t);
- SharedPtr<Network> nw(RR->nc->network(nwid));
- if ((nw)&&(source() == nw->controller())) { // only respond to requests from controller
- TRACE("NETWORK_CONFIG_REFRESH from %s, refreshing network %.16llx",source().toString().c_str(),nwid);
- nw->requestConfiguration();
- }
- }
- peer->received(RR,_fromSock,_remoteAddress,hops(),packetId(),Packet::VERB_NETWORK_CONFIG_REFRESH,0,Packet::VERB_NOP,Utils::now());
- } catch (std::exception &exc) {
- TRACE("dropped NETWORK_CONFIG_REFRESH from %s(%s): unexpected exception: %s",source().toString().c_str(),_remoteAddress.toString().c_str(),exc.what());
- } catch ( ... ) {
- TRACE("dropped NETWORK_CONFIG_REFRESH from %s(%s): unexpected exception: (unknown)",source().toString().c_str(),_remoteAddress.toString().c_str());
- }
- return true;
-}
-
bool IncomingPacket::_doMULTICAST_GATHER(const RuntimeEnvironment *RR,const SharedPtr<Peer> &peer)
{
try {