ZT_jniutils.cpp 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032
  1. /*
  2. * ZeroTier One - Network Virtualization Everywhere
  3. * Copyright (C) 2011-2016 ZeroTier, Inc. https://www.zerotier.com/
  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. #include "ZT_jniutils.h"
  19. #include "ZT_jnilookup.h"
  20. #include "ZT_jniarray.h"
  21. #include <string>
  22. #include <assert.h>
  23. #include <arpa/inet.h>
  24. #include <netinet/in.h>
  25. #include <sys/types.h>
  26. #include <sys/socket.h>
  27. extern JniLookup lookup;
  28. #ifdef __cplusplus
  29. extern "C" {
  30. #endif
  31. jobject createResultObject(JNIEnv *env, ZT_ResultCode code)
  32. {
  33. jclass resultClass = NULL;
  34. jobject resultObject = NULL;
  35. resultClass = lookup.findClass("com/zerotier/sdk/ResultCode");
  36. if(resultClass == NULL)
  37. {
  38. LOGE("Couldnt find ResultCode class");
  39. return NULL; // exception thrown
  40. }
  41. std::string fieldName;
  42. switch(code)
  43. {
  44. case ZT_RESULT_OK:
  45. case ZT_RESULT_OK_IGNORED:
  46. LOGV("ZT_RESULT_OK");
  47. fieldName = "RESULT_OK";
  48. break;
  49. case ZT_RESULT_FATAL_ERROR_OUT_OF_MEMORY:
  50. LOGV("ZT_RESULT_FATAL_ERROR_OUT_OF_MEMORY");
  51. fieldName = "RESULT_FATAL_ERROR_OUT_OF_MEMORY";
  52. break;
  53. case ZT_RESULT_FATAL_ERROR_DATA_STORE_FAILED:
  54. LOGV("RESULT_FATAL_ERROR_DATA_STORE_FAILED");
  55. fieldName = "RESULT_FATAL_ERROR_DATA_STORE_FAILED";
  56. break;
  57. case ZT_RESULT_ERROR_NETWORK_NOT_FOUND:
  58. LOGV("ZT_RESULT_ERROR_NETWORK_NOT_FOUND");
  59. fieldName = "RESULT_ERROR_NETWORK_NOT_FOUND";
  60. break;
  61. case ZT_RESULT_ERROR_UNSUPPORTED_OPERATION:
  62. LOGV("ZT_RESULT_ERROR_UNSUPPORTED_OPERATION");
  63. fieldName = "RESULT_ERROR_UNSUPPORTED_OPERATION";
  64. break;
  65. case ZT_RESULT_ERROR_BAD_PARAMETER:
  66. LOGV("ZT_RESULT_ERROR_BAD_PARAMETER");
  67. fieldName = "ZT_RESULT_ERROR_BAD_PARAMETER";
  68. break;
  69. case ZT_RESULT_FATAL_ERROR_INTERNAL:
  70. default:
  71. LOGV("ZT_RESULT_FATAL_ERROR_INTERNAL");
  72. fieldName = "RESULT_FATAL_ERROR_INTERNAL";
  73. break;
  74. }
  75. jfieldID enumField = lookup.findStaticField(resultClass, fieldName.c_str(), "Lcom/zerotier/sdk/ResultCode;");
  76. if(env->ExceptionCheck() || enumField == NULL)
  77. {
  78. LOGE("Error on FindStaticField");
  79. return NULL;
  80. }
  81. resultObject = env->GetStaticObjectField(resultClass, enumField);
  82. if(env->ExceptionCheck() || resultObject == NULL)
  83. {
  84. LOGE("Error on GetStaticObjectField");
  85. }
  86. return resultObject;
  87. }
  88. jobject createVirtualNetworkStatus(JNIEnv *env, ZT_VirtualNetworkStatus status)
  89. {
  90. jobject statusObject = NULL;
  91. jclass statusClass = lookup.findClass("com/zerotier/sdk/VirtualNetworkStatus");
  92. if(statusClass == NULL)
  93. {
  94. return NULL; // exception thrown
  95. }
  96. std::string fieldName;
  97. switch(status)
  98. {
  99. case ZT_NETWORK_STATUS_REQUESTING_CONFIGURATION:
  100. fieldName = "NETWORK_STATUS_REQUESTING_CONFIGURATION";
  101. break;
  102. case ZT_NETWORK_STATUS_OK:
  103. fieldName = "NETWORK_STATUS_OK";
  104. break;
  105. case ZT_NETWORK_STATUS_ACCESS_DENIED:
  106. fieldName = "NETWORK_STATUS_ACCESS_DENIED";
  107. break;
  108. case ZT_NETWORK_STATUS_NOT_FOUND:
  109. fieldName = "NETWORK_STATUS_NOT_FOUND";
  110. break;
  111. case ZT_NETWORK_STATUS_PORT_ERROR:
  112. fieldName = "NETWORK_STATUS_PORT_ERROR";
  113. break;
  114. case ZT_NETWORK_STATUS_CLIENT_TOO_OLD:
  115. fieldName = "NETWORK_STATUS_CLIENT_TOO_OLD";
  116. break;
  117. }
  118. jfieldID enumField = lookup.findStaticField(statusClass, fieldName.c_str(), "Lcom/zerotier/sdk/VirtualNetworkStatus;");
  119. statusObject = env->GetStaticObjectField(statusClass, enumField);
  120. return statusObject;
  121. }
  122. jobject createEvent(JNIEnv *env, ZT_Event event)
  123. {
  124. jclass eventClass = NULL;
  125. jobject eventObject = NULL;
  126. eventClass = lookup.findClass("com/zerotier/sdk/Event");
  127. if(eventClass == NULL)
  128. {
  129. return NULL;
  130. }
  131. std::string fieldName;
  132. switch(event)
  133. {
  134. case ZT_EVENT_UP:
  135. fieldName = "EVENT_UP";
  136. break;
  137. case ZT_EVENT_OFFLINE:
  138. fieldName = "EVENT_OFFLINE";
  139. break;
  140. case ZT_EVENT_ONLINE:
  141. fieldName = "EVENT_ONLINE";
  142. break;
  143. case ZT_EVENT_DOWN:
  144. fieldName = "EVENT_DOWN";
  145. break;
  146. case ZT_EVENT_FATAL_ERROR_IDENTITY_COLLISION:
  147. fieldName = "EVENT_FATAL_ERROR_IDENTITY_COLLISION";
  148. break;
  149. case ZT_EVENT_TRACE:
  150. fieldName = "EVENT_TRACE";
  151. break;
  152. case ZT_EVENT_USER_MESSAGE:
  153. break;
  154. case ZT_EVENT_REMOTE_TRACE:
  155. default:
  156. break;
  157. }
  158. jfieldID enumField = lookup.findStaticField(eventClass, fieldName.c_str(), "Lcom/zerotier/sdk/Event;");
  159. eventObject = env->GetStaticObjectField(eventClass, enumField);
  160. return eventObject;
  161. }
  162. jobject createPeerRole(JNIEnv *env, ZT_PeerRole role)
  163. {
  164. jclass peerRoleClass = NULL;
  165. jobject peerRoleObject = NULL;
  166. peerRoleClass = lookup.findClass("com/zerotier/sdk/PeerRole");
  167. if(peerRoleClass == NULL)
  168. {
  169. return NULL;
  170. }
  171. std::string fieldName;
  172. switch(role)
  173. {
  174. case ZT_PEER_ROLE_LEAF:
  175. fieldName = "PEER_ROLE_LEAF";
  176. break;
  177. case ZT_PEER_ROLE_MOON:
  178. fieldName = "PEER_ROLE_MOON";
  179. break;
  180. case ZT_PEER_ROLE_PLANET:
  181. fieldName = "PEER_ROLE_PLANET";
  182. break;
  183. }
  184. jfieldID enumField = lookup.findStaticField(peerRoleClass, fieldName.c_str(), "Lcom/zerotier/sdk/PeerRole;");
  185. peerRoleObject = env->GetStaticObjectField(peerRoleClass, enumField);
  186. return peerRoleObject;
  187. }
  188. jobject createVirtualNetworkType(JNIEnv *env, ZT_VirtualNetworkType type)
  189. {
  190. jclass vntypeClass = NULL;
  191. jobject vntypeObject = NULL;
  192. vntypeClass = lookup.findClass("com/zerotier/sdk/VirtualNetworkType");
  193. if(env->ExceptionCheck() || vntypeClass == NULL)
  194. {
  195. return NULL;
  196. }
  197. std::string fieldName;
  198. switch(type)
  199. {
  200. case ZT_NETWORK_TYPE_PRIVATE:
  201. fieldName = "NETWORK_TYPE_PRIVATE";
  202. break;
  203. case ZT_NETWORK_TYPE_PUBLIC:
  204. fieldName = "NETWORK_TYPE_PUBLIC";
  205. break;
  206. }
  207. jfieldID enumField = lookup.findStaticField(vntypeClass, fieldName.c_str(), "Lcom/zerotier/sdk/VirtualNetworkType;");
  208. vntypeObject = env->GetStaticObjectField(vntypeClass, enumField);
  209. return vntypeObject;
  210. }
  211. jobject createVirtualNetworkConfigOperation(JNIEnv *env, ZT_VirtualNetworkConfigOperation op)
  212. {
  213. jclass vnetConfigOpClass = NULL;
  214. jobject vnetConfigOpObject = NULL;
  215. vnetConfigOpClass = lookup.findClass("com/zerotier/sdk/VirtualNetworkConfigOperation");
  216. if(env->ExceptionCheck() || vnetConfigOpClass == NULL)
  217. {
  218. return NULL;
  219. }
  220. std::string fieldName;
  221. switch(op)
  222. {
  223. case ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_UP:
  224. fieldName = "VIRTUAL_NETWORK_CONFIG_OPERATION_UP";
  225. break;
  226. case ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_CONFIG_UPDATE:
  227. fieldName = "VIRTUAL_NETWORK_CONFIG_OPERATION_CONFIG_UPDATE";
  228. break;
  229. case ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_DOWN:
  230. fieldName = "VIRTUAL_NETWORK_CONFIG_OPERATION_DOWN";
  231. break;
  232. case ZT_VIRTUAL_NETWORK_CONFIG_OPERATION_DESTROY:
  233. fieldName = "VIRTUAL_NETWORK_CONFIG_OPERATION_DESTROY";
  234. break;
  235. }
  236. jfieldID enumField = lookup.findStaticField(vnetConfigOpClass, fieldName.c_str(), "Lcom/zerotier/sdk/VirtualNetworkConfigOperation;");
  237. vnetConfigOpObject = env->GetStaticObjectField(vnetConfigOpClass, enumField);
  238. return vnetConfigOpObject;
  239. }
  240. jobject newInetAddress(JNIEnv *env, const sockaddr_storage &addr)
  241. {
  242. LOGV("newInetAddress");
  243. jclass inetAddressClass = NULL;
  244. jmethodID inetAddress_getByAddress = NULL;
  245. inetAddressClass = lookup.findClass("java/net/InetAddress");
  246. if(env->ExceptionCheck() || inetAddressClass == NULL)
  247. {
  248. LOGE("Error finding InetAddress class");
  249. return NULL;
  250. }
  251. inetAddress_getByAddress = lookup.findStaticMethod(
  252. inetAddressClass, "getByAddress", "([B)Ljava/net/InetAddress;");
  253. if(env->ExceptionCheck() || inetAddress_getByAddress == NULL)
  254. {
  255. LOGE("Erorr finding getByAddress() static method");
  256. return NULL;
  257. }
  258. jobject inetAddressObj = NULL;
  259. switch(addr.ss_family)
  260. {
  261. case AF_INET6:
  262. {
  263. sockaddr_in6 *ipv6 = (sockaddr_in6*)&addr;
  264. jbyteArray buff = env->NewByteArray(16);
  265. if(buff == NULL)
  266. {
  267. LOGE("Error creating IPV6 byte array");
  268. return NULL;
  269. }
  270. env->SetByteArrayRegion(buff, 0, 16, (jbyte*)ipv6->sin6_addr.s6_addr);
  271. inetAddressObj = env->CallStaticObjectMethod(
  272. inetAddressClass, inetAddress_getByAddress, buff);
  273. }
  274. break;
  275. case AF_INET:
  276. {
  277. sockaddr_in *ipv4 = (sockaddr_in*)&addr;
  278. jbyteArray buff = env->NewByteArray(4);
  279. if(buff == NULL)
  280. {
  281. LOGE("Error creating IPV4 byte array");
  282. return NULL;
  283. }
  284. env->SetByteArrayRegion(buff, 0, 4, (jbyte*)&ipv4->sin_addr);
  285. inetAddressObj = env->CallStaticObjectMethod(
  286. inetAddressClass, inetAddress_getByAddress, buff);
  287. }
  288. break;
  289. }
  290. if(env->ExceptionCheck() || inetAddressObj == NULL) {
  291. LOGE("Error creating InetAddress object");
  292. return NULL;
  293. }
  294. return inetAddressObj;
  295. }
  296. jobject newInetSocketAddress(JNIEnv *env, const sockaddr_storage &addr)
  297. {
  298. LOGV("newInetSocketAddress Called");
  299. jclass inetSocketAddressClass = NULL;
  300. jmethodID inetSocketAddress_constructor = NULL;
  301. inetSocketAddressClass = lookup.findClass("java/net/InetSocketAddress");
  302. if(env->ExceptionCheck() || inetSocketAddressClass == NULL)
  303. {
  304. LOGE("Error finding InetSocketAddress Class");
  305. return NULL;
  306. }
  307. jobject inetAddressObject = NULL;
  308. if(addr.ss_family != 0)
  309. {
  310. inetAddressObject = newInetAddress(env, addr);
  311. if(env->ExceptionCheck() || inetAddressObject == NULL)
  312. {
  313. LOGE("Error creating new inet address");
  314. return NULL;
  315. }
  316. }
  317. else
  318. {
  319. return NULL;
  320. }
  321. inetSocketAddress_constructor = lookup.findMethod(
  322. inetSocketAddressClass, "<init>", "(Ljava/net/InetAddress;I)V");
  323. if(env->ExceptionCheck() || inetSocketAddress_constructor == NULL)
  324. {
  325. LOGE("Error finding InetSocketAddress constructor");
  326. return NULL;
  327. }
  328. int port = 0;
  329. switch(addr.ss_family)
  330. {
  331. case AF_INET6:
  332. {
  333. LOGV("IPV6 Address");
  334. sockaddr_in6 *ipv6 = (sockaddr_in6*)&addr;
  335. port = ntohs(ipv6->sin6_port);
  336. LOGV("Port %d", port);
  337. }
  338. break;
  339. case AF_INET:
  340. {
  341. LOGV("IPV4 Address");
  342. sockaddr_in *ipv4 = (sockaddr_in*)&addr;
  343. port = ntohs(ipv4->sin_port);
  344. LOGV("Port: %d", port);
  345. }
  346. break;
  347. default:
  348. {
  349. break;
  350. }
  351. }
  352. jobject inetSocketAddressObject = env->NewObject(inetSocketAddressClass, inetSocketAddress_constructor, inetAddressObject, port);
  353. if(env->ExceptionCheck() || inetSocketAddressObject == NULL) {
  354. LOGE("Error creating InetSocketAddress object");
  355. }
  356. return inetSocketAddressObject;
  357. }
  358. jobject newPeerPhysicalPath(JNIEnv *env, const ZT_PeerPhysicalPath &ppp)
  359. {
  360. LOGV("newPeerPhysicalPath Called");
  361. jclass pppClass = NULL;
  362. jfieldID addressField = NULL;
  363. jfieldID lastSendField = NULL;
  364. jfieldID lastReceiveField = NULL;
  365. jfieldID preferredField = NULL;
  366. jmethodID ppp_constructor = NULL;
  367. pppClass = lookup.findClass("com/zerotier/sdk/PeerPhysicalPath");
  368. if(env->ExceptionCheck() || pppClass == NULL)
  369. {
  370. LOGE("Error finding PeerPhysicalPath class");
  371. return NULL;
  372. }
  373. addressField = lookup.findField(pppClass, "address", "Ljava/net/InetSocketAddress;");
  374. if(env->ExceptionCheck() || addressField == NULL)
  375. {
  376. LOGE("Error finding address field");
  377. return NULL;
  378. }
  379. lastSendField = lookup.findField(pppClass, "lastSend", "J");
  380. if(env->ExceptionCheck() || lastSendField == NULL)
  381. {
  382. LOGE("Error finding lastSend field");
  383. return NULL;
  384. }
  385. lastReceiveField = lookup.findField(pppClass, "lastReceive", "J");
  386. if(env->ExceptionCheck() || lastReceiveField == NULL)
  387. {
  388. LOGE("Error finding lastReceive field");
  389. return NULL;
  390. }
  391. preferredField = lookup.findField(pppClass, "preferred", "Z");
  392. if(env->ExceptionCheck() || preferredField == NULL)
  393. {
  394. LOGE("Error finding preferred field");
  395. return NULL;
  396. }
  397. ppp_constructor = lookup.findMethod(pppClass, "<init>", "()V");
  398. if(env->ExceptionCheck() || ppp_constructor == NULL)
  399. {
  400. LOGE("Error finding PeerPhysicalPath constructor");
  401. return NULL;
  402. }
  403. jobject pppObject = env->NewObject(pppClass, ppp_constructor);
  404. if(env->ExceptionCheck() || pppObject == NULL)
  405. {
  406. LOGE("Error creating PPP object");
  407. return NULL; // out of memory
  408. }
  409. jobject addressObject = newInetSocketAddress(env, ppp.address);
  410. if(env->ExceptionCheck() || addressObject == NULL) {
  411. LOGE("Error creating InetSocketAddress object");
  412. return NULL;
  413. }
  414. env->SetObjectField(pppObject, addressField, addressObject);
  415. env->SetLongField(pppObject, lastSendField, ppp.lastSend);
  416. env->SetLongField(pppObject, lastReceiveField, ppp.lastReceive);
  417. env->SetBooleanField(pppObject, preferredField, ppp.preferred);
  418. if(env->ExceptionCheck()) {
  419. LOGE("Exception assigning fields to PeerPhysicalPath object");
  420. }
  421. return pppObject;
  422. }
  423. jobject newPeer(JNIEnv *env, const ZT_Peer &peer)
  424. {
  425. LOGV("newPeer called");
  426. jclass peerClass = NULL;
  427. jfieldID addressField = NULL;
  428. jfieldID versionMajorField = NULL;
  429. jfieldID versionMinorField = NULL;
  430. jfieldID versionRevField = NULL;
  431. jfieldID latencyField = NULL;
  432. jfieldID roleField = NULL;
  433. jfieldID pathsField = NULL;
  434. jmethodID peer_constructor = NULL;
  435. peerClass = lookup.findClass("com/zerotier/sdk/Peer");
  436. if(env->ExceptionCheck() || peerClass == NULL)
  437. {
  438. LOGE("Error finding Peer class");
  439. return NULL;
  440. }
  441. addressField = lookup.findField(peerClass, "address", "J");
  442. if(env->ExceptionCheck() || addressField == NULL)
  443. {
  444. LOGE("Error finding address field of Peer object");
  445. return NULL;
  446. }
  447. versionMajorField = lookup.findField(peerClass, "versionMajor", "I");
  448. if(env->ExceptionCheck() || versionMajorField == NULL)
  449. {
  450. LOGE("Error finding versionMajor field of Peer object");
  451. return NULL;
  452. }
  453. versionMinorField = lookup.findField(peerClass, "versionMinor", "I");
  454. if(env->ExceptionCheck() || versionMinorField == NULL)
  455. {
  456. LOGE("Error finding versionMinor field of Peer object");
  457. return NULL;
  458. }
  459. versionRevField = lookup.findField(peerClass, "versionRev", "I");
  460. if(env->ExceptionCheck() || versionRevField == NULL)
  461. {
  462. LOGE("Error finding versionRev field of Peer object");
  463. return NULL;
  464. }
  465. latencyField = lookup.findField(peerClass, "latency", "I");
  466. if(env->ExceptionCheck() || latencyField == NULL)
  467. {
  468. LOGE("Error finding latency field of Peer object");
  469. return NULL;
  470. }
  471. roleField = lookup.findField(peerClass, "role", "Lcom/zerotier/sdk/PeerRole;");
  472. if(env->ExceptionCheck() || roleField == NULL)
  473. {
  474. LOGE("Error finding role field of Peer object");
  475. return NULL;
  476. }
  477. pathsField = lookup.findField(peerClass, "paths", "[Lcom/zerotier/sdk/PeerPhysicalPath;");
  478. if(env->ExceptionCheck() || pathsField == NULL)
  479. {
  480. LOGE("Error finding paths field of Peer object");
  481. return NULL;
  482. }
  483. peer_constructor = lookup.findMethod(peerClass, "<init>", "()V");
  484. if(env->ExceptionCheck() || peer_constructor == NULL)
  485. {
  486. LOGE("Error finding Peer constructor");
  487. return NULL;
  488. }
  489. jobject peerObject = env->NewObject(peerClass, peer_constructor);
  490. if(env->ExceptionCheck() || peerObject == NULL)
  491. {
  492. LOGE("Error creating Peer object");
  493. return NULL; // out of memory
  494. }
  495. env->SetLongField(peerObject, addressField, (jlong)peer.address);
  496. env->SetIntField(peerObject, versionMajorField, peer.versionMajor);
  497. env->SetIntField(peerObject, versionMinorField, peer.versionMinor);
  498. env->SetIntField(peerObject, versionRevField, peer.versionRev);
  499. env->SetIntField(peerObject, latencyField, peer.latency);
  500. env->SetObjectField(peerObject, roleField, createPeerRole(env, peer.role));
  501. jclass peerPhysicalPathClass = lookup.findClass("com/zerotier/sdk/PeerPhysicalPath");
  502. if(env->ExceptionCheck() || peerPhysicalPathClass == NULL)
  503. {
  504. LOGE("Error finding PeerPhysicalPath class");
  505. return NULL;
  506. }
  507. jobjectArray arrayObject = env->NewObjectArray(
  508. peer.pathCount, peerPhysicalPathClass, NULL);
  509. if(env->ExceptionCheck() || arrayObject == NULL)
  510. {
  511. LOGE("Error creating PeerPhysicalPath[] array");
  512. return NULL;
  513. }
  514. for(unsigned int i = 0; i < peer.pathCount; ++i)
  515. {
  516. jobject path = newPeerPhysicalPath(env, peer.paths[i]);
  517. env->SetObjectArrayElement(arrayObject, i, path);
  518. if(env->ExceptionCheck()) {
  519. LOGE("exception assigning PeerPhysicalPath to array");
  520. break;
  521. }
  522. }
  523. env->SetObjectField(peerObject, pathsField, arrayObject);
  524. return peerObject;
  525. }
  526. jobject newNetworkConfig(JNIEnv *env, const ZT_VirtualNetworkConfig &vnetConfig)
  527. {
  528. jclass vnetConfigClass = NULL;
  529. jmethodID vnetConfig_constructor = NULL;
  530. jfieldID nwidField = NULL;
  531. jfieldID macField = NULL;
  532. jfieldID nameField = NULL;
  533. jfieldID statusField = NULL;
  534. jfieldID typeField = NULL;
  535. jfieldID mtuField = NULL;
  536. jfieldID dhcpField = NULL;
  537. jfieldID bridgeField = NULL;
  538. jfieldID broadcastEnabledField = NULL;
  539. jfieldID portErrorField = NULL;
  540. jfieldID netconfRevisionField = NULL;
  541. jfieldID assignedAddressesField = NULL;
  542. jfieldID routesField = NULL;
  543. jfieldID dnsField = NULL;
  544. vnetConfigClass = lookup.findClass("com/zerotier/sdk/VirtualNetworkConfig");
  545. if(vnetConfigClass == NULL)
  546. {
  547. LOGE("Couldn't find com.zerotier.sdk.VirtualNetworkConfig");
  548. return NULL;
  549. }
  550. vnetConfig_constructor = lookup.findMethod(
  551. vnetConfigClass, "<init>", "()V");
  552. if(env->ExceptionCheck() || vnetConfig_constructor == NULL)
  553. {
  554. LOGE("Couldn't find VirtualNetworkConfig Constructor");
  555. return NULL;
  556. }
  557. jobject vnetConfigObj = env->NewObject(vnetConfigClass, vnetConfig_constructor);
  558. if(env->ExceptionCheck() || vnetConfigObj == NULL)
  559. {
  560. LOGE("Error creating new VirtualNetworkConfig object");
  561. return NULL;
  562. }
  563. nwidField = lookup.findField(vnetConfigClass, "nwid", "J");
  564. if(env->ExceptionCheck() || nwidField == NULL)
  565. {
  566. LOGE("Error getting nwid field");
  567. return NULL;
  568. }
  569. macField = lookup.findField(vnetConfigClass, "mac", "J");
  570. if(env->ExceptionCheck() || macField == NULL)
  571. {
  572. LOGE("Error getting mac field");
  573. return NULL;
  574. }
  575. nameField = lookup.findField(vnetConfigClass, "name", "Ljava/lang/String;");
  576. if(env->ExceptionCheck() || nameField == NULL)
  577. {
  578. LOGE("Error getting name field");
  579. return NULL;
  580. }
  581. statusField = lookup.findField(vnetConfigClass, "status", "Lcom/zerotier/sdk/VirtualNetworkStatus;");
  582. if(env->ExceptionCheck() || statusField == NULL)
  583. {
  584. LOGE("Error getting status field");
  585. return NULL;
  586. }
  587. typeField = lookup.findField(vnetConfigClass, "type", "Lcom/zerotier/sdk/VirtualNetworkType;");
  588. if(env->ExceptionCheck() || typeField == NULL)
  589. {
  590. LOGE("Error getting type field");
  591. return NULL;
  592. }
  593. mtuField = lookup.findField(vnetConfigClass, "mtu", "I");
  594. if(env->ExceptionCheck() || mtuField == NULL)
  595. {
  596. LOGE("Error getting mtu field");
  597. return NULL;
  598. }
  599. dhcpField = lookup.findField(vnetConfigClass, "dhcp", "Z");
  600. if(env->ExceptionCheck() || dhcpField == NULL)
  601. {
  602. LOGE("Error getting dhcp field");
  603. return NULL;
  604. }
  605. bridgeField = lookup.findField(vnetConfigClass, "bridge", "Z");
  606. if(env->ExceptionCheck() || bridgeField == NULL)
  607. {
  608. LOGE("Error getting bridge field");
  609. return NULL;
  610. }
  611. broadcastEnabledField = lookup.findField(vnetConfigClass, "broadcastEnabled", "Z");
  612. if(env->ExceptionCheck() || broadcastEnabledField == NULL)
  613. {
  614. LOGE("Error getting broadcastEnabled field");
  615. return NULL;
  616. }
  617. portErrorField = lookup.findField(vnetConfigClass, "portError", "I");
  618. if(env->ExceptionCheck() || portErrorField == NULL)
  619. {
  620. LOGE("Error getting portError field");
  621. return NULL;
  622. }
  623. netconfRevisionField = lookup.findField(vnetConfigClass, "netconfRevision", "J");
  624. if(env->ExceptionCheck() || netconfRevisionField == NULL)
  625. {
  626. LOGE("Error getting netconfRevision field");
  627. return NULL;
  628. }
  629. assignedAddressesField = lookup.findField(vnetConfigClass, "assignedAddresses",
  630. "[Ljava/net/InetSocketAddress;");
  631. if(env->ExceptionCheck() || assignedAddressesField == NULL)
  632. {
  633. LOGE("Error getting assignedAddresses field");
  634. return NULL;
  635. }
  636. routesField = lookup.findField(vnetConfigClass, "routes",
  637. "[Lcom/zerotier/sdk/VirtualNetworkRoute;");
  638. if(env->ExceptionCheck() || routesField == NULL)
  639. {
  640. LOGE("Error getting routes field");
  641. return NULL;
  642. }
  643. dnsField = lookup.findField(vnetConfigClass, "dns", "Lcom/zerotier/sdk/VirtualNetworkDNS;");
  644. if(env->ExceptionCheck() || dnsField == NULL)
  645. {
  646. LOGE("Error getting DNS field");
  647. return NULL;
  648. }
  649. env->SetLongField(vnetConfigObj, nwidField, vnetConfig.nwid);
  650. env->SetLongField(vnetConfigObj, macField, vnetConfig.mac);
  651. jstring nameStr = env->NewStringUTF(vnetConfig.name);
  652. if(env->ExceptionCheck() || nameStr == NULL)
  653. {
  654. return NULL; // out of memory
  655. }
  656. env->SetObjectField(vnetConfigObj, nameField, nameStr);
  657. jobject statusObject = createVirtualNetworkStatus(env, vnetConfig.status);
  658. if(env->ExceptionCheck() || statusObject == NULL)
  659. {
  660. return NULL;
  661. }
  662. env->SetObjectField(vnetConfigObj, statusField, statusObject);
  663. jobject typeObject = createVirtualNetworkType(env, vnetConfig.type);
  664. if(env->ExceptionCheck() || typeObject == NULL)
  665. {
  666. return NULL;
  667. }
  668. env->SetObjectField(vnetConfigObj, typeField, typeObject);
  669. env->SetIntField(vnetConfigObj, mtuField, (int)vnetConfig.mtu);
  670. env->SetBooleanField(vnetConfigObj, dhcpField, vnetConfig.dhcp);
  671. env->SetBooleanField(vnetConfigObj, bridgeField, vnetConfig.bridge);
  672. env->SetBooleanField(vnetConfigObj, broadcastEnabledField, vnetConfig.broadcastEnabled);
  673. env->SetIntField(vnetConfigObj, portErrorField, vnetConfig.portError);
  674. jclass inetSocketAddressClass = lookup.findClass("java/net/InetSocketAddress");
  675. if(env->ExceptionCheck() || inetSocketAddressClass == NULL)
  676. {
  677. LOGE("Error finding InetSocketAddress class");
  678. return NULL;
  679. }
  680. jobjectArray assignedAddrArrayObj = env->NewObjectArray(
  681. vnetConfig.assignedAddressCount, inetSocketAddressClass, NULL);
  682. if(env->ExceptionCheck() || assignedAddrArrayObj == NULL)
  683. {
  684. LOGE("Error creating InetSocketAddress[] array");
  685. return NULL;
  686. }
  687. for(unsigned int i = 0; i < vnetConfig.assignedAddressCount; ++i)
  688. {
  689. jobject inetAddrObj = newInetSocketAddress(env, vnetConfig.assignedAddresses[i]);
  690. env->SetObjectArrayElement(assignedAddrArrayObj, i, inetAddrObj);
  691. if(env->ExceptionCheck())
  692. {
  693. LOGE("Error assigning InetSocketAddress to array");
  694. return NULL;
  695. }
  696. }
  697. env->SetObjectField(vnetConfigObj, assignedAddressesField, assignedAddrArrayObj);
  698. jclass virtualNetworkRouteClass = lookup.findClass("com/zerotier/sdk/VirtualNetworkRoute");
  699. if(env->ExceptionCheck() || virtualNetworkRouteClass == NULL)
  700. {
  701. LOGE("Error finding VirtualNetworkRoute class");
  702. return NULL;
  703. }
  704. jobjectArray routesArrayObj = env->NewObjectArray(
  705. vnetConfig.routeCount, virtualNetworkRouteClass, NULL);
  706. if(env->ExceptionCheck() || routesArrayObj == NULL)
  707. {
  708. LOGE("Error creating VirtualNetworkRoute[] array");
  709. return NULL;
  710. }
  711. for(unsigned int i = 0; i < vnetConfig.routeCount; ++i)
  712. {
  713. jobject routeObj = newVirtualNetworkRoute(env, vnetConfig.routes[i]);
  714. env->SetObjectArrayElement(routesArrayObj, i, routeObj);
  715. if(env->ExceptionCheck())
  716. {
  717. LOGE("Error assigning VirtualNetworkRoute to array");
  718. return NULL;
  719. }
  720. }
  721. env->SetObjectField(vnetConfigObj, routesField, routesArrayObj);
  722. jobject dnsObj = newVirtualNetworkDNS(env, vnetConfig.dns);
  723. if (dnsObj != NULL) {
  724. env->SetObjectField(vnetConfigObj, dnsField, dnsObj);
  725. }
  726. return vnetConfigObj;
  727. }
  728. jobject newVersion(JNIEnv *env, int major, int minor, int rev)
  729. {
  730. // create a com.zerotier.sdk.Version object
  731. jclass versionClass = NULL;
  732. jmethodID versionConstructor = NULL;
  733. versionClass = lookup.findClass("com/zerotier/sdk/Version");
  734. if(env->ExceptionCheck() || versionClass == NULL)
  735. {
  736. return NULL;
  737. }
  738. versionConstructor = lookup.findMethod(
  739. versionClass, "<init>", "()V");
  740. if(env->ExceptionCheck() || versionConstructor == NULL)
  741. {
  742. return NULL;
  743. }
  744. jobject versionObj = env->NewObject(versionClass, versionConstructor);
  745. if(env->ExceptionCheck() || versionObj == NULL)
  746. {
  747. return NULL;
  748. }
  749. // copy data to Version object
  750. jfieldID majorField = NULL;
  751. jfieldID minorField = NULL;
  752. jfieldID revisionField = NULL;
  753. majorField = lookup.findField(versionClass, "major", "I");
  754. if(env->ExceptionCheck() || majorField == NULL)
  755. {
  756. return NULL;
  757. }
  758. minorField = lookup.findField(versionClass, "minor", "I");
  759. if(env->ExceptionCheck() || minorField == NULL)
  760. {
  761. return NULL;
  762. }
  763. revisionField = lookup.findField(versionClass, "revision", "I");
  764. if(env->ExceptionCheck() || revisionField == NULL)
  765. {
  766. return NULL;
  767. }
  768. env->SetIntField(versionObj, majorField, (jint)major);
  769. env->SetIntField(versionObj, minorField, (jint)minor);
  770. env->SetIntField(versionObj, revisionField, (jint)rev);
  771. return versionObj;
  772. }
  773. jobject newVirtualNetworkRoute(JNIEnv *env, const ZT_VirtualNetworkRoute &route)
  774. {
  775. jclass virtualNetworkRouteClass = NULL;
  776. jmethodID routeConstructor = NULL;
  777. virtualNetworkRouteClass = lookup.findClass("com/zerotier/sdk/VirtualNetworkRoute");
  778. if(env->ExceptionCheck() || virtualNetworkRouteClass == NULL)
  779. {
  780. return NULL;
  781. }
  782. routeConstructor = lookup.findMethod(virtualNetworkRouteClass, "<init>", "()V");
  783. if(env->ExceptionCheck() || routeConstructor == NULL)
  784. {
  785. return NULL;
  786. }
  787. jobject routeObj = env->NewObject(virtualNetworkRouteClass, routeConstructor);
  788. if(env->ExceptionCheck() || routeObj == NULL)
  789. {
  790. return NULL;
  791. }
  792. jfieldID targetField = NULL;
  793. jfieldID viaField = NULL;
  794. jfieldID flagsField = NULL;
  795. jfieldID metricField = NULL;
  796. targetField = lookup.findField(virtualNetworkRouteClass, "target",
  797. "Ljava/net/InetSocketAddress;");
  798. if(env->ExceptionCheck() || targetField == NULL)
  799. {
  800. return NULL;
  801. }
  802. viaField = lookup.findField(virtualNetworkRouteClass, "via",
  803. "Ljava/net/InetSocketAddress;");
  804. if(env->ExceptionCheck() || targetField == NULL)
  805. {
  806. return NULL;
  807. }
  808. flagsField = lookup.findField(virtualNetworkRouteClass, "flags", "I");
  809. if(env->ExceptionCheck() || flagsField == NULL)
  810. {
  811. return NULL;
  812. }
  813. metricField = lookup.findField(virtualNetworkRouteClass, "metric", "I");
  814. if(env->ExceptionCheck() || metricField == NULL)
  815. {
  816. return NULL;
  817. }
  818. jobject targetObj = newInetSocketAddress(env, route.target);
  819. jobject viaObj = newInetSocketAddress(env, route.via);
  820. env->SetObjectField(routeObj, targetField, targetObj);
  821. env->SetObjectField(routeObj, viaField, viaObj);
  822. env->SetIntField(routeObj, flagsField, (jint)route.flags);
  823. env->SetIntField(routeObj, metricField, (jint)route.metric);
  824. return routeObj;
  825. }
  826. jobject newVirtualNetworkDNS(JNIEnv *env, const ZT_VirtualNetworkDNS &dns)
  827. {
  828. jclass virtualNetworkDNSClass = NULL;
  829. jmethodID dnsConstructor = NULL;
  830. virtualNetworkDNSClass = lookup.findClass("com/zerotier/sdk/VirtualNetworkDNS");
  831. if (env->ExceptionCheck() || virtualNetworkDNSClass == NULL) {
  832. return NULL;
  833. }
  834. dnsConstructor = lookup.findMethod(virtualNetworkDNSClass, "<init>", "()V");
  835. if(env->ExceptionCheck() || dnsConstructor == NULL) {
  836. return NULL;
  837. }
  838. jobject dnsObj = env->NewObject(virtualNetworkDNSClass, dnsConstructor);
  839. if(env->ExceptionCheck() || dnsObj == NULL) {
  840. return NULL;
  841. }
  842. jfieldID domainField = NULL;
  843. jfieldID serversField = NULL;
  844. domainField = lookup.findField(virtualNetworkDNSClass, "domain", "Ljava/lang/String;");
  845. if(env->ExceptionCheck() || domainField == NULL)
  846. {
  847. return NULL;
  848. }
  849. serversField = lookup.findField(virtualNetworkDNSClass, "servers", "Ljava/util/ArrayList;");
  850. if(env->ExceptionCheck() || serversField == NULL) {
  851. return NULL;
  852. }
  853. if (strlen(dns.domain) > 0) {
  854. InitListJNI(env);
  855. jstring domain = env->NewStringUTF(dns.domain);
  856. jobject addrArray = env->NewObject(java_util_ArrayList, java_util_ArrayList_, 0);
  857. struct sockaddr_storage nullAddr;
  858. memset(&nullAddr, 0, sizeof(struct sockaddr_storage));
  859. for(int i = 0; i < ZT_MAX_DNS_SERVERS; ++i) {
  860. struct sockaddr_storage tmp = dns.server_addr[i];
  861. if (memcmp(&tmp, &nullAddr, sizeof(struct sockaddr_storage)) != 0) {
  862. jobject addr = newInetSocketAddress(env, tmp);
  863. env->CallBooleanMethod(addrArray, java_util_ArrayList_add, addr);
  864. env->DeleteLocalRef(addr);
  865. }
  866. }
  867. env->SetObjectField(dnsObj, domainField, domain);
  868. env->SetObjectField(dnsObj, serversField, addrArray);
  869. return dnsObj;
  870. }
  871. return NULL;
  872. }
  873. #ifdef __cplusplus
  874. }
  875. #endif