1 /* ****************************************************************
3 * Copyright 2014 Samsung Electronics All Rights Reserved.
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
19 ******************************************************************/
25 #include "caedrinterface.h"
26 #include "caedrutils.h"
27 #include "caedrserver.h"
29 #include "oic_malloc.h"
30 #include "cathreadpool.h" /* for thread pool */
32 #include "uarraylist.h"
33 #include "caadapterutils.h"
34 #include "org_iotivity_ca_CaEdrInterface.h"
35 #include "oic_string.h"
37 #define TAG PCF("OIC_CA_EDR_SERVER")
39 static const char METHODID_OBJECTNONPARAM[] = "()Landroid/bluetooth/BluetoothAdapter;";
40 static const char CLASSPATH_BT_ADPATER[] = "android/bluetooth/BluetoothAdapter";
41 static const char CLASSPATH_BT_UUID[] = "java/util/UUID";
43 static ca_thread_pool_t g_threadPoolHandle = NULL;
48 * Maximum CoAP over TCP header length
49 * to know the total data length.
51 #define EDR_MAX_HEADER_LEN 6
54 * server socket instance.
56 static jobject g_serverSocketObject = NULL;
59 * Mutex to synchronize unicast server.
61 static ca_mutex g_mutexUnicastServer = NULL;
64 * Flag to control the Receive Unicast Data Thread.
66 static bool g_stopUnicast = false;
69 * Mutex to synchronize secure multicast server.
71 static ca_mutex g_mutexMulticastServer = NULL;
74 * Flag to control the Receive Multicast Data Thread.
76 static bool g_stopMulticast = false;
79 * Mutex to synchronize accept server.
81 static ca_mutex g_mutexAcceptServer = NULL;
84 * Flag to control the Accept Thread.
86 static bool g_stopAccept = false;
89 * Mutex to synchronize server socket.
91 static ca_mutex g_mutexServerSocket = NULL;
93 static jobject g_serverSocket = NULL;
96 * Mutex to synchronize device state list.
98 static ca_mutex g_mutexStateList = NULL;
101 * Mutex to synchronize device object list.
103 static ca_mutex g_mutexObjectList = NULL;
106 * Thread context information for unicast, multicast and secured unicast server.
111 CAAdapterServerType_t type;
112 } CAAdapterReceiveThreadContext_t;
117 } CAAdapterAcceptThreadContext_t;
120 * Maintains the callback to be notified when data received from remote
123 static CAEDRDataReceivedCallback g_edrPacketReceivedCallback = NULL;
125 static void CAReceiveHandler(void *data)
127 OIC_LOG(DEBUG, TAG, "IN - CAReceiveHandler..");
129 VERIFY_NON_NULL_VOID(data, TAG, "Invalid thread context");
131 bool isAttached = false;
133 jint res = (*g_jvm)->GetEnv(g_jvm, (void**) &env, JNI_VERSION_1_6);
136 OIC_LOG(DEBUG, TAG, "CAReceiveHandler - Could not get JNIEnv pointer");
137 res = (*g_jvm)->AttachCurrentThread(g_jvm, &env, NULL);
141 OIC_LOG(ERROR, TAG, "AttachCurrentThread failed");
147 CAAdapterReceiveThreadContext_t *ctx = (CAAdapterReceiveThreadContext_t *) data;
149 while (true != *(ctx->stopFlag))
151 if (!CAEDRNativeIsEnableBTAdapter(env))
153 OIC_LOG(INFO, TAG, "BT adapter is not enabled");
157 // if new socket object is added in socket list after below logic is ran.
158 // new socket will be started to read after next while loop
159 uint32_t length = CAEDRGetSocketListLength();
162 for (uint32_t idx = 0; idx < length; idx++)
164 CAEDRNativeReadData(env, idx);
171 (*g_jvm)->DetachCurrentThread(g_jvm);
176 OIC_LOG(DEBUG, TAG, "OUT - CAReceiveHandler");
179 static void CAAcceptHandler(void *data)
181 OIC_LOG(DEBUG, TAG, "AcceptThread start");
183 VERIFY_NON_NULL_VOID(data, TAG, "CAAcceptHandler: data is null");
185 bool isAttached = false;
187 jint res = (*g_jvm)->GetEnv(g_jvm, (void**) &env, JNI_VERSION_1_6);
190 OIC_LOG(DEBUG, TAG, "CAAcceptHandler - Could not get JNIEnv pointer");
191 res = (*g_jvm)->AttachCurrentThread(g_jvm, &env, NULL);
195 OIC_LOG(ERROR, TAG, "AttachCurrentThread failed");
201 jobject jni_obj_BTServerSocket = CAEDRNativeListen(env);
202 if (!jni_obj_BTServerSocket)
204 OIC_LOG(ERROR, TAG, "AcceptThread: jni_obj_BTServerSocket is null");
208 (*g_jvm)->DetachCurrentThread(g_jvm);
214 ca_mutex_lock(g_mutexServerSocket);
215 g_serverSocket = (*env)->NewGlobalRef(env, jni_obj_BTServerSocket);
216 ca_mutex_unlock(g_mutexServerSocket);
218 CAAdapterAcceptThreadContext_t *ctx = (CAAdapterAcceptThreadContext_t *) data;
220 // it should be initialized for restart accept thread
221 ca_mutex_lock(g_mutexAcceptServer);
222 g_stopAccept = false;
223 ca_mutex_unlock(g_mutexAcceptServer);
225 while (true != *(ctx->stopFlag))
227 OIC_LOG(DEBUG, TAG, "AcceptThread running");
229 // when BT state is changed with Off. its thread will be stopped
230 if (!CAEDRNativeIsEnableBTAdapter(env))
232 OIC_LOG(INFO, TAG, "BT adapter is not enabled");
233 ca_mutex_lock(g_mutexAcceptServer);
235 ca_mutex_unlock(g_mutexAcceptServer);
236 ca_mutex_lock(g_mutexServerSocket);
237 g_serverSocket = NULL;
238 ca_mutex_unlock(g_mutexServerSocket);
242 CAEDRNativeAccept(env, g_serverSocket);
248 (*g_jvm)->DetachCurrentThread(g_jvm);
253 OIC_LOG(DEBUG, TAG, "AcceptThread finish");
259 * implement for adapter common method.
261 CAResult_t CAEDRServerStart()
263 if (!g_threadPoolHandle)
265 return CA_STATUS_NOT_INITIALIZED;
268 CAEDRServerStartAcceptThread();
269 CAResult_t res = CAEDRStartUnicastServer(false);
270 if (CA_STATUS_OK != res)
272 OIC_LOG(ERROR, TAG, "CAEDRStartUnicastServer failed");
274 return CA_STATUS_FAILED;
280 CAResult_t CAEDRServerStop()
282 CAEDRStopUnicastServer();
283 CAEDRStopMulticastServer();
285 ca_mutex_lock(g_mutexAcceptServer);
287 ca_mutex_unlock(g_mutexAcceptServer);
291 OIC_LOG(DEBUG, TAG, "g_jvm is null");
292 return CA_STATUS_FAILED;
295 bool isAttached = false;
297 jint res = (*g_jvm)->GetEnv(g_jvm, (void**) &env, JNI_VERSION_1_6);
300 OIC_LOG(DEBUG, TAG, "Could not get JNIEnv pointer");
301 res = (*g_jvm)->AttachCurrentThread(g_jvm, &env, NULL);
305 OIC_LOG(ERROR, TAG, "AttachCurrentThread failed");
306 return CA_STATUS_FAILED;
311 CAEDRNatvieCloseServerTask(env);
315 (*g_jvm)->DetachCurrentThread(g_jvm);
321 void CAEDRSetPacketReceivedCallback(CAEDRDataReceivedCallback packetReceivedCallback)
323 g_edrPacketReceivedCallback = packetReceivedCallback;
326 static void CAEDRServerDestroyMutex()
328 if (g_mutexUnicastServer)
330 ca_mutex_free(g_mutexUnicastServer);
331 g_mutexUnicastServer = NULL;
334 if (g_mutexMulticastServer)
336 ca_mutex_free(g_mutexMulticastServer);
337 g_mutexMulticastServer = NULL;
340 if (g_mutexAcceptServer)
342 ca_mutex_free(g_mutexAcceptServer);
343 g_mutexAcceptServer = NULL;
346 if (g_mutexServerSocket)
348 ca_mutex_free(g_mutexServerSocket);
349 g_mutexServerSocket = NULL;
352 if (g_mutexStateList)
354 ca_mutex_free(g_mutexStateList);
355 g_mutexStateList = NULL;
358 if (g_mutexObjectList)
360 ca_mutex_free(g_mutexObjectList);
361 g_mutexObjectList = NULL;
365 static CAResult_t CAEDRServerCreateMutex()
367 g_mutexUnicastServer = ca_mutex_new();
368 if (!g_mutexUnicastServer)
370 OIC_LOG(ERROR, TAG, "Failed to created mutex!");
371 return CA_STATUS_FAILED;
374 g_mutexMulticastServer = ca_mutex_new();
375 if (!g_mutexMulticastServer)
377 OIC_LOG(ERROR, TAG, "Failed to created mutex!");
379 CAEDRServerDestroyMutex();
380 return CA_STATUS_FAILED;
383 g_mutexAcceptServer = ca_mutex_new();
384 if (!g_mutexAcceptServer)
386 OIC_LOG(ERROR, TAG, "Failed to created mutex!");
388 CAEDRServerDestroyMutex();
389 return CA_STATUS_FAILED;
392 g_mutexServerSocket = ca_mutex_new();
393 if (!g_mutexServerSocket)
395 OIC_LOG(ERROR, TAG, "Failed to created mutex!");
397 CAEDRServerDestroyMutex();
398 return CA_STATUS_FAILED;
401 g_mutexStateList = ca_mutex_new();
402 if (!g_mutexStateList)
404 OIC_LOG(ERROR, TAG, "Failed to created mutex!");
406 CAEDRServerDestroyMutex();
407 return CA_STATUS_FAILED;
410 g_mutexObjectList = ca_mutex_new();
411 if (!g_mutexObjectList)
413 OIC_LOG(ERROR, TAG, "Failed to created mutex!");
415 CAEDRServerDestroyMutex();
416 return CA_STATUS_FAILED;
422 void CAEDRServerJniInit()
424 OIC_LOG(DEBUG, TAG, "CAEDRServerJniInit");
425 g_jvm = CANativeJNIGetJavaVM();
428 CAResult_t CAEDRServerInitialize(ca_thread_pool_t handle)
430 OIC_LOG(DEBUG, TAG, "CAEDRServerInitialize");
431 VERIFY_NON_NULL(handle, TAG, "handle is NULL");
432 g_threadPoolHandle = handle;
433 CAEDRServerJniInit();
436 CAResult_t result = CAEDRServerCreateMutex();
440 CAResult_t CAEDRServerStartAcceptThread()
442 bool isAttached = false;
444 jint res = (*g_jvm)->GetEnv(g_jvm, (void**) &env, JNI_VERSION_1_6);
447 OIC_LOG(DEBUG, TAG, "Could not get JNIEnv pointer");
448 res = (*g_jvm)->AttachCurrentThread(g_jvm, &env, NULL);
452 OIC_LOG(ERROR, TAG, "AttachCurrentThread failed");
453 return CA_STATUS_FAILED;
458 jstring jni_address = CAEDRNativeGetLocalDeviceAddress(env);
461 const char* localAddress = (*env)->GetStringUTFChars(env, jni_address, NULL);
462 OIC_LOG_V(DEBUG, TAG, "My BT Address is %s", localAddress);
463 (*env)->ReleaseStringUTFChars(env, jni_address, localAddress);
466 ca_mutex_lock(g_mutexStateList);
467 CAEDRNativeCreateDeviceStateList();
468 ca_mutex_unlock(g_mutexStateList);
470 ca_mutex_lock(g_mutexObjectList);
471 CAEDRNativeCreateDeviceSocketList();
472 ca_mutex_unlock(g_mutexObjectList);
476 (*g_jvm)->DetachCurrentThread(g_jvm);
479 CAAdapterReceiveThreadContext_t *ctx = (CAAdapterReceiveThreadContext_t *) OICMalloc(
480 sizeof(CAAdapterReceiveThreadContext_t));
483 OIC_LOG(ERROR, TAG, "Out of memory!");
484 return CA_MEMORY_ALLOC_FAILED;
487 ctx->stopFlag = &g_stopAccept;
488 if (CA_STATUS_OK != ca_thread_pool_add_task(g_threadPoolHandle, CAAcceptHandler, (void *) ctx))
490 OIC_LOG(ERROR, TAG, "Failed to create read thread!");
491 OICFree((void *) ctx);
492 return CA_STATUS_FAILED;
498 void CAEDRServerTerminate()
500 OIC_LOG(DEBUG, TAG, "CAEDRServerTerminate");
506 bool isAttached = false;
508 jint res = (*g_jvm)->GetEnv(g_jvm, (void**) &env, JNI_VERSION_1_6);
511 OIC_LOG(DEBUG, TAG, "Could not get JNIEnv pointer");
512 res = (*g_jvm)->AttachCurrentThread(g_jvm, &env, NULL);
516 OIC_LOG(ERROR, TAG, "AttachCurrentThread failed");
522 CAEDRNativeSocketCloseToAll(env);
526 (*g_jvm)->DetachCurrentThread(g_jvm);
529 CAEDRNativeRemoveAllDeviceState();
530 CAEDRNativeRemoveAllDeviceSocket(env);
533 CAEDRServerDestroyMutex();
536 CAResult_t CAEDRStartUnicastServer(bool isSecured)
538 OIC_LOG(DEBUG, TAG, "CAEDRStartUnicastServer");
540 ca_mutex_lock(g_mutexUnicastServer);
543 * The task to listen for data from unicast is added to the thread pool.
544 * This is a blocking call is made where we try to receive some data..
545 * We will keep waiting until some data is received.
546 * This task will be terminated when thread pool is freed on stopping the adapters.
547 * Thread context will be freed by thread on exit.
549 CAAdapterReceiveThreadContext_t *ctx = (CAAdapterReceiveThreadContext_t *) OICMalloc(
550 sizeof(CAAdapterReceiveThreadContext_t));
553 OIC_LOG(ERROR, TAG, "Out of memory!");
554 ca_mutex_unlock(g_mutexUnicastServer);
555 return CA_MEMORY_ALLOC_FAILED;
558 ctx->stopFlag = &g_stopUnicast;
559 ctx->type = isSecured ? CA_SECURED_UNICAST_SERVER : CA_UNICAST_SERVER;
560 if (CA_STATUS_OK != ca_thread_pool_add_task(g_threadPoolHandle, CAReceiveHandler, (void *) ctx))
562 OIC_LOG(ERROR, TAG, "Failed to create read thread!");
563 ca_mutex_unlock(g_mutexUnicastServer);
564 OICFree((void *) ctx);
565 return CA_STATUS_FAILED;
567 ca_mutex_unlock(g_mutexUnicastServer);
569 OIC_LOG(DEBUG, TAG, "OUT");
573 CAResult_t CAEDRStartMulticastServer()
575 OIC_LOG(DEBUG, TAG, "CAEDRStartMulticastServer");
577 ca_mutex_lock(g_mutexMulticastServer);
580 * The task to listen to data from multicast socket is added to the thread pool.
581 * This is a blocking call is made where we try to receive some data.
582 * We will keep waiting until some data is received.
583 * This task will be terminated when thread pool is freed on stopping the adapters.
584 * Thread context will be freed by thread on exit.
586 CAAdapterReceiveThreadContext_t *ctx = (CAAdapterReceiveThreadContext_t *) OICMalloc(
587 sizeof(CAAdapterReceiveThreadContext_t));
590 OIC_LOG(ERROR, TAG, "Out of memory!");
591 ca_mutex_unlock(g_mutexMulticastServer);
593 return CA_MEMORY_ALLOC_FAILED;
596 ctx->stopFlag = &g_stopMulticast;
597 ctx->type = CA_MULTICAST_SERVER;
599 g_stopMulticast = false;
600 if (CA_STATUS_OK != ca_thread_pool_add_task(g_threadPoolHandle, CAReceiveHandler, (void *) ctx))
602 OIC_LOG(ERROR, TAG, "thread_pool_add_task failed!");
604 g_stopMulticast = true;
605 ca_mutex_unlock(g_mutexMulticastServer);
606 OICFree((void *) ctx);
608 return CA_STATUS_FAILED;
610 ca_mutex_unlock(g_mutexMulticastServer);
612 OIC_LOG(DEBUG, TAG, "OUT");
616 CAResult_t CAEDRStopUnicastServer()
618 OIC_LOG(DEBUG, TAG, "CAEDRStopUnicastServer");
620 ca_mutex_lock(g_mutexUnicastServer);
621 g_stopUnicast = true;
622 ca_mutex_unlock(g_mutexUnicastServer);
627 CAResult_t CAEDRStopMulticastServer()
629 OIC_LOG(DEBUG, TAG, "CAEDRStopMulticastServer");
631 ca_mutex_lock(g_mutexMulticastServer);
632 g_stopMulticast = true;
633 ca_mutex_unlock(g_mutexMulticastServer);
635 OIC_LOG(INFO, TAG, "Multicast server stopped");
640 CAResult_t CAEDRNativeReadData(JNIEnv *env, uint32_t id)
642 if ((*env)->ExceptionCheck(env))
644 (*env)->ExceptionDescribe(env);
645 (*env)->ExceptionClear(env);
646 OIC_LOG(ERROR, TAG, "env error!!");
647 return CA_STATUS_FAILED;
650 // check whether this socket object is connected or not.
651 jobject jni_obj_socket = CAEDRNativeGetDeviceSocket(id);
654 return CA_STATUS_INVALID_PARAM;
657 jstring jni_str_address = CAEDRNativeGetAddressFromDeviceSocket(env, jni_obj_socket);
658 if (!jni_str_address)
660 OIC_LOG(ERROR, TAG, "jni_str_address is null");
661 return CA_STATUS_FAILED;
663 const char* address = (*env)->GetStringUTFChars(env, jni_str_address, NULL);
665 // check it whether is still connected or not through google api
666 jboolean ret = CAEDRIsConnectedForSocket(env, jni_obj_socket);
669 OIC_LOG(ERROR, TAG, "it is not connected yet.");
671 // remove socket to list
672 CAEDRNativeRemoveDeviceSocket(env, jni_obj_socket);
673 (*env)->ReleaseStringUTFChars(env, jni_str_address, address);
674 (*env)->DeleteLocalRef(env, jni_str_address);
676 return CA_STATUS_FAILED;
679 // start to read through InputStream
680 jclass jni_cid_BTsocket = (*env)->FindClass(env, "android/bluetooth/BluetoothSocket");
681 if (!jni_cid_BTsocket)
683 OIC_LOG(ERROR, TAG, "jni_cid_BTsocket is null");
684 (*env)->DeleteLocalRef(env, jni_str_address);
685 return CA_STATUS_FAILED;
687 jmethodID jni_mid_getInputStream = (*env)->GetMethodID(env, jni_cid_BTsocket,
689 "()Ljava/io/InputStream;");
691 jobject jni_obj_inputStream = (*env)->CallObjectMethod(env, jni_obj_socket,
692 jni_mid_getInputStream);
693 if (!jni_obj_inputStream)
695 OIC_LOG(ERROR, TAG, "jni_obj_inputStream is null");
696 (*env)->DeleteLocalRef(env, jni_cid_BTsocket);
697 (*env)->DeleteLocalRef(env, jni_str_address);
698 return CA_STATUS_FAILED;
701 jclass jni_cid_InputStream = (*env)->FindClass(env, "java/io/InputStream");
702 if (!jni_cid_InputStream)
704 OIC_LOG(ERROR, TAG, "jni_cid_InputStream is null");
708 jmethodID jni_mid_available = (*env)->GetMethodID(env, jni_cid_InputStream,
710 if (!jni_mid_available)
712 OIC_LOG(ERROR, TAG, "jni_mid_available is null");
716 jint available = (*env)->CallIntMethod(env, jni_obj_inputStream, jni_mid_available);
718 CAConnectedDeviceInfo_t *deviceInfo = NULL;
721 OIC_LOG_V(DEBUG, TAG, "get InputStream..%d, %s", id, address);
722 jmethodID jni_mid_read = (*env)->GetMethodID(env, jni_cid_InputStream,
726 OIC_LOG(ERROR, TAG, "jni_mid_read is null");
730 deviceInfo = (CAConnectedDeviceInfo_t *) CAEDRGetDeviceInfoFromAddress(address);
733 OIC_LOG(ERROR, TAG, "failed to get device info from list");
737 jint bufSize = (deviceInfo->totalDataLen == 0) ?
738 EDR_MAX_HEADER_LEN : deviceInfo->totalDataLen;
739 if (!deviceInfo->recvData)
741 deviceInfo->recvData = OICCalloc(1, bufSize);
742 if (!deviceInfo->recvData)
744 OIC_LOG(ERROR, TAG, "out of memory");
749 jbyteArray jbuf = (*env)->NewByteArray(env, (jint) bufSize - deviceInfo->recvDataLen);
750 jint recvLen = (*env)->CallIntMethod(env, jni_obj_inputStream, jni_mid_read,
752 (jint) bufSize - deviceInfo->recvDataLen);
755 (*env)->DeleteLocalRef(env, jbuf);
759 jbyte* buf = (*env)->GetByteArrayElements(env, jbuf, NULL);
762 (*env)->DeleteLocalRef(env, jbuf);
765 memcpy(deviceInfo->recvData + deviceInfo->recvDataLen, (const char*) buf, recvLen);
766 deviceInfo->recvDataLen += recvLen;
768 OIC_LOG(DEBUG, TAG, "read something from InputStream");
770 if (!deviceInfo->totalDataLen)
772 coap_transport_type transport = coap_get_tcp_header_type_from_initbyte(
773 ((unsigned char *) deviceInfo->recvData)[0] >> 4);
774 size_t headerLen = coap_get_tcp_header_length_for_transport(transport);
775 if (deviceInfo->recvData && deviceInfo->recvDataLen >= headerLen)
777 deviceInfo->totalDataLen = coap_get_total_message_length(deviceInfo->recvData,
778 deviceInfo->recvDataLen);
779 OIC_LOG_V(DEBUG, TAG, "total data length [%d] bytes", deviceInfo->totalDataLen);
781 uint8_t *newBuf = OICRealloc(deviceInfo->recvData, deviceInfo->totalDataLen);
784 OIC_LOG(ERROR, TAG, "out of memory");
785 (*env)->ReleaseByteArrayElements(env, jbuf, buf, 0);
786 (*env)->DeleteLocalRef(env, jbuf);
789 deviceInfo->recvData = newBuf;
793 if (deviceInfo->totalDataLen == deviceInfo->recvDataLen)
795 if ((*env)->ExceptionCheck(env))
797 OIC_LOG(ERROR, TAG, "read Error!!!");
798 (*env)->ExceptionDescribe(env);
799 (*env)->ExceptionClear(env);
801 // update state to disconnect
802 // the socket will be close next read thread routine
803 ca_mutex_lock(g_mutexStateList);
804 CAEDRUpdateDeviceState(STATE_DISCONNECTED, address);
805 ca_mutex_unlock(g_mutexStateList);
807 (*env)->ReleaseByteArrayElements(env, jbuf, buf, 0);
808 (*env)->DeleteLocalRef(env, jbuf);
812 if (g_edrPacketReceivedCallback)
814 OIC_LOG_V(DEBUG, TAG,"data will be sent to callback routine: \
815 %s, %d", deviceInfo->recvData, deviceInfo->recvDataLen);
817 uint32_t sentLength = 0;
818 g_edrPacketReceivedCallback(address, (void*) deviceInfo->recvData,
819 deviceInfo->recvDataLen, &sentLength);
821 OICFree(deviceInfo->recvData);
822 deviceInfo->recvData = NULL;
823 deviceInfo->recvDataLen = 0;
824 deviceInfo->totalDataLen = 0;
827 (*env)->ReleaseByteArrayElements(env, jbuf, buf, 0);
828 (*env)->DeleteLocalRef(env, jbuf);
830 (*env)->DeleteLocalRef(env, jni_obj_inputStream);
831 (*env)->DeleteLocalRef(env, jni_cid_InputStream);
832 (*env)->DeleteLocalRef(env, jni_cid_BTsocket);
833 (*env)->ReleaseStringUTFChars(env, jni_str_address, address);
834 (*env)->DeleteLocalRef(env, jni_str_address);
839 (*env)->DeleteLocalRef(env, jni_obj_inputStream);
840 (*env)->DeleteLocalRef(env, jni_cid_InputStream);
841 (*env)->DeleteLocalRef(env, jni_cid_BTsocket);
842 (*env)->ReleaseStringUTFChars(env, jni_str_address, address);
843 (*env)->DeleteLocalRef(env, jni_str_address);
845 return CA_STATUS_FAILED;
848 jboolean CAEDRIsConnectedForSocket(JNIEnv *env, jobject socket)
852 OIC_LOG(ERROR, TAG, "socket is null");
856 jclass jni_cid_BTsocket = (*env)->FindClass(env, "android/bluetooth/BluetoothSocket");
857 if (!jni_cid_BTsocket)
859 OIC_LOG(ERROR, TAG, "jni_cid_BTsocket is null");
863 jmethodID jni_mid_isConnected = (*env)->GetMethodID(env, jni_cid_BTsocket, "isConnected",
865 if (!jni_mid_isConnected)
867 OIC_LOG(ERROR, TAG, "jni_mid_isConnected is null.");
868 (*env)->DeleteLocalRef(env, jni_cid_BTsocket);
872 jboolean jni_isConnected = (*env)->CallBooleanMethod(env, socket, jni_mid_isConnected);
874 (*env)->DeleteLocalRef(env, jni_cid_BTsocket);
876 return jni_isConnected;
879 void CANativeStartListenTask(JNIEnv *env)
881 jobject jni_obj_BTServerSocket = CAEDRNativeListen(env);
882 if (!jni_obj_BTServerSocket)
884 OIC_LOG(ERROR, TAG, "jni_obj_BTServerSocket is null");
888 ca_mutex_lock(g_mutexServerSocket);
889 g_serverSocket = (*env)->NewGlobalRef(env, jni_obj_BTServerSocket);
890 ca_mutex_unlock(g_mutexServerSocket);
893 jobject CAEDRNativeListen(JNIEnv *env)
895 OIC_LOG(DEBUG, TAG, "CAEDRNativeListen - IN");
897 if (!CAEDRNativeIsEnableBTAdapter(env))
899 OIC_LOG(INFO, TAG, "BT adapter is not enabled");
903 jclass jni_cid_BTAdapter = (*env)->FindClass(env, CLASSPATH_BT_ADPATER);
904 if (!jni_cid_BTAdapter)
906 OIC_LOG(ERROR, TAG, "jni_cid_BTAdapter is null");
911 jmethodID jni_mid_getDefaultAdapter = (*env)->GetStaticMethodID(env, jni_cid_BTAdapter,
913 METHODID_OBJECTNONPARAM);
914 if (!jni_mid_getDefaultAdapter)
916 OIC_LOG(ERROR, TAG, "jni_mid_getDefaultAdapter is null");
920 jobject jni_obj_BTAdapter = (*env)->CallStaticObjectMethod(env, jni_cid_BTAdapter,
921 jni_mid_getDefaultAdapter);
922 if (!jni_obj_BTAdapter)
924 OIC_LOG(ERROR, TAG, "jni_obj_BTAdapter is null");
928 // get listen method ID
929 jmethodID jni_mid_listen = (*env)->GetMethodID(
930 env, jni_cid_BTAdapter, "listenUsingInsecureRfcommWithServiceRecord",
931 "(Ljava/lang/String;Ljava/util/UUID;)Landroid/bluetooth/BluetoothServerSocket;");
934 OIC_LOG(ERROR, TAG, "jni_mid_listen is null");
937 // listenUsingInsecureRfcommWithServiceRecord / listenUsingRfcommWithServiceRecord
939 jclass jni_cid_uuid = (*env)->FindClass(env, CLASSPATH_BT_UUID);
942 OIC_LOG(ERROR, TAG, "jni_mid_listen is null");
946 jmethodID jni_mid_fromString = (*env)->GetStaticMethodID(
947 env, jni_cid_uuid, "fromString", "(Ljava/lang/String;)Ljava/util/UUID;");
948 if (!jni_mid_fromString)
950 OIC_LOG(ERROR, TAG, "jni_mid_fromString is null");
954 jstring jni_uuid = (*env)->NewStringUTF(env, OIC_EDR_SERVICE_ID);
957 OIC_LOG(ERROR, TAG, "jni_uuid is null");
960 jobject jni_obj_uuid = (*env)->CallStaticObjectMethod(env, jni_cid_uuid, jni_mid_fromString,
964 OIC_LOG(ERROR, TAG, "jni_obj_uuid is null");
969 jstring jni_name = (*env)->NewStringUTF(env, "BluetoothTestSecure");
972 OIC_LOG(ERROR, TAG, "jni_name is null");
975 jobject jni_obj_BTServerSocket = (*env)->CallObjectMethod(env, jni_obj_BTAdapter, jni_mid_listen,
976 jni_name, jni_obj_uuid);
977 if (!jni_obj_BTServerSocket)
979 OIC_LOG(ERROR, TAG, "jni_obj_BTServerSocket is null");
983 g_serverSocketObject = (*env)->NewGlobalRef(env, jni_obj_BTServerSocket);
985 OIC_LOG(DEBUG, TAG, "CAEDRNativeListen - OUT");
987 return jni_obj_BTServerSocket;
990 void CAEDRNativeAccept(JNIEnv *env, jobject serverSocketObject)
992 OIC_LOG(DEBUG, TAG, "CAEDRNativeAccept - IN");
994 if (NULL != serverSocketObject)
996 jclass jni_cid_BTServerSocket = (*env)->FindClass(
997 env, "android/bluetooth/BluetoothServerSocket");
998 if (!jni_cid_BTServerSocket)
1000 OIC_LOG(ERROR, TAG, "jni_cid_BTServerSocket is null");
1004 jmethodID jni_mid_accept = (*env)->GetMethodID(env, jni_cid_BTServerSocket, "accept",
1005 "()Landroid/bluetooth/BluetoothSocket;");
1006 if (!jni_mid_accept)
1008 OIC_LOG(ERROR, TAG, "jni_mid_accept is null");
1012 OIC_LOG(DEBUG, TAG, "initiating accept...");
1014 jobject jni_obj_BTSocket = (*env)->CallObjectMethod(env, serverSocketObject,
1016 if (!jni_obj_BTSocket)
1018 OIC_LOG(ERROR, TAG, "jni_obj_BTSocket is null");
1020 if ((*env)->ExceptionCheck(env))
1022 OIC_LOG(ERROR, TAG, "socket might closed or timeout!!!");
1023 (*env)->ExceptionDescribe(env);
1024 (*env)->ExceptionClear(env);
1029 // get remote address
1030 jstring j_str_address = CAEDRNativeGetAddressFromDeviceSocket(env, jni_obj_BTSocket);
1033 OIC_LOG(ERROR, TAG, "j_str_address is null");
1037 const char* address = (*env)->GetStringUTFChars(env, j_str_address, NULL);
1038 OIC_LOG_V(DEBUG, TAG, "address is %s", address);
1040 // set socket to list
1041 jobject jni_socket = (*env)->NewGlobalRef(env, jni_obj_BTSocket);
1042 ca_mutex_lock(g_mutexObjectList);
1043 CAEDRNativeAddDeviceSocketToList(env, jni_socket);
1044 ca_mutex_unlock(g_mutexObjectList);
1046 OIC_LOG(DEBUG, TAG, "Accepted!!");
1049 ca_mutex_lock(g_mutexStateList);
1050 CAEDRUpdateDeviceState(STATE_CONNECTED, address);
1051 ca_mutex_unlock(g_mutexStateList);
1053 (*env)->ReleaseStringUTFChars(env, j_str_address, address);
1054 (*env)->DeleteLocalRef(env, j_str_address);
1058 OIC_LOG(DEBUG, TAG, "serverSocket is close previously");
1061 OIC_LOG(DEBUG, TAG, "CAEDRNativeAccept - OUT");
1065 * InputStream & BluetoothServerSocket will be close for Terminating.
1067 void CAEDRNatvieCloseServerTask(JNIEnv* env)
1071 OIC_LOG(DEBUG, TAG, "Accept Resource will be close");
1073 jclass jni_cid_BTServerSocket = (*env)->FindClass(
1074 env, "android/bluetooth/BluetoothServerSocket");
1075 if (!jni_cid_BTServerSocket)
1077 OIC_LOG(ERROR, TAG, "jni_cid_BTServerSocket is null");
1081 jmethodID jni_mid_accept = (*env)->GetMethodID(env, jni_cid_BTServerSocket, "close", "()V");
1082 if (!jni_mid_accept)
1084 OIC_LOG(ERROR, TAG, "jni_mid_accept is null");
1087 (*env)->CallVoidMethod(env, g_serverSocket, jni_mid_accept);
1088 (*env)->DeleteGlobalRef(env, g_serverSocket);
1089 g_serverSocket = NULL;
1091 OIC_LOG(DEBUG, TAG, "close accept obj");