Lines Matching full:env
66 static void s_aws_mqtt5_client_log_and_throw_exception(JNIEnv *env, const char *message, int error_… in s_aws_mqtt5_client_log_and_throw_exception() argument
70 aws_jni_throw_runtime_exception(env, "%s - error code: %i", message, error_code); in s_aws_mqtt5_client_log_and_throw_exception()
78 JNIEnv *env, in s_aws_mqtt5_http_proxy_options_java_destroy() argument
81 (void)env; in s_aws_mqtt5_http_proxy_options_java_destroy()
103 JNIEnv *env, in s_aws_mqtt5_http_proxy_options_create_from_java() argument
113 jobject jni_proxy_connection_type = (*env)->CallObjectMethod( in s_aws_mqtt5_http_proxy_options_create_from_java()
114 env, java_http_proxy_options, http_proxy_options_properties.proxy_get_connection_type_id); in s_aws_mqtt5_http_proxy_options_create_from_java()
115 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_http_proxy_options_create_from_java()
119 jint jni_proxy_connection_type_value = (*env)->CallIntMethod( in s_aws_mqtt5_http_proxy_options_create_from_java()
120 … env, jni_proxy_connection_type, http_proxy_connection_type_properties.proxy_get_value_id); in s_aws_mqtt5_http_proxy_options_create_from_java()
121 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_http_proxy_options_create_from_java()
141 jstring jni_proxy_host = (jstring)(*env)->CallObjectMethod( in s_aws_mqtt5_http_proxy_options_create_from_java()
142 env, java_http_proxy_options, http_proxy_options_properties.proxy_get_proxy_host_id); in s_aws_mqtt5_http_proxy_options_create_from_java()
143 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_http_proxy_options_create_from_java()
148 … struct aws_byte_cursor tmp_cursor = aws_jni_byte_cursor_from_jstring_acquire(env, jni_proxy_host); in s_aws_mqtt5_http_proxy_options_create_from_java()
151 aws_jni_byte_cursor_from_jstring_release(env, jni_proxy_host, tmp_cursor); in s_aws_mqtt5_http_proxy_options_create_from_java()
157 …(*env)->CallIntMethod(env, java_http_proxy_options, http_proxy_options_properties.proxy_get_proxy_… in s_aws_mqtt5_http_proxy_options_create_from_java()
158 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_http_proxy_options_create_from_java()
165 jobject jni_proxy_tls_context = (*env)->CallObjectMethod( in s_aws_mqtt5_http_proxy_options_create_from_java()
166 env, java_http_proxy_options, http_proxy_options_properties.proxy_get_proxy_tls_context_id); in s_aws_mqtt5_http_proxy_options_create_from_java()
167 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_http_proxy_options_create_from_java()
172 …(*env)->CallLongMethod(env, jni_proxy_tls_context, crt_resource_properties.get_native_handle_metho… in s_aws_mqtt5_http_proxy_options_create_from_java()
183 jobject jni_proxy_authorization_type = (*env)->CallObjectMethod( in s_aws_mqtt5_http_proxy_options_create_from_java()
184 …env, java_http_proxy_options, http_proxy_options_properties.proxy_get_proxy_authorization_type_id); in s_aws_mqtt5_http_proxy_options_create_from_java()
185 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_http_proxy_options_create_from_java()
189 jint jni_proxy_authorization_type_value = (*env)->CallIntMethod( in s_aws_mqtt5_http_proxy_options_create_from_java()
190 … env, jni_proxy_authorization_type, http_proxy_connection_type_properties.proxy_get_value_id); in s_aws_mqtt5_http_proxy_options_create_from_java()
191 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_http_proxy_options_create_from_java()
197 jstring jni_proxy_authorization_username = (jstring)(*env)->CallObjectMethod( in s_aws_mqtt5_http_proxy_options_create_from_java()
198 … env, java_http_proxy_options, http_proxy_options_properties.proxy_get_authorization_username_id); in s_aws_mqtt5_http_proxy_options_create_from_java()
199 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_http_proxy_options_create_from_java()
205 aws_jni_byte_cursor_from_jstring_acquire(env, jni_proxy_authorization_username); in s_aws_mqtt5_http_proxy_options_create_from_java()
210 aws_jni_byte_cursor_from_jstring_release(env, jni_proxy_authorization_username, tmp_cursor); in s_aws_mqtt5_http_proxy_options_create_from_java()
215 jstring jni_proxy_authorization_password = (jstring)(*env)->CallObjectMethod( in s_aws_mqtt5_http_proxy_options_create_from_java()
216 … env, java_http_proxy_options, http_proxy_options_properties.proxy_get_authorization_password_id); in s_aws_mqtt5_http_proxy_options_create_from_java()
217 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_http_proxy_options_create_from_java()
223 aws_jni_byte_cursor_from_jstring_acquire(env, jni_proxy_authorization_password); in s_aws_mqtt5_http_proxy_options_create_from_java()
228 aws_jni_byte_cursor_from_jstring_release(env, jni_proxy_authorization_password, tmp_cursor); in s_aws_mqtt5_http_proxy_options_create_from_java()
236 s_aws_mqtt5_http_proxy_options_java_destroy(env, allocator, http_options); in s_aws_mqtt5_http_proxy_options_create_from_java()
245 JNIEnv *env, in aws_mqtt5_client_java_destroy() argument
256 (*env)->DeleteGlobalRef(env, java_client->jni_client); in aws_mqtt5_client_java_destroy()
259 (*env)->DeleteGlobalRef(env, java_client->jni_publish_events); in aws_mqtt5_client_java_destroy()
262 (*env)->DeleteGlobalRef(env, java_client->jni_lifecycle_events); in aws_mqtt5_client_java_destroy()
272 static void s_complete_future_with_exception(JNIEnv *env, jobject *future, int error_code) { in s_complete_future_with_exception() argument
273 if (!env || !future) { in s_complete_future_with_exception()
277 jobject crt_exception = aws_jni_new_crt_exception_from_error_code(env, error_code); in s_complete_future_with_exception()
278 (*env)->CallBooleanMethod( in s_complete_future_with_exception()
279 … env, *future, completable_future_properties.complete_exceptionally_method_id, crt_exception); in s_complete_future_with_exception()
280 aws_jni_check_and_clear_exception(env); in s_complete_future_with_exception()
281 (*env)->DeleteLocalRef(env, crt_exception); in s_complete_future_with_exception()
304 /********** JNI ENV ACQUIRE **********/ in s_aws_mqtt5_client_java_lifecycle_event()
306 JNIEnv *env = aws_jni_acquire_thread_env(jvm); in s_aws_mqtt5_client_java_lifecycle_event() local
307 if (env == NULL) { in s_aws_mqtt5_client_java_lifecycle_event()
309 AWS_LOGF_ERROR(AWS_LS_MQTT5_CLIENT, "LifecycleEvent: could not get env"); in s_aws_mqtt5_client_java_lifecycle_event()
356 jint local_frame_result = (*env)->PushLocalFrame(env, (jint)references_needed); in s_aws_mqtt5_client_java_lifecycle_event()
359 …env, "LifecycleEvent: could not push local JNI frame with 14 allocation minimum!", AWS_ERROR_INVAL… in s_aws_mqtt5_client_java_lifecycle_event()
360 aws_jni_release_thread_env(jvm, env); in s_aws_mqtt5_client_java_lifecycle_event()
366 … connack_data = s_aws_mqtt5_client_create_jni_connack_packet_from_native(env, event->connack_data); in s_aws_mqtt5_client_java_lifecycle_event()
375 …disconnect_data = s_aws_mqtt5_client_create_jni_disconnect_packet_from_native(env, event->disconne… in s_aws_mqtt5_client_java_lifecycle_event()
384 …ettings_data = s_aws_mqtt5_client_create_jni_negotiated_settings_from_native(env, event->settings); in s_aws_mqtt5_client_java_lifecycle_event()
390 env, "LifecycleEvent: no lifecycle events found!", AWS_ERROR_INVALID_STATE); in s_aws_mqtt5_client_java_lifecycle_event()
400 java_lifecycle_return_data = (*env)->NewObject( in s_aws_mqtt5_client_java_lifecycle_event()
401 env, in s_aws_mqtt5_client_java_lifecycle_event()
404 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_lifecycle_event()
406 (*env)->CallVoidMethod( in s_aws_mqtt5_client_java_lifecycle_event()
407 env, in s_aws_mqtt5_client_java_lifecycle_event()
416 java_lifecycle_return_data = (*env)->NewObject( in s_aws_mqtt5_client_java_lifecycle_event()
417 env, in s_aws_mqtt5_client_java_lifecycle_event()
422 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_lifecycle_event()
425 …(*env)->CallVoidMethod(env, java_client->jni_client, mqtt5_client_properties.client_set_is_connect… in s_aws_mqtt5_client_java_lifecycle_event()
427 (*env)->CallVoidMethod( in s_aws_mqtt5_client_java_lifecycle_event()
428 env, in s_aws_mqtt5_client_java_lifecycle_event()
438 java_lifecycle_return_data = (*env)->NewObject( in s_aws_mqtt5_client_java_lifecycle_event()
439 env, in s_aws_mqtt5_client_java_lifecycle_event()
444 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_lifecycle_event()
446 (*env)->CallVoidMethod( in s_aws_mqtt5_client_java_lifecycle_event()
447 env, in s_aws_mqtt5_client_java_lifecycle_event()
458 java_lifecycle_return_data = (*env)->NewObject( in s_aws_mqtt5_client_java_lifecycle_event()
459 env, in s_aws_mqtt5_client_java_lifecycle_event()
464 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_lifecycle_event()
467 (*env)->CallVoidMethod( in s_aws_mqtt5_client_java_lifecycle_event()
468 … env, java_client->jni_client, mqtt5_client_properties.client_set_is_connected, false); in s_aws_mqtt5_client_java_lifecycle_event()
470 (*env)->CallVoidMethod( in s_aws_mqtt5_client_java_lifecycle_event()
471 env, in s_aws_mqtt5_client_java_lifecycle_event()
481 java_lifecycle_return_data = (*env)->NewObject( in s_aws_mqtt5_client_java_lifecycle_event()
482 env, in s_aws_mqtt5_client_java_lifecycle_event()
485 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_lifecycle_event()
487 (*env)->CallVoidMethod( in s_aws_mqtt5_client_java_lifecycle_event()
488 env, in s_aws_mqtt5_client_java_lifecycle_event()
502 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_lifecycle_event()
504 (*env)->PopLocalFrame(env, NULL); in s_aws_mqtt5_client_java_lifecycle_event()
505 /********** JNI ENV RELEASE **********/ in s_aws_mqtt5_client_java_lifecycle_event()
506 aws_jni_release_thread_env(jvm, env); in s_aws_mqtt5_client_java_lifecycle_event()
524 /********** JNI ENV ACQUIRE **********/ in s_aws_mqtt5_client_java_publish_received()
526 JNIEnv *env = aws_jni_acquire_thread_env(jvm); in s_aws_mqtt5_client_java_publish_received() local
527 if (env == NULL) { in s_aws_mqtt5_client_java_publish_received()
529 AWS_LOGF_ERROR(AWS_LS_MQTT5_CLIENT, "publishReceived function: could not get env"); in s_aws_mqtt5_client_java_publish_received()
560 jint local_frame_result = (*env)->PushLocalFrame(env, (jint)references_needed); in s_aws_mqtt5_client_java_publish_received()
563 env, in s_aws_mqtt5_client_java_publish_received()
573 …jobject publish_packet_data = s_aws_mqtt5_client_create_jni_publish_packet_from_native(env, publis… in s_aws_mqtt5_client_java_publish_received()
579 publish_packet_return_data = (*env)->NewObject( in s_aws_mqtt5_client_java_publish_received()
580 env, in s_aws_mqtt5_client_java_publish_received()
584 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_publish_received()
587 (*env)->CallVoidMethod( in s_aws_mqtt5_client_java_publish_received()
588 env, in s_aws_mqtt5_client_java_publish_received()
593 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_publish_received()
599 (*env)->PopLocalFrame(env, NULL); in s_aws_mqtt5_client_java_publish_received()
600 /********** JNI ENV RELEASE **********/ in s_aws_mqtt5_client_java_publish_received()
601 aws_jni_release_thread_env(jvm, env); in s_aws_mqtt5_client_java_publish_received()
605 JNIEnv *env, in s_aws_mqtt5_client_java_publish_callback_destructor() argument
610 if (callback_return_data->jni_publish_future && env != NULL) { in s_aws_mqtt5_client_java_publish_callback_destructor()
611 (*env)->DeleteGlobalRef(env, callback_return_data->jni_publish_future); in s_aws_mqtt5_client_java_publish_callback_destructor()
625 JNIEnv *env = NULL; in s_aws_mqtt5_client_java_publish_completion() local
640 /********** JNI ENV ACQUIRE **********/ in s_aws_mqtt5_client_java_publish_completion()
642 env = aws_jni_acquire_thread_env(jvm); in s_aws_mqtt5_client_java_publish_completion()
643 if (env == NULL) { in s_aws_mqtt5_client_java_publish_completion()
645 AWS_LOGF_ERROR(AWS_LS_MQTT5_CLIENT, "PublishCompletion function: could not get env"); in s_aws_mqtt5_client_java_publish_completion()
677 jint local_frame_result = (*env)->PushLocalFrame(env, (jint)references_needed); in s_aws_mqtt5_client_java_publish_completion()
692 publish_packet_result_data = (*env)->NewObject( in s_aws_mqtt5_client_java_publish_completion()
693 …env, mqtt5_publish_result_properties.result_class, mqtt5_publish_result_properties.result_construc… in s_aws_mqtt5_client_java_publish_completion()
694 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_publish_completion()
701 …jobject puback_packet_data = s_aws_mqtt5_client_create_jni_puback_packet_from_native(env, puback_p… in s_aws_mqtt5_client_java_publish_completion()
708 publish_packet_result_data = (*env)->NewObject( in s_aws_mqtt5_client_java_publish_completion()
709 env, in s_aws_mqtt5_client_java_publish_completion()
713 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_publish_completion()
722 (*env)->CallBooleanMethod( in s_aws_mqtt5_client_java_publish_completion()
723 …env, jni_publish_future, completable_future_properties.complete_method_id, publish_packet_result_d… in s_aws_mqtt5_client_java_publish_completion()
724 if (aws_jni_check_and_clear_exception(env)) { in s_aws_mqtt5_client_java_publish_completion()
732 s_complete_future_with_exception(env, &jni_publish_future, exception_error_code); in s_aws_mqtt5_client_java_publish_completion()
736 s_aws_mqtt5_client_java_publish_callback_destructor(env, return_data); in s_aws_mqtt5_client_java_publish_completion()
737 if (env != NULL) { in s_aws_mqtt5_client_java_publish_completion()
739 (*env)->PopLocalFrame(env, NULL); in s_aws_mqtt5_client_java_publish_completion()
741 /********** JNI ENV RELEASE **********/ in s_aws_mqtt5_client_java_publish_completion()
742 aws_jni_release_thread_env(jvm, env); in s_aws_mqtt5_client_java_publish_completion()
748 JNIEnv *env, in s_aws_mqtt5_client_java_subscribe_callback_destructor() argument
753 if (callback_return_data->jni_subscribe_future && env != NULL) { in s_aws_mqtt5_client_java_subscribe_callback_destructor()
754 (*env)->DeleteGlobalRef(env, callback_return_data->jni_subscribe_future); in s_aws_mqtt5_client_java_subscribe_callback_destructor()
766 JNIEnv *env = NULL; in s_aws_mqtt5_client_java_subscribe_completion() local
782 /********** JNI ENV ACQUIRE **********/ in s_aws_mqtt5_client_java_subscribe_completion()
784 env = aws_jni_acquire_thread_env(jvm); in s_aws_mqtt5_client_java_subscribe_completion()
785 if (env == NULL) { in s_aws_mqtt5_client_java_subscribe_completion()
787 AWS_LOGF_ERROR(AWS_LS_MQTT5_CLIENT, "SubscribeCompletion: could not get env"); in s_aws_mqtt5_client_java_subscribe_completion()
818 jint local_frame_result = (*env)->PushLocalFrame(env, (jint)references_needed); in s_aws_mqtt5_client_java_subscribe_completion()
831 suback_packet_data = (*env)->NewObject( in s_aws_mqtt5_client_java_subscribe_completion()
832 env, in s_aws_mqtt5_client_java_subscribe_completion()
837 env, in s_aws_mqtt5_client_java_subscribe_completion()
851 env, in s_aws_mqtt5_client_java_subscribe_completion()
867 env, in s_aws_mqtt5_client_java_subscribe_completion()
879 (*env)->CallBooleanMethod( in s_aws_mqtt5_client_java_subscribe_completion()
880 … env, jni_subscribe_future, completable_future_properties.complete_method_id, suback_packet_data); in s_aws_mqtt5_client_java_subscribe_completion()
881 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_subscribe_completion()
886 s_complete_future_with_exception(env, &jni_subscribe_future, exception_error_code); in s_aws_mqtt5_client_java_subscribe_completion()
890 s_aws_mqtt5_client_java_subscribe_callback_destructor(env, return_data); in s_aws_mqtt5_client_java_subscribe_completion()
891 if (env != NULL) { in s_aws_mqtt5_client_java_subscribe_completion()
893 (*env)->PopLocalFrame(env, NULL); in s_aws_mqtt5_client_java_subscribe_completion()
895 /********** JNI ENV RELEASE **********/ in s_aws_mqtt5_client_java_subscribe_completion()
896 aws_jni_release_thread_env(jvm, env); in s_aws_mqtt5_client_java_subscribe_completion()
901 JNIEnv *env, in s_aws_mqtt5_client_java_unsubscribe_callback_destructor() argument
906 if (callback_return_data->jni_unsubscribe_future && env != NULL) { in s_aws_mqtt5_client_java_unsubscribe_callback_destructor()
907 (*env)->DeleteGlobalRef(env, callback_return_data->jni_unsubscribe_future); in s_aws_mqtt5_client_java_unsubscribe_callback_destructor()
919 JNIEnv *env = NULL; in s_aws_mqtt5_client_java_unsubscribe_completion() local
936 /********** JNI ENV ACQUIRE **********/ in s_aws_mqtt5_client_java_unsubscribe_completion()
938 env = aws_jni_acquire_thread_env(jvm); in s_aws_mqtt5_client_java_unsubscribe_completion()
939 if (env == NULL) { in s_aws_mqtt5_client_java_unsubscribe_completion()
941 AWS_LOGF_ERROR(AWS_LS_MQTT5_CLIENT, "UnsubscribeCompletion: could not get env"); in s_aws_mqtt5_client_java_unsubscribe_completion()
967 jint local_frame_result = (*env)->PushLocalFrame(env, (jint)references_needed); in s_aws_mqtt5_client_java_unsubscribe_completion()
981 jobject unsuback_packet_data = (*env)->NewObject( in s_aws_mqtt5_client_java_unsubscribe_completion()
982 env, in s_aws_mqtt5_client_java_unsubscribe_completion()
987 env, in s_aws_mqtt5_client_java_unsubscribe_completion()
1001 env, in s_aws_mqtt5_client_java_unsubscribe_completion()
1017 env, in s_aws_mqtt5_client_java_unsubscribe_completion()
1028 (*env)->CallBooleanMethod( in s_aws_mqtt5_client_java_unsubscribe_completion()
1029 …env, jni_unsubscribe_future, completable_future_properties.complete_method_id, unsuback_packet_dat… in s_aws_mqtt5_client_java_unsubscribe_completion()
1030 aws_jni_check_and_clear_exception(env); /* To hide JNI warning */ in s_aws_mqtt5_client_java_unsubscribe_completion()
1035 s_complete_future_with_exception(env, &jni_unsubscribe_future, exception_error_code); in s_aws_mqtt5_client_java_unsubscribe_completion()
1039 s_aws_mqtt5_client_java_unsubscribe_callback_destructor(env, return_data); in s_aws_mqtt5_client_java_unsubscribe_completion()
1040 if (env != NULL) { in s_aws_mqtt5_client_java_unsubscribe_completion()
1042 (*env)->PopLocalFrame(env, NULL); in s_aws_mqtt5_client_java_unsubscribe_completion()
1044 /********** JNI ENV RELEASE **********/ in s_aws_mqtt5_client_java_unsubscribe_completion()
1045 aws_jni_release_thread_env(jvm, env); in s_aws_mqtt5_client_java_unsubscribe_completion()
1057 /********** JNI ENV ACQUIRE **********/ in s_aws_mqtt5_client_java_termination()
1059 JNIEnv *env = aws_jni_acquire_thread_env(jvm); in s_aws_mqtt5_client_java_termination() local
1060 if (env == NULL) { in s_aws_mqtt5_client_java_termination()
1062 …ROR(AWS_LS_MQTT5_CLIENT, "MQTT5 client termination function in JNI called, but could not get env"); in s_aws_mqtt5_client_java_termination()
1066 … (*env)->CallVoidMethod(env, java_client->jni_client, crt_resource_properties.release_references); in s_aws_mqtt5_client_java_termination()
1070 aws_mqtt5_client_java_destroy(env, allocator, java_client); in s_aws_mqtt5_client_java_termination()
1072 /********** JNI ENV RELEASE **********/ in s_aws_mqtt5_client_java_termination()
1073 aws_jni_release_thread_env(jvm, env); in s_aws_mqtt5_client_java_termination()
1081 JNIEnv *env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStart() argument
1085 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStart()
1090 env, "Mqtt5Client.start: Invalid/null client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStart()
1095 env, "Mqtt5Client.start: Invalid/null native client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStart()
1102 …env, "Mqtt5Client.start: aws_mqtt5_client_start returned a non AWS_OP_SUCCESS code!", aws_last_err… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStart()
1107 JNIEnv *env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStop() argument
1112 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStop()
1118 env, "Mqtt5Client.stop: Invalid/null client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStop()
1123 env, "Mqtt5Client.stop: Invalid/null native client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStop()
1132 … aws_mqtt5_packet_disconnect_view_create_from_java(env, allocator, jni_disconnect_packet); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStop()
1135 env, "Mqtt5Client.stop: Invalid/null disconnect packet", aws_last_error()); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStop()
1144 …env, "Mqtt5Client.stop: aws_mqtt5_client_stop returned a non AWS_OP_SUCCESS code!", return_result); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStop()
1150 aws_mqtt5_packet_disconnect_view_java_destroy(env, allocator, java_disconnect_packet); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalStop()
1156 JNIEnv *env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish() argument
1162 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish()
1172 env, "Mqtt5Client.publish: Invalid/null client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish()
1177 env, "Mqtt5Client.publish: Invalid/null publish future", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish()
1195 return_data->jni_publish_future = (*env)->NewGlobalRef(env, jni_publish_future); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish()
1202 …java_publish_packet = aws_mqtt5_packet_publish_view_create_from_java(env, allocator, jni_publish_p… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish()
1221 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish()
1225 aws_mqtt5_packet_publish_view_java_destroy(env, allocator, java_publish_packet); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish()
1228 s_aws_mqtt5_client_java_publish_callback_destructor(env, return_data); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish()
1234 aws_mqtt5_packet_publish_view_java_destroy(env, allocator, java_publish_packet); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalPublish()
1239 JNIEnv *env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe() argument
1245 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe()
1255 env, "Mqtt5Client.subscribe: Invalid/null client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe()
1260 … env, "Mqtt5Client.subscribe: Invalid/null subscribe future", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe()
1278 return_data->jni_subscribe_future = (*env)->NewGlobalRef(env, jni_subscribe_future); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe()
1285 …java_subscribe_packet = aws_mqtt5_packet_subscribe_view_create_from_java(env, allocator, jni_subsc… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe()
1303 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe()
1307 aws_mqtt5_packet_subscribe_view_java_destroy(env, allocator, java_subscribe_packet); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe()
1310 s_aws_mqtt5_client_java_subscribe_callback_destructor(env, return_data); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe()
1316 aws_mqtt5_packet_subscribe_view_java_destroy(env, allocator, java_subscribe_packet); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalSubscribe()
1321 JNIEnv *env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe() argument
1327 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe()
1337 env, "Mqtt5Client.unsubscribe: Invalid/null client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe()
1342 … env, "Mqtt5Client.unsubscribe: Invalid/null unsubscribe future", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe()
1360 return_data->jni_unsubscribe_future = (*env)->NewGlobalRef(env, jni_unsubscribe_future); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe()
1368 aws_mqtt5_packet_unsubscribe_view_create_from_java(env, allocator, jni_unsubscribe_packet); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe()
1389 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe()
1393 aws_mqtt5_packet_unsubscribe_view_java_destroy(env, allocator, java_unsubscribe_packet); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe()
1396 s_aws_mqtt5_client_java_unsubscribe_callback_destructor(env, return_data); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe()
1402 aws_mqtt5_packet_unsubscribe_view_java_destroy(env, allocator, java_unsubscribe_packet); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalUnsubscribe()
1407 JNIEnv *env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics() argument
1411 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1416 … env, "Mqtt5Client.getOperationStatistics: Invalid/null client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1421 …env, "Mqtt5Client.getOperationStatistics: Invalid/null native client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1426 jobject jni_operation_statistics = (*env)->NewObject( in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1427 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1437 (*env)->SetLongField( in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1438 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1442 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1445 env, "Mqtt5Client.getOperationStatistics: could not create incomplete operation count"); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1449 (*env)->SetLongField( in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1450 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1454 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1457 env, "Mqtt5Client.getOperationStatistics: could not create incomplete operation size"); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1461 (*env)->SetLongField( in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1462 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1466 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1469 env, "Mqtt5Client.getOperationStatistics: could not create unacked operation count"); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1473 (*env)->SetLongField( in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1474 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1478 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1481 env, "Mqtt5Client.getOperationStatistics: could not create unacked operation size"); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalGetOperationStatistics()
1522 /********** JNI ENV ACQUIRE **********/ in s_aws_mqtt5_client_java_websocket_handshake_transform()
1523 JNIEnv *env = aws_jni_acquire_thread_env(java_client->jvm); in s_aws_mqtt5_client_java_websocket_handshake_transform() local
1524 if (env == NULL) { in s_aws_mqtt5_client_java_websocket_handshake_transform()
1541 jobject java_http_request = aws_java_http_request_from_native(env, request, NULL); in s_aws_mqtt5_client_java_websocket_handshake_transform()
1550 (*env)->CallVoidMethod( in s_aws_mqtt5_client_java_websocket_handshake_transform()
1551 …env, jni_client, mqtt5_client_properties.client_on_websocket_handshake_id, java_http_request, ws_h… in s_aws_mqtt5_client_java_websocket_handshake_transform()
1552 AWS_FATAL_ASSERT(!aws_jni_check_and_clear_exception(env)); in s_aws_mqtt5_client_java_websocket_handshake_transform()
1555 (*env)->DeleteLocalRef(env, java_http_request); in s_aws_mqtt5_client_java_websocket_handshake_transform()
1556 aws_jni_release_thread_env(java_client->jvm, env); in s_aws_mqtt5_client_java_websocket_handshake_transform()
1557 /********** JNI ENV RELEASE SUCCESS PATH **********/ in s_aws_mqtt5_client_java_websocket_handshake_transform()
1565 aws_jni_release_thread_env(java_client->jvm, env); in s_aws_mqtt5_client_java_websocket_handshake_transform()
1566 /********** JNI ENV RELEASE FAILURE PATH **********/ in s_aws_mqtt5_client_java_websocket_handshake_transform()
1570 JNIEnv *env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalWebsocketHandshakeComplete() argument
1578 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalWebsocketHandshakeComplete()
1589 …if ((*env)->IsInstanceOf(env, jni_throwable, crt_runtime_exception_properties.crt_runtime_exceptio… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalWebsocketHandshakeComplete()
1590 …error_code = (*env)->GetIntField(env, jni_throwable, crt_runtime_exception_properties.error_code_f… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalWebsocketHandshakeComplete()
1599 env, jni_marshalled_request, NULL, ws_handshake->http_request)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientInternalWebsocketHandshakeComplete()
1610 JNIEnv *env, in s_initialize_topic_aliasing_options() argument
1614 jobject jni_outbound_behavior = (*env)->GetObjectField( in s_initialize_topic_aliasing_options()
1615 …env, jni_topic_aliasing_options, mqtt5_topic_aliasing_options_properties.outbound_behavior_field_i… in s_initialize_topic_aliasing_options()
1617 jint enum_value = (*env)->CallIntMethod( in s_initialize_topic_aliasing_options()
1618 …env, jni_outbound_behavior, mqtt5_outbound_topic_alias_behavior_type_properties.get_value_method_i… in s_initialize_topic_aliasing_options()
1619 if (aws_jni_check_and_clear_exception(env)) { in s_initialize_topic_aliasing_options()
1628 jobject jni_outbound_cache_max_size = (*env)->GetObjectField( in s_initialize_topic_aliasing_options()
1629 …env, jni_topic_aliasing_options, mqtt5_topic_aliasing_options_properties.outbound_cache_max_size_f… in s_initialize_topic_aliasing_options()
1632 …(*env)->CallIntMethod(env, jni_outbound_cache_max_size, boxed_integer_properties.integer_get_value… in s_initialize_topic_aliasing_options()
1642 jobject jni_inbound_behavior = (*env)->GetObjectField( in s_initialize_topic_aliasing_options()
1643 …env, jni_topic_aliasing_options, mqtt5_topic_aliasing_options_properties.inbound_behavior_field_id… in s_initialize_topic_aliasing_options()
1645 jint enum_value = (*env)->CallIntMethod( in s_initialize_topic_aliasing_options()
1646 …env, jni_inbound_behavior, mqtt5_inbound_topic_alias_behavior_type_properties.get_value_method_id); in s_initialize_topic_aliasing_options()
1647 if (aws_jni_check_and_clear_exception(env)) { in s_initialize_topic_aliasing_options()
1656 jobject jni_inbound_cache_max_size = (*env)->GetObjectField( in s_initialize_topic_aliasing_options()
1657 …env, jni_topic_aliasing_options, mqtt5_topic_aliasing_options_properties.inbound_cache_max_size_fi… in s_initialize_topic_aliasing_options()
1660 …(*env)->CallIntMethod(env, jni_inbound_cache_max_size, boxed_integer_properties.integer_get_value_… in s_initialize_topic_aliasing_options()
1681 JNIEnv *env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew() argument
1688 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1707 jint local_frame_result = (*env)->PushLocalFrame(env, (jint)21); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1710 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1721 env, "MQTT5 client new: could not initialize new client", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1726 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1736 env, "MQTT5 client new: Could not get host name from options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1742 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1751 env, "MQTT5 client new: Could not get port from options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1760 env, "MQTT5 client new: no bootstrap found", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1764 … (*env)->CallLongMethod(env, jni_bootstrap, crt_resource_properties.get_native_handle_method_id); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1765 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1767 … env, "MQTT5 client new: could not get native handle for bootstrap", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1776 …(*env)->CallObjectMethod(env, jni_options, mqtt5_client_options_properties.options_get_socket_opti… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1777 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1779 env, "MQTT5 client new: error getting socket options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1784 …(*env)->CallLongMethod(env, jni_socket_options, crt_resource_properties.get_native_handle_method_i… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1785 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1787 …env, "MQTT5 client new: could not get native handle for socket options", AWS_ERROR_INVALID_ARGUMEN… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1802 …(*env)->CallObjectMethod(env, jni_options, mqtt5_client_options_properties.options_get_tls_options… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1803 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1805 env, "MQTT5 client new: error getting tls options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1810 … (*env)->CallLongMethod(env, jni_tls_options, crt_resource_properties.get_native_handle_method_id); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1811 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1813 … env, "MQTT5 client new: could not get native handle for tls options", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1827 …(*env)->GetObjectField(env, jni_options, mqtt5_client_options_properties.http_proxy_options_field_… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1828 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1830 env, "MQTT5 client new: error getting http proxy options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1835 …s_aws_mqtt5_http_proxy_options_create_from_java(env, allocator, java_client, jni_http_proxy_option… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1840 …env, "MQTT5 client new: http proxy connection type has to be set to tunnel", AWS_ERROR_INVALID_STA… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1846 …connect_options = aws_mqtt5_packet_connect_view_create_from_java(env, allocator, jni_connect_optio… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1847 if (connect_options != NULL || aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1851 env, "MQTT5 client new: error getting connect options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1858 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1868 … env, "MQTT5 client new: Could not get session behavior from options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1877 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1887 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1899 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1909 …env, "MQTT5 client new: Could not get offline queue behavior from options", AWS_ERROR_INVALID_STAT… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1918 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1928 … env, "MQTT5 client new: Could not get retry jitter mode from options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1937 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1946 …env, "MQTT5 client new: Could not get minimum reconnect delay from options", AWS_ERROR_INVALID_STA… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1955 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1964 …env, "MQTT5 client new: Could not get maximum reconnect delay from options", AWS_ERROR_INVALID_STA… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1973 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1982 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
1993 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2002 … env, "MQTT5 client new: Could not get ping timeout from options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2011 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2020 … env, "MQTT5 client new: Could not get ConnAck timeout from options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2029 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2038 … env, "MQTT5 client new: Could not get Ack timeout from options", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2045 jint jvmresult = (*env)->GetJavaVM(env, &java_client->jvm); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2047 …s_aws_mqtt5_client_log_and_throw_exception(env, "MQTT5 client new: Unable to get JVM", AWS_ERROR_I… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2050 java_client->jni_client = (*env)->NewGlobalRef(env, jni_client); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2060 … (*env)->GetObjectField(env, jni_client, mqtt5_client_properties.websocket_handshake_field_id); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2061 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2063 … env, "MQTT5 client new: error getting websocket handshake transform", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2072 … (*env)->GetObjectField(env, jni_options, mqtt5_client_options_properties.publish_events_field_id); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2073 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2075 env, "MQTT5 client new: error getting publish events", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2079 java_client->jni_publish_events = (*env)->NewGlobalRef(env, jni_publish_events); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2083 …(*env)->GetObjectField(env, jni_options, mqtt5_client_options_properties.lifecycle_events_field_id… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2084 if (aws_jni_check_and_clear_exception(env)) { in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2086 env, "MQTT5 client new: error getting lifecycle events", AWS_ERROR_INVALID_STATE); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2090 java_client->jni_lifecycle_events = (*env)->NewGlobalRef(env, jni_lifecycle_events); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2096 …(*env)->GetObjectField(env, jni_options, mqtt5_client_options_properties.topic_aliasing_options_fi… in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2099 …if (s_initialize_topic_aliasing_options(env, &topic_aliasing_options, jni_topic_aliasing_options) … in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2113 env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2123 aws_mqtt5_packet_connect_view_java_destroy(env, allocator, connect_options); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2124 s_aws_mqtt5_http_proxy_options_java_destroy(env, allocator, java_http_proxy_options); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2128 (*env)->PopLocalFrame(env, NULL); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2134 aws_mqtt5_client_java_destroy(env, allocator, java_client); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientNew()
2139 JNIEnv *env, in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientDestroy() argument
2143 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientDestroy()
2148 env, "MQTT5 client destroy: Invalid/null client", AWS_ERROR_INVALID_ARGUMENT); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientDestroy()
2157 aws_mqtt5_client_java_destroy(env, allocator, java_client); in Java_software_amazon_awssdk_crt_mqtt5_Mqtt5Client_mqtt5ClientDestroy()