}\r
case JNI_EVERSION:\r
LOGE ("JNI version is not supported");\r
+ return NULL;\r
default:\r
LOGE ("Failed to get the environment");\r
return NULL;\r
return nullptr;\r
}\r
jstring jTopicName = (jstring) env->GetObjectField( jTopic, fid_name);\r
- const char *topicName;\r
+ const char *topicName = NULL;\r
if (jTopicName)\r
{\r
topicName = env->GetStringUTFChars( jTopicName, NULL);\r
if (topicObj == NULL)\r
{\r
LOGE("Error: object of field Topic is null");\r
+ delete nsTopicList;\r
return nullptr;\r
}\r
const char *name = getNativeTopicName(env, topicObj);\r
if (name == nullptr)\r
{\r
LOGE("Error: Couldn't find topic Name");\r
+ delete nsTopicList;\r
return nullptr;\r
}\r
std::string topicName(name);\r
- OIC::Service::NSTopic::NSTopicState state;\r
+ OIC::Service::NSTopic::NSTopicState state = OIC::Service::NSTopic::NSTopicState::UNSUBSCRIBED;\r
if (!getNativeTopicState(env, topicObj, state))\r
{\r
+ delete nsTopicList;\r
return nullptr;\r
}\r
nsTopicList->addTopic(topicName, state);\r
{\r
LOGD ("ConsumerService_onDiscoverProvider - IN");\r
\r
- jint envRet;\r
+ jint envRet = 0;;\r
JNIEnv *env = GetJNIEnv(&envRet);\r
- if (NULL == env) return ;\r
+ if (NULL == env)\r
+ {\r
+ return ;\r
+ }\r
\r
jobject jDiscoverListener = (jobject) env->NewLocalRef(g_obj_discoverListener);\r
if (!jDiscoverListener)\r
{\r
LOGE ("Failed to Get jDiscoverListener");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
if (!obj_provider)\r
{\r
LOGE ("Failed to Get Provider Object");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
if (!cls)\r
{\r
LOGE ("Failed to Get ObjectClass for jDiscoverListener");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
jmethodID mid = env->GetMethodID(\r
if (!mid)\r
{\r
LOGE ("Failed to Get MethodID for onProviderDiscovered");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
env->CallVoidMethod(jDiscoverListener, mid, obj_provider);\r
\r
env->DeleteLocalRef(jDiscoverListener);\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
LOGD ("ConsumerService_onDiscoverProvider - OUT");\r
return ;\r
}\r
{\r
LOGD ("ConsumerService_onProviderState -IN");\r
\r
- jint envRet;\r
+ jint envRet = 0;;\r
JNIEnv *env = GetJNIEnv(&envRet);\r
- if (NULL == env) return ;\r
+ if (NULL == env)\r
+ {\r
+ return ;\r
+ }\r
\r
jobject jAcceptListener = (jobject) env->NewLocalRef(g_obj_acceptListener);\r
if (!jAcceptListener)\r
{\r
LOGE ("Failed to Get jAcceptListener");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
jobject obj_state = getJavaProviderState(env, state);\r
if (!obj_state)\r
{\r
LOGE ("Failed to Get ProviderState Object");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
if (!cls)\r
{\r
LOGE ("Failed to Get ObjectClass for jAcceptListener");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
jmethodID mid = env->GetMethodID(\r
if (!mid)\r
{\r
LOGE ("Failed to Get MethodID for onProviderState");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
env->CallVoidMethod(jAcceptListener, mid, obj_state);\r
\r
env->DeleteLocalRef(jAcceptListener);\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
LOGD ("ConsumerService_onProviderState -OUT");\r
return ;\r
\r
{\r
LOGD ("ConsumerService_onMessagePosted -IN");\r
\r
- jint envRet;\r
+ jint envRet=0;;\r
JNIEnv *env = GetJNIEnv(&envRet);\r
- if (NULL == env) return ;\r
+ if (NULL == env)\r
+ {\r
+ return ;\r
+ }\r
\r
jobject jPostListener = (jobject) env->NewLocalRef(g_obj_postListener);\r
if (!jPostListener)\r
{\r
LOGE ("Failed to Get jPostListener");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
if (!obj_message)\r
{\r
LOGE ("Failed to Get Message Object");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
jclass cls = env->GetObjectClass(jPostListener);\r
if (!cls)\r
{\r
LOGE ("Failed to Get ObjectClass for jPostListener");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
jmethodID mid = env->GetMethodID(\r
if (!mid)\r
{\r
LOGE ("Failed to Get MethodID for onMessageReceived");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
env->CallVoidMethod(jPostListener, mid, obj_message);\r
\r
env->DeleteLocalRef(jPostListener);\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
LOGD ("ConsumerService_onMessagePosted -OUT");\r
return ;\r
}\r
{\r
LOGD ("ConsumerService_onSyncInfoReceived - IN");\r
\r
- jint envRet;\r
+ jint envRet=0;;\r
JNIEnv *env = GetJNIEnv(&envRet);\r
- if (NULL == env) return ;\r
+ if (NULL == env)\r
+ {\r
+ return ;\r
+ }\r
\r
jobject jSyncListener = (jobject) env->NewLocalRef(g_obj_syncListener);\r
if (!jSyncListener)\r
{\r
LOGE ("Failed to Get jSyncListener");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
if (!syncType)\r
{\r
LOGE ("Failed to Get syncType for SyncInfo");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
jclass cls_SyncInfo = (jclass) (env->NewLocalRef(g_cls_SyncInfo));\r
if (!cls_SyncInfo)\r
{\r
LOGE ("Failed to Get ObjectClass for SyncInfo");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
jmethodID mid_syncInfo = env->GetMethodID(\r
if (!mid_syncInfo)\r
{\r
LOGE ("Failed to Get MethodID for SyncInfo");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
if (!obj_syncInfo)\r
{\r
LOGE ("Failed to Get Object for SyncInfo");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
if (!cls)\r
{\r
LOGE ("Failed to Get ObjectClass for jSyncListener");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
jmethodID mid = env->GetMethodID(\r
if (!mid)\r
{\r
LOGE ("Failed to Get MethodID for onSyncInfoReceived");\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
return ;\r
}\r
\r
\r
env->DeleteLocalRef(jSyncListener);\r
env->DeleteLocalRef(cls_SyncInfo);\r
- if (JNI_EDETACHED == envRet) g_jvm_consumer->DetachCurrentThread();\r
+ if (JNI_EDETACHED == envRet)\r
+ {\r
+ g_jvm_consumer->DetachCurrentThread();\r
+ }\r
LOGD ("ConsumerService_onSyncInfoReceived - OUT");\r
return ;\r
}\r
return NULL;\r
}\r
jlong jProvider = env->GetLongField(jObj, nativeHandle);\r
- OIC::Service::NSTopicsList *topicList;\r
+ OIC::Service::NSTopicsList *topicList = nullptr;\r
if (jProvider)\r
{\r
LOGD ("calling subscribe on mNativeHandle");\r
return (jint) OIC::Service::NSResult::ERROR;\r
}\r
jlong jProvider = env->GetLongField(jObj, nativeHandle);\r
- OIC::Service::NSResult result;\r
+ OIC::Service::NSResult result = OIC::Service::NSResult::FAIL;\r
if (jProvider)\r
{\r
LOGD ("calling subscribe on mNativeHandle");\r
return NULL;\r
}\r
jlong jProvider = env->GetLongField(jObj, nativeHandle);\r
- OIC::Service::NSProviderState state;\r
+ OIC::Service::NSProviderState state = OIC::Service::NSProviderState::DENY;\r
if (jProvider)\r
{\r
LOGD ("calling getProviderState on mNativeHandle");\r
LOGD("ConsumerService_JNI_OnLoad");\r
g_jvm_consumer = jvm;\r
\r
- JNIEnv *env;\r
+ JNIEnv *env = NULL;\r
if (jvm->GetEnv((void **)&env, JNI_CURRENT_VERSION) != JNI_OK)\r
{\r
LOGE("Failed to get the environment using GetEnv()");\r
JNIEXPORT void JNICALL JNI_OnUnload(JavaVM *jvm, void *reserved)\r
{\r
LOGI("ConsumerService_JNI_OnUnload");\r
- JNIEnv *env;\r
+ JNIEnv *env = NULL;\r
\r
if (jvm->GetEnv((void **)&env, JNI_CURRENT_VERSION) != JNI_OK)\r
{\r
}
case JNI_EVERSION:
LOGE ("JNI version is not supported");
+ return NULL;
default:
LOGE ("Failed to get the environment");
return NULL;
jlong jttl = (jlong) env->GetLongField( jMsg, fid_ttl);
uint64_t ttl = jttl;
- LOGD("TTL: %d\n", ttl);
+ LOGD("TTL: %lld\n", ttl);
// Message Title
jfieldID fid_title = env->GetFieldID( cls, "mTitle", "Ljava/lang/String;");
}
}
- OIC::Service::NSMessage *nsMsg;
+ OIC::Service::NSMessage *nsMsg = nullptr;
jfieldID nativeHandle = env->GetFieldID(cls, "mNativeHandle", "J");
if (!nativeHandle)
{
{
LOGD("JNIProviderService_onSubscribeListenerCb - IN");
- jint envRet;
+ jint envRet = 0;;
JNIEnv *env = GetJNIEnv(&envRet);
- if (NULL == env) return ;
+ if (NULL == env)
+ {
+ return ;
+ }
jobject jSubscriptionListener = (jobject) env->NewLocalRef(g_obj_subscriptionListener);
if (!jSubscriptionListener)
{
LOGE ("Failed to Get jSubscriptionListener");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return ;
}
if (!cls_consumer)
{
LOGE ("Failed to Get ObjectClass for Consumer");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return ;
}
if (!mid_consumer)
{
LOGE ("Failed to Get MethodID for Consumer<init>");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return ;
}
jobject obj_consumer = env->NewObject( cls_consumer, mid_consumer, jConsumerId);
if (!cls)
{
LOGE("Failed to Get ObjectClass of jSubscriptionListener");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return;
}
jmethodID mid = env->GetMethodID(
if (!mid)
{
LOGE("Failed to Get MethodID of onConsumerSubscribed");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return;
}
env->CallVoidMethod( jSubscriptionListener, mid, obj_consumer);
env->DeleteLocalRef(jSubscriptionListener);
env->DeleteLocalRef(cls_consumer);
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
LOGD("JNIProviderService_onSubscribeListenerCb - OUT");
return;
}
{
LOGD("JNIProviderService_onSyncInfoListenerCb - IN");
- jint envRet;
+ jint envRet = 0;;
JNIEnv *env = GetJNIEnv(&envRet);
- if (NULL == env) return ;
+ if(NULL == env)
+ {
+ return ;
+ }
jobject jSyncListener = (jobject) env->NewLocalRef(g_obj_syncListener);
if (!jSyncListener)
{
LOGE ("Failed to Get jSyncListener");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return ;
}
if (!syncType)
{
LOGE ("Failed to Get syncType for SyncInfo");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return ;
}
jclass cls_SyncInfo = (jclass) (env->NewLocalRef(g_cls_SyncInfo));
if (!cls_SyncInfo)
{
LOGE ("Failed to Get ObjectClass for SyncInfo");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return ;
}
jmethodID mid_syncInfo = env->GetMethodID(
if (!mid_syncInfo)
{
LOGE ("Failed to Get MethodID for SyncInfo");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return ;
}
if (!obj_syncInfo)
{
LOGE ("Failed to Get Object for SyncInfo");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
return ;
}
if (!cls)
{
LOGE("Failed to Get ObjectClass");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
- return;
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
+ return ;
}
jmethodID mid = env->GetMethodID(
cls,
if (!mid)
{
LOGE("Failed to Get MethodID");
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
- return;
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
+ return ;
}
env->CallVoidMethod( jSyncListener, mid, obj_syncInfo);
env->DeleteLocalRef(jSyncListener);
env->DeleteLocalRef(cls_SyncInfo);
- if (JNI_EDETACHED == envRet) g_jvm_provider->DetachCurrentThread();
-
+ if (JNI_EDETACHED == envRet)
+ {
+ g_jvm_provider->DetachCurrentThread();
+ }
LOGD("JNIProviderService: OnSyncInfoListenerCb - OUT");
return;
}
jobject obj_topicList = getJavaTopicsList(env, topicList);
+ delete topicList;
LOGD("JNIProviderService: nativeGetRegisteredTopicList - OUT");
return obj_topicList;
OIC::Service::NSConsumer *consumer =
OIC::Service::NSProviderService::getInstance()->getConsumer(consumerId);
if (consumer)
+ {
return (jint) consumer->acceptSubscription((bool)jAccepted);
+ }
LOGE("Couldn't find consumer");
LOGD("JNIProviderService: nativeAcceptSubscription - OUT");
return NULL;
}
jobject obj_topicList = getJavaTopicsList(env, topicList);
+ delete topicList;
+
LOGD("JNIProviderService: nativeGetConsumerTopicList - OUT");
return obj_topicList;
}
LOGD("ProviderService_JNI_OnLoad");
g_jvm_provider = jvm;
- JNIEnv *env;
+ JNIEnv *env = NULL;
if (jvm->GetEnv((void **)&env, JNI_CURRENT_VERSION) != JNI_OK)
{
LOGE("Failed to get the environment using GetEnv()");
JNIEXPORT void JNICALL JNI_OnUnload(JavaVM *jvm, void *reserved)
{
LOGD("ProviderService_JNI_OnUnload");
- JNIEnv *env;
+ JNIEnv *env = NULL;
if (jvm->GetEnv((void **)&env, JNI_CURRENT_VERSION) != JNI_OK)
{