ZT_jniutils.cpp 31 KB

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