ZT1_jniutils.cpp 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949
  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. LOGD("IPV6 Address");
  299. sockaddr_in6 *ipv6 = (sockaddr_in6*)&addr;
  300. port = ntohs(ipv6->sin6_port);
  301. LOGD("Port %d", port);
  302. }
  303. break;
  304. case AF_INET:
  305. {
  306. LOGD("IPV4 Address");
  307. sockaddr_in *ipv4 = (sockaddr_in*)&addr;
  308. port = ntohs(ipv4->sin_port);
  309. LOGD("Port: %d", port);
  310. }
  311. break;
  312. default:
  313. {
  314. LOGE("ERROR: addr.ss_family is not set or unknown");
  315. break;
  316. }
  317. };
  318. jobject inetSocketAddressObject = env->NewObject(inetSocketAddressClass, inetSocketAddress_constructor, inetAddressObject, port);
  319. if(env->ExceptionCheck() || inetSocketAddressObject == NULL) {
  320. LOGE("Error creating InetSocketAddress object");
  321. }
  322. return inetSocketAddressObject;
  323. }
  324. jobject newMulticastGroup(JNIEnv *env, const ZT1_MulticastGroup &mc)
  325. {
  326. jclass multicastGroupClass = NULL;
  327. jmethodID multicastGroup_constructor = NULL;
  328. jfieldID macField = NULL;
  329. jfieldID adiField = NULL;
  330. multicastGroupClass = cache.findClass("com/zerotier/sdk/MulticastGroup");
  331. if(env->ExceptionCheck() || multicastGroupClass == NULL)
  332. {
  333. return NULL;
  334. }
  335. multicastGroup_constructor = cache.findMethod(
  336. multicastGroupClass, "<init>", "()V");
  337. if(env->ExceptionCheck() || multicastGroup_constructor == NULL)
  338. {
  339. return NULL;
  340. }
  341. jobject multicastGroupObj = env->NewObject(multicastGroupClass, multicastGroup_constructor);
  342. if(env->ExceptionCheck() || multicastGroupObj == NULL)
  343. {
  344. return NULL;
  345. }
  346. macField = cache.findField(multicastGroupClass, "mac", "J");
  347. if(env->ExceptionCheck() || macField == NULL)
  348. {
  349. return NULL;
  350. }
  351. adiField = cache.findField(multicastGroupClass, "adi", "J");
  352. if(env->ExceptionCheck() || adiField == NULL)
  353. {
  354. return NULL;
  355. }
  356. env->SetLongField(multicastGroupObj, macField, mc.mac);
  357. env->SetLongField(multicastGroupObj, adiField, mc.adi);
  358. return multicastGroupObj;
  359. }
  360. jobject newPeerPhysicalPath(JNIEnv *env, const ZT1_PeerPhysicalPath &ppp)
  361. {
  362. LOGV("newPeerPhysicalPath Called");
  363. jclass pppClass = NULL;
  364. jfieldID addressField = NULL;
  365. jfieldID lastSendField = NULL;
  366. jfieldID lastReceiveField = NULL;
  367. jfieldID fixedField = NULL;
  368. jfieldID activeField = NULL;
  369. jfieldID preferredField = NULL;
  370. jmethodID ppp_constructor = NULL;
  371. pppClass = cache.findClass("com/zerotier/sdk/PeerPhysicalPath");
  372. if(env->ExceptionCheck() || pppClass == NULL)
  373. {
  374. LOGE("Error finding PeerPhysicalPath class");
  375. return NULL;
  376. }
  377. addressField = cache.findField(pppClass, "address", "Ljava/net/InetSocketAddress;");
  378. if(env->ExceptionCheck() || addressField == NULL)
  379. {
  380. LOGE("Error finding address field");
  381. return NULL;
  382. }
  383. lastSendField = cache.findField(pppClass, "lastSend", "J");
  384. if(env->ExceptionCheck() || lastSendField == NULL)
  385. {
  386. LOGE("Error finding lastSend field");
  387. return NULL;
  388. }
  389. lastReceiveField = cache.findField(pppClass, "lastReceive", "J");
  390. if(env->ExceptionCheck() || lastReceiveField == NULL)
  391. {
  392. LOGE("Error finding lastReceive field");
  393. return NULL;
  394. }
  395. fixedField = cache.findField(pppClass, "fixed", "Z");
  396. if(env->ExceptionCheck() || fixedField == NULL)
  397. {
  398. LOGE("Error finding fixed field");
  399. return NULL;
  400. }
  401. activeField = cache.findField(pppClass, "active", "Z");
  402. if(env->ExceptionCheck() || activeField == NULL)
  403. {
  404. LOGE("Error finding active field");
  405. return NULL;
  406. }
  407. preferredField = cache.findField(pppClass, "preferred", "Z");
  408. if(env->ExceptionCheck() || preferredField == NULL)
  409. {
  410. LOGE("Error finding preferred field");
  411. return NULL;
  412. }
  413. ppp_constructor = cache.findMethod(pppClass, "<init>", "()V");
  414. if(env->ExceptionCheck() || ppp_constructor == NULL)
  415. {
  416. LOGE("Error finding PeerPhysicalPath constructor");
  417. return NULL;
  418. }
  419. jobject pppObject = env->NewObject(pppClass, ppp_constructor);
  420. if(env->ExceptionCheck() || pppObject == NULL)
  421. {
  422. LOGE("Error creating PPP object");
  423. return NULL; // out of memory
  424. }
  425. jobject addressObject = newInetSocketAddress(env, ppp.address);
  426. if(env->ExceptionCheck() || addressObject == NULL) {
  427. LOGE("Error creating InetSocketAddress object");
  428. return NULL;
  429. }
  430. env->SetObjectField(pppObject, addressField, addressObject);
  431. env->SetLongField(pppObject, lastSendField, ppp.lastSend);
  432. env->SetLongField(pppObject, lastReceiveField, ppp.lastReceive);
  433. env->SetBooleanField(pppObject, fixedField, ppp.fixed);
  434. env->SetBooleanField(pppObject, activeField, ppp.active);
  435. env->SetBooleanField(pppObject, preferredField, ppp.preferred);
  436. if(env->ExceptionCheck()) {
  437. LOGE("Exception assigning fields to PeerPhysicalPath object");
  438. }
  439. return pppObject;
  440. }
  441. jobject newPeer(JNIEnv *env, const ZT1_Peer &peer)
  442. {
  443. LOGV("newPeer called");
  444. jclass peerClass = NULL;
  445. jfieldID addressField = NULL;
  446. jfieldID lastUnicastFrameField = NULL;
  447. jfieldID lastMulticastFrameField = NULL;
  448. jfieldID versionMajorField = NULL;
  449. jfieldID versionMinorField = NULL;
  450. jfieldID versionRevField = NULL;
  451. jfieldID latencyField = NULL;
  452. jfieldID roleField = NULL;
  453. jfieldID pathsField = NULL;
  454. jmethodID peer_constructor = NULL;
  455. peerClass = cache.findClass("com/zerotier/sdk/Peer");
  456. if(env->ExceptionCheck() || peerClass == NULL)
  457. {
  458. LOGE("Error finding Peer class");
  459. return NULL;
  460. }
  461. addressField = cache.findField(peerClass, "address", "J");
  462. if(env->ExceptionCheck() || addressField == NULL)
  463. {
  464. LOGE("Error finding address field of Peer object");
  465. return NULL;
  466. }
  467. lastUnicastFrameField = cache.findField(peerClass, "lastUnicastFrame", "J");
  468. if(env->ExceptionCheck() || lastUnicastFrameField == NULL)
  469. {
  470. LOGE("Error finding lastUnicastFrame field of Peer object");
  471. return NULL;
  472. }
  473. lastMulticastFrameField = cache.findField(peerClass, "lastMulticastFrame", "J");
  474. if(env->ExceptionCheck() || lastMulticastFrameField == NULL)
  475. {
  476. LOGE("Error finding lastMulticastFrame field of Peer object");
  477. return NULL;
  478. }
  479. versionMajorField = cache.findField(peerClass, "versionMajor", "I");
  480. if(env->ExceptionCheck() || versionMajorField == NULL)
  481. {
  482. LOGE("Error finding versionMajor field of Peer object");
  483. return NULL;
  484. }
  485. versionMinorField = cache.findField(peerClass, "versionMinor", "I");
  486. if(env->ExceptionCheck() || versionMinorField == NULL)
  487. {
  488. LOGE("Error finding versionMinor field of Peer object");
  489. return NULL;
  490. }
  491. versionRevField = cache.findField(peerClass, "versionRev", "I");
  492. if(env->ExceptionCheck() || versionRevField == NULL)
  493. {
  494. LOGE("Error finding versionRev field of Peer object");
  495. return NULL;
  496. }
  497. latencyField = cache.findField(peerClass, "latency", "I");
  498. if(env->ExceptionCheck() || latencyField == NULL)
  499. {
  500. LOGE("Error finding latency field of Peer object");
  501. return NULL;
  502. }
  503. roleField = cache.findField(peerClass, "role", "Lcom/zerotier/sdk/PeerRole;");
  504. if(env->ExceptionCheck() || roleField == NULL)
  505. {
  506. LOGE("Error finding role field of Peer object");
  507. return NULL;
  508. }
  509. pathsField = cache.findField(peerClass, "paths", "[Lcom/zerotier/sdk/PeerPhysicalPath;");
  510. if(env->ExceptionCheck() || pathsField == NULL)
  511. {
  512. LOGE("Error finding paths field of Peer object");
  513. return NULL;
  514. }
  515. peer_constructor = cache.findMethod(peerClass, "<init>", "()V");
  516. if(env->ExceptionCheck() || peer_constructor == NULL)
  517. {
  518. LOGE("Error finding Peer constructor");
  519. return NULL;
  520. }
  521. jobject peerObject = env->NewObject(peerClass, peer_constructor);
  522. if(env->ExceptionCheck() || peerObject == NULL)
  523. {
  524. LOGE("Error creating Peer object");
  525. return NULL; // out of memory
  526. }
  527. env->SetLongField(peerObject, addressField, (jlong)peer.address);
  528. env->SetLongField(peerObject, lastUnicastFrameField, (jlong)peer.lastUnicastFrame);
  529. env->SetLongField(peerObject, lastMulticastFrameField, (jlong)peer.lastMulticastFrame);
  530. env->SetIntField(peerObject, versionMajorField, peer.versionMajor);
  531. env->SetIntField(peerObject, versionMinorField, peer.versionMinor);
  532. env->SetIntField(peerObject, versionRevField, peer.versionRev);
  533. env->SetIntField(peerObject, latencyField, peer.latency);
  534. env->SetObjectField(peerObject, roleField, createPeerRole(env, peer.role));
  535. jclass peerPhysicalPathClass = cache.findClass("com/zerotier/sdk/PeerPhysicalPath");
  536. if(env->ExceptionCheck() || peerPhysicalPathClass == NULL)
  537. {
  538. LOGE("Error finding PeerPhysicalPath class");
  539. return NULL;
  540. }
  541. jobjectArray arrayObject = env->NewObjectArray(
  542. peer.pathCount, peerPhysicalPathClass, NULL);
  543. if(env->ExceptionCheck() || arrayObject == NULL)
  544. {
  545. LOGE("Error creating PeerPhysicalPath[] array");
  546. return NULL;
  547. }
  548. for(unsigned int i = 0; i < peer.pathCount; ++i)
  549. {
  550. jobject path = newPeerPhysicalPath(env, peer.paths[i]);
  551. env->SetObjectArrayElement(arrayObject, i, path);
  552. if(env->ExceptionCheck()) {
  553. LOGE("exception assigning PeerPhysicalPath to array");
  554. break;
  555. }
  556. }
  557. env->SetObjectField(peerObject, pathsField, arrayObject);
  558. return peerObject;
  559. }
  560. jobject newNetworkConfig(JNIEnv *env, const ZT1_VirtualNetworkConfig &vnetConfig)
  561. {
  562. jclass vnetConfigClass = NULL;
  563. jmethodID vnetConfig_constructor = NULL;
  564. jfieldID nwidField = NULL;
  565. jfieldID macField = NULL;
  566. jfieldID nameField = NULL;
  567. jfieldID statusField = NULL;
  568. jfieldID typeField = NULL;
  569. jfieldID mtuField = NULL;
  570. jfieldID dhcpField = NULL;
  571. jfieldID bridgeField = NULL;
  572. jfieldID broadcastEnabledField = NULL;
  573. jfieldID portErrorField = NULL;
  574. jfieldID enabledField = NULL;
  575. jfieldID netconfRevisionField = NULL;
  576. jfieldID multicastSubscriptionsField = NULL;
  577. jfieldID assignedAddressesField = NULL;
  578. vnetConfigClass = cache.findClass("com/zerotier/sdk/VirtualNetworkConfig");
  579. if(vnetConfigClass == NULL)
  580. {
  581. LOGE("Couldn't find com.zerotier.sdk.VirtualNetworkConfig");
  582. return NULL;
  583. }
  584. vnetConfig_constructor = cache.findMethod(
  585. vnetConfigClass, "<init>", "()V");
  586. if(env->ExceptionCheck() || vnetConfig_constructor == NULL)
  587. {
  588. LOGE("Couldn't find VirtualNetworkConfig Constructor");
  589. return NULL;
  590. }
  591. jobject vnetConfigObj = env->NewObject(vnetConfigClass, vnetConfig_constructor);
  592. if(env->ExceptionCheck() || vnetConfigObj == NULL)
  593. {
  594. LOGE("Error creating new VirtualNetworkConfig object");
  595. return NULL;
  596. }
  597. nwidField = cache.findField(vnetConfigClass, "nwid", "J");
  598. if(env->ExceptionCheck() || nwidField == NULL)
  599. {
  600. LOGE("Error getting nwid field");
  601. return NULL;
  602. }
  603. macField = cache.findField(vnetConfigClass, "mac", "J");
  604. if(env->ExceptionCheck() || macField == NULL)
  605. {
  606. LOGE("Error getting mac field");
  607. return NULL;
  608. }
  609. nameField = cache.findField(vnetConfigClass, "name", "Ljava/lang/String;");
  610. if(env->ExceptionCheck() || nameField == NULL)
  611. {
  612. LOGE("Error getting name field");
  613. return NULL;
  614. }
  615. statusField = cache.findField(vnetConfigClass, "status", "Lcom/zerotier/sdk/VirtualNetworkStatus;");
  616. if(env->ExceptionCheck() || statusField == NULL)
  617. {
  618. LOGE("Error getting status field");
  619. return NULL;
  620. }
  621. typeField = cache.findField(vnetConfigClass, "type", "Lcom/zerotier/sdk/VirtualNetworkType;");
  622. if(env->ExceptionCheck() || typeField == NULL)
  623. {
  624. LOGE("Error getting type field");
  625. return NULL;
  626. }
  627. mtuField = cache.findField(vnetConfigClass, "mtu", "I");
  628. if(env->ExceptionCheck() || mtuField == NULL)
  629. {
  630. LOGE("Error getting mtu field");
  631. return NULL;
  632. }
  633. dhcpField = cache.findField(vnetConfigClass, "dhcp", "Z");
  634. if(env->ExceptionCheck() || dhcpField == NULL)
  635. {
  636. LOGE("Error getting dhcp field");
  637. return NULL;
  638. }
  639. bridgeField = cache.findField(vnetConfigClass, "bridge", "Z");
  640. if(env->ExceptionCheck() || bridgeField == NULL)
  641. {
  642. LOGE("Error getting bridge field");
  643. return NULL;
  644. }
  645. broadcastEnabledField = cache.findField(vnetConfigClass, "broadcastEnabled", "Z");
  646. if(env->ExceptionCheck() || broadcastEnabledField == NULL)
  647. {
  648. LOGE("Error getting broadcastEnabled field");
  649. return NULL;
  650. }
  651. portErrorField = cache.findField(vnetConfigClass, "portError", "I");
  652. if(env->ExceptionCheck() || portErrorField == NULL)
  653. {
  654. LOGE("Error getting portError field");
  655. return NULL;
  656. }
  657. enabledField = cache.findField(vnetConfigClass, "enabled", "Z");
  658. if(env->ExceptionCheck() || enabledField == NULL)
  659. {
  660. LOGE("Error getting enabled field");
  661. return NULL;
  662. }
  663. netconfRevisionField = cache.findField(vnetConfigClass, "netconfRevision", "J");
  664. if(env->ExceptionCheck() || netconfRevisionField == NULL)
  665. {
  666. LOGE("Error getting netconfRevision field");
  667. return NULL;
  668. }
  669. multicastSubscriptionsField = cache.findField(vnetConfigClass, "multicastSubscriptions", "[Lcom/zerotier/sdk/MulticastGroup;");
  670. if(env->ExceptionCheck() || multicastSubscriptionsField == NULL)
  671. {
  672. LOGE("Error getting multicastSubscriptions field");
  673. return NULL;
  674. }
  675. assignedAddressesField = cache.findField(vnetConfigClass, "assignedAddresses", "[Ljava/net/InetSocketAddress;");
  676. if(env->ExceptionCheck() || assignedAddressesField == NULL)
  677. {
  678. LOGE("Error getting assignedAddresses field");
  679. return NULL;
  680. }
  681. env->SetLongField(vnetConfigObj, nwidField, vnetConfig.nwid);
  682. env->SetLongField(vnetConfigObj, macField, vnetConfig.mac);
  683. jstring nameStr = env->NewStringUTF(vnetConfig.name);
  684. if(env->ExceptionCheck() || nameStr == NULL)
  685. {
  686. return NULL; // out of memory
  687. }
  688. env->SetObjectField(vnetConfigObj, nameField, nameStr);
  689. jobject statusObject = createVirtualNetworkStatus(env, vnetConfig.status);
  690. if(env->ExceptionCheck() || statusObject == NULL)
  691. {
  692. return NULL;
  693. }
  694. env->SetObjectField(vnetConfigObj, statusField, statusObject);
  695. jobject typeObject = createVirtualNetworkType(env, vnetConfig.type);
  696. if(env->ExceptionCheck() || typeObject == NULL)
  697. {
  698. return NULL;
  699. }
  700. env->SetObjectField(vnetConfigObj, typeField, typeObject);
  701. env->SetIntField(vnetConfigObj, mtuField, vnetConfig.mtu);
  702. env->SetBooleanField(vnetConfigObj, dhcpField, vnetConfig.dhcp);
  703. env->SetBooleanField(vnetConfigObj, bridgeField, vnetConfig.bridge);
  704. env->SetBooleanField(vnetConfigObj, broadcastEnabledField, vnetConfig.broadcastEnabled);
  705. env->SetBooleanField(vnetConfigObj, enabledField, vnetConfig.enabled);
  706. env->SetIntField(vnetConfigObj, portErrorField, vnetConfig.portError);
  707. jclass multicastGroupClass = cache.findClass("com/zerotier/sdk/MulticastGroup");
  708. if(env->ExceptionCheck() || multicastGroupClass == NULL)
  709. {
  710. LOGE("Error finding MulticastGroup class");
  711. return NULL;
  712. }
  713. jobjectArray mcastSubsArrayObj = env->NewObjectArray(
  714. vnetConfig.multicastSubscriptionCount, multicastGroupClass, NULL);
  715. if(env->ExceptionCheck() || mcastSubsArrayObj == NULL) {
  716. LOGE("Error creating MulticastGroup[] array");
  717. return NULL;
  718. }
  719. for(unsigned int i = 0; i < vnetConfig.multicastSubscriptionCount; ++i)
  720. {
  721. jobject mcastObj = newMulticastGroup(env, vnetConfig.multicastSubscriptions[i]);
  722. env->SetObjectArrayElement(mcastSubsArrayObj, i, mcastObj);
  723. if(env->ExceptionCheck())
  724. {
  725. LOGE("Error assigning MulticastGroup to array");
  726. }
  727. }
  728. env->SetObjectField(vnetConfigObj, multicastSubscriptionsField, mcastSubsArrayObj);
  729. jclass inetSocketAddressClass = cache.findClass("java/net/InetSocketAddress");
  730. if(env->ExceptionCheck() || inetSocketAddressClass == NULL)
  731. {
  732. LOGE("Error finding InetSocketAddress class");
  733. return NULL;
  734. }
  735. jobjectArray assignedAddrArrayObj = env->NewObjectArray(
  736. vnetConfig.assignedAddressCount, inetSocketAddressClass, NULL);
  737. if(env->ExceptionCheck() || assignedAddrArrayObj == NULL)
  738. {
  739. LOGE("Error creating InetSocketAddress[] array");
  740. return NULL;
  741. }
  742. for(unsigned int i = 0; i < vnetConfig.assignedAddressCount; ++i)
  743. {
  744. jobject inetAddrObj = newInetSocketAddress(env, vnetConfig.assignedAddresses[i]);
  745. env->SetObjectArrayElement(assignedAddrArrayObj, i, inetAddrObj);
  746. if(env->ExceptionCheck())
  747. {
  748. LOGE("Error assigning InetSocketAddress to array");
  749. return NULL;
  750. }
  751. }
  752. env->SetObjectField(vnetConfigObj, assignedAddressesField, assignedAddrArrayObj);
  753. return vnetConfigObj;
  754. }
  755. jobject newVersion(JNIEnv *env, int major, int minor, int rev, long featureFlags)
  756. {
  757. // create a com.zerotier.sdk.Version object
  758. jclass versionClass = NULL;
  759. jmethodID versionConstructor = NULL;
  760. versionClass = cache.findClass("com/zerotier/sdk/Version");
  761. if(env->ExceptionCheck() || versionClass == NULL)
  762. {
  763. return NULL;
  764. }
  765. versionConstructor = cache.findMethod(
  766. versionClass, "<init>", "()V");
  767. if(env->ExceptionCheck() || versionConstructor == NULL)
  768. {
  769. return NULL;
  770. }
  771. jobject versionObj = env->NewObject(versionClass, versionConstructor);
  772. if(env->ExceptionCheck() || versionObj == NULL)
  773. {
  774. return NULL;
  775. }
  776. // copy data to Version object
  777. jfieldID majorField = NULL;
  778. jfieldID minorField = NULL;
  779. jfieldID revisionField = NULL;
  780. jfieldID featureFlagsField = NULL;
  781. majorField = cache.findField(versionClass, "major", "I");
  782. if(env->ExceptionCheck() || majorField == NULL)
  783. {
  784. return NULL;
  785. }
  786. minorField = cache.findField(versionClass, "minor", "I");
  787. if(env->ExceptionCheck() || minorField == NULL)
  788. {
  789. return NULL;
  790. }
  791. revisionField = cache.findField(versionClass, "revision", "I");
  792. if(env->ExceptionCheck() || revisionField == NULL)
  793. {
  794. return NULL;
  795. }
  796. featureFlagsField = cache.findField(versionClass, "featureFlags", "J");
  797. if(env->ExceptionCheck() || featureFlagsField == NULL)
  798. {
  799. return NULL;
  800. }
  801. env->SetIntField(versionObj, majorField, (jint)major);
  802. env->SetIntField(versionObj, minorField, (jint)minor);
  803. env->SetIntField(versionObj, revisionField, (jint)rev);
  804. env->SetLongField(versionObj, featureFlagsField, (jlong)featureFlags);
  805. return versionObj;
  806. }
  807. #ifdef __cplusplus
  808. }
  809. #endif