com_zerotierone_sdk_Node.cpp 29 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070
  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 "com_zerotierone_sdk_Node.h"
  28. #include "ZT1_jniutils.h"
  29. #include <ZeroTierOne.h>
  30. #include <map>
  31. #include <string>
  32. #include <assert.h>
  33. #include <string.h>
  34. #ifdef __cplusplus
  35. extern "C" {
  36. #endif
  37. namespace {
  38. struct JniRef
  39. {
  40. JniRef()
  41. : env(NULL)
  42. , node(NULL)
  43. , dataStoreGetListener(NULL)
  44. , dataStorePutListener(NULL)
  45. , packetSender(NULL)
  46. , frameListener(NULL)
  47. , configListener(NULL)
  48. {}
  49. uint64_t id;
  50. JNIEnv *env;
  51. ZT1_Node *node;
  52. jobject dataStoreGetListener;
  53. jobject dataStorePutListener;
  54. jobject packetSender;
  55. jobject frameListener;
  56. jobject configListener;
  57. };
  58. int VirtualNetworkConfigFunctionCallback(ZT1_Node *node,void *userData,uint64_t,enum ZT1_VirtualNetworkConfigOperation,const ZT1_VirtualNetworkConfig *)
  59. {
  60. JniRef *ref = (JniRef*)userData;
  61. assert(ref->node == node);
  62. JNIEnv *env = ref->env;
  63. return 0;
  64. }
  65. void VirtualNetworkFrameFunctionCallback(ZT1_Node *node,void *userData,uint64_t,uint64_t,uint64_t,unsigned int,unsigned int,const void *,unsigned int)
  66. {
  67. JniRef *ref = (JniRef*)userData;
  68. assert(ref->node == node);
  69. JNIEnv *env = ref->env;
  70. }
  71. void EventCallback(ZT1_Node *node,void *userData,enum ZT1_Event,const void *)
  72. {
  73. JniRef *ref = (JniRef*)userData;
  74. assert(ref->node == node);
  75. JNIEnv *env = ref->env;
  76. }
  77. long DataStoreGetFunction(ZT1_Node *node,void *userData,const char *,void *,unsigned long,unsigned long,unsigned long *)
  78. {
  79. JniRef *ref = (JniRef*)userData;
  80. assert(ref->node == node);
  81. JNIEnv *env = ref->env;
  82. return 0;
  83. }
  84. int DataStorePutFunction(ZT1_Node *node,void *userData,const char *,const void *,unsigned long,int)
  85. {
  86. JniRef *ref = (JniRef*)userData;
  87. assert(ref->node == node);
  88. JNIEnv *env = ref->env;
  89. return 0;
  90. }
  91. int WirePacketSendFunction(ZT1_Node *node,void *userData,const struct sockaddr_storage *,unsigned int,const void *,unsigned int)
  92. {
  93. JniRef *ref = (JniRef*)userData;
  94. assert(ref->node == node);
  95. JNIEnv *env = ref->env;
  96. return 0;
  97. }
  98. typedef std::map<uint64_t, JniRef*> NodeMap;
  99. static NodeMap nodeMap;
  100. ZT1_Node* findNode(uint64_t nodeId)
  101. {
  102. NodeMap::iterator found = nodeMap.find(nodeId);
  103. if(found != nodeMap.end())
  104. {
  105. JniRef *ref = found->second;
  106. return ref->node;
  107. }
  108. return NULL;
  109. }
  110. }
  111. /*
  112. * Class: com_zerotierone_sdk_Node
  113. * Method: node_init
  114. * Signature: (J)Lcom/zerotierone/sdk/ResultCode;
  115. */
  116. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_node_1init(
  117. JNIEnv *env, jobject obj, jlong now)
  118. {
  119. jobject resultObject = createResultObject(env, ZT1_RESULT_OK);
  120. ZT1_Node *node;
  121. JniRef *ref = new JniRef;
  122. ZT1_ResultCode rc = ZT1_Node_new(
  123. &node,
  124. ref,
  125. (uint64_t)now,
  126. &DataStoreGetFunction,
  127. &DataStorePutFunction,
  128. &WirePacketSendFunction,
  129. &VirtualNetworkFrameFunctionCallback,
  130. &VirtualNetworkConfigFunctionCallback,
  131. &EventCallback);
  132. if(rc != ZT1_RESULT_OK)
  133. {
  134. resultObject = createResultObject(env, rc);
  135. if(node)
  136. {
  137. ZT1_Node_delete(node);
  138. node = NULL;
  139. }
  140. delete ref;
  141. ref = NULL;
  142. return resultObject;
  143. }
  144. ref->id = (uint64_t)now;
  145. ref->env = env;
  146. ref->node = node;
  147. jclass cls = env->GetObjectClass(obj);
  148. jfieldID fid = env->GetFieldID(
  149. cls, "getListener", "Lcom/zerotierone/sdk/DataStoreGetListener;");
  150. if(fid == NULL)
  151. {
  152. return NULL; // exception already thrown
  153. }
  154. ref->dataStoreGetListener = env->GetObjectField(obj, fid);
  155. if(ref->dataStoreGetListener == NULL)
  156. {
  157. return NULL;
  158. }
  159. fid = env->GetFieldID(
  160. cls, "putListener", "Lcom/zerotierone/sdk/DataStorePutLisetner;");
  161. if(fid == NULL)
  162. {
  163. return NULL; // exception already thrown
  164. }
  165. ref->dataStorePutListener = env->GetObjectField(obj, fid);
  166. if(ref->dataStorePutListener == NULL)
  167. {
  168. return NULL;
  169. }
  170. fid = env->GetFieldID(
  171. cls, "sender", "Lcom/zerotierone/sdk/PacketSender;");
  172. if(fid == NULL)
  173. {
  174. return NULL; // exception already thrown
  175. }
  176. ref->packetSender = env->GetObjectField(obj, fid);
  177. if(ref->packetSender == NULL)
  178. {
  179. return NULL;
  180. }
  181. fid = env->GetFieldID(
  182. cls, "frameListener", "Lcom/zerotierone/sdk/VirtualNetworkFrameListener;");
  183. if(fid == NULL)
  184. {
  185. return NULL; // exception already thrown
  186. }
  187. ref->frameListener = env->GetObjectField(obj, fid);
  188. if(ref->frameListener = NULL)
  189. {
  190. return NULL;
  191. }
  192. fid = env->GetFieldID(
  193. cls, "configListener", "Lcom/zerotierone/sdk/VirtualNetworkConfigListener;");
  194. if(fid == NULL)
  195. {
  196. return NULL; // exception already thrown
  197. }
  198. ref->configListener = env->GetObjectField(obj, fid);
  199. if(ref->configListener == NULL)
  200. {
  201. return NULL;
  202. }
  203. nodeMap.insert(std::make_pair(ref->id, ref));
  204. return resultObject;
  205. }
  206. /*
  207. * Class: com_zerotierone_sdk_Node
  208. * Method: node_delete
  209. * Signature: (J)V
  210. */
  211. JNIEXPORT void JNICALL Java_com_zerotierone_sdk_Node_node_1delete(
  212. JNIEnv *env, jobject obj, jlong id)
  213. {
  214. uint64_t nodeId = (uint64_t)id;
  215. NodeMap::iterator found = nodeMap.find(nodeId);
  216. if(found != nodeMap.end())
  217. {
  218. JniRef *ref = found->second;
  219. nodeMap.erase(found);
  220. ZT1_Node_delete(ref->node);
  221. delete ref;
  222. ref = NULL;
  223. }
  224. }
  225. /*
  226. * Class: com_zerotierone_sdk_Node
  227. * Method: processVirtualNetworkFrame
  228. * Signature: (JJJJJII[B[J)Lcom/zerotierone/sdk/ResultCode;
  229. */
  230. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_processVirtualNetworkFrame(
  231. JNIEnv *env, jobject obj,
  232. jlong id,
  233. jlong in_now,
  234. jlong in_nwid,
  235. jlong in_sourceMac,
  236. jlong in_destMac,
  237. jint in_etherType,
  238. jint in_vlanId,
  239. jbyteArray in_frameData,
  240. jlongArray out_nextBackgroundTaskDeadline)
  241. {
  242. uint64_t nodeId = (uint64_t) id;
  243. ZT1_Node *node = findNode(nodeId);
  244. if(node == NULL)
  245. {
  246. // cannot find valid node. We should never get here.
  247. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  248. }
  249. unsigned int nbtd_len = env->GetArrayLength(out_nextBackgroundTaskDeadline);
  250. if(nbtd_len < 1)
  251. {
  252. // array for next background task length has 0 elements!
  253. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  254. }
  255. uint64_t now = (uint64_t)in_now;
  256. uint64_t nwid = (uint64_t)in_nwid;
  257. uint64_t sourceMac = (uint64_t)in_sourceMac;
  258. uint64_t destMac = (uint64_t)in_destMac;
  259. unsigned int etherType = (unsigned int)in_etherType;
  260. unsigned int vlanId = (unsigned int)in_vlanId;
  261. unsigned int frameLength = env->GetArrayLength(in_frameData);
  262. jbyte *frameData =env->GetByteArrayElements(in_frameData, NULL);
  263. uint64_t nextBackgroundTaskDeadline = 0;
  264. ZT1_ResultCode rc = ZT1_Node_processVirtualNetworkFrame(
  265. node,
  266. now,
  267. nwid,
  268. sourceMac,
  269. destMac,
  270. etherType,
  271. vlanId,
  272. (const void*)frameData,
  273. frameLength,
  274. &nextBackgroundTaskDeadline);
  275. jlong *outDeadline = env->GetLongArrayElements(out_nextBackgroundTaskDeadline, NULL);
  276. outDeadline[0] = (jlong)nextBackgroundTaskDeadline;
  277. env->ReleaseLongArrayElements(out_nextBackgroundTaskDeadline, outDeadline, 0);
  278. env->ReleaseByteArrayElements(in_frameData, frameData, 0);
  279. return createResultObject(env, rc);
  280. }
  281. /*
  282. * Class: com_zerotierone_sdk_Node
  283. * Method: processWirePacket
  284. * Signature: (JJLjava/net/InetAddress;I[B[J)Lcom/zerotierone/sdk/ResultCode;
  285. */
  286. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_processWirePacket(
  287. JNIEnv *env, jobject obj,
  288. jlong id,
  289. jlong in_now,
  290. jobject in_remoteAddress,
  291. jint in_linkDesparation,
  292. jbyteArray in_packetData,
  293. jlongArray out_nextBackgroundTaskDeadline)
  294. {
  295. uint64_t nodeId = (uint64_t) id;
  296. ZT1_Node *node = findNode(nodeId);
  297. if(node == NULL)
  298. {
  299. // cannot find valid node. We should never get here.
  300. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  301. }
  302. unsigned int nbtd_len = env->GetArrayLength(out_nextBackgroundTaskDeadline);
  303. if(nbtd_len < 1)
  304. {
  305. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  306. }
  307. uint64_t now = (uint64_t)in_now;
  308. unsigned int linkDesparation = (unsigned int)in_linkDesparation;
  309. // get the java.net.InetAddress class and getAddress() method
  310. jclass inetAddressClass = env->FindClass("java/net/InetAddress");
  311. if(inetAddressClass == NULL)
  312. {
  313. // can't find java.net.InetAddress
  314. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  315. }
  316. jmethodID getAddressMethod = env->GetMethodID(
  317. inetAddressClass, "getAddress", "()[B");
  318. if(getAddressMethod == NULL)
  319. {
  320. // cant find InetAddress.getAddres()
  321. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  322. }
  323. // Call InetAddress.getAddress()
  324. jbyteArray addressArray = (jbyteArray)env->CallObjectMethod(in_remoteAddress, getAddressMethod);
  325. if(addressArray == NULL)
  326. {
  327. // unable to call getAddress()
  328. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  329. }
  330. unsigned int addrSize = env->GetArrayLength(addressArray);
  331. // get the address bytes
  332. jbyte *addr = env->GetByteArrayElements(addressArray, NULL);
  333. sockaddr_storage remoteAddress = {};
  334. if(addrSize == 16)
  335. {
  336. // IPV6 address
  337. sockaddr_in6 ipv6 = {};
  338. ipv6.sin6_family = AF_INET6;
  339. memcpy(ipv6.sin6_addr.s6_addr, addr, 16);
  340. memcpy(&remoteAddress, &ipv6, sizeof(sockaddr_in6));
  341. }
  342. else if(addrSize = 4)
  343. {
  344. // IPV4 address
  345. sockaddr_in ipv4 = {};
  346. ipv4.sin_family = AF_INET;
  347. memcpy(&ipv4.sin_addr, addr, 4);
  348. memcpy(&remoteAddress, &ipv4, sizeof(sockaddr_in));
  349. }
  350. else
  351. {
  352. // unknown address type
  353. env->ReleaseByteArrayElements(addressArray, addr, 0);
  354. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  355. }
  356. unsigned int packetLength = env->GetArrayLength(in_packetData);
  357. jbyte *packetData = env->GetByteArrayElements(in_packetData, NULL);
  358. uint64_t nextBackgroundTaskDeadline = 0;
  359. ZT1_ResultCode rc = ZT1_Node_processWirePacket(
  360. node,
  361. now,
  362. &remoteAddress,
  363. linkDesparation,
  364. packetData,
  365. packetLength,
  366. &nextBackgroundTaskDeadline);
  367. jlong *outDeadline = env->GetLongArrayElements(out_nextBackgroundTaskDeadline, NULL);
  368. outDeadline[0] = (jlong)nextBackgroundTaskDeadline;
  369. env->ReleaseLongArrayElements(out_nextBackgroundTaskDeadline, outDeadline, 0);
  370. env->ReleaseByteArrayElements(addressArray, addr, 0);
  371. env->ReleaseByteArrayElements(in_packetData, packetData, 0);
  372. return createResultObject(env, ZT1_RESULT_OK);
  373. }
  374. /*
  375. * Class: com_zerotierone_sdk_Node
  376. * Method: processBackgroundTasks
  377. * Signature: (JJ[J)Lcom/zerotierone/sdk/ResultCode;
  378. */
  379. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_processBackgroundTasks(
  380. JNIEnv *env, jobject obj,
  381. jlong id,
  382. jlong in_now,
  383. jlongArray out_nextBackgroundTaskDeadline)
  384. {
  385. uint64_t nodeId = (uint64_t) id;
  386. ZT1_Node *node = findNode(nodeId);
  387. if(node == NULL)
  388. {
  389. // cannot find valid node. We should never get here.
  390. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  391. }
  392. unsigned int nbtd_len = env->GetArrayLength(out_nextBackgroundTaskDeadline);
  393. if(nbtd_len < 1)
  394. {
  395. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  396. }
  397. uint64_t now = (uint64_t)in_now;
  398. uint64_t nextBackgroundTaskDeadline = 0;
  399. ZT1_ResultCode rc = ZT1_Node_processBackgroundTasks(node, now, &nextBackgroundTaskDeadline);
  400. jlong *outDeadline = env->GetLongArrayElements(out_nextBackgroundTaskDeadline, NULL);
  401. outDeadline[0] = (jlong)nextBackgroundTaskDeadline;
  402. env->ReleaseLongArrayElements(out_nextBackgroundTaskDeadline, outDeadline, 0);
  403. return createResultObject(env, rc);
  404. }
  405. /*
  406. * Class: com_zerotierone_sdk_Node
  407. * Method: join
  408. * Signature: (JJ)Lcom/zerotierone/sdk/ResultCode;
  409. */
  410. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_join(
  411. JNIEnv *env, jobject obj, jlong id, jlong in_nwid)
  412. {
  413. uint64_t nodeId = (uint64_t) id;
  414. ZT1_Node *node = findNode(nodeId);
  415. if(node == NULL)
  416. {
  417. // cannot find valid node. We should never get here.
  418. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  419. }
  420. uint64_t nwid = (uint64_t)in_nwid;
  421. ZT1_ResultCode rc = ZT1_Node_join(node, nwid);
  422. return createResultObject(env, rc);
  423. }
  424. /*
  425. * Class: com_zerotierone_sdk_Node
  426. * Method: leave
  427. * Signature: (JJ)Lcom/zerotierone/sdk/ResultCode;
  428. */
  429. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_leave(
  430. JNIEnv *env, jobject obj, jlong id, jlong in_nwid)
  431. {
  432. uint64_t nodeId = (uint64_t) id;
  433. ZT1_Node *node = findNode(nodeId);
  434. if(node == NULL)
  435. {
  436. // cannot find valid node. We should never get here.
  437. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  438. }
  439. uint64_t nwid = (uint64_t)in_nwid;
  440. ZT1_ResultCode rc = ZT1_Node_leave(node, nwid);
  441. return createResultObject(env, rc);
  442. }
  443. /*
  444. * Class: com_zerotierone_sdk_Node
  445. * Method: multicastSubscribe
  446. * Signature: (JJJJ)Lcom/zerotierone/sdk/ResultCode;
  447. */
  448. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_multicastSubscribe(
  449. JNIEnv *env, jobject obj,
  450. jlong id,
  451. jlong in_nwid,
  452. jlong in_multicastGroup,
  453. jlong in_multicastAdi)
  454. {
  455. uint64_t nodeId = (uint64_t) id;
  456. ZT1_Node *node = findNode(nodeId);
  457. if(node == NULL)
  458. {
  459. // cannot find valid node. We should never get here.
  460. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  461. }
  462. uint64_t nwid = (uint64_t)in_nwid;
  463. uint64_t multicastGroup = (uint64_t)in_multicastGroup;
  464. uint64_t multicastAdi = (uint64_t)in_multicastAdi;
  465. ZT1_ResultCode rc = ZT1_Node_multicastSubscribe(
  466. node, nwid, multicastGroup, multicastAdi);
  467. return createResultObject(env, rc);
  468. }
  469. /*
  470. * Class: com_zerotierone_sdk_Node
  471. * Method: multicastUnsubscribe
  472. * Signature: (JJJJ)Lcom/zerotierone/sdk/ResultCode;
  473. */
  474. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_multicastUnsubscribe(
  475. JNIEnv *env, jobject obj,
  476. jlong id,
  477. jlong in_nwid,
  478. jlong in_multicastGroup,
  479. jlong in_multicastAdi)
  480. {
  481. uint64_t nodeId = (uint64_t) id;
  482. ZT1_Node *node = findNode(nodeId);
  483. if(node == NULL)
  484. {
  485. // cannot find valid node. We should never get here.
  486. return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
  487. }
  488. uint64_t nwid = (uint64_t)in_nwid;
  489. uint64_t multicastGroup = (uint64_t)in_multicastGroup;
  490. uint64_t multicastAdi = (uint64_t)in_multicastAdi;
  491. ZT1_ResultCode rc = ZT1_Node_multicastUnsubscribe(
  492. node, nwid, multicastGroup, multicastAdi);
  493. return createResultObject(env, rc);
  494. }
  495. /*
  496. * Class: com_zerotierone_sdk_Node
  497. * Method: address
  498. * Signature: (J)J
  499. */
  500. JNIEXPORT jlong JNICALL Java_com_zerotierone_sdk_Node_address(
  501. JNIEnv *env , jobject obj, jlong id)
  502. {
  503. uint64_t nodeId = (uint64_t) id;
  504. ZT1_Node *node = findNode(nodeId);
  505. if(node == NULL)
  506. {
  507. // cannot find valid node. We should never get here.
  508. return 0;
  509. }
  510. uint64_t address = ZT1_Node_address(node);
  511. return (jlong)address;
  512. }
  513. /*
  514. * Class: com_zerotierone_sdk_Node
  515. * Method: status
  516. * Signature: (J)Lcom/zerotierone/sdk/NodeStatus;
  517. */
  518. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_status
  519. (JNIEnv *env, jobject obj, jlong id)
  520. {
  521. uint64_t nodeId = (uint64_t) id;
  522. ZT1_Node *node = findNode(nodeId);
  523. if(node == NULL)
  524. {
  525. // cannot find valid node. We should never get here.
  526. return 0;
  527. }
  528. // static so we only have to look these up once
  529. static jclass nodeStatusClass = NULL;
  530. static jmethodID nodeStatusConstructor = NULL;
  531. // create a com.zerotierone.sdk.NodeStatus object
  532. if(nodeStatusClass == NULL)
  533. {
  534. nodeStatusClass = env->FindClass("com/zerotierone/sdk/NodeStatus");
  535. if(nodeStatusClass == NULL)
  536. {
  537. return NULL;
  538. }
  539. }
  540. if(nodeStatusConstructor == NULL)
  541. {
  542. nodeStatusConstructor = env->GetMethodID(
  543. nodeStatusClass, "<init>", "()V");
  544. if(nodeStatusConstructor == NULL)
  545. {
  546. return NULL;
  547. }
  548. }
  549. jobject nodeStatusObj = env->NewObject(nodeStatusClass, nodeStatusConstructor);
  550. if(nodeStatusObj == NULL)
  551. {
  552. return NULL;
  553. }
  554. ZT1_NodeStatus nodeStatus;
  555. ZT1_Node_status(node, &nodeStatus);
  556. static jfieldID addressField = NULL;
  557. static jfieldID publicIdentityField = NULL;
  558. static jfieldID secretIdentityField = NULL;
  559. static jfieldID onlineField = NULL;
  560. if(addressField == NULL)
  561. {
  562. addressField = env->GetFieldID(nodeStatusClass, "address", "J");
  563. if(addressField == NULL)
  564. {
  565. return NULL;
  566. }
  567. }
  568. if(publicIdentityField == NULL)
  569. {
  570. publicIdentityField = env->GetFieldID(nodeStatusClass, "publicIdentity", "Ljava/lang/String;");
  571. if(publicIdentityField == NULL)
  572. {
  573. return NULL;
  574. }
  575. }
  576. if(secretIdentityField == NULL)
  577. {
  578. secretIdentityField = env->GetFieldID(nodeStatusClass, "secretIdentity", "Ljava/lang/String;");
  579. if(secretIdentityField == NULL)
  580. {
  581. return NULL;
  582. }
  583. }
  584. if(onlineField == NULL)
  585. {
  586. onlineField = env->GetFieldID(nodeStatusClass, "online", "Z");
  587. if(onlineField == NULL)
  588. {
  589. return NULL;
  590. }
  591. }
  592. env->SetLongField(nodeStatusObj, addressField, nodeStatus.address);
  593. jstring pubIdentStr = env->NewStringUTF(nodeStatus.publicIdentity);
  594. if(pubIdentStr == NULL)
  595. {
  596. return NULL; // out of memory
  597. }
  598. env->SetObjectField(nodeStatusObj, publicIdentityField, pubIdentStr);
  599. jstring secIdentStr = env->NewStringUTF(nodeStatus.secretIdentity);
  600. if(secIdentStr == NULL)
  601. {
  602. return NULL; // out of memory
  603. }
  604. env->SetObjectField(nodeStatusObj, secretIdentityField, secIdentStr);
  605. env->SetBooleanField(nodeStatusObj, onlineField, nodeStatus.online);
  606. return nodeStatusObj;
  607. }
  608. /*
  609. * Class: com_zerotierone_sdk_Node
  610. * Method: networkConfig
  611. * Signature: (J)Lcom/zerotierone/sdk/VirtualNetworkConfig;
  612. */
  613. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_networkConfig(
  614. JNIEnv *env, jobject obj, jlong id, jlong nwid)
  615. {
  616. uint64_t nodeId = (uint64_t) id;
  617. ZT1_Node *node = findNode(nodeId);
  618. if(node == NULL)
  619. {
  620. // cannot find valid node. We should never get here.
  621. return 0;
  622. }
  623. // create a com.zerotierone.sdk.VirtualNetworkConfig object
  624. jclass vnetConfigClass = env->FindClass("com/zerotierone/sdk/VirtualNetworkConfig");
  625. if(vnetConfigClass == NULL)
  626. {
  627. return NULL;
  628. }
  629. jmethodID vnetConfigConstructor = env->GetMethodID(
  630. vnetConfigClass, "<init>", "()V");
  631. if(vnetConfigConstructor == NULL)
  632. {
  633. return NULL;
  634. }
  635. jobject vnetConfigObj = env->NewObject(vnetConfigClass, vnetConfigConstructor);
  636. if(vnetConfigObj == NULL)
  637. {
  638. return NULL;
  639. }
  640. ZT1_VirtualNetworkConfig *vnetConfig = ZT1_Node_networkConfig(node, nwid);
  641. static jfieldID nwidField = NULL;
  642. static jfieldID macField = NULL;
  643. static jfieldID nameField = NULL;
  644. static jfieldID statusField = NULL;
  645. static jfieldID typeField = NULL;
  646. static jfieldID mtuField = NULL;
  647. static jfieldID dhcpField = NULL;
  648. static jfieldID bridgeField = NULL;
  649. static jfieldID broadcastEnabledField = NULL;
  650. static jfieldID portErrorField = NULL;
  651. static jfieldID enabledField = NULL;
  652. static jfieldID netconfRevisionField = NULL;
  653. static jfieldID multicastSubscriptionsField = NULL;
  654. static jfieldID assignedAddressesField = NULL;
  655. if(nwidField == NULL)
  656. {
  657. nwidField = env->GetFieldID(vnetConfigClass, "nwid", "J");
  658. if(nwidField == NULL)
  659. {
  660. return NULL;
  661. }
  662. }
  663. if(macField == NULL)
  664. {
  665. macField = env->GetFieldID(vnetConfigClass, "mac", "J");
  666. if(macField == NULL)
  667. {
  668. return NULL;
  669. }
  670. }
  671. if(nameField == NULL)
  672. {
  673. nameField = env->GetFieldID(vnetConfigClass, "name", "Ljava/lang/String;");
  674. if(nameField == NULL)
  675. {
  676. return NULL;
  677. }
  678. }
  679. if(statusField == NULL)
  680. {
  681. statusField = env->GetFieldID(vnetConfigClass, "status", "Lcom/zerotierone/sdk/VirtualNetworStatus;");
  682. if(statusField == NULL)
  683. {
  684. return NULL;
  685. }
  686. }
  687. if(typeField == NULL)
  688. {
  689. typeField = env->GetFieldID(vnetConfigClass, "type", "Lcom/zerotierone/sdk/VirtualNetworkType;");
  690. if(typeField == NULL)
  691. {
  692. return NULL;
  693. }
  694. }
  695. if(mtuField == NULL)
  696. {
  697. mtuField = env->GetFieldID(vnetConfigClass, "mtu", "I");
  698. if(mtuField == NULL)
  699. {
  700. return NULL;
  701. }
  702. }
  703. if(dhcpField == NULL)
  704. {
  705. dhcpField = env->GetFieldID(vnetConfigClass, "dhcp", "Z");
  706. if(dhcpField == NULL)
  707. {
  708. return NULL;
  709. }
  710. }
  711. if(bridgeField == NULL)
  712. {
  713. bridgeField = env->GetFieldID(vnetConfigClass, "bridge", "Z");
  714. if(bridgeField == NULL)
  715. {
  716. return NULL;
  717. }
  718. }
  719. if(broadcastEnabledField == NULL)
  720. {
  721. broadcastEnabledField = env->GetFieldID(vnetConfigClass, "broadcastEnabled", "Z");
  722. if(broadcastEnabledField == NULL)
  723. {
  724. return NULL;
  725. }
  726. }
  727. if(portErrorField == NULL)
  728. {
  729. portErrorField == env->GetFieldID(vnetConfigClass, "portError", "Z");
  730. if(portErrorField == NULL)
  731. {
  732. return NULL;
  733. }
  734. }
  735. if(enabledField == NULL)
  736. {
  737. enabledField = env->GetFieldID(vnetConfigClass, "enabled", "Z");
  738. if(enabledField == NULL)
  739. {
  740. return NULL;
  741. }
  742. }
  743. if(netconfRevisionField == NULL)
  744. {
  745. netconfRevisionField = env->GetFieldID(vnetConfigClass, "netconfRevision", "J");
  746. if(netconfRevisionField == NULL)
  747. {
  748. return NULL;
  749. }
  750. }
  751. if(multicastSubscriptionsField == NULL)
  752. {
  753. multicastSubscriptionsField = env->GetFieldID(vnetConfigClass, "multicastSubscriptions", "Ljava/util/ArrayList;");
  754. if(multicastSubscriptionsField == NULL)
  755. {
  756. return NULL;
  757. }
  758. }
  759. if(assignedAddressesField == NULL)
  760. {
  761. assignedAddressesField = env->GetFieldID(vnetConfigClass, "assignedAddresses", "Ljava/util/ArrayList;");
  762. if(assignedAddressesField == NULL)
  763. {
  764. return NULL;
  765. }
  766. }
  767. env->SetLongField(vnetConfigObj, nwidField, vnetConfig->nwid);
  768. env->SetLongField(vnetConfigObj, macField, vnetConfig->mac);
  769. jstring nameStr = env->NewStringUTF(vnetConfig->name);
  770. if(nameStr == NULL)
  771. {
  772. return NULL; // out of memory
  773. }
  774. env->SetObjectField(vnetConfigObj, nameField, nameStr);
  775. jobject statusObject = createVirtualNetworkStatus(env, vnetConfig->status);
  776. if(statusObject == NULL)
  777. {
  778. return NULL;
  779. }
  780. env->SetObjectField(vnetConfigObj, statusField, statusObject);
  781. jobject typeObject = createVirtualNetworkType(env, vnetConfig->type);
  782. if(typeObject == NULL)
  783. {
  784. return NULL;
  785. }
  786. env->SetObjectField(vnetConfigObj, typeField, typeObject);
  787. env->SetIntField(vnetConfigObj, mtuField, vnetConfig->mtu);
  788. env->SetBooleanField(vnetConfigObj, dhcpField, vnetConfig->dhcp);
  789. env->SetBooleanField(vnetConfigObj, bridgeField, vnetConfig->bridge);
  790. env->SetBooleanField(vnetConfigObj, broadcastEnabledField, vnetConfig->broadcastEnabled);
  791. env->SetBooleanField(vnetConfigObj, portErrorField, vnetConfig->portError);
  792. jobject mcastSubsArrayObj = newArrayList(env);
  793. for(unsigned int i = 0; i < vnetConfig->multicastSubscriptionCount; ++i)
  794. {
  795. jobject mcastObj = newMulticastGroup(env, vnetConfig->multicastSubscriptions[i]);
  796. appendItemToArrayList(env, mcastSubsArrayObj, mcastObj);
  797. }
  798. env->SetObjectField(vnetConfigObj, multicastSubscriptionsField, mcastSubsArrayObj);
  799. jobject assignedAddrArrayObj = newArrayList(env);
  800. for(unsigned int i = 0; i < vnetConfig->assignedAddressCount; ++i)
  801. {
  802. jobject inetAddrObj = newInetAddress(env, vnetConfig->assignedAddresses[i]);
  803. appendItemToArrayList(env, assignedAddrArrayObj, inetAddrObj);
  804. }
  805. env->SetObjectField(vnetConfigObj, assignedAddressesField, assignedAddrArrayObj);
  806. ZT1_Node_freeQueryResult(node, vnetConfig);
  807. vnetConfig = NULL;
  808. return vnetConfigObj;
  809. }
  810. /*
  811. * Class: com_zerotierone_sdk_Node
  812. * Method: version
  813. * Signature: (J)Lcom/zerotierone/sdk/Version;
  814. */
  815. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_version(
  816. JNIEnv *env, jobject obj)
  817. {
  818. // create a com.zerotierone.sdk.Version object
  819. jclass versionClass = env->FindClass("com/zerotierone/sdk/Version");
  820. if(versionClass == NULL)
  821. {
  822. return NULL;
  823. }
  824. jmethodID versionConstructor = env->GetMethodID(
  825. versionClass, "<init>", "()V");
  826. if(versionConstructor == NULL)
  827. {
  828. return NULL;
  829. }
  830. jobject versionObj = env->NewObject(versionClass, versionConstructor);
  831. if(versionObj == NULL)
  832. {
  833. return NULL;
  834. }
  835. int major = 0;
  836. int minor = 0;
  837. int revision = 0;
  838. unsigned long featureFlags = 0;
  839. ZT1_version(&major, &minor, &revision, &featureFlags);
  840. // copy data to Version object
  841. static jfieldID majorField = NULL;
  842. static jfieldID minorField = NULL;
  843. static jfieldID revisionField = NULL;
  844. static jfieldID featureFlagsField = NULL;
  845. if(majorField == NULL)
  846. {
  847. majorField = env->GetFieldID(versionClass, "major", "I");
  848. if(majorField = NULL)
  849. {
  850. return NULL;
  851. }
  852. }
  853. if(minorField == NULL)
  854. {
  855. minorField = env->GetFieldID(versionClass, "minor", "I");
  856. if(minorField == NULL)
  857. {
  858. return NULL;
  859. }
  860. }
  861. if(revisionField == NULL)
  862. {
  863. revisionField = env->GetFieldID(versionClass, "revision", "I");
  864. if(revisionField == NULL)
  865. {
  866. return NULL;
  867. }
  868. }
  869. if(featureFlagsField == NULL)
  870. {
  871. featureFlagsField = env->GetFieldID(versionClass, "featureFlags", "J");
  872. if(featureFlagsField == NULL)
  873. {
  874. return NULL;
  875. }
  876. }
  877. env->SetIntField(versionObj, majorField, (jint)major);
  878. env->SetIntField(versionObj, minorField, (jint)minor);
  879. env->SetIntField(versionObj, revisionField, (jint)revision);
  880. env->SetLongField(versionObj, featureFlagsField, (jlong)featureFlags);
  881. return versionObj;
  882. }
  883. /*
  884. * Class: com_zerotierone_sdk_Node
  885. * Method: peers
  886. * Signature: (J)Ljava/util/ArrayList;
  887. */
  888. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_peers(
  889. JNIEnv *env, jobject obj, jlong id)
  890. {
  891. return NULL;
  892. }
  893. /*
  894. * Class: com_zerotierone_sdk_Node
  895. * Method: networks
  896. * Signature: (J)Ljava/util/ArrayList;
  897. */
  898. JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_networks(
  899. JNIEnv *env, jobject obj, jlong id)
  900. {
  901. return NULL;
  902. }
  903. #ifdef __cplusplus
  904. } // extern "C"
  905. #endif