123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185 |
- /*
- * ZeroTier One - Network Virtualization Everywhere
- * Copyright (C) 2011-2015 ZeroTier, Inc.
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- *
- * --
- *
- * ZeroTier may be used and distributed under the terms of the GPLv3, which
- * are available at: http://www.gnu.org/licenses/gpl-3.0.html
- *
- * If you would like to embed ZeroTier into a commercial application or
- * redistribute it in a modified binary form, please contact ZeroTier Networks
- * LLC. Start here: http://www.zerotier.com/
- */
- #include "com_zerotierone_sdk_Node.h"
- #include "ZT1_jniutils.h"
- #include <ZeroTierOne.h>
- #include <map>
- #include <string>
- #include <assert.h>
- #include <string.h>
- #ifdef __cplusplus
- extern "C" {
- #endif
- namespace {
- struct JniRef
- {
- JniRef()
- : jvm(NULL)
- , node(NULL)
- , dataStoreGetListener(NULL)
- , dataStorePutListener(NULL)
- , packetSender(NULL)
- , eventListener(NULL)
- , frameListener(NULL)
- , configListener(NULL)
- {}
- ~JniRef()
- {
- JNIEnv *env = NULL;
- jvm->GetEnv((void**)&env, JNI_VERSION_1_6);
- env->DeleteGlobalRef(dataStoreGetListener);
- env->DeleteGlobalRef(dataStorePutListener);
- env->DeleteGlobalRef(packetSender);
- env->DeleteGlobalRef(eventListener);
- env->DeleteGlobalRef(frameListener);
- env->DeleteGlobalRef(configListener);
- }
- uint64_t id;
- JavaVM *jvm;
- ZT1_Node *node;
- jobject dataStoreGetListener;
- jobject dataStorePutListener;
- jobject packetSender;
- jobject eventListener;
- jobject frameListener;
- jobject configListener;
- };
- int VirtualNetworkConfigFunctionCallback(
- ZT1_Node *node,
- void *userData,
- uint64_t nwid,
- enum ZT1_VirtualNetworkConfigOperation operation,
- const ZT1_VirtualNetworkConfig *config)
- {
- JniRef *ref = (JniRef*)userData;
- JNIEnv *env = NULL;
- ref->jvm->GetEnv((void**)&env, JNI_VERSION_1_6);
- jclass configListenerClass = env->GetObjectClass(ref->configListener);
- if(configListenerClass == NULL)
- {
- LOGE("Couldn't find class for VirtualNetworkConfigListener instance");
- return -1;
- }
- jmethodID configListenerCallbackMethod = env->GetMethodID(configListenerClass,
- "onNetworkConfigurationUpdated",
- "(JLcom/zerotierone/sdk/VirtualNetworkConfigOperation;Lcom/zerotierone/sdk/VirtualNetworkConfig;)I");
- if(configListenerCallbackMethod == NULL)
- {
- LOGE("Couldn't find onVirtualNetworkFrame() method");
- return -2;
- }
- jobject operationObject = createVirtualNetworkConfigOperation(env, operation);
- if(operationObject == NULL)
- {
- LOGE("Error creating VirtualNetworkConfigOperation object");
- return -3;
- }
- jobject networkConfigObject = newNetworkConfig(env, *config);
- if(networkConfigObject == NULL)
- {
- LOGE("Error creating VirtualNetworkConfig object");
- return -4;
- }
- return env->CallIntMethod(
- ref->configListener,
- configListenerCallbackMethod,
- (jlong)nwid, operationObject, networkConfigObject);
- }
- void VirtualNetworkFrameFunctionCallback(ZT1_Node *node,void *userData,
- uint64_t nwid,
- uint64_t sourceMac,
- uint64_t destMac,
- unsigned int etherType,
- unsigned int vlanid,
- const void *frameData,
- unsigned int frameLength)
- {
- JniRef *ref = (JniRef*)userData;
- assert(ref->node == node);
- JNIEnv *env = NULL;
- ref->jvm->GetEnv((void**)&env, JNI_VERSION_1_6);
- jclass frameListenerClass = env->GetObjectClass(ref->frameListener);
- if(frameListenerClass == NULL)
- {
- LOGE("Couldn't find class for VirtualNetworkFrameListener instance");
- return;
- }
- jmethodID frameListenerCallbackMethod = env->GetMethodID(
- frameListenerClass,
- "onVirtualNetworkFrame", "(JJJJJ[B)V");
- if(frameListenerCallbackMethod == NULL)
- {
- LOGE("Couldn't find onVirtualNetworkFrame() method");
- return;
- }
- jbyteArray dataArray = env->NewByteArray(frameLength);
- env->SetByteArrayRegion(dataArray, 0, frameLength, (jbyte*)frameData);
- env->CallVoidMethod(ref->frameListener, frameListenerCallbackMethod, nwid, sourceMac, destMac, etherType, vlanid, dataArray);
- }
- void EventCallback(ZT1_Node *node,void *userData,enum ZT1_Event event, const void *data)
- {
- JniRef *ref = (JniRef*)userData;
- assert(ref->node == node);
- JNIEnv *env = NULL;
- ref->jvm->GetEnv((void**)&env, JNI_VERSION_1_6);
- jclass eventListenerClass = env->GetObjectClass(ref->eventListener);
- if(eventListenerClass == NULL)
- {
- LOGE("Couldn't class for EventListener instance");
- return;
- }
- jmethodID onEventMethod = env->GetMethodID(eventListenerClass,
- "onEvent", "(Lcom/zerotierone/sdk/Event;)V");
- if(onEventMethod == NULL)
- {
- LOGE("Couldn't find onEvent method");
- return;
- }
- jmethodID onOutOfDateMethod = env->GetMethodID(eventListenerClass,
- "onOutOfDate", "(Lcom/zerotierone/sdk/Version;)V");
- if(onOutOfDateMethod == NULL)
- {
- LOGE("Couldn't find onOutOfDate method");
- return;
- }
- jmethodID onNetworkErrorMethod = env->GetMethodID(eventListenerClass,
- "onNetworkError", "(Lcom/zerotierone/sdk/Event;Ljava/net/InetSocketAddress;)V");
- if(onNetworkErrorMethod == NULL)
- {
- LOGE("Couldn't find onNetworkError method");
- return;
- }
- jmethodID onTraceMethod = env->GetMethodID(eventListenerClass,
- "onTrace", "(Ljava/lang/String;)V");
- if(onTraceMethod == NULL)
- {
- LOGE("Couldn't find onTrace method");
- return;
- }
- jobject eventObject = createEvent(env, event);
- if(eventObject == NULL)
- {
- return;
- }
- switch(event)
- {
- case ZT1_EVENT_UP:
- case ZT1_EVENT_OFFLINE:
- case ZT1_EVENT_ONLINE:
- case ZT1_EVENT_DOWN:
- case ZT1_EVENT_FATAL_ERROR_IDENTITY_COLLISION:
- {
- // call onEvent()
- env->CallVoidMethod(ref->eventListener, onEventMethod, eventObject);
- }
- break;
- case ZT1_EVENT_SAW_MORE_RECENT_VERSION:
- {
- // call onOutOfDate()
- if(data != NULL)
- {
- int *version = (int*)data;
- jobject verisonObj = newVersion(env, version[0], version[1], version[2], 0);
- env->CallVoidMethod(ref->eventListener, onOutOfDateMethod, verisonObj);
- }
- }
- break;
- case ZT1_EVENT_AUTHENTICATION_FAILURE:
- case ZT1_EVENT_INVALID_PACKET:
- {
- // call onNetworkError()
- if(data != NULL)
- {
- sockaddr_storage *addr = (sockaddr_storage*)data;
- jobject addressObj = newInetSocketAddress(env, *addr);
- env->CallVoidMethod(ref->eventListener, onNetworkErrorMethod, addressObj);
- }
- }
- case ZT1_EVENT_TRACE:
- {
- // call onTrace()
- if(data != NULL)
- {
- const char* message = (const char*)data;
- jstring messageStr = env->NewStringUTF(message);
- env->CallVoidMethod(ref->eventListener, onTraceMethod, messageStr);
- }
- }
- break;
- }
- }
- long DataStoreGetFunction(ZT1_Node *node,void *userData,
- const char *objectName,
- void *buffer,
- unsigned long bufferSize,
- unsigned long bufferIndex,
- unsigned long *out_objectSize)
- {
- JniRef *ref = (JniRef*)userData;
- JNIEnv *env = NULL;
- ref->jvm->GetEnv((void**)&env, JNI_VERSION_1_6);
- jclass dataStoreGetClass = env->GetObjectClass(ref->dataStoreGetListener);
- if(dataStoreGetClass == NULL)
- {
- LOGE("Couldn't find class for DataStoreGetListener instance");
- return -2;
- }
- jmethodID dataStoreGetCallbackMethod = env->GetMethodID(
- dataStoreGetClass,
- "onDataStoreGet",
- "(Ljava/lang/String;[BJ[J)J");
- if(dataStoreGetCallbackMethod == NULL)
- {
- LOGE("Couldn't find onDataStoreGet method");
- return -2;
- }
- jstring nameStr = env->NewStringUTF(objectName);
- if(nameStr == NULL)
- {
- LOGE("Error creating name string object");
- return -2; // out of memory
- }
- jbyteArray bufferObj = env->NewByteArray(bufferSize);
- if(bufferObj == NULL)
- {
- LOGE("Error creating byte[] buffer of size: %lu", bufferSize);
- return -2;
- }
- jlongArray objectSizeObj = env->NewLongArray(1);
- if(objectSizeObj == NULL)
- {
- LOGE("Error creating long[1] array for actual object size");
- return -2; // couldn't create long[1] array
- }
- LOGD("Calling onDataStoreGet(%s, %p, %lu, %p)",
- objectName, buffer, bufferIndex, objectSizeObj);
- long retval = env->CallLongMethod(
- ref->dataStoreGetListener, dataStoreGetCallbackMethod,
- nameStr, bufferObj, (jlong)bufferIndex, objectSizeObj);
- if(retval > 0)
- {
- env->GetByteArrayRegion(bufferObj, 0, bufferSize, (jbyte*)buffer);
- env->GetLongArrayRegion(objectSizeObj, 0, 1, (jlong*)out_objectSize);
- env->ReleaseByteArrayElements(bufferObj, (jbyte*)buffer, 0);
- env->ReleaseLongArrayElements(objectSizeObj, (jlong*)out_objectSize, 0);
- }
- LOGI("Out Object Size: %lu", *out_objectSize);
- return retval;
- }
- int DataStorePutFunction(ZT1_Node *node,void *userData,
- const char *objectName,
- const void *buffer,
- unsigned long bufferSize,
- int secure)
- {
- JniRef *ref = (JniRef*)userData;
- JNIEnv *env = NULL;
- ref->jvm->GetEnv((void**)&env, JNI_VERSION_1_6);
- jclass dataStorePutClass = env->GetObjectClass(ref->dataStorePutListener);
- if(dataStorePutClass == NULL)
- {
- LOGE("Couldn't find class for DataStorePutListener instance");
- return -1;
- }
- jmethodID dataStorePutCallbackMethod = env->GetMethodID(
- dataStorePutClass,
- "onDataStorePut",
- "(Ljava/lang/String;[BZ)I");
- if(dataStorePutCallbackMethod == NULL)
- {
- LOGE("Couldn't find onDataStorePut method");
- return -2;
- }
- jmethodID deleteMethod = env->GetMethodID(dataStorePutClass,
- "onDelete", "(Ljava/lang/String;)I");
- if(deleteMethod == NULL)
- {
- LOGE("Couldn't find onDelete method");
- return -3;
- }
- jstring nameStr = env->NewStringUTF(objectName);
- if(buffer == NULL)
- {
- // delete operation
- return env->CallIntMethod(
- ref->dataStorePutListener, deleteMethod, nameStr);
- }
- else
- {
- // set operation
- jbyteArray bufferObj = env->NewByteArray(bufferSize);
- env->SetByteArrayRegion(bufferObj, 0, bufferSize, (jbyte*)buffer);
- bool bsecure = secure != 0;
- return env->CallIntMethod(ref->dataStorePutListener,
- dataStorePutCallbackMethod,
- nameStr, bufferObj, bsecure);
- }
- }
- int WirePacketSendFunction(ZT1_Node *node,void *userData,\
- const struct sockaddr_storage *address,
- unsigned int linkDesparation,
- const void *buffer,
- unsigned int bufferSize)
- {
- JniRef *ref = (JniRef*)userData;
- assert(ref->node == node);
- JNIEnv *env = NULL;
- ref->jvm->GetEnv((void**)&env, JNI_VERSION_1_6);
- jclass packetSenderClass = env->GetObjectClass(ref->packetSender);
- if(packetSenderClass == NULL)
- {
- LOGE("Couldn't find class for PacketSender instance");
- return -1;
- }
- jmethodID packetSenderCallbackMethod = env->GetMethodID(packetSenderClass,
- "onSendPacketRequested", "(Ljava/net/InetSocketAddress;I[B)I");
- if(packetSenderCallbackMethod == NULL)
- {
- LOGE("Couldn't find onSendPacketRequested method");
- return -2;
- }
-
- jobject addressObj = newInetSocketAddress(env, *address);
- jbyteArray bufferObj = env->NewByteArray(bufferSize);
- env->SetByteArrayRegion(bufferObj, 0, bufferSize, (jbyte*)buffer);
- return env->CallIntMethod(ref->packetSender, packetSenderCallbackMethod, addressObj, linkDesparation, bufferObj);
- }
- typedef std::map<uint64_t, JniRef*> NodeMap;
- static NodeMap nodeMap;
- ZT1_Node* findNode(uint64_t nodeId)
- {
- NodeMap::iterator found = nodeMap.find(nodeId);
- if(found != nodeMap.end())
- {
- JniRef *ref = found->second;
- return ref->node;
- }
- return NULL;
- }
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: node_init
- * Signature: (J)Lcom/zerotierone/sdk/ResultCode;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_node_1init(
- JNIEnv *env, jobject obj, jlong now)
- {
- LOGD("Creating ZT1_Node struct");
- jobject resultObject = createResultObject(env, ZT1_RESULT_OK);
- ZT1_Node *node;
- JniRef *ref = new JniRef;
- ref->id = (uint64_t)now;
- env->GetJavaVM(&ref->jvm);
- jclass cls = env->GetObjectClass(obj);
- jfieldID fid = env->GetFieldID(
- cls, "getListener", "Lcom/zerotierone/sdk/DataStoreGetListener;");
- if(fid == NULL)
- {
- return NULL; // exception already thrown
- }
- jobject tmp = env->GetObjectField(obj, fid);
- if(tmp == NULL)
- {
- return NULL;
- }
- ref->dataStoreGetListener = env->NewGlobalRef(tmp);
- fid = env->GetFieldID(
- cls, "putListener", "Lcom/zerotierone/sdk/DataStorePutListener;");
- if(fid == NULL)
- {
- return NULL; // exception already thrown
- }
- tmp = env->GetObjectField(obj, fid);
- if(tmp == NULL)
- {
- return NULL;
- }
- ref->dataStorePutListener = env->NewGlobalRef(tmp);
- fid = env->GetFieldID(
- cls, "sender", "Lcom/zerotierone/sdk/PacketSender;");
- if(fid == NULL)
- {
- return NULL; // exception already thrown
- }
- tmp = env->GetObjectField(obj, fid);
- if(tmp == NULL)
- {
- return NULL;
- }
- ref->packetSender = env->NewGlobalRef(tmp);
- fid = env->GetFieldID(
- cls, "frameListener", "Lcom/zerotierone/sdk/VirtualNetworkFrameListener;");
- if(fid == NULL)
- {
- return NULL; // exception already thrown
- }
- tmp = env->GetObjectField(obj, fid);
- if(tmp == NULL)
- {
- return NULL;
- }
- ref->frameListener = env->NewGlobalRef(tmp);
- fid = env->GetFieldID(
- cls, "configListener", "Lcom/zerotierone/sdk/VirtualNetworkConfigListener;");
- if(fid == NULL)
- {
- return NULL; // exception already thrown
- }
- tmp = env->GetObjectField(obj, fid);
- if(tmp == NULL)
- {
- return NULL;
- }
- ref->configListener = env->NewGlobalRef(tmp);
- fid = env->GetFieldID(
- cls, "eventListener", "Lcom/zerotierone/sdk/EventListener;");
- if(fid == NULL)
- {
- return NULL;
- }
- tmp = env->GetObjectField(obj, fid);
- if(tmp == NULL)
- {
- return NULL;
- }
- ref->eventListener = env->NewGlobalRef(tmp);
- ZT1_ResultCode rc = ZT1_Node_new(
- &node,
- ref,
- (uint64_t)now,
- &DataStoreGetFunction,
- &DataStorePutFunction,
- &WirePacketSendFunction,
- &VirtualNetworkFrameFunctionCallback,
- &VirtualNetworkConfigFunctionCallback,
- &EventCallback);
- if(rc != ZT1_RESULT_OK)
- {
- LOGE("Error creating Node: %d", rc);
- resultObject = createResultObject(env, rc);
- if(node)
- {
- ZT1_Node_delete(node);
- node = NULL;
- }
- delete ref;
- ref = NULL;
- return resultObject;
- }
- ref->node = node;
- nodeMap.insert(std::make_pair(ref->id, ref));
- return resultObject;
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: node_delete
- * Signature: (J)V
- */
- JNIEXPORT void JNICALL Java_com_zerotierone_sdk_Node_node_1delete(
- JNIEnv *env, jobject obj, jlong id)
- {
- LOGD("Destroying ZT1_Node struct");
- uint64_t nodeId = (uint64_t)id;
- NodeMap::iterator found = nodeMap.find(nodeId);
- if(found != nodeMap.end())
- {
- JniRef *ref = found->second;
- nodeMap.erase(found);
- ZT1_Node_delete(ref->node);
- delete ref;
- ref = NULL;
- }
- else
- {
- LOGE("Attempted to delete a node that doesn't exist!");
- }
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: processVirtualNetworkFrame
- * Signature: (JJJJJII[B[J)Lcom/zerotierone/sdk/ResultCode;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_processVirtualNetworkFrame(
- JNIEnv *env, jobject obj,
- jlong id,
- jlong in_now,
- jlong in_nwid,
- jlong in_sourceMac,
- jlong in_destMac,
- jint in_etherType,
- jint in_vlanId,
- jbyteArray in_frameData,
- jlongArray out_nextBackgroundTaskDeadline)
- {
- uint64_t nodeId = (uint64_t) id;
-
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- unsigned int nbtd_len = env->GetArrayLength(out_nextBackgroundTaskDeadline);
- if(nbtd_len < 1)
- {
- // array for next background task length has 0 elements!
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- uint64_t now = (uint64_t)in_now;
- uint64_t nwid = (uint64_t)in_nwid;
- uint64_t sourceMac = (uint64_t)in_sourceMac;
- uint64_t destMac = (uint64_t)in_destMac;
- unsigned int etherType = (unsigned int)in_etherType;
- unsigned int vlanId = (unsigned int)in_vlanId;
- unsigned int frameLength = env->GetArrayLength(in_frameData);
- jbyte *frameData =env->GetByteArrayElements(in_frameData, NULL);
- uint64_t nextBackgroundTaskDeadline = 0;
- ZT1_ResultCode rc = ZT1_Node_processVirtualNetworkFrame(
- node,
- now,
- nwid,
- sourceMac,
- destMac,
- etherType,
- vlanId,
- (const void*)frameData,
- frameLength,
- &nextBackgroundTaskDeadline);
- jlong *outDeadline = env->GetLongArrayElements(out_nextBackgroundTaskDeadline, NULL);
- outDeadline[0] = (jlong)nextBackgroundTaskDeadline;
- env->ReleaseLongArrayElements(out_nextBackgroundTaskDeadline, outDeadline, 0);
- env->ReleaseByteArrayElements(in_frameData, frameData, 0);
- return createResultObject(env, rc);
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: processWirePacket
- * Signature: (JJLjava/net/InetSocketAddress;I[B[J)Lcom/zerotierone/sdk/ResultCode;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_processWirePacket(
- JNIEnv *env, jobject obj,
- jlong id,
- jlong in_now,
- jobject in_remoteAddress,
- jint in_linkDesparation,
- jbyteArray in_packetData,
- jlongArray out_nextBackgroundTaskDeadline)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- unsigned int nbtd_len = env->GetArrayLength(out_nextBackgroundTaskDeadline);
- if(nbtd_len < 1)
- {
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- uint64_t now = (uint64_t)in_now;
- unsigned int linkDesparation = (unsigned int)in_linkDesparation;
- // get the java.net.InetSocketAddress class and getAddress() method
- jclass inetAddressClass = env->FindClass("java/net/InetAddress");
- if(inetAddressClass == NULL)
- {
- // can't find java.net.InetAddress
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- jmethodID getAddressMethod = env->GetMethodID(
- inetAddressClass, "getAddress", "()[B");
- if(getAddressMethod == NULL)
- {
- // cant find InetAddress.getAddres()
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- jclass InetSocketAddressClass = env->FindClass("java/net/InetSocketAddress");
- if(InetSocketAddressClass == NULL)
- {
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- jmethodID inetSockGetAddressMethod = env->GetMethodID(
- InetSocketAddressClass, "getAddress", "()Ljava/net/InetAddress;");
- jobject addrObject = env->CallObjectMethod(in_remoteAddress, inetSockGetAddressMethod);
- if(addrObject == NULL)
- {
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- // Call InetAddress.getAddress()
- jbyteArray addressArray = (jbyteArray)env->CallObjectMethod(addrObject, getAddressMethod);
- if(addressArray == NULL)
- {
- // unable to call getAddress()
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- unsigned int addrSize = env->GetArrayLength(addressArray);
- // get the address bytes
- jbyte *addr = env->GetByteArrayElements(addressArray, NULL);
- sockaddr_storage remoteAddress = {};
- if(addrSize == 16)
- {
- // IPV6 address
- sockaddr_in6 ipv6 = {};
- ipv6.sin6_family = AF_INET6;
- memcpy(ipv6.sin6_addr.s6_addr, addr, 16);
- memcpy(&remoteAddress, &ipv6, sizeof(sockaddr_in6));
- }
- else if(addrSize == 4)
- {
- // IPV4 address
- sockaddr_in ipv4 = {};
- ipv4.sin_family = AF_INET;
- memcpy(&ipv4.sin_addr, addr, 4);
- memcpy(&remoteAddress, &ipv4, sizeof(sockaddr_in));
- }
- else
- {
- // unknown address type
- env->ReleaseByteArrayElements(addressArray, addr, 0);
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- unsigned int packetLength = env->GetArrayLength(in_packetData);
- jbyte *packetData = env->GetByteArrayElements(in_packetData, NULL);
- uint64_t nextBackgroundTaskDeadline = 0;
- ZT1_ResultCode rc = ZT1_Node_processWirePacket(
- node,
- now,
- &remoteAddress,
- linkDesparation,
- packetData,
- packetLength,
- &nextBackgroundTaskDeadline);
- jlong *outDeadline = env->GetLongArrayElements(out_nextBackgroundTaskDeadline, NULL);
- outDeadline[0] = (jlong)nextBackgroundTaskDeadline;
- env->ReleaseLongArrayElements(out_nextBackgroundTaskDeadline, outDeadline, 0);
- env->ReleaseByteArrayElements(addressArray, addr, 0);
- env->ReleaseByteArrayElements(in_packetData, packetData, 0);
- return createResultObject(env, rc);
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: processBackgroundTasks
- * Signature: (JJ[J)Lcom/zerotierone/sdk/ResultCode;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_processBackgroundTasks(
- JNIEnv *env, jobject obj,
- jlong id,
- jlong in_now,
- jlongArray out_nextBackgroundTaskDeadline)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- unsigned int nbtd_len = env->GetArrayLength(out_nextBackgroundTaskDeadline);
- if(nbtd_len < 1)
- {
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- uint64_t now = (uint64_t)in_now;
- uint64_t nextBackgroundTaskDeadline = 0;
- ZT1_ResultCode rc = ZT1_Node_processBackgroundTasks(node, now, &nextBackgroundTaskDeadline);
- jlong *outDeadline = env->GetLongArrayElements(out_nextBackgroundTaskDeadline, NULL);
- outDeadline[0] = (jlong)nextBackgroundTaskDeadline;
- env->ReleaseLongArrayElements(out_nextBackgroundTaskDeadline, outDeadline, 0);
- return createResultObject(env, rc);
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: join
- * Signature: (JJ)Lcom/zerotierone/sdk/ResultCode;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_join(
- JNIEnv *env, jobject obj, jlong id, jlong in_nwid)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- uint64_t nwid = (uint64_t)in_nwid;
- ZT1_ResultCode rc = ZT1_Node_join(node, nwid);
- return createResultObject(env, rc);
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: leave
- * Signature: (JJ)Lcom/zerotierone/sdk/ResultCode;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_leave(
- JNIEnv *env, jobject obj, jlong id, jlong in_nwid)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- uint64_t nwid = (uint64_t)in_nwid;
- ZT1_ResultCode rc = ZT1_Node_leave(node, nwid);
- return createResultObject(env, rc);
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: multicastSubscribe
- * Signature: (JJJJ)Lcom/zerotierone/sdk/ResultCode;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_multicastSubscribe(
- JNIEnv *env, jobject obj,
- jlong id,
- jlong in_nwid,
- jlong in_multicastGroup,
- jlong in_multicastAdi)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- uint64_t nwid = (uint64_t)in_nwid;
- uint64_t multicastGroup = (uint64_t)in_multicastGroup;
- uint64_t multicastAdi = (uint64_t)in_multicastAdi;
- ZT1_ResultCode rc = ZT1_Node_multicastSubscribe(
- node, nwid, multicastGroup, multicastAdi);
- return createResultObject(env, rc);
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: multicastUnsubscribe
- * Signature: (JJJJ)Lcom/zerotierone/sdk/ResultCode;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_multicastUnsubscribe(
- JNIEnv *env, jobject obj,
- jlong id,
- jlong in_nwid,
- jlong in_multicastGroup,
- jlong in_multicastAdi)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return createResultObject(env, ZT1_RESULT_FATAL_ERROR_INTERNAL);
- }
- uint64_t nwid = (uint64_t)in_nwid;
- uint64_t multicastGroup = (uint64_t)in_multicastGroup;
- uint64_t multicastAdi = (uint64_t)in_multicastAdi;
- ZT1_ResultCode rc = ZT1_Node_multicastUnsubscribe(
- node, nwid, multicastGroup, multicastAdi);
- return createResultObject(env, rc);
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: address
- * Signature: (J)J
- */
- JNIEXPORT jlong JNICALL Java_com_zerotierone_sdk_Node_address(
- JNIEnv *env , jobject obj, jlong id)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return 0;
- }
- uint64_t address = ZT1_Node_address(node);
- return (jlong)address;
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: status
- * Signature: (J)Lcom/zerotierone/sdk/NodeStatus;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_status
- (JNIEnv *env, jobject obj, jlong id)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return 0;
- }
- jclass nodeStatusClass = NULL;
- jmethodID nodeStatusConstructor = NULL;
- // create a com.zerotierone.sdk.NodeStatus object
- nodeStatusClass = env->FindClass("com/zerotierone/sdk/NodeStatus");
- if(nodeStatusClass == NULL)
- {
- return NULL;
- }
-
- nodeStatusConstructor = env->GetMethodID(
- nodeStatusClass, "<init>", "()V");
- if(nodeStatusConstructor == NULL)
- {
- return NULL;
- }
- jobject nodeStatusObj = env->NewObject(nodeStatusClass, nodeStatusConstructor);
- if(nodeStatusObj == NULL)
- {
- return NULL;
- }
- ZT1_NodeStatus nodeStatus;
- ZT1_Node_status(node, &nodeStatus);
- jfieldID addressField = NULL;
- jfieldID publicIdentityField = NULL;
- jfieldID secretIdentityField = NULL;
- jfieldID onlineField = NULL;
- addressField = env->GetFieldID(nodeStatusClass, "address", "J");
- if(addressField == NULL)
- {
- return NULL;
- }
- publicIdentityField = env->GetFieldID(nodeStatusClass, "publicIdentity", "Ljava/lang/String;");
- if(publicIdentityField == NULL)
- {
- return NULL;
- }
- secretIdentityField = env->GetFieldID(nodeStatusClass, "secretIdentity", "Ljava/lang/String;");
- if(secretIdentityField == NULL)
- {
- return NULL;
- }
- onlineField = env->GetFieldID(nodeStatusClass, "online", "Z");
- if(onlineField == NULL)
- {
- return NULL;
- }
- env->SetLongField(nodeStatusObj, addressField, nodeStatus.address);
- jstring pubIdentStr = env->NewStringUTF(nodeStatus.publicIdentity);
- if(pubIdentStr == NULL)
- {
- return NULL; // out of memory
- }
- env->SetObjectField(nodeStatusObj, publicIdentityField, pubIdentStr);
- jstring secIdentStr = env->NewStringUTF(nodeStatus.secretIdentity);
- if(secIdentStr == NULL)
- {
- return NULL; // out of memory
- }
- env->SetObjectField(nodeStatusObj, secretIdentityField, secIdentStr);
- env->SetBooleanField(nodeStatusObj, onlineField, nodeStatus.online);
- return nodeStatusObj;
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: networkConfig
- * Signature: (J)Lcom/zerotierone/sdk/VirtualNetworkConfig;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_networkConfig(
- JNIEnv *env, jobject obj, jlong id, jlong nwid)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return 0;
- }
- ZT1_VirtualNetworkConfig *vnetConfig = ZT1_Node_networkConfig(node, nwid);
-
- jobject vnetConfigObject = newNetworkConfig(env, *vnetConfig);
- ZT1_Node_freeQueryResult(node, vnetConfig);
- return vnetConfigObject;
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: version
- * Signature: (J)Lcom/zerotierone/sdk/Version;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_version(
- JNIEnv *env, jobject obj)
- {
- int major = 0;
- int minor = 0;
- int revision = 0;
- unsigned long featureFlags = 0;
- ZT1_version(&major, &minor, &revision, &featureFlags);
- return newVersion(env, major, minor, revision, featureFlags);
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: peers
- * Signature: (J)Ljava/util/ArrayList;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_peers(
- JNIEnv *env, jobject obj, jlong id)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return 0;
- }
- ZT1_PeerList *peerList = ZT1_Node_peers(node);
- if(peerList == NULL)
- {
- return NULL;
- }
- jobject peerListObject = newArrayList(env);
- if(peerListObject == NULL)
- {
- ZT1_Node_freeQueryResult(node, peerList);
- return NULL;
- }
- for(unsigned int i = 0; i < peerList->peerCount; ++i)
- {
- jobject peerObj = newPeer(env, peerList->peers[i]);
- appendItemToArrayList(env, peerListObject, peerObj);
- }
- ZT1_Node_freeQueryResult(node, peerList);
- peerList = NULL;
- return peerListObject;
- }
- /*
- * Class: com_zerotierone_sdk_Node
- * Method: networks
- * Signature: (J)Ljava/util/ArrayList;
- */
- JNIEXPORT jobject JNICALL Java_com_zerotierone_sdk_Node_networks(
- JNIEnv *env, jobject obj, jlong id)
- {
- uint64_t nodeId = (uint64_t) id;
- ZT1_Node *node = findNode(nodeId);
- if(node == NULL)
- {
- // cannot find valid node. We should never get here.
- return 0;
- }
- ZT1_VirtualNetworkList *networkList = ZT1_Node_networks(node);
- if(networkList == NULL)
- {
- return NULL;
- }
- jobject networkListObject = newArrayList(env);
- if(networkListObject == NULL)
- {
- ZT1_Node_freeQueryResult(node, networkList);
- return NULL;
- }
- for(unsigned int i = 0; i < networkList->networkCount; ++i)
- {
- jobject networkObject = newNetworkConfig(env, networkList->networks[i]);
- appendItemToArrayList(env, networkListObject, networkObject);
- }
- ZT1_Node_freeQueryResult(node, networkList);
- return networkListObject;
- }
- #ifdef __cplusplus
- } // extern "C"
- #endif
|