ZT1_jniutils.cpp 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939
  1. #include "ZT1_jniutils.h"
  2. #include "ZT1_jnicache.h"
  3. #include <string>
  4. #include <assert.h>
  5. extern JniCache cache;
  6. #ifdef __cplusplus
  7. extern "C" {
  8. #endif
  9. jobject createResultObject(JNIEnv *env, ZT1_ResultCode code)
  10. {
  11. jclass resultClass = NULL;
  12. jobject resultObject = NULL;
  13. resultClass = cache.findClass("com/zerotier/sdk/ResultCode");
  14. if(resultClass == NULL)
  15. {
  16. LOGE("Couldnt find ResultCode class");
  17. return NULL; // exception thrown
  18. }
  19. std::string fieldName;
  20. switch(code)
  21. {
  22. case ZT1_RESULT_OK:
  23. LOGV("ZT1_RESULT_OK");
  24. fieldName = "RESULT_OK";
  25. break;
  26. case ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY:
  27. LOGV("ZT1_RESULT_FATAL_ERROR_OUT_OF_MEMORY");
  28. fieldName = "RESULT_FATAL_ERROR_OUT_OF_MEMORY";
  29. break;
  30. case ZT1_RESULT_FATAL_ERROR_DATA_STORE_FAILED:
  31. LOGV("RESULT_FATAL_ERROR_DATA_STORE_FAILED");
  32. fieldName = "RESULT_FATAL_ERROR_DATA_STORE_FAILED";
  33. break;
  34. case ZT1_RESULT_ERROR_NETWORK_NOT_FOUND:
  35. LOGV("RESULT_FATAL_ERROR_DATA_STORE_FAILED");
  36. fieldName = "RESULT_ERROR_NETWORK_NOT_FOUND";
  37. break;
  38. case ZT1_RESULT_FATAL_ERROR_INTERNAL:
  39. default:
  40. LOGV("RESULT_FATAL_ERROR_DATA_STORE_FAILED");
  41. fieldName = "RESULT_FATAL_ERROR_INTERNAL";
  42. break;
  43. }
  44. jfieldID enumField = cache.findStaticField(resultClass, fieldName.c_str(), "Lcom/zerotier/sdk/ResultCode;");
  45. if(env->ExceptionCheck() || enumField == NULL)
  46. {
  47. LOGE("Error on FindStaticField");
  48. return NULL;
  49. }
  50. resultObject = env->GetStaticObjectField(resultClass, enumField);
  51. if(env->ExceptionCheck() || resultObject == NULL)
  52. {
  53. LOGE("Error on GetStaticObjectField");
  54. }
  55. return resultObject;
  56. }
  57. jobject createVirtualNetworkStatus(JNIEnv *env, ZT1_VirtualNetworkStatus status)
  58. {
  59. jobject statusObject = NULL;
  60. jclass statusClass = cache.findClass("com/zerotier/sdk/VirtualNetworkStatus");
  61. if(statusClass == NULL)
  62. {
  63. return NULL; // exception thrown
  64. }
  65. std::string fieldName;
  66. switch(status)
  67. {
  68. case ZT1_NETWORK_STATUS_REQUESTING_CONFIGURATION:
  69. fieldName = "NETWORK_STATUS_REQUESTING_CONFIGURATION";
  70. break;
  71. case ZT1_NETWORK_STATUS_OK:
  72. fieldName = "NETWORK_STATUS_OK";
  73. break;
  74. case ZT1_NETWORK_STATUS_ACCESS_DENIED:
  75. fieldName = "NETWORK_STATUS_ACCESS_DENIED";
  76. break;
  77. case ZT1_NETWORK_STATUS_NOT_FOUND:
  78. fieldName = "NETWORK_STATUS_NOT_FOUND";
  79. break;
  80. case ZT1_NETWORK_STATUS_PORT_ERROR:
  81. fieldName = "NETWORK_STATUS_PORT_ERROR";
  82. break;
  83. case ZT1_NETWORK_STATUS_CLIENT_TOO_OLD:
  84. fieldName = "NETWORK_STATUS_CLIENT_TOO_OLD";
  85. break;
  86. }
  87. jfieldID enumField = cache.findStaticField(statusClass, fieldName.c_str(), "Lcom/zerotier/sdk/VirtualNetworkStatus;");
  88. statusObject = env->GetStaticObjectField(statusClass, enumField);
  89. return statusObject;
  90. }
  91. jobject createEvent(JNIEnv *env, ZT1_Event event)
  92. {
  93. jclass eventClass = NULL;
  94. jobject eventObject = NULL;
  95. eventClass = cache.findClass("com/zerotier/sdk/Event");
  96. if(eventClass == NULL)
  97. {
  98. return NULL;
  99. }
  100. std::string fieldName;
  101. switch(event)
  102. {
  103. case ZT1_EVENT_UP:
  104. fieldName = "EVENT_UP";
  105. break;
  106. case ZT1_EVENT_OFFLINE:
  107. fieldName = "EVENT_OFFLINE";
  108. break;
  109. case ZT1_EVENT_ONLINE:
  110. fieldName = "EVENT_ONLINE";
  111. break;
  112. case ZT1_EVENT_DOWN:
  113. fieldName = "EVENT_DOWN";
  114. break;
  115. case ZT1_EVENT_FATAL_ERROR_IDENTITY_COLLISION:
  116. fieldName = "EVENT_FATAL_ERROR_IDENTITY_COLLISION";
  117. break;
  118. case ZT1_EVENT_SAW_MORE_RECENT_VERSION:
  119. fieldName = "EVENT_SAW_MORE_RECENT_VERSION";
  120. break;
  121. case ZT1_EVENT_AUTHENTICATION_FAILURE:
  122. fieldName = "EVENT_AUTHENTICATION_FAILURE";
  123. break;
  124. case ZT1_EVENT_INVALID_PACKET:
  125. fieldName = "EVENT_INVALID_PACKET";
  126. break;
  127. case ZT1_EVENT_TRACE:
  128. fieldName = "EVENT_TRACE";
  129. break;
  130. }
  131. jfieldID enumField = cache.findStaticField(eventClass, fieldName.c_str(), "Lcom/zerotier/sdk/Event;");
  132. eventObject = env->GetStaticObjectField(eventClass, enumField);
  133. return eventObject;
  134. }
  135. jobject createPeerRole(JNIEnv *env, ZT1_PeerRole role)
  136. {
  137. jclass peerRoleClass = NULL;
  138. jobject peerRoleObject = NULL;
  139. peerRoleClass = cache.findClass("com/zerotier/sdk/PeerRole");
  140. if(peerRoleClass == NULL)
  141. {
  142. return NULL;
  143. }
  144. std::string fieldName;
  145. switch(role)
  146. {
  147. case ZT1_PEER_ROLE_LEAF:
  148. fieldName = "PEER_ROLE_LEAF";
  149. break;
  150. case ZT1_PEER_ROLE_HUB:
  151. fieldName = "PEER_ROLE_HUB";
  152. break;
  153. case ZT1_PEER_ROLE_SUPERNODE:
  154. fieldName = "PEER_ROLE_SUPERNODE";
  155. break;
  156. }
  157. jfieldID enumField = cache.findStaticField(peerRoleClass, fieldName.c_str(), "Lcom/zerotier/sdk/PeerRole;");
  158. peerRoleObject = env->GetStaticObjectField(peerRoleClass, enumField);
  159. return peerRoleObject;
  160. }
  161. jobject createVirtualNetworkType(JNIEnv *env, ZT1_VirtualNetworkType type)
  162. {
  163. jclass vntypeClass = NULL;
  164. jobject vntypeObject = NULL;
  165. vntypeClass = cache.findClass("com/zerotier/sdk/VirtualNetworkType");
  166. if(env->ExceptionCheck() || vntypeClass == NULL)
  167. {
  168. return NULL;
  169. }
  170. std::string fieldName;
  171. switch(type)
  172. {
  173. case ZT1_NETWORK_TYPE_PRIVATE:
  174. fieldName = "NETWORK_TYPE_PRIVATE";
  175. break;
  176. case ZT1_NETWORK_TYPE_PUBLIC:
  177. fieldName = "NETWORK_TYPE_PUBLIC";
  178. break;
  179. }
  180. jfieldID enumField = cache.findStaticField(vntypeClass, fieldName.c_str(), "Lcom/zerotier/sdk/VirtualNetworkType;");
  181. vntypeObject = env->GetStaticObjectField(vntypeClass, enumField);
  182. return vntypeObject;
  183. }
  184. jobject createVirtualNetworkConfigOperation(JNIEnv *env, ZT1_VirtualNetworkConfigOperation op)
  185. {
  186. jclass vnetConfigOpClass = NULL;
  187. jobject vnetConfigOpObject = NULL;
  188. vnetConfigOpClass = cache.findClass("com/zerotier/sdk/VirtualNetworkConfigOperation");
  189. if(env->ExceptionCheck() || vnetConfigOpClass == NULL)
  190. {
  191. return NULL;
  192. }
  193. std::string fieldName;
  194. switch(op)
  195. {
  196. case ZT1_VIRTUAL_NETWORK_CONFIG_OPERATION_UP:
  197. fieldName = "VIRTUAL_NETWORK_CONFIG_OPERATION_UP";
  198. break;
  199. case ZT1_VIRTUAL_NETWORK_CONFIG_OPERATION_CONFIG_UPDATE:
  200. fieldName = "VIRTUAL_NETWORK_CONFIG_OPERATION_CONFIG_UPDATE";
  201. break;
  202. case ZT1_VIRTUAL_NETWORK_CONFIG_OPERATION_DOWN:
  203. fieldName = "VIRTUAL_NETWORK_CONFIG_OPERATION_DOWN";
  204. break;
  205. case ZT1_VIRTUAL_NETWORK_CONFIG_OPERATION_DESTROY:
  206. fieldName = "VIRTUAL_NETWORK_CONFIG_OPERATION_DESTROY";
  207. break;
  208. }
  209. jfieldID enumField = cache.findStaticField(vnetConfigOpClass, fieldName.c_str(), "Lcom/zerotier/sdk/VirtualNetworkConfigOperation;");
  210. vnetConfigOpObject = env->GetStaticObjectField(vnetConfigOpClass, enumField);
  211. return vnetConfigOpObject;
  212. }
  213. jobject newInetAddress(JNIEnv *env, const sockaddr_storage &addr)
  214. {
  215. LOGV("newInetAddress");
  216. jclass inetAddressClass = NULL;
  217. jmethodID inetAddress_getByAddress = NULL;
  218. inetAddressClass = cache.findClass("java/net/InetAddress");
  219. if(env->ExceptionCheck() || inetAddressClass == NULL)
  220. {
  221. LOGE("Error finding InetAddress class");
  222. return NULL;
  223. }
  224. inetAddress_getByAddress = cache.findStaticMethod(
  225. inetAddressClass, "getByAddress", "([B)Ljava/net/InetAddress;");
  226. if(env->ExceptionCheck() || inetAddress_getByAddress == NULL)
  227. {
  228. LOGE("Erorr finding getByAddress() static method");
  229. return NULL;
  230. }
  231. jobject inetAddressObj = NULL;
  232. switch(addr.ss_family)
  233. {
  234. case AF_INET6:
  235. {
  236. sockaddr_in6 *ipv6 = (sockaddr_in6*)&addr;
  237. jbyteArray buff = env->NewByteArray(16);
  238. if(buff == NULL)
  239. {
  240. LOGE("Error creating IPV6 byte array");
  241. return NULL;
  242. }
  243. env->SetByteArrayRegion(buff, 0, 16, (jbyte*)ipv6->sin6_addr.s6_addr);
  244. inetAddressObj = env->CallStaticObjectMethod(
  245. inetAddressClass, inetAddress_getByAddress, buff);
  246. }
  247. break;
  248. case AF_INET:
  249. {
  250. sockaddr_in *ipv4 = (sockaddr_in*)&addr;
  251. jbyteArray buff = env->NewByteArray(4);
  252. if(buff == NULL)
  253. {
  254. LOGE("Error creating IPV4 byte array");
  255. return NULL;
  256. }
  257. env->SetByteArrayRegion(buff, 0, 4, (jbyte*)&ipv4->sin_addr);
  258. inetAddressObj = env->CallStaticObjectMethod(
  259. inetAddressClass, inetAddress_getByAddress, buff);
  260. }
  261. break;
  262. }
  263. if(env->ExceptionCheck() || inetAddressObj == NULL) {
  264. LOGE("Error creating InetAddress object");
  265. return NULL;
  266. }
  267. return inetAddressObj;
  268. }
  269. jobject newInetSocketAddress(JNIEnv *env, const sockaddr_storage &addr)
  270. {
  271. LOGV("newInetSocketAddress Called");
  272. jclass inetSocketAddressClass = NULL;
  273. jmethodID inetSocketAddress_constructor = NULL;
  274. inetSocketAddressClass = cache.findClass("java/net/InetSocketAddress");
  275. if(env->ExceptionCheck() || inetSocketAddressClass == NULL)
  276. {
  277. LOGE("Error finding InetSocketAddress Class");
  278. return NULL;
  279. }
  280. jobject inetAddressObject = newInetAddress(env, addr);
  281. if(env->ExceptionCheck() || inetAddressObject == NULL)
  282. {
  283. LOGE("Error creating new inet address");
  284. return NULL;
  285. }
  286. inetSocketAddress_constructor = cache.findMethod(
  287. inetSocketAddressClass, "<init>", "(Ljava/net/InetAddress;I)V");
  288. if(env->ExceptionCheck() || inetSocketAddress_constructor == NULL)
  289. {
  290. LOGE("Error finding InetSocketAddress constructor");
  291. return NULL;
  292. }
  293. int port = 0;
  294. switch(addr.ss_family)
  295. {
  296. case AF_INET6:
  297. {
  298. sockaddr_in6 *ipv6 = (sockaddr_in6*)&addr;
  299. port = ntohs(ipv6->sin6_port);
  300. }
  301. break;
  302. case AF_INET:
  303. {
  304. sockaddr_in *ipv4 = (sockaddr_in*)&addr;
  305. port = ntohs(ipv4->sin_port);
  306. }
  307. break;
  308. };
  309. jobject inetSocketAddressObject = env->NewObject(inetSocketAddressClass, inetSocketAddress_constructor, inetAddressObject, port);
  310. if(env->ExceptionCheck() || inetSocketAddressObject == NULL) {
  311. LOGE("Error creating InetSocketAddress object");
  312. }
  313. return inetSocketAddressObject;
  314. }
  315. jobject newMulticastGroup(JNIEnv *env, const ZT1_MulticastGroup &mc)
  316. {
  317. jclass multicastGroupClass = NULL;
  318. jmethodID multicastGroup_constructor = NULL;
  319. jfieldID macField = NULL;
  320. jfieldID adiField = NULL;
  321. multicastGroupClass = cache.findClass("com/zerotier/sdk/MulticastGroup");
  322. if(env->ExceptionCheck() || multicastGroupClass == NULL)
  323. {
  324. return NULL;
  325. }
  326. multicastGroup_constructor = cache.findMethod(
  327. multicastGroupClass, "<init>", "()V");
  328. if(env->ExceptionCheck() || multicastGroup_constructor == NULL)
  329. {
  330. return NULL;
  331. }
  332. jobject multicastGroupObj = env->NewObject(multicastGroupClass, multicastGroup_constructor);
  333. if(env->ExceptionCheck() || multicastGroupObj == NULL)
  334. {
  335. return NULL;
  336. }
  337. macField = cache.findField(multicastGroupClass, "mac", "J");
  338. if(env->ExceptionCheck() || macField == NULL)
  339. {
  340. return NULL;
  341. }
  342. adiField = cache.findField(multicastGroupClass, "adi", "J");
  343. if(env->ExceptionCheck() || adiField == NULL)
  344. {
  345. return NULL;
  346. }
  347. env->SetLongField(multicastGroupObj, macField, mc.mac);
  348. env->SetLongField(multicastGroupObj, adiField, mc.adi);
  349. return multicastGroupObj;
  350. }
  351. jobject newPeerPhysicalPath(JNIEnv *env, const ZT1_PeerPhysicalPath &ppp)
  352. {
  353. LOGV("newPeerPhysicalPath Called");
  354. jclass pppClass = NULL;
  355. jfieldID addressField = NULL;
  356. jfieldID lastSendField = NULL;
  357. jfieldID lastReceiveField = NULL;
  358. jfieldID fixedField = NULL;
  359. jfieldID activeField = NULL;
  360. jfieldID preferredField = NULL;
  361. jmethodID ppp_constructor = NULL;
  362. pppClass = cache.findClass("com/zerotier/sdk/PeerPhysicalPath");
  363. if(env->ExceptionCheck() || pppClass == NULL)
  364. {
  365. LOGE("Error finding PeerPhysicalPath class");
  366. return NULL;
  367. }
  368. addressField = cache.findField(pppClass, "address", "Ljava/net/InetSocketAddress;");
  369. if(env->ExceptionCheck() || addressField == NULL)
  370. {
  371. LOGE("Error finding address field");
  372. return NULL;
  373. }
  374. lastSendField = cache.findField(pppClass, "lastSend", "J");
  375. if(env->ExceptionCheck() || lastSendField == NULL)
  376. {
  377. LOGE("Error finding lastSend field");
  378. return NULL;
  379. }
  380. lastReceiveField = cache.findField(pppClass, "lastReceive", "J");
  381. if(env->ExceptionCheck() || lastReceiveField == NULL)
  382. {
  383. LOGE("Error finding lastReceive field");
  384. return NULL;
  385. }
  386. fixedField = cache.findField(pppClass, "fixed", "Z");
  387. if(env->ExceptionCheck() || fixedField == NULL)
  388. {
  389. LOGE("Error finding fixed field");
  390. return NULL;
  391. }
  392. activeField = cache.findField(pppClass, "active", "Z");
  393. if(env->ExceptionCheck() || activeField == NULL)
  394. {
  395. LOGE("Error finding active field");
  396. return NULL;
  397. }
  398. preferredField = cache.findField(pppClass, "preferred", "Z");
  399. if(env->ExceptionCheck() || preferredField == NULL)
  400. {
  401. LOGE("Error finding preferred field");
  402. return NULL;
  403. }
  404. ppp_constructor = cache.findMethod(pppClass, "<init>", "()V");
  405. if(env->ExceptionCheck() || ppp_constructor == NULL)
  406. {
  407. LOGE("Error finding PeerPhysicalPath constructor");
  408. return NULL;
  409. }
  410. jobject pppObject = env->NewObject(pppClass, ppp_constructor);
  411. if(env->ExceptionCheck() || pppObject == NULL)
  412. {
  413. LOGE("Error creating PPP object");
  414. return NULL; // out of memory
  415. }
  416. jobject addressObject = newInetSocketAddress(env, ppp.address);
  417. if(env->ExceptionCheck() || addressObject == NULL) {
  418. LOGE("Error creating InetSocketAddress object");
  419. return NULL;
  420. }
  421. env->SetObjectField(pppObject, addressField, addressObject);
  422. env->SetLongField(pppObject, lastSendField, ppp.lastSend);
  423. env->SetLongField(pppObject, lastReceiveField, ppp.lastReceive);
  424. env->SetBooleanField(pppObject, fixedField, ppp.fixed);
  425. env->SetBooleanField(pppObject, activeField, ppp.active);
  426. env->SetBooleanField(pppObject, preferredField, ppp.preferred);
  427. if(env->ExceptionCheck()) {
  428. LOGE("Exception assigning fields to PeerPhysicalPath object");
  429. }
  430. return pppObject;
  431. }
  432. jobject newPeer(JNIEnv *env, const ZT1_Peer &peer)
  433. {
  434. LOGV("newPeer called");
  435. jclass peerClass = NULL;
  436. jfieldID addressField = NULL;
  437. jfieldID lastUnicastFrameField = NULL;
  438. jfieldID lastMulticastFrameField = NULL;
  439. jfieldID versionMajorField = NULL;
  440. jfieldID versionMinorField = NULL;
  441. jfieldID versionRevField = NULL;
  442. jfieldID latencyField = NULL;
  443. jfieldID roleField = NULL;
  444. jfieldID pathsField = NULL;
  445. jmethodID peer_constructor = NULL;
  446. peerClass = cache.findClass("com/zerotier/sdk/Peer");
  447. if(env->ExceptionCheck() || peerClass == NULL)
  448. {
  449. LOGE("Error finding Peer class");
  450. return NULL;
  451. }
  452. addressField = cache.findField(peerClass, "address", "J");
  453. if(env->ExceptionCheck() || addressField == NULL)
  454. {
  455. LOGE("Error finding address field of Peer object");
  456. return NULL;
  457. }
  458. lastUnicastFrameField = cache.findField(peerClass, "lastUnicastFrame", "J");
  459. if(env->ExceptionCheck() || lastUnicastFrameField == NULL)
  460. {
  461. LOGE("Error finding lastUnicastFrame field of Peer object");
  462. return NULL;
  463. }
  464. lastMulticastFrameField = cache.findField(peerClass, "lastMulticastFrame", "J");
  465. if(env->ExceptionCheck() || lastMulticastFrameField == NULL)
  466. {
  467. LOGE("Error finding lastMulticastFrame field of Peer object");
  468. return NULL;
  469. }
  470. versionMajorField = cache.findField(peerClass, "versionMajor", "I");
  471. if(env->ExceptionCheck() || versionMajorField == NULL)
  472. {
  473. LOGE("Error finding versionMajor field of Peer object");
  474. return NULL;
  475. }
  476. versionMinorField = cache.findField(peerClass, "versionMinor", "I");
  477. if(env->ExceptionCheck() || versionMinorField == NULL)
  478. {
  479. LOGE("Error finding versionMinor field of Peer object");
  480. return NULL;
  481. }
  482. versionRevField = cache.findField(peerClass, "versionRev", "I");
  483. if(env->ExceptionCheck() || versionRevField == NULL)
  484. {
  485. LOGE("Error finding versionRev field of Peer object");
  486. return NULL;
  487. }
  488. latencyField = cache.findField(peerClass, "latency", "I");
  489. if(env->ExceptionCheck() || latencyField == NULL)
  490. {
  491. LOGE("Error finding latency field of Peer object");
  492. return NULL;
  493. }
  494. roleField = cache.findField(peerClass, "role", "Lcom/zerotier/sdk/PeerRole;");
  495. if(env->ExceptionCheck() || roleField == NULL)
  496. {
  497. LOGE("Error finding role field of Peer object");
  498. return NULL;
  499. }
  500. pathsField = cache.findField(peerClass, "paths", "[Lcom/zerotier/sdk/PeerPhysicalPath;");
  501. if(env->ExceptionCheck() || pathsField == NULL)
  502. {
  503. LOGE("Error finding paths field of Peer object");
  504. return NULL;
  505. }
  506. peer_constructor = cache.findMethod(peerClass, "<init>", "()V");
  507. if(env->ExceptionCheck() || peer_constructor == NULL)
  508. {
  509. LOGE("Error finding Peer constructor");
  510. return NULL;
  511. }
  512. jobject peerObject = env->NewObject(peerClass, peer_constructor);
  513. if(env->ExceptionCheck() || peerObject == NULL)
  514. {
  515. LOGE("Error creating Peer object");
  516. return NULL; // out of memory
  517. }
  518. LOGD("JNI Peer Latency: %d", peer.latency);
  519. env->SetLongField(peerObject, addressField, (jlong)peer.address);
  520. env->SetLongField(peerObject, lastUnicastFrameField, (jlong)peer.lastUnicastFrame);
  521. env->SetLongField(peerObject, lastMulticastFrameField, (jlong)peer.lastMulticastFrame);
  522. env->SetIntField(peerObject, versionMajorField, peer.versionMajor);
  523. env->SetIntField(peerObject, versionMinorField, peer.versionMinor);
  524. env->SetIntField(peerObject, versionRevField, peer.versionRev);
  525. env->SetIntField(peerObject, latencyField, peer.latency);
  526. env->SetObjectField(peerObject, roleField, createPeerRole(env, peer.role));
  527. jclass peerPhysicalPathClass = cache.findClass("com/zerotier/sdk/PeerPhysicalPath");
  528. if(env->ExceptionCheck() || peerPhysicalPathClass == NULL)
  529. {
  530. LOGE("Error finding PeerPhysicalPath class");
  531. return NULL;
  532. }
  533. jobjectArray arrayObject = env->NewObjectArray(
  534. peer.pathCount, peerPhysicalPathClass, NULL);
  535. if(env->ExceptionCheck() || arrayObject == NULL)
  536. {
  537. LOGE("Error creating PeerPhysicalPath[] array");
  538. return NULL;
  539. }
  540. for(unsigned int i = 0; i < peer.pathCount; ++i)
  541. {
  542. jobject path = newPeerPhysicalPath(env, peer.paths[i]);
  543. env->SetObjectArrayElement(arrayObject, i, path);
  544. if(env->ExceptionCheck()) {
  545. LOGE("exception assigning PeerPhysicalPath to array");
  546. break;
  547. }
  548. }
  549. env->SetObjectField(peerObject, pathsField, arrayObject);
  550. return peerObject;
  551. }
  552. jobject newNetworkConfig(JNIEnv *env, const ZT1_VirtualNetworkConfig &vnetConfig)
  553. {
  554. jclass vnetConfigClass = NULL;
  555. jmethodID vnetConfig_constructor = NULL;
  556. jfieldID nwidField = NULL;
  557. jfieldID macField = NULL;
  558. jfieldID nameField = NULL;
  559. jfieldID statusField = NULL;
  560. jfieldID typeField = NULL;
  561. jfieldID mtuField = NULL;
  562. jfieldID dhcpField = NULL;
  563. jfieldID bridgeField = NULL;
  564. jfieldID broadcastEnabledField = NULL;
  565. jfieldID portErrorField = NULL;
  566. jfieldID enabledField = NULL;
  567. jfieldID netconfRevisionField = NULL;
  568. jfieldID multicastSubscriptionsField = NULL;
  569. jfieldID assignedAddressesField = NULL;
  570. vnetConfigClass = cache.findClass("com/zerotier/sdk/VirtualNetworkConfig");
  571. if(vnetConfigClass == NULL)
  572. {
  573. LOGE("Couldn't find com.zerotier.sdk.VirtualNetworkConfig");
  574. return NULL;
  575. }
  576. vnetConfig_constructor = cache.findMethod(
  577. vnetConfigClass, "<init>", "()V");
  578. if(env->ExceptionCheck() || vnetConfig_constructor == NULL)
  579. {
  580. LOGE("Couldn't find VirtualNetworkConfig Constructor");
  581. return NULL;
  582. }
  583. jobject vnetConfigObj = env->NewObject(vnetConfigClass, vnetConfig_constructor);
  584. if(env->ExceptionCheck() || vnetConfigObj == NULL)
  585. {
  586. LOGE("Error creating new VirtualNetworkConfig object");
  587. return NULL;
  588. }
  589. nwidField = cache.findField(vnetConfigClass, "nwid", "J");
  590. if(env->ExceptionCheck() || nwidField == NULL)
  591. {
  592. LOGE("Error getting nwid field");
  593. return NULL;
  594. }
  595. macField = cache.findField(vnetConfigClass, "mac", "J");
  596. if(env->ExceptionCheck() || macField == NULL)
  597. {
  598. LOGE("Error getting mac field");
  599. return NULL;
  600. }
  601. nameField = cache.findField(vnetConfigClass, "name", "Ljava/lang/String;");
  602. if(env->ExceptionCheck() || nameField == NULL)
  603. {
  604. LOGE("Error getting name field");
  605. return NULL;
  606. }
  607. statusField = cache.findField(vnetConfigClass, "status", "Lcom/zerotier/sdk/VirtualNetworkStatus;");
  608. if(env->ExceptionCheck() || statusField == NULL)
  609. {
  610. LOGE("Error getting status field");
  611. return NULL;
  612. }
  613. typeField = cache.findField(vnetConfigClass, "type", "Lcom/zerotier/sdk/VirtualNetworkType;");
  614. if(env->ExceptionCheck() || typeField == NULL)
  615. {
  616. LOGE("Error getting type field");
  617. return NULL;
  618. }
  619. mtuField = cache.findField(vnetConfigClass, "mtu", "I");
  620. if(env->ExceptionCheck() || mtuField == NULL)
  621. {
  622. LOGE("Error getting mtu field");
  623. return NULL;
  624. }
  625. dhcpField = cache.findField(vnetConfigClass, "dhcp", "Z");
  626. if(env->ExceptionCheck() || dhcpField == NULL)
  627. {
  628. LOGE("Error getting dhcp field");
  629. return NULL;
  630. }
  631. bridgeField = cache.findField(vnetConfigClass, "bridge", "Z");
  632. if(env->ExceptionCheck() || bridgeField == NULL)
  633. {
  634. LOGE("Error getting bridge field");
  635. return NULL;
  636. }
  637. broadcastEnabledField = cache.findField(vnetConfigClass, "broadcastEnabled", "Z");
  638. if(env->ExceptionCheck() || broadcastEnabledField == NULL)
  639. {
  640. LOGE("Error getting broadcastEnabled field");
  641. return NULL;
  642. }
  643. portErrorField = cache.findField(vnetConfigClass, "portError", "I");
  644. if(env->ExceptionCheck() || portErrorField == NULL)
  645. {
  646. LOGE("Error getting portError field");
  647. return NULL;
  648. }
  649. enabledField = cache.findField(vnetConfigClass, "enabled", "Z");
  650. if(env->ExceptionCheck() || enabledField == NULL)
  651. {
  652. LOGE("Error getting enabled field");
  653. return NULL;
  654. }
  655. netconfRevisionField = cache.findField(vnetConfigClass, "netconfRevision", "J");
  656. if(env->ExceptionCheck() || netconfRevisionField == NULL)
  657. {
  658. LOGE("Error getting netconfRevision field");
  659. return NULL;
  660. }
  661. multicastSubscriptionsField = cache.findField(vnetConfigClass, "multicastSubscriptions", "[Lcom/zerotier/sdk/MulticastGroup;");
  662. if(env->ExceptionCheck() || multicastSubscriptionsField == NULL)
  663. {
  664. LOGE("Error getting multicastSubscriptions field");
  665. return NULL;
  666. }
  667. assignedAddressesField = cache.findField(vnetConfigClass, "assignedAddresses", "[Ljava/net/InetSocketAddress;");
  668. if(env->ExceptionCheck() || assignedAddressesField == NULL)
  669. {
  670. LOGE("Error getting assignedAddresses field");
  671. return NULL;
  672. }
  673. env->SetLongField(vnetConfigObj, nwidField, vnetConfig.nwid);
  674. env->SetLongField(vnetConfigObj, macField, vnetConfig.mac);
  675. jstring nameStr = env->NewStringUTF(vnetConfig.name);
  676. if(env->ExceptionCheck() || nameStr == NULL)
  677. {
  678. return NULL; // out of memory
  679. }
  680. env->SetObjectField(vnetConfigObj, nameField, nameStr);
  681. jobject statusObject = createVirtualNetworkStatus(env, vnetConfig.status);
  682. if(env->ExceptionCheck() || statusObject == NULL)
  683. {
  684. return NULL;
  685. }
  686. env->SetObjectField(vnetConfigObj, statusField, statusObject);
  687. jobject typeObject = createVirtualNetworkType(env, vnetConfig.type);
  688. if(env->ExceptionCheck() || typeObject == NULL)
  689. {
  690. return NULL;
  691. }
  692. env->SetObjectField(vnetConfigObj, typeField, typeObject);
  693. env->SetIntField(vnetConfigObj, mtuField, vnetConfig.mtu);
  694. env->SetBooleanField(vnetConfigObj, dhcpField, vnetConfig.dhcp);
  695. env->SetBooleanField(vnetConfigObj, bridgeField, vnetConfig.bridge);
  696. env->SetBooleanField(vnetConfigObj, broadcastEnabledField, vnetConfig.broadcastEnabled);
  697. env->SetIntField(vnetConfigObj, portErrorField, vnetConfig.portError);
  698. jclass multicastGroupClass = cache.findClass("com/zerotier/sdk/MulticastGroup");
  699. if(env->ExceptionCheck() || multicastGroupClass == NULL)
  700. {
  701. LOGE("Error finding MulticastGroup class");
  702. return NULL;
  703. }
  704. jobjectArray mcastSubsArrayObj = env->NewObjectArray(
  705. vnetConfig.multicastSubscriptionCount, multicastGroupClass, NULL);
  706. if(env->ExceptionCheck() || mcastSubsArrayObj == NULL) {
  707. LOGE("Error creating MulticastGroup[] array");
  708. return NULL;
  709. }
  710. for(unsigned int i = 0; i < vnetConfig.multicastSubscriptionCount; ++i)
  711. {
  712. jobject mcastObj = newMulticastGroup(env, vnetConfig.multicastSubscriptions[i]);
  713. env->SetObjectArrayElement(mcastSubsArrayObj, i, mcastObj);
  714. if(env->ExceptionCheck())
  715. {
  716. LOGE("Error assigning MulticastGroup to array");
  717. }
  718. }
  719. env->SetObjectField(vnetConfigObj, multicastSubscriptionsField, mcastSubsArrayObj);
  720. jclass inetSocketAddressClass = cache.findClass("java/net/InetSocketAddress");
  721. if(env->ExceptionCheck() || inetSocketAddressClass == NULL)
  722. {
  723. LOGE("Error finding InetSocketAddress class");
  724. return NULL;
  725. }
  726. jobjectArray assignedAddrArrayObj = env->NewObjectArray(
  727. vnetConfig.assignedAddressCount, inetSocketAddressClass, NULL);
  728. if(env->ExceptionCheck() || assignedAddrArrayObj == NULL)
  729. {
  730. LOGE("Error creating InetSocketAddress[] array");
  731. return NULL;
  732. }
  733. for(unsigned int i = 0; i < vnetConfig.assignedAddressCount; ++i)
  734. {
  735. jobject inetAddrObj = newInetAddress(env, vnetConfig.assignedAddresses[i]);
  736. env->SetObjectArrayElement(assignedAddrArrayObj, i, inetAddrObj);
  737. if(env->ExceptionCheck())
  738. {
  739. LOGE("Error assigning InetSocketAddress to array");
  740. return NULL;
  741. }
  742. }
  743. env->SetObjectField(vnetConfigObj, assignedAddressesField, assignedAddrArrayObj);
  744. return vnetConfigObj;
  745. }
  746. jobject newVersion(JNIEnv *env, int major, int minor, int rev, long featureFlags)
  747. {
  748. // create a com.zerotier.sdk.Version object
  749. jclass versionClass = NULL;
  750. jmethodID versionConstructor = NULL;
  751. versionClass = cache.findClass("com/zerotier/sdk/Version");
  752. if(env->ExceptionCheck() || versionClass == NULL)
  753. {
  754. return NULL;
  755. }
  756. versionConstructor = cache.findMethod(
  757. versionClass, "<init>", "()V");
  758. if(env->ExceptionCheck() || versionConstructor == NULL)
  759. {
  760. return NULL;
  761. }
  762. jobject versionObj = env->NewObject(versionClass, versionConstructor);
  763. if(env->ExceptionCheck() || versionObj == NULL)
  764. {
  765. return NULL;
  766. }
  767. // copy data to Version object
  768. jfieldID majorField = NULL;
  769. jfieldID minorField = NULL;
  770. jfieldID revisionField = NULL;
  771. jfieldID featureFlagsField = NULL;
  772. majorField = cache.findField(versionClass, "major", "I");
  773. if(env->ExceptionCheck() || majorField == NULL)
  774. {
  775. return NULL;
  776. }
  777. minorField = cache.findField(versionClass, "minor", "I");
  778. if(env->ExceptionCheck() || minorField == NULL)
  779. {
  780. return NULL;
  781. }
  782. revisionField = cache.findField(versionClass, "revision", "I");
  783. if(env->ExceptionCheck() || revisionField == NULL)
  784. {
  785. return NULL;
  786. }
  787. featureFlagsField = cache.findField(versionClass, "featureFlags", "J");
  788. if(env->ExceptionCheck() || featureFlagsField == NULL)
  789. {
  790. return NULL;
  791. }
  792. env->SetIntField(versionObj, majorField, (jint)major);
  793. env->SetIntField(versionObj, minorField, (jint)minor);
  794. env->SetIntField(versionObj, revisionField, (jint)rev);
  795. env->SetLongField(versionObj, featureFlagsField, (jlong)featureFlags);
  796. return versionObj;
  797. }
  798. #ifdef __cplusplus
  799. }
  800. #endif