-/*\r
-* //******************************************************************\r
-* //\r
-* // Copyright 2015 Intel Corporation.\r
-* //\r
-* //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=\r
-* //\r
-* // Licensed under the Apache License, Version 2.0 (the "License");\r
-* // you may not use this file except in compliance with the License.\r
-* // You may obtain a copy of the License at\r
-* //\r
-* // http://www.apache.org/licenses/LICENSE-2.0\r
-* //\r
-* // Unless required by applicable law or agreed to in writing, software\r
-* // distributed under the License is distributed on an "AS IS" BASIS,\r
-* // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
-* // See the License for the specific language governing permissions and\r
-* // limitations under the License.\r
-* //\r
-* //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=\r
-*/\r
-#include "JniOnPutListener.h"\r
-#include "JniOcResource.h"\r
-#include "JniOcRepresentation.h"\r
-#include "JniUtils.h"\r
-\r
-JniOnPutListener::JniOnPutListener(JNIEnv *env, jobject jListener, JniOcResource* owner)\r
- : m_ownerResource(owner)\r
-{\r
- m_jwListener = env->NewWeakGlobalRef(jListener);\r
-}\r
-\r
-JniOnPutListener::~JniOnPutListener()\r
-{\r
- if (m_jwListener)\r
- {\r
- jint ret;\r
- JNIEnv *env = GetJNIEnv(ret);\r
- if (NULL == env) return;\r
-\r
- env->DeleteWeakGlobalRef(m_jwListener);\r
-\r
- if (JNI_EDETACHED == ret) g_jvm->DetachCurrentThread();\r
- }\r
-}\r
-\r
-void JniOnPutListener::onPutCallback(const HeaderOptions& headerOptions,\r
- const OCRepresentation& ocRepresentation, const int eCode)\r
-{\r
- jint envRet;\r
- JNIEnv *env = GetJNIEnv(envRet);\r
- if (NULL == env) return;\r
-\r
- jobject jListener = env->NewLocalRef(m_jwListener);\r
- if (!jListener)\r
- {\r
- checkExAndRemoveListener(env);\r
- if (JNI_EDETACHED == envRet) g_jvm->DetachCurrentThread();\r
- return;\r
- }\r
- jclass clsL = env->GetObjectClass(jListener);\r
- if (!clsL)\r
- {\r
- checkExAndRemoveListener(env);\r
- if (JNI_EDETACHED == envRet) g_jvm->DetachCurrentThread();\r
- return;\r
- }\r
-\r
- if (OC_STACK_OK != eCode)\r
- {\r
- jobject ex = GetOcException(eCode, "stack error in onPutCallback");\r
- if (!ex)\r
- {\r
- checkExAndRemoveListener(env);\r
- if (JNI_EDETACHED == envRet) g_jvm->DetachCurrentThread();\r
- return;\r
- }\r
- jmethodID midL = env->GetMethodID(clsL, "onPutFailed", "(Ljava/lang/Throwable;)V");\r
- if (!midL)\r
- {\r
- checkExAndRemoveListener(env);\r
- if (JNI_EDETACHED == envRet) g_jvm->DetachCurrentThread();\r
- return;\r
- }\r
- env->CallVoidMethod(jListener, midL, ex);\r
- }\r
- else\r
- {\r
- jobject jHeaderOptionList = JniUtils::convertHeaderOptionsVectorToJavaList(env, headerOptions);\r
- if (!jHeaderOptionList)\r
- {\r
- checkExAndRemoveListener(env);\r
- if (JNI_EDETACHED == envRet) g_jvm->DetachCurrentThread();\r
- return;\r
- }\r
-\r
- OCRepresentation * rep = new OCRepresentation(ocRepresentation);\r
- jlong handle = reinterpret_cast<jlong>(rep);\r
- jobject jRepresentation = env->NewObject(g_cls_OcRepresentation, g_mid_OcRepresentation_N_ctor_bool,\r
- handle, true);\r
- if (!jRepresentation)\r
- {\r
- delete rep;\r
- checkExAndRemoveListener(env);\r
- if (JNI_EDETACHED == envRet) g_jvm->DetachCurrentThread();\r
- return;\r
- }\r
-\r
- jmethodID midL = env->GetMethodID(clsL, "onPutCompleted",\r
- "(Ljava/util/List;Lorg/iotivity/base/OcRepresentation;)V");\r
-\r
- if (!midL)\r
- {\r
- checkExAndRemoveListener(env);\r
- if (JNI_EDETACHED == envRet) g_jvm->DetachCurrentThread();\r
- return;\r
- }\r
-\r
- env->CallVoidMethod(jListener, midL, jHeaderOptionList, jRepresentation);\r
- if (env->ExceptionCheck())\r
- {\r
- LOGE("Java exception is thrown");\r
- delete rep;\r
- }\r
- }\r
-\r
- checkExAndRemoveListener(env);\r
- if (JNI_EDETACHED == envRet) g_jvm->DetachCurrentThread();\r
-}\r
-\r
-void JniOnPutListener::checkExAndRemoveListener(JNIEnv* env)\r
-{\r
- if (env->ExceptionCheck())\r
- {\r
- jthrowable ex = env->ExceptionOccurred();\r
- env->ExceptionClear();\r
- m_ownerResource->removeOnPutListener(env, m_jwListener);\r
- env->Throw((jthrowable)ex);\r
- }\r
- else\r
- {\r
- m_ownerResource->removeOnPutListener(env, m_jwListener);\r
- }\r
-}
\ No newline at end of file
+/*
+* //******************************************************************
+* //
+* // Copyright 2015 Intel Corporation.
+* //
+* //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
+* //
+* // Licensed under the Apache License, Version 2.0 (the "License");
+* // you may not use this file except in compliance with the License.
+* // You may obtain a copy of the License at
+* //
+* // http://www.apache.org/licenses/LICENSE-2.0
+* //
+* // Unless required by applicable law or agreed to in writing, software
+* // distributed under the License is distributed on an "AS IS" BASIS,
+* // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* // See the License for the specific language governing permissions and
+* // limitations under the License.
+* //
+* //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
+*/
+#include "JniOnPutListener.h"
+#include "JniOcResource.h"
+#include "JniOcRepresentation.h"
+#include "JniUtils.h"
+
+JniOnPutListener::JniOnPutListener(JNIEnv *env, jobject jListener, RemoveListenerCallback removeListener)
+ : m_removeListener(removeListener)
+{
+ m_jwListener = env->NewWeakGlobalRef(jListener);
+}
+
+JniOnPutListener::~JniOnPutListener()
+{
+ if (m_jwListener)
+ {
+ jint ret = JNI_ERR;
+ JNIEnv *env = GetJNIEnv(ret);
+ if (nullptr == env)
+ {
+ return;
+ }
+
+ env->DeleteWeakGlobalRef(m_jwListener);
+ m_jwListener = nullptr;
+
+ if (JNI_EDETACHED == ret)
+ {
+ g_jvm->DetachCurrentThread();
+ }
+ }
+}
+
+void JniOnPutListener::onPutCallback(const HeaderOptions& headerOptions,
+ const OCRepresentation& ocRepresentation, const int eCode)
+{
+ jint envRet = JNI_ERR;
+ JNIEnv *env = GetJNIEnv(envRet);
+ if (nullptr == env)
+ {
+ return;
+ }
+
+ jobject jListener = env->NewLocalRef(m_jwListener);
+ if (!jListener)
+ {
+ checkExAndRemoveListener(env);
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm->DetachCurrentThread();
+ }
+ return;
+ }
+ jclass clsL = env->GetObjectClass(jListener);
+ if (!clsL)
+ {
+ checkExAndRemoveListener(env);
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm->DetachCurrentThread();
+ }
+ return;
+ }
+
+ if (OC_STACK_OK != eCode && OC_STACK_RESOURCE_CHANGED != eCode)
+ {
+ jobject ex = GetOcException(eCode, "stack error in onPutCallback");
+ if (!ex)
+ {
+ checkExAndRemoveListener(env);
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm->DetachCurrentThread();
+ }
+ return;
+ }
+ jmethodID midL = env->GetMethodID(clsL, "onPutFailed", "(Ljava/lang/Throwable;)V");
+ if (!midL)
+ {
+ checkExAndRemoveListener(env);
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm->DetachCurrentThread();
+ }
+ return;
+ }
+ env->CallVoidMethod(jListener, midL, ex);
+ }
+ else
+ {
+ jobject jHeaderOptionList = JniUtils::convertHeaderOptionsVectorToJavaList(env, headerOptions);
+ if (!jHeaderOptionList)
+ {
+ checkExAndRemoveListener(env);
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm->DetachCurrentThread();
+ }
+ return;
+ }
+
+ OCRepresentation * rep = new OCRepresentation(ocRepresentation);
+ jlong handle = reinterpret_cast<jlong>(rep);
+ jobject jRepresentation = env->NewObject(g_cls_OcRepresentation, g_mid_OcRepresentation_N_ctor_bool,
+ handle, true);
+ if (!jRepresentation)
+ {
+ delete rep;
+ checkExAndRemoveListener(env);
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm->DetachCurrentThread();
+ }
+ return;
+ }
+
+ jmethodID midL = env->GetMethodID(clsL, "onPutCompleted",
+ "(Ljava/util/List;Lorg/iotivity/base/OcRepresentation;)V");
+
+ if (!midL)
+ {
+ checkExAndRemoveListener(env);
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm->DetachCurrentThread();
+ }
+ return;
+ }
+
+ env->CallVoidMethod(jListener, midL, jHeaderOptionList, jRepresentation);
+ if (env->ExceptionCheck())
+ {
+ LOGE("Java exception is thrown");
+ delete rep;
+ }
+ }
+
+ checkExAndRemoveListener(env);
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm->DetachCurrentThread();
+ }
+}
+
+void JniOnPutListener::checkExAndRemoveListener(JNIEnv* env)
+{
+ if (env->ExceptionCheck())
+ {
+ jthrowable ex = env->ExceptionOccurred();
+ env->ExceptionClear();
+ m_removeListener(env, m_jwListener);
+ env->Throw((jthrowable)ex);
+ }
+ else
+ {
+ m_removeListener(env, m_jwListener);
+ }
+}
projects / platform / upstream / iotivity.git / blobdiff