diff options
| -rw-r--r-- | netconf-service/old/Makefile | 7 | ||||
| -rw-r--r-- | netconf-service/old/netconf-test.cpp | 83 | ||||
| -rw-r--r-- | netconf-service/old/netconf.cpp | 518 |
3 files changed, 0 insertions, 608 deletions
diff --git a/netconf-service/old/Makefile b/netconf-service/old/Makefile deleted file mode 100644 index 23067d48..00000000 --- a/netconf-service/old/Makefile +++ /dev/null @@ -1,7 +0,0 @@ -all: - gcc -O6 -c ../ext/lz4/lz4hc.c ../ext/lz4/lz4.c - g++ -DZT_OSNAME="linux" -DZT_ARCH="x86_64" -I/usr/include/mysql -I../ext/bin/libcrypto/include -O -pthread -o netconf.service netconf.cpp ../node/Utils.cpp ../node/Identity.cpp ../node/Salsa20.cpp ../node/C25519.cpp ../node/SHA512.cpp ../node/CertificateOfMembership.cpp lz4.o lz4hc.o -lmysqlpp -# g++ -DZT_OSNAME="linux" -DZT_ARCH="x86_64" -I/usr/include/mysql -I../ext/bin/libcrypto/include -O -pthread -o netconf-test netconf-test.cpp ../node/Utils.cpp ../node/Identity.cpp ../node/Salsa20.cpp ../node/Logger.cpp ../node/Service.cpp ../node/C25519.cpp ../node/SHA512.cpp lz4.o lz4hc.o - -clean: - rm -f *.o netconf.service netconf-test diff --git a/netconf-service/old/netconf-test.cpp b/netconf-service/old/netconf-test.cpp deleted file mode 100644 index 605b94f1..00000000 --- a/netconf-service/old/netconf-test.cpp +++ /dev/null @@ -1,83 +0,0 @@ -/* - * ZeroTier One - Global Peer to Peer Ethernet - * Copyright (C) 2011-2014 ZeroTier Networks LLC - * - * This program is free software: you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation, either version 3 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program. If not, see <http://www.gnu.org/licenses/>. - * - * -- - * - * ZeroTier may be used and distributed under the terms of the GPLv3, which - * are available at: http://www.gnu.org/licenses/gpl-3.0.html - * - * If you would like to embed ZeroTier into a commercial application or - * redistribute it in a modified binary form, please contact ZeroTier Networks - * LLC. Start here: http://www.zerotier.com/ - */ - -/* Self-tester that makes both new and repeated requests to netconf */ - -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <time.h> -#include <sys/time.h> - -#include <vector> -#include <string> -#include <iostream> - -#include "../node/Dictionary.hpp" -#include "../node/Service.hpp" -#include "../node/Identity.hpp" -#include "../node/RuntimeEnvironment.hpp" -#include "../node/Logger.hpp" -#include "../node/Thread.hpp" - -using namespace ZeroTier; - -static void svcHandler(void *arg,Service &svc,const Dictionary &msg) -{ - std::cout << msg.toString(); -} - -int main(int argc,char **argv) -{ - RuntimeEnvironment renv; - renv.log = new Logger((const char *)0,(const char *)0,0); - Service svc(&renv,"netconf","./netconf.service",&svcHandler,(void *)0); - - srand(time(0)); - - std::vector<Identity> population; - for(;;) { - Identity id; - if ((population.empty())||(rand() < (RAND_MAX / 4))) { - id.generate(); - population.push_back(id); - std::cout << "Testing with new identity: " << id.address().toString() << std::endl; - } else { - id = population[rand() % population.size()]; - Thread::sleep(1000); - std::cout << "Testing with existing identity: " << id.address().toString() << std::endl; - } - - Dictionary request; - request["type"] = "netconf-request"; - request["peerId"] = id.toString(false); - request["nwid"] = "6c92786fee000001"; - request["requestId"] = "12345"; - - svc.send(request); - } -} diff --git a/netconf-service/old/netconf.cpp b/netconf-service/old/netconf.cpp deleted file mode 100644 index 3a03864c..00000000 --- a/netconf-service/old/netconf.cpp +++ /dev/null @@ -1,518 +0,0 @@ -/* - * ZeroTier One - Global Peer to Peer Ethernet - * Copyright (C) 2011-2014 ZeroTier Networks LLC - * - * This program is free software: you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation, either version 3 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program. If not, see <http://www.gnu.org/licenses/>. - * - * -- - * - * ZeroTier may be used and distributed under the terms of the GPLv3, which - * are available at: http://www.gnu.org/licenses/gpl-3.0.html - * - * If you would like to embed ZeroTier into a commercial application or - * redistribute it in a modified binary form, please contact ZeroTier Networks - * LLC. Start here: http://www.zerotier.com/ - */ - -/* - * This is the netconf service. It's currently used only by netconf nodes that - * are run by ZeroTier itself. There is nothing to prevent you from running - * your own if you wanted to create your own networks outside our system. - * - * That being said, we'd like to charge for private networks to support - * ZeroTier One and future development efforts. So while this software is - * open source and we're not going to stop you from sidestepping this, we - * do ask -- honor system here -- that you pay for private networks if you - * are going to use them for any commercial purpose such as a business VPN - * alternative. - * - * This will at the moment only build on Linux and requires the mysql++ - * library, which is available here: - * - * http://tangentsoft.net/mysql++/ - * - * (Packages are available for CentOS via EPEL and for any Debian distro.) - * - * This program must be built and installed in the services.d subfolder of - * the ZeroTier One home folder of the node designated to act as a master - * for networks. Doing so will enable the NETWORK_CONFIG_REQUEST protocol - * verb. - */ - -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <stdint.h> -#include <unistd.h> -#include <errno.h> -#include <sys/stat.h> -#include <sys/types.h> -#include <arpa/inet.h> - -#include <iostream> -#include <string> -#include <map> -#include <list> -#include <vector> -#include <algorithm> - -#include <mysql++/mysql++.h> - -#include "../version.h" - -#include "../node/Constants.hpp" -#include "../node/Dictionary.hpp" -#include "../node/Identity.hpp" -#include "../node/Utils.hpp" -#include "../node/Mutex.hpp" -#include "../node/NetworkConfig.hpp" -#include "../node/CertificateOfMembership.hpp" - -using namespace ZeroTier; -using namespace mysqlpp; - -static Mutex stdoutWriteLock; -static Connection *dbCon = (Connection *)0; -static char mysqlHost[64],mysqlPort[64],mysqlDatabase[64],mysqlUser[64],mysqlPassword[64]; - -int main(int argc,char **argv) -{ - { - char *ee = getenv("ZT_NETCONF_MYSQL_HOST"); - if (!ee) { - fprintf(stderr,"missing environment variable: ZT_NETCONF_MYSQL_HOST\n"); - return -1; - } - strcpy(mysqlHost,ee); - ee = getenv("ZT_NETCONF_MYSQL_PORT"); - if (!ee) - strcpy(mysqlPort,"3306"); - else strcpy(mysqlPort,ee); - ee = getenv("ZT_NETCONF_MYSQL_DATABASE"); - if (!ee) { - fprintf(stderr,"missing environment variable: ZT_NETCONF_MYSQL_DATABASE\n"); - return -1; - } - strcpy(mysqlDatabase,ee); - ee = getenv("ZT_NETCONF_MYSQL_USER"); - if (!ee) { - fprintf(stderr,"missing environment variable: ZT_NETCONF_MYSQL_USER\n"); - return -1; - } - strcpy(mysqlUser,ee); - ee = getenv("ZT_NETCONF_MYSQL_PASSWORD"); - if (!ee) { - fprintf(stderr,"missing environment variable: ZT_NETCONF_MYSQL_PASSWORD\n"); - return -1; - } - strcpy(mysqlPassword,ee); - } - - char buf[131072],buf2[131072]; - Identity signingIdentity; - std::string dictBuf; - - try { - dbCon = new Connection(mysqlDatabase,mysqlHost,mysqlUser,mysqlPassword,(unsigned int)strtol(mysqlPort,(char **)0,10)); - if (dbCon->connected()) { - fprintf(stderr,"connected to mysql server successfully\n"); - } else { - fprintf(stderr,"unable to connect to database server\n"); - return -1; - } - } catch (std::exception &exc) { - fprintf(stderr,"unable to connect to database server: %s\n",exc.what()); - return -1; - } - - // Send ready message to tell parent that the service is up, and to - // solicit netconf-init. - { - Dictionary response; - response["type"] = "ready"; - std::string respm = response.toString(); - uint32_t respml = (uint32_t)htonl((uint32_t)respm.length()); - stdoutWriteLock.lock(); - write(STDOUT_FILENO,&respml,4); - write(STDOUT_FILENO,respm.data(),respm.length()); - stdoutWriteLock.unlock(); - } - - for(;;) { - for(int l=0;l<4;) { - int n = (int)read(STDIN_FILENO,buf + l,4 - l); - if (n < 0) { - fprintf(stderr,"error reading frame size from stdin: %s\n",strerror(errno)); - return -1; - } - l += n; - } - unsigned int fsize = (unsigned int)ntohl(*((const uint32_t *)buf)); - - while (dictBuf.length() < fsize) { - int n = (int)read(STDIN_FILENO,buf,std::min((int)sizeof(buf),(int)(fsize - dictBuf.length()))); - if (n < 0) { - fprintf(stderr,"error reading frame from stdin: %s\n",strerror(errno)); - return -1; - } - for(int i=0;i<n;++i) - dictBuf.push_back(buf[i]); - } - Dictionary request(dictBuf); - dictBuf = ""; - - if (!dbCon->connected()) { - fprintf(stderr,"connection to database server lost\n"); - return -1; - } - - // Check QNetworkConfigRefresh (MEMORY table) and push network - // config refreshes to queued peer/network pairs. - try { - Dictionary to; - { - Query q = dbCon->query(); - q << "SELECT DISTINCT LOWER(HEX(Node_id)) AS Node_id,LOWER(HEX(Network_id)) AS Network_id FROM QNetworkConfigRefresh"; - StoreQueryResult rs = q.store(); - for(unsigned long i=0;i<rs.num_rows();++i) { - std::string &nwids = to[rs[i]["Node_id"].c_str()]; - if (nwids.length()) - nwids.push_back(','); - nwids.append(rs[i]["Network_id"]); - } - } - - { - Query q = dbCon->query(); - q << "DELETE FROM QNetworkConfigRefresh"; - q.exec(); - } - - Dictionary response; - response["type"] = "netconf-push"; - response["to"] = to.toString(); - std::string respm = response.toString(); - uint32_t respml = (uint32_t)htonl((uint32_t)respm.length()); - - stdoutWriteLock.lock(); - write(STDOUT_FILENO,&respml,4); - write(STDOUT_FILENO,respm.data(),respm.length()); - stdoutWriteLock.unlock(); - } catch ( ... ) {} - - try { - const std::string &reqType = request.get("type"); - if (reqType == "netconf-init") { // initialization to set things like netconf's identity - Identity netconfId(request.get("netconfId")); - if ((netconfId)&&(netconfId.hasPrivate())) { - signingIdentity = netconfId; - fprintf(stderr,"got netconf signing identity: %s\n",signingIdentity.toString(false).c_str()); - } else { - fprintf(stderr,"netconfId invalid or lacks private key\n"); - return -1; - } - } else if (reqType == "netconf-request") { // NETWORK_CONFIG_REQUEST packet - if (!signingIdentity) { - fprintf(stderr,"no signing identity; missing netconf-init?\n"); - return -1; - } - - // Deserialize querying peer identity and network ID - Identity peerIdentity(request.get("peerId")); - uint64_t nwid = strtoull(request.get("nwid").c_str(),(char **)0,16); - std::string fromAddr(request.get("from","")); - - // Meta-information from node, such as (future) geo-location stuff - Dictionary meta; - if (request.contains("meta")) - meta.fromString(request.get("meta")); - - // Check validity of node's identity, ignore request on failure - if (!peerIdentity.locallyValidate()) { - fprintf(stderr,"identity failed validity check: %s\n",peerIdentity.toString(false).c_str()); - continue; - } - - // Save node's identity if unknown - { - Query q = dbCon->query(); - q << "SELECT identity FROM Node WHERE id = " << peerIdentity.address().toInt(); - StoreQueryResult rs = q.store(); - if (rs.num_rows() > 0) { - if (rs[0]["identity"] != peerIdentity.toString(false)) { - // TODO: handle collisions... - continue; - } - } else { - q = dbCon->query(); - q << "INSERT INTO Node (id,creationTime,identity) VALUES (" << peerIdentity.address().toInt() << "," << Utils::now() << "," << quote << peerIdentity.toString(false) << ")"; - if (!q.exec()) { - fprintf(stderr,"error inserting Node row for peer %s, aborting netconf request\n",peerIdentity.address().toString().c_str()); - continue; - } - // TODO: launch background validation - } - } - - // Look up core network information - bool isOpen = false; - unsigned int multicastPrefixBits = 0; - unsigned int multicastDepth = 0; - bool emulateArp = false; - bool emulateNdp = false; - unsigned int arpCacheTtl = 0; - unsigned int ndpCacheTtl = 0; - std::string name; - std::string desc; - { - Query q = dbCon->query(); - q << "SELECT * FROM Network WHERE id = " << nwid; - StoreQueryResult rs = q.store(); - if (rs.num_rows() > 0) { - name = rs[0]["name"].c_str(); - desc = rs[0]["desc"].c_str(); - isOpen = ((int)rs[0]["isOpen"] > 0); - emulateArp = ((int)rs[0]["emulateArp"] > 0); - emulateNdp = ((int)rs[0]["emulateNdp"] > 0); - arpCacheTtl = (unsigned int)rs[0]["arpCacheTtl"]; - ndpCacheTtl = (unsigned int)rs[0]["ndpCacheTtl"]; - multicastPrefixBits = (unsigned int)rs[0]["multicastPrefixBits"]; - multicastDepth = (unsigned int)rs[0]["multicastDepth"]; - } else { - Dictionary response; - response["peer"] = peerIdentity.address().toString(); - response["nwid"] = request.get("nwid"); - response["type"] = "netconf-response"; - response["requestId"] = request.get("requestId"); - response["error"] = "OBJ_NOT_FOUND"; - std::string respm = response.toString(); - uint32_t respml = (uint32_t)htonl((uint32_t)respm.length()); - - stdoutWriteLock.lock(); - write(STDOUT_FILENO,&respml,4); - write(STDOUT_FILENO,respm.data(),respm.length()); - stdoutWriteLock.unlock(); - - continue; // ABORT, wait for next request - } - } - - // Check membership if this is a closed network - bool authenticated = true; - if (!isOpen) { - Query q = dbCon->query(); - q << "SELECT Node_id FROM NetworkNodes WHERE Network_id = " << nwid << " AND Node_id = " << peerIdentity.address().toInt(); - StoreQueryResult rs = q.store(); - if (!rs.num_rows()) { - Dictionary response; - response["peer"] = peerIdentity.address().toString(); - response["nwid"] = request.get("nwid"); - response["type"] = "netconf-response"; - response["requestId"] = request.get("requestId"); - response["error"] = "ACCESS_DENIED"; - std::string respm = response.toString(); - uint32_t respml = (uint32_t)htonl((uint32_t)respm.length()); - - stdoutWriteLock.lock(); - write(STDOUT_FILENO,&respml,4); - write(STDOUT_FILENO,respm.data(),respm.length()); - stdoutWriteLock.unlock(); - - authenticated = false; - } - } - - // Update most recent activity entry for this peer, also indicating - // whether authentication was successful. - { - if (fromAddr.length()) { - Query q = dbCon->query(); - q << "INSERT INTO NetworkActivity (Network_id,Node_id,lastActivityTime,authenticated,lastActivityFrom) VALUES (" << nwid << "," << peerIdentity.address().toInt() << "," << Utils::now() << "," << (authenticated ? 1 : 0) << "," << quote << fromAddr << ") ON DUPLICATE KEY UPDATE lastActivityTime = VALUES(lastActivityTime),authenticated = VALUES(authenticated),lastActivityFrom = VALUES(lastActivityFrom)"; - q.exec(); - } else { - Query q = dbCon->query(); - q << "INSERT INTO NetworkActivity (Network_id,Node_id,lastActivityTime,authenticated) VALUES (" << nwid << "," << peerIdentity.address().toInt() << "," << Utils::now() << "," << (authenticated ? 1 : 0) << ") ON DUPLICATE KEY UPDATE lastActivityTime = VALUES(lastActivityTime),authenticated = VALUES(authenticated)"; - q.exec(); - } - } - - if (!authenticated) - continue; // ABORT, wait for next request - - // Get list of etherTypes in comma-delimited hex format - std::string etherTypeWhitelist; - { - Query q = dbCon->query(); - q << "SELECT DISTINCT LOWER(HEX(etherType)) AS etherType FROM NetworkEthertypes WHERE Network_id = " << nwid; - StoreQueryResult rs = q.store(); - for(unsigned long i=0;i<rs.num_rows();++i) { - if (etherTypeWhitelist.length() > 0) - etherTypeWhitelist.push_back(','); - etherTypeWhitelist.append(rs[i]["etherType"].c_str()); - } - } - - // Get multicast group rates in dictionary format - Dictionary multicastRates; - { - Query q = dbCon->query(); - q << "SELECT DISTINCT multicastGroupMac,multicastGroupAdi,preload,maxBalance,accrual FROM NetworkMulticastRates WHERE Network_id = " << nwid; - StoreQueryResult rs = q.store(); - for(unsigned long i=0;i<rs.num_rows();++i) { - unsigned long preload = (unsigned long)rs[i]["preload"]; - unsigned long maxBalance = (unsigned long)rs[i]["maxBalance"]; - unsigned long accrual = (unsigned long)rs[i]["accrual"]; - unsigned long long mac = (unsigned long long)rs[i]["multicastGroupMac"]; - sprintf(buf,"%.12llx/%lx",(mac & 0xffffffffffffULL),(unsigned long)rs[i]["multicastGroupAdi"]); - sprintf(buf2,"%lx,%lx,%lx",preload,maxBalance,accrual); - multicastRates[buf] = buf2; - } - } - - // Check for (or assign?) static IP address assignments - std::string ipv4Static; - std::string ipv6Static; - { - Query q = dbCon->query(); - q << "SELECT INET_NTOA(ip) AS ip,netmaskBits FROM IPv4Static WHERE Node_id = " << peerIdentity.address().toInt() << " AND Network_id = " << nwid; - StoreQueryResult rs = q.store(); - if (rs.num_rows() > 0) { - for(int i=0;i<rs.num_rows();++i) { - if (ipv4Static.length()) - ipv4Static.push_back(','); - ipv4Static.append(rs[i]["ip"].c_str()); - ipv4Static.push_back('/'); - ipv4Static.append(rs[i]["netmaskBits"].c_str()); - } - } - - // Try to auto-assign if there's any auto-assign networks with space - // available. - if (!ipv4Static.length()) { - unsigned char addressBytes[5]; - peerIdentity.address().copyTo(addressBytes,5); - - q = dbCon->query(); - q << "SELECT ipNet,netmaskBits FROM IPv4AutoAssign WHERE Network_id = " << nwid; - rs = q.store(); - if (rs.num_rows() > 0) { - for(int aaRow=0;aaRow<rs.num_rows();++aaRow) { - uint32_t ipNet = (uint32_t)((unsigned long)rs[aaRow]["ipNet"]); - unsigned int netmaskBits = (unsigned int)rs[aaRow]["netmaskBits"]; - - if ((netmaskBits > 0)&&(ipNet)) { - uint32_t tryIp = (((uint32_t)addressBytes[1]) << 24) | - (((uint32_t)addressBytes[2]) << 16) | - (((uint32_t)addressBytes[3]) << 8) | - ((((uint32_t)addressBytes[4]) % 254) + 1); - tryIp &= (0xffffffff >> netmaskBits); - tryIp |= ipNet; - - for(int k=0;k<100000;++k) { - Query q2 = dbCon->query(); - q2 << "INSERT INTO IPv4Static (Network_id,Node_id,ip,netmaskBits) VALUES (" << nwid << "," << peerIdentity.address().toInt() << "," << tryIp << "," << netmaskBits << ")"; - if (q2.exec()) { - sprintf(buf,"%u.%u.%u.%u",(unsigned int)((tryIp >> 24) & 0xff),(unsigned int)((tryIp >> 16) & 0xff),(unsigned int)((tryIp >> 8) & 0xff),(unsigned int)(tryIp & 0xff)); - if (ipv4Static.length()) - ipv4Static.push_back(','); - ipv4Static.append(buf); - ipv4Static.push_back('/'); - sprintf(buf,"%u",netmaskBits); - ipv4Static.append(buf); - break; - } else { // insert will fail if IP is in use due to uniqueness constraints in DB - ++tryIp; - if ((tryIp & 0xff) == 0) - tryIp |= 1; - tryIp &= (0xffffffff >> netmaskBits); - tryIp |= ipNet; - } - } - - if (ipv4Static.length()) - break; - } - } - } - } - } - - // Assemble response dictionary to send to peer - Dictionary netconf; - sprintf(buf,"%d.%d.%d",ZEROTIER_ONE_VERSION_MAJOR,ZEROTIER_ONE_VERSION_MINOR,ZEROTIER_ONE_VERSION_REVISION); - netconf[ZT_NETWORKCONFIG_DICT_KEY_NETCONF_SERVICE_VERSION] = buf; - sprintf(buf,"%.16llx",(unsigned long long)nwid); - netconf[ZT_NETWORKCONFIG_DICT_KEY_NETWORK_ID] = buf; - netconf[ZT_NETWORKCONFIG_DICT_KEY_ISSUED_TO] = peerIdentity.address().toString(); - netconf[ZT_NETWORKCONFIG_DICT_KEY_NAME] = name; - netconf[ZT_NETWORKCONFIG_DICT_KEY_DESC] = desc; - netconf[ZT_NETWORKCONFIG_DICT_KEY_IS_OPEN] = (isOpen ? "1" : "0"); - netconf[ZT_NETWORKCONFIG_DICT_KEY_ALLOWED_ETHERNET_TYPES] = etherTypeWhitelist; - netconf[ZT_NETWORKCONFIG_DICT_KEY_MULTICAST_RATES] = multicastRates.toString(); - sprintf(buf,"%llx",(unsigned long long)Utils::now()); - netconf[ZT_NETWORKCONFIG_DICT_KEY_TIMESTAMP] = buf; - netconf[ZT_NETWORKCONFIG_DICT_KEY_EMULATE_ARP] = (emulateArp ? "1" : "0"); - netconf[ZT_NETWORKCONFIG_DICT_KEY_EMULATE_NDP] = (emulateNdp ? "1" : "0"); - if (arpCacheTtl) { - sprintf(buf,"%x",arpCacheTtl); - netconf[ZT_NETWORKCONFIG_DICT_KEY_ARP_CACHE_TTL] = buf; - } - if (ndpCacheTtl) { - sprintf(buf,"%x",ndpCacheTtl); - netconf[ZT_NETWORKCONFIG_DICT_KEY_NDP_CACHE_TTL] = buf; - } - if (multicastPrefixBits) { - sprintf(buf,"%x",multicastPrefixBits); - netconf[ZT_NETWORKCONFIG_DICT_KEY_MULTICAST_PREFIX_BITS] = buf; - } - if (multicastDepth) { - sprintf(buf,"%x",multicastDepth); - netconf[ZT_NETWORKCONFIG_DICT_KEY_MULTICAST_DEPTH] = buf; - } - if (ipv4Static.length()) - netconf[ZT_NETWORKCONFIG_DICT_KEY_IPV4_STATIC] = ipv4Static; - if (ipv6Static.length()) - netconf[ZT_NETWORKCONFIG_DICT_KEY_IPV6_STATIC] = ipv6Static; - if ((!isOpen)&&(authenticated)) { - CertificateOfMembership com(Utils::now(),ZT_NETWORK_AUTOCONF_DELAY * 3,nwid,peerIdentity.address()); - com.sign(signingIdentity); - netconf[ZT_NETWORKCONFIG_DICT_KEY_CERTIFICATE_OF_MEMBERSHIP] = com.toString(); - } - - // Send netconf as service bus response - { - Dictionary response; - response["peer"] = peerIdentity.address().toString(); - response["nwid"] = request.get("nwid"); - response["type"] = "netconf-response"; - response["requestId"] = request.get("requestId"); - response["netconf"] = netconf.toString(); - std::string respm = response.toString(); - uint32_t respml = (uint32_t)htonl((uint32_t)respm.length()); - - stdoutWriteLock.lock(); - write(STDOUT_FILENO,&respml,4); - write(STDOUT_FILENO,respm.data(),respm.length()); - stdoutWriteLock.unlock(); - - // LOOP, wait for next request - } - } - } catch (std::exception &exc) { - fprintf(stderr,"unexpected exception handling message: %s\n",exc.what()); - } catch ( ... ) { - fprintf(stderr,"unexpected exception handling message: unknown exception\n"); - } - } -} |