Node.cpp 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664
  1. /*
  2. * ZeroTier One - Network Virtualization Everywhere
  3. * Copyright (C) 2011-2015 ZeroTier, Inc.
  4. *
  5. * This program is free software: you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation, either version 3 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  17. *
  18. * --
  19. *
  20. * ZeroTier may be used and distributed under the terms of the GPLv3, which
  21. * are available at: http://www.gnu.org/licenses/gpl-3.0.html
  22. *
  23. * If you would like to embed ZeroTier into a commercial application or
  24. * redistribute it in a modified binary form, please contact ZeroTier Networks
  25. * LLC. Start here: http://www.zerotier.com/
  26. */
  27. #include "../version.h"
  28. #include "Constants.hpp"
  29. #include "Node.hpp"
  30. #include "RuntimeEnvironment.hpp"
  31. #include "NetworkConfigMaster.hpp"
  32. #include "CMWC4096.hpp"
  33. #include "Switch.hpp"
  34. #include "Multicaster.hpp"
  35. #include "AntiRecursion.hpp"
  36. #include "Topology.hpp"
  37. #include "Buffer.hpp"
  38. #include "Packet.hpp"
  39. #include "Address.hpp"
  40. #include "Identity.hpp"
  41. #include "SelfAwareness.hpp"
  42. #include "Defaults.hpp"
  43. namespace ZeroTier {
  44. /****************************************************************************/
  45. /* Public Node interface (C++, exposed via CAPI bindings) */
  46. /****************************************************************************/
  47. Node::Node(
  48. uint64_t now,
  49. void *uptr,
  50. ZT1_DataStoreGetFunction dataStoreGetFunction,
  51. ZT1_DataStorePutFunction dataStorePutFunction,
  52. ZT1_WirePacketSendFunction wirePacketSendFunction,
  53. ZT1_VirtualNetworkFrameFunction virtualNetworkFrameFunction,
  54. ZT1_VirtualNetworkConfigFunction virtualNetworkConfigFunction,
  55. ZT1_EventCallback eventCallback,
  56. const char *overrideRootTopology) :
  57. RR(new RuntimeEnvironment(this)),
  58. _uptr(uptr),
  59. _dataStoreGetFunction(dataStoreGetFunction),
  60. _dataStorePutFunction(dataStorePutFunction),
  61. _wirePacketSendFunction(wirePacketSendFunction),
  62. _virtualNetworkFrameFunction(virtualNetworkFrameFunction),
  63. _virtualNetworkConfigFunction(virtualNetworkConfigFunction),
  64. _eventCallback(eventCallback),
  65. _networks(),
  66. _networks_m(),
  67. _now(now),
  68. _startTimeAfterInactivity(0),
  69. _lastPingCheck(0),
  70. _lastHousekeepingRun(0),
  71. _coreDesperation(0)
  72. {
  73. _newestVersionSeen[0] = ZEROTIER_ONE_VERSION_MAJOR;
  74. _newestVersionSeen[1] = ZEROTIER_ONE_VERSION_MINOR;
  75. _newestVersionSeen[2] = ZEROTIER_ONE_VERSION_REVISION;
  76. _online = false;
  77. std::string idtmp(dataStoreGet("identity.secret"));
  78. if ((!idtmp.length())||(!RR->identity.fromString(idtmp))||(!RR->identity.hasPrivate())) {
  79. TRACE("identity.secret not found, generating...");
  80. RR->identity.generate();
  81. idtmp = RR->identity.toString(true);
  82. if (!dataStorePut("identity.secret",idtmp,true)) {
  83. delete RR;
  84. throw std::runtime_error("unable to write identity.secret");
  85. }
  86. idtmp = RR->identity.toString(false);
  87. if (!dataStorePut("identity.public",idtmp,false)) {
  88. delete RR;
  89. throw std::runtime_error("unable to write identity.public");
  90. }
  91. }
  92. RR->publicIdentityStr = RR->identity.toString(false);
  93. RR->secretIdentityStr = RR->identity.toString(true);
  94. try {
  95. RR->prng = new CMWC4096();
  96. RR->sw = new Switch(RR);
  97. RR->mc = new Multicaster(RR);
  98. RR->antiRec = new AntiRecursion();
  99. RR->topology = new Topology(RR);
  100. RR->sa = new SelfAwareness(RR);
  101. } catch ( ... ) {
  102. delete RR->sa;
  103. delete RR->topology;
  104. delete RR->antiRec;
  105. delete RR->mc;
  106. delete RR->sw;
  107. delete RR->prng;
  108. delete RR;
  109. throw;
  110. }
  111. Dictionary rt;
  112. if (overrideRootTopology) {
  113. rt.fromString(std::string(overrideRootTopology));
  114. } else {
  115. std::string rttmp(dataStoreGet("root-topology"));
  116. if (rttmp.length() > 0) {
  117. rt.fromString(rttmp);
  118. if (!Topology::authenticateRootTopology(rt))
  119. rt.clear();
  120. }
  121. if (!rt.size())
  122. rt.fromString(ZT_DEFAULTS.defaultRootTopology);
  123. }
  124. RR->topology->setSupernodes(Dictionary(rt.get("supernodes","")));
  125. postEvent(ZT1_EVENT_UP);
  126. }
  127. Node::~Node()
  128. {
  129. delete RR->sa;
  130. delete RR->topology;
  131. delete RR->antiRec;
  132. delete RR->mc;
  133. delete RR->sw;
  134. delete RR->prng;
  135. delete RR;
  136. }
  137. ZT1_ResultCode Node::processWirePacket(
  138. uint64_t now,
  139. const struct sockaddr_storage *remoteAddress,
  140. unsigned int linkDesperation,
  141. const void *packetData,
  142. unsigned int packetLength,
  143. uint64_t *nextBackgroundTaskDeadline)
  144. {
  145. if (now >= *nextBackgroundTaskDeadline) {
  146. ZT1_ResultCode rc = processBackgroundTasks(now,nextBackgroundTaskDeadline);
  147. if (rc != ZT1_RESULT_OK)
  148. return rc;
  149. } else _now = now;
  150. RR->sw->onRemotePacket(*(reinterpret_cast<const InetAddress *>(remoteAddress)),linkDesperation,packetData,packetLength);
  151. return ZT1_RESULT_OK;
  152. }
  153. ZT1_ResultCode Node::processVirtualNetworkFrame(
  154. uint64_t now,
  155. uint64_t nwid,
  156. uint64_t sourceMac,
  157. uint64_t destMac,
  158. unsigned int etherType,
  159. unsigned int vlanId,
  160. const void *frameData,
  161. unsigned int frameLength,
  162. uint64_t *nextBackgroundTaskDeadline)
  163. {
  164. if (now >= *nextBackgroundTaskDeadline) {
  165. ZT1_ResultCode rc = processBackgroundTasks(now,nextBackgroundTaskDeadline);
  166. if (rc != ZT1_RESULT_OK)
  167. return rc;
  168. } else _now = now;
  169. SharedPtr<Network> nw(network(nwid));
  170. if (nw)
  171. RR->sw->onLocalEthernet(nw,MAC(sourceMac),MAC(destMac),etherType,vlanId,frameData,frameLength);
  172. else return ZT1_RESULT_ERROR_NETWORK_NOT_FOUND;
  173. return ZT1_RESULT_OK;
  174. }
  175. class _PingPeersThatNeedPing
  176. {
  177. public:
  178. _PingPeersThatNeedPing(const RuntimeEnvironment *renv,uint64_t now) :
  179. lastReceiveFromUpstream(0),
  180. RR(renv),
  181. _now(now),
  182. _supernodes(RR->topology->supernodeAddresses()) {}
  183. uint64_t lastReceiveFromUpstream;
  184. inline void operator()(Topology &t,const SharedPtr<Peer> &p)
  185. {
  186. if (std::find(_supernodes.begin(),_supernodes.end(),p->address()) != _supernodes.end()) {
  187. p->doPingAndKeepalive(RR,_now);
  188. if (p->lastReceive() > lastReceiveFromUpstream)
  189. lastReceiveFromUpstream = p->lastReceive();
  190. } else if (p->alive(_now)) {
  191. p->doPingAndKeepalive(RR,_now);
  192. }
  193. }
  194. private:
  195. const RuntimeEnvironment *RR;
  196. uint64_t _now;
  197. std::vector<Address> _supernodes;
  198. };
  199. ZT1_ResultCode Node::processBackgroundTasks(uint64_t now,uint64_t *nextBackgroundTaskDeadline)
  200. {
  201. _now = now;
  202. Mutex::Lock bl(_backgroundTasksLock);
  203. if ((now - _lastPingCheck) >= ZT_PING_CHECK_INVERVAL) {
  204. _lastPingCheck = now;
  205. // This is used as a floor for the desperation and online status
  206. // calculations if we just started up or have been asleep.
  207. if ((now - _startTimeAfterInactivity) > (ZT_PING_CHECK_INVERVAL * 3))
  208. _startTimeAfterInactivity = now;
  209. try {
  210. _PingPeersThatNeedPing pfunc(RR,now);
  211. RR->topology->eachPeer<_PingPeersThatNeedPing &>(pfunc);
  212. const uint64_t lastActivityAgo = now - std::max(_startTimeAfterInactivity,pfunc.lastReceiveFromUpstream);
  213. _coreDesperation = (unsigned int)(lastActivityAgo / (ZT_PING_CHECK_INVERVAL * ZT_CORE_DESPERATION_INCREMENT));
  214. bool oldOnline = _online;
  215. _online = (lastActivityAgo < ZT_PEER_ACTIVITY_TIMEOUT);
  216. if (oldOnline != _online)
  217. postEvent(_online ? ZT1_EVENT_ONLINE : ZT1_EVENT_OFFLINE);
  218. } catch ( ... ) {
  219. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  220. }
  221. try {
  222. Mutex::Lock _l(_networks_m);
  223. for(std::map< uint64_t,SharedPtr<Network> >::const_iterator n(_networks.begin());n!=_networks.end();++n) {
  224. if ((now - n->second->lastConfigUpdate()) >= ZT_NETWORK_AUTOCONF_DELAY)
  225. n->second->requestConfiguration();
  226. }
  227. } catch ( ... ) {
  228. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  229. }
  230. }
  231. if ((now - _lastHousekeepingRun) >= ZT_HOUSEKEEPING_PERIOD) {
  232. _lastHousekeepingRun = now;
  233. try {
  234. RR->topology->clean(now);
  235. } catch ( ... ) {
  236. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  237. }
  238. try {
  239. RR->mc->clean(now);
  240. } catch ( ... ) {
  241. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  242. }
  243. }
  244. try {
  245. *nextBackgroundTaskDeadline = now + (uint64_t)std::max(std::min((unsigned long)ZT_PING_CHECK_INVERVAL,RR->sw->doTimerTasks(now)),(unsigned long)ZT_CORE_TIMER_TASK_GRANULARITY);
  246. } catch ( ... ) {
  247. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  248. }
  249. return ZT1_RESULT_OK;
  250. }
  251. ZT1_ResultCode Node::join(uint64_t nwid)
  252. {
  253. Mutex::Lock _l(_networks_m);
  254. SharedPtr<Network> &nw = _networks[nwid];
  255. if (!nw)
  256. nw = SharedPtr<Network>(new Network(RR,nwid));
  257. return ZT1_RESULT_OK;
  258. }
  259. ZT1_ResultCode Node::leave(uint64_t nwid)
  260. {
  261. Mutex::Lock _l(_networks_m);
  262. std::map< uint64_t,SharedPtr<Network> >::iterator nw(_networks.find(nwid));
  263. if (nw != _networks.end()) {
  264. nw->second->destroy();
  265. _networks.erase(nw);
  266. }
  267. return ZT1_RESULT_OK;
  268. }
  269. ZT1_ResultCode Node::multicastSubscribe(uint64_t nwid,uint64_t multicastGroup,unsigned long multicastAdi)
  270. {
  271. Mutex::Lock _l(_networks_m);
  272. std::map< uint64_t,SharedPtr<Network> >::iterator nw(_networks.find(nwid));
  273. if (nw != _networks.end())
  274. nw->second->multicastSubscribe(MulticastGroup(MAC(multicastGroup),(uint32_t)(multicastAdi & 0xffffffff)));
  275. return ZT1_RESULT_OK;
  276. }
  277. ZT1_ResultCode Node::multicastUnsubscribe(uint64_t nwid,uint64_t multicastGroup,unsigned long multicastAdi)
  278. {
  279. Mutex::Lock _l(_networks_m);
  280. std::map< uint64_t,SharedPtr<Network> >::iterator nw(_networks.find(nwid));
  281. if (nw != _networks.end())
  282. nw->second->multicastUnsubscribe(MulticastGroup(MAC(multicastGroup),(uint32_t)(multicastAdi & 0xffffffff)));
  283. return ZT1_RESULT_OK;
  284. }
  285. void Node::status(ZT1_NodeStatus *status)
  286. {
  287. status->address = RR->identity.address().toInt();
  288. status->publicIdentity = RR->publicIdentityStr.c_str();
  289. status->secretIdentity = RR->secretIdentityStr.c_str();
  290. status->online = _online ? 1 : 0;
  291. }
  292. ZT1_PeerList *Node::peers()
  293. {
  294. std::map< Address,SharedPtr<Peer> > peers(RR->topology->allPeers());
  295. char *buf = (char *)::malloc(sizeof(ZT1_PeerList) + (sizeof(ZT1_Peer) * peers.size()));
  296. if (!buf)
  297. return (ZT1_PeerList *)0;
  298. ZT1_PeerList *pl = (ZT1_PeerList *)buf;
  299. pl->peers = (ZT1_Peer *)(buf + sizeof(ZT1_PeerList));
  300. pl->peerCount = 0;
  301. for(std::map< Address,SharedPtr<Peer> >::iterator pi(peers.begin());pi!=peers.end();++pi) {
  302. ZT1_Peer *p = &(pl->peers[pl->peerCount++]);
  303. p->address = pi->second->address().toInt();
  304. if (pi->second->remoteVersionKnown()) {
  305. p->versionMajor = pi->second->remoteVersionMajor();
  306. p->versionMinor = pi->second->remoteVersionMinor();
  307. p->versionRev = pi->second->remoteVersionRevision();
  308. } else {
  309. p->versionMajor = -1;
  310. p->versionMinor = -1;
  311. p->versionRev = -1;
  312. }
  313. p->latency = pi->second->latency();
  314. p->role = RR->topology->isSupernode(pi->second->address()) ? ZT1_PEER_ROLE_SUPERNODE : ZT1_PEER_ROLE_LEAF;
  315. std::vector<Path> paths(pi->second->paths());
  316. p->pathCount = 0;
  317. for(std::vector<Path>::iterator path(paths.begin());path!=paths.end();++path) {
  318. memcpy(&(p->paths[p->pathCount].address),&(path->address()),sizeof(struct sockaddr_storage));
  319. p->paths[p->pathCount].lastSend = path->lastSend();
  320. p->paths[p->pathCount].lastReceive = path->lastReceived();
  321. p->paths[p->pathCount].fixed = path->fixed() ? 1 : 0;
  322. ++p->pathCount;
  323. }
  324. }
  325. return pl;
  326. }
  327. ZT1_VirtualNetworkConfig *Node::networkConfig(uint64_t nwid)
  328. {
  329. Mutex::Lock _l(_networks_m);
  330. std::map< uint64_t,SharedPtr<Network> >::iterator nw(_networks.find(nwid));
  331. if (nw != _networks.end()) {
  332. ZT1_VirtualNetworkConfig *nc = (ZT1_VirtualNetworkConfig *)::malloc(sizeof(ZT1_VirtualNetworkConfig));
  333. nw->second->externalConfig(nc);
  334. return nc;
  335. }
  336. return (ZT1_VirtualNetworkConfig *)0;
  337. }
  338. ZT1_VirtualNetworkList *Node::networks()
  339. {
  340. Mutex::Lock _l(_networks_m);
  341. char *buf = (char *)::malloc(sizeof(ZT1_VirtualNetworkList) + (sizeof(ZT1_VirtualNetworkConfig) * _networks.size()));
  342. if (!buf)
  343. return (ZT1_VirtualNetworkList *)0;
  344. ZT1_VirtualNetworkList *nl = (ZT1_VirtualNetworkList *)buf;
  345. nl->networks = (ZT1_VirtualNetworkConfig *)(buf + sizeof(ZT1_VirtualNetworkList));
  346. nl->networkCount = 0;
  347. for(std::map< uint64_t,SharedPtr<Network> >::const_iterator n(_networks.begin());n!=_networks.end();++n)
  348. n->second->externalConfig(&(nl->networks[nl->networkCount++]));
  349. return nl;
  350. }
  351. void Node::freeQueryResult(void *qr)
  352. {
  353. if (qr)
  354. ::free(qr);
  355. }
  356. void Node::setNetconfMaster(void *networkConfigMasterInstance)
  357. {
  358. RR->netconfMaster = reinterpret_cast<NetworkConfigMaster *>(networkConfigMasterInstance);
  359. }
  360. /****************************************************************************/
  361. /* Node methods used only within node/ */
  362. /****************************************************************************/
  363. std::string Node::dataStoreGet(const char *name)
  364. {
  365. char buf[16384];
  366. std::string r;
  367. unsigned long olen = 0;
  368. do {
  369. long n = _dataStoreGetFunction(reinterpret_cast<ZT1_Node *>(this),_uptr,name,buf,sizeof(buf),r.length(),&olen);
  370. if (n <= 0)
  371. return std::string();
  372. r.append(buf,n);
  373. } while (r.length() < olen);
  374. return r;
  375. }
  376. void Node::postNewerVersionIfNewer(unsigned int major,unsigned int minor,unsigned int rev)
  377. {
  378. if (Peer::compareVersion(major,minor,rev,_newestVersionSeen[0],_newestVersionSeen[1],_newestVersionSeen[2]) > 0) {
  379. _newestVersionSeen[0] = major;
  380. _newestVersionSeen[1] = minor;
  381. _newestVersionSeen[2] = rev;
  382. this->postEvent(ZT1_EVENT_SAW_MORE_RECENT_VERSION,(const void *)_newestVersionSeen);
  383. }
  384. }
  385. #ifdef ZT_TRACE
  386. void Node::postTrace(const char *module,unsigned int line,const char *fmt,...)
  387. {
  388. static Mutex traceLock;
  389. va_list ap;
  390. char tmp1[1024],tmp2[1024],tmp3[256];
  391. Mutex::Lock _l(traceLock);
  392. #ifdef __WINDOWS__
  393. ctime_s(tmp3,sizeof(tmp3),&now);
  394. char *nowstr = tmp3;
  395. #else
  396. time_t now = (time_t)(_now / 1000ULL);
  397. char *nowstr = ctime_r(&now,tmp3);
  398. #endif
  399. unsigned long nowstrlen = strlen(nowstr);
  400. if (nowstr[nowstrlen-1] == '\n')
  401. nowstr[--nowstrlen] = (char)0;
  402. if (nowstr[nowstrlen-1] == '\r')
  403. nowstr[--nowstrlen] = (char)0;
  404. va_start(ap,fmt);
  405. vsnprintf(tmp2,sizeof(tmp2),fmt,ap);
  406. va_end(ap);
  407. tmp2[sizeof(tmp2)-1] = (char)0;
  408. Utils::snprintf(tmp1,sizeof(tmp1),"[%s] %s:%u %s",nowstr,module,line,tmp2);
  409. postEvent(ZT1_EVENT_TRACE,tmp1);
  410. }
  411. #endif // ZT_TRACE
  412. } // namespace ZeroTier
  413. /****************************************************************************/
  414. /* CAPI bindings */
  415. /****************************************************************************/
  416. extern "C" {
  417. enum ZT1_ResultCode ZT1_Node_new(
  418. ZT1_Node **node,
  419. void *uptr,
  420. uint64_t now,
  421. ZT1_DataStoreGetFunction dataStoreGetFunction,
  422. ZT1_DataStorePutFunction dataStorePutFunction,
  423. ZT1_WirePacketSendFunction wirePacketSendFunction,
  424. ZT1_VirtualNetworkFrameFunction virtualNetworkFrameFunction,
  425. ZT1_VirtualNetworkConfigFunction virtualNetworkConfigFunction,
  426. ZT1_EventCallback eventCallback,
  427. const char *overrideRootTopology)
  428. {
  429. *node = (ZT1_Node *)0;
  430. try {
  431. *node = reinterpret_cast<ZT1_Node *>(new ZeroTier::Node(now,uptr,dataStoreGetFunction,dataStorePutFunction,wirePacketSendFunction,virtualNetworkFrameFunction,virtualNetworkConfigFunction,eventCallback,overrideRootTopology));
  432. return ZT1_RESULT_OK;
  433. } catch (std::bad_alloc &exc) {
  434. return ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY;
  435. } catch (std::runtime_error &exc) {
  436. return ZT1_RESULT_FATAL_ERROR_DATA_STORE_FAILED;
  437. } catch ( ... ) {
  438. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  439. }
  440. }
  441. void ZT1_Node_delete(ZT1_Node *node)
  442. {
  443. try {
  444. delete (reinterpret_cast<ZeroTier::Node *>(node));
  445. } catch ( ... ) {}
  446. }
  447. enum ZT1_ResultCode ZT1_Node_processWirePacket(
  448. ZT1_Node *node,
  449. uint64_t now,
  450. const struct sockaddr_storage *remoteAddress,
  451. unsigned int linkDesperation,
  452. const void *packetData,
  453. unsigned int packetLength,
  454. uint64_t *nextBackgroundTaskDeadline)
  455. {
  456. try {
  457. return reinterpret_cast<ZeroTier::Node *>(node)->processWirePacket(now,remoteAddress,linkDesperation,packetData,packetLength,nextBackgroundTaskDeadline);
  458. } catch (std::bad_alloc &exc) {
  459. return ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY;
  460. } catch ( ... ) {
  461. reinterpret_cast<ZeroTier::Node *>(node)->postEvent(ZT1_EVENT_INVALID_PACKET,(const void *)remoteAddress);
  462. return ZT1_RESULT_OK;
  463. }
  464. }
  465. enum ZT1_ResultCode ZT1_Node_processVirtualNetworkFrame(
  466. ZT1_Node *node,
  467. uint64_t now,
  468. uint64_t nwid,
  469. uint64_t sourceMac,
  470. uint64_t destMac,
  471. unsigned int etherType,
  472. unsigned int vlanId,
  473. const void *frameData,
  474. unsigned int frameLength,
  475. uint64_t *nextBackgroundTaskDeadline)
  476. {
  477. try {
  478. return reinterpret_cast<ZeroTier::Node *>(node)->processVirtualNetworkFrame(now,nwid,sourceMac,destMac,etherType,vlanId,frameData,frameLength,nextBackgroundTaskDeadline);
  479. } catch (std::bad_alloc &exc) {
  480. return ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY;
  481. } catch ( ... ) {
  482. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  483. }
  484. }
  485. enum ZT1_ResultCode ZT1_Node_processBackgroundTasks(ZT1_Node *node,uint64_t now,uint64_t *nextBackgroundTaskDeadline)
  486. {
  487. try {
  488. return reinterpret_cast<ZeroTier::Node *>(node)->processBackgroundTasks(now,nextBackgroundTaskDeadline);
  489. } catch (std::bad_alloc &exc) {
  490. return ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY;
  491. } catch ( ... ) {
  492. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  493. }
  494. }
  495. enum ZT1_ResultCode ZT1_Node_join(ZT1_Node *node,uint64_t nwid)
  496. {
  497. try {
  498. return reinterpret_cast<ZeroTier::Node *>(node)->join(nwid);
  499. } catch (std::bad_alloc &exc) {
  500. return ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY;
  501. } catch ( ... ) {
  502. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  503. }
  504. }
  505. enum ZT1_ResultCode ZT1_Node_leave(ZT1_Node *node,uint64_t nwid)
  506. {
  507. try {
  508. return reinterpret_cast<ZeroTier::Node *>(node)->leave(nwid);
  509. } catch (std::bad_alloc &exc) {
  510. return ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY;
  511. } catch ( ... ) {
  512. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  513. }
  514. }
  515. enum ZT1_ResultCode ZT1_Node_multicastSubscribe(ZT1_Node *node,uint64_t nwid,uint64_t multicastGroup,unsigned long multicastAdi)
  516. {
  517. try {
  518. return reinterpret_cast<ZeroTier::Node *>(node)->multicastSubscribe(nwid,multicastGroup,multicastAdi);
  519. } catch (std::bad_alloc &exc) {
  520. return ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY;
  521. } catch ( ... ) {
  522. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  523. }
  524. }
  525. enum ZT1_ResultCode ZT1_Node_multicastUnsubscribe(ZT1_Node *node,uint64_t nwid,uint64_t multicastGroup,unsigned long multicastAdi)
  526. {
  527. try {
  528. return reinterpret_cast<ZeroTier::Node *>(node)->multicastUnsubscribe(nwid,multicastGroup,multicastAdi);
  529. } catch (std::bad_alloc &exc) {
  530. return ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY;
  531. } catch ( ... ) {
  532. return ZT1_RESULT_FATAL_ERROR_INTERNAL;
  533. }
  534. }
  535. void ZT1_Node_status(ZT1_Node *node,ZT1_NodeStatus *status)
  536. {
  537. try {
  538. reinterpret_cast<ZeroTier::Node *>(node)->status(status);
  539. } catch ( ... ) {}
  540. }
  541. ZT1_PeerList *ZT1_Node_peers(ZT1_Node *node)
  542. {
  543. try {
  544. return reinterpret_cast<ZeroTier::Node *>(node)->peers();
  545. } catch ( ... ) {
  546. return (ZT1_PeerList *)0;
  547. }
  548. }
  549. ZT1_VirtualNetworkConfig *ZT1_Node_networkConfig(ZT1_Node *node,uint64_t nwid)
  550. {
  551. try {
  552. return reinterpret_cast<ZeroTier::Node *>(node)->networkConfig(nwid);
  553. } catch ( ... ) {
  554. return (ZT1_VirtualNetworkConfig *)0;
  555. }
  556. }
  557. ZT1_VirtualNetworkList *ZT1_Node_networks(ZT1_Node *node)
  558. {
  559. try {
  560. return reinterpret_cast<ZeroTier::Node *>(node)->networks();
  561. } catch ( ... ) {
  562. return (ZT1_VirtualNetworkList *)0;
  563. }
  564. }
  565. void ZT1_Node_freeQueryResult(ZT1_Node *node,void *qr)
  566. {
  567. try {
  568. reinterpret_cast<ZeroTier::Node *>(node)->freeQueryResult(qr);
  569. } catch ( ... ) {}
  570. }
  571. void ZT1_Node_setNetconfMaster(ZT1_Node *node,void *networkConfigMasterInstance)
  572. {
  573. try {
  574. reinterpret_cast<ZeroTier::Node *>(node)->setNetconfMaster(networkConfigMasterInstance);
  575. } catch ( ... ) {}
  576. }
  577. void ZT1_version(int *major,int *minor,int *revision,unsigned long *featureFlags)
  578. {
  579. if (major) *major = ZEROTIER_ONE_VERSION_MAJOR;
  580. if (minor) *minor = ZEROTIER_ONE_VERSION_MINOR;
  581. if (revision) *revision = ZEROTIER_ONE_VERSION_REVISION;
  582. if (featureFlags) {
  583. *featureFlags = (
  584. ZT1_FEATURE_FLAG_THREAD_SAFE
  585. );
  586. }
  587. }
  588. } // extern "C"