Lines Matching full:env
39 static void s_shutdown_callback_data_destroy(JNIEnv *env, struct shutdown_callback_data *callback_d… in s_shutdown_callback_data_destroy() argument
46 (*env)->DeleteWeakGlobalRef(env, callback_data->java_server_listener); in s_shutdown_callback_data_destroy()
50 (*env)->DeleteGlobalRef(env, callback_data->java_listener_handler); in s_shutdown_callback_data_destroy()
63 static void s_server_connection_data_destroy(JNIEnv *env, struct connection_callback_data *callback… in s_server_connection_data_destroy() argument
69 (*env)->DeleteGlobalRef(env, callback_data->java_listener_handler); in s_server_connection_data_destroy()
73 (*env)->DeleteGlobalRef(env, callback_data->java_server_connection); in s_server_connection_data_destroy()
77 (*env)->DeleteGlobalRef(env, callback_data->java_connection_handler); in s_server_connection_data_destroy()
90 /********** JNI ENV ACQUIRE **********/ in s_server_listener_shutdown_complete()
91 JNIEnv *env = aws_jni_acquire_thread_env(callback_data->jvm); in s_server_listener_shutdown_complete() local
92 if (env == NULL) { in s_server_listener_shutdown_complete()
97 jobject java_server_listener = (*env)->NewLocalRef(env, callback_data->java_server_listener); in s_server_listener_shutdown_complete()
99 …(*env)->CallVoidMethod(env, java_server_listener, event_stream_server_listener_properties.onShutdo… in s_server_listener_shutdown_complete()
100 aws_jni_check_and_clear_exception(env); in s_server_listener_shutdown_complete()
101 (*env)->DeleteLocalRef(env, java_server_listener); in s_server_listener_shutdown_complete()
105 s_shutdown_callback_data_destroy(env, callback_data); in s_server_listener_shutdown_complete()
106 aws_jni_release_thread_env(jvm, env); in s_server_listener_shutdown_complete()
107 /********** JNI ENV RELEASE **********/ in s_server_listener_shutdown_complete()
116 static void s_server_continuation_data_destroy(JNIEnv *env, struct continuation_callback_data *call… in s_server_continuation_data_destroy() argument
122 (*env)->DeleteGlobalRef(env, callback_data->java_continuation_handler); in s_server_continuation_data_destroy()
126 (*env)->DeleteGlobalRef(env, callback_data->java_continuation); in s_server_continuation_data_destroy()
140 /********** JNI ENV ACQUIRE **********/ in s_stream_continuation_fn()
141 JNIEnv *env = aws_jni_acquire_thread_env(callback_data->jvm); in s_stream_continuation_fn() local
142 if (env == NULL) { in s_stream_continuation_fn()
148 aws_jni_get_allocator(), env, message_args->headers, message_args->headers_count); in s_stream_continuation_fn()
151 jbyteArray payload_byte_array = aws_jni_byte_array_from_cursor(env, &payload_cur); in s_stream_continuation_fn()
152 (*env)->CallVoidMethod( in s_stream_continuation_fn()
153 env, in s_stream_continuation_fn()
160 (*env)->DeleteLocalRef(env, headers_array); in s_stream_continuation_fn()
161 (*env)->DeleteLocalRef(env, payload_byte_array); in s_stream_continuation_fn()
163 aws_jni_check_and_clear_exception(env); in s_stream_continuation_fn()
165 aws_jni_release_thread_env(callback_data->jvm, env); in s_stream_continuation_fn()
166 /********** JNI ENV RELEASE **********/ in s_stream_continuation_fn()
175 /********** JNI ENV ACQUIRE **********/ in s_stream_continuation_closed_fn()
176 JNIEnv *env = aws_jni_acquire_thread_env(continuation_callback_data->jvm); in s_stream_continuation_closed_fn() local
177 if (env == NULL) { in s_stream_continuation_closed_fn()
182 (*env)->CallVoidMethod( in s_stream_continuation_closed_fn()
183 env, in s_stream_continuation_closed_fn()
187 aws_jni_check_and_clear_exception(env); in s_stream_continuation_closed_fn()
190 s_server_continuation_data_destroy(env, continuation_callback_data); in s_stream_continuation_closed_fn()
191 aws_jni_release_thread_env(jvm, env); in s_stream_continuation_closed_fn()
192 /********** JNI ENV RELEASE **********/ in s_stream_continuation_closed_fn()
208 /********** JNI ENV ACQUIRE **********/ in s_on_incoming_stream_fn()
209 JNIEnv *env = aws_jni_acquire_thread_env(callback_data->jvm); in s_on_incoming_stream_fn() local
210 if (env == NULL) { in s_on_incoming_stream_fn()
224 java_continuation = (*env)->NewObject( in s_on_incoming_stream_fn()
225 env, in s_on_incoming_stream_fn()
230 aws_jni_check_and_clear_exception(env); in s_on_incoming_stream_fn()
237 continuation_callback_data->java_continuation = (*env)->NewGlobalRef(env, java_continuation); in s_on_incoming_stream_fn()
244 jbyteArray operation_name_array = aws_jni_byte_array_from_cursor(env, &operation_name); in s_on_incoming_stream_fn()
246 java_continuation_handler = (*env)->CallObjectMethod( in s_on_incoming_stream_fn()
247 env, in s_on_incoming_stream_fn()
252 (*env)->DeleteLocalRef(env, operation_name_array); in s_on_incoming_stream_fn()
253 aws_jni_check_and_clear_exception(env); in s_on_incoming_stream_fn()
261 …continuation_callback_data->java_continuation_handler = (*env)->NewGlobalRef(env, java_continuatio… in s_on_incoming_stream_fn()
271 (*env)->DeleteLocalRef(env, java_continuation_handler); in s_on_incoming_stream_fn()
272 (*env)->DeleteLocalRef(env, java_continuation); in s_on_incoming_stream_fn()
274 aws_jni_release_thread_env(callback_data->jvm, env); in s_on_incoming_stream_fn()
275 /********** JNI ENV RELEASE SUCCESS PATH **********/ in s_on_incoming_stream_fn()
282 (*env)->DeleteLocalRef(env, java_continuation_handler); in s_on_incoming_stream_fn()
286 (*env)->DeleteLocalRef(env, java_continuation); in s_on_incoming_stream_fn()
290 s_server_continuation_data_destroy(env, continuation_callback_data); in s_on_incoming_stream_fn()
292 aws_jni_release_thread_env(callback_data->jvm, env); in s_on_incoming_stream_fn()
293 /********** JNI ENV RELEASE FAILURE PATH **********/ in s_on_incoming_stream_fn()
306 /********** JNI ENV ACQUIRE **********/ in s_connection_protocol_message_fn()
307 JNIEnv *env = aws_jni_acquire_thread_env(callback_data->jvm); in s_connection_protocol_message_fn() local
308 if (env == NULL) { in s_connection_protocol_message_fn()
314 aws_jni_get_allocator(), env, message_args->headers, message_args->headers_count); in s_connection_protocol_message_fn()
317 jbyteArray payload_byte_array = aws_jni_byte_array_from_cursor(env, &payload_cur); in s_connection_protocol_message_fn()
319 (*env)->CallVoidMethod( in s_connection_protocol_message_fn()
320 env, in s_connection_protocol_message_fn()
327 (*env)->DeleteLocalRef(env, headers_array); in s_connection_protocol_message_fn()
328 (*env)->DeleteLocalRef(env, payload_byte_array); in s_connection_protocol_message_fn()
330 aws_jni_check_and_clear_exception(env); in s_connection_protocol_message_fn()
332 aws_jni_release_thread_env(callback_data->jvm, env); in s_connection_protocol_message_fn()
333 /********** JNI ENV RELEASE **********/ in s_connection_protocol_message_fn()
344 /********** JNI ENV ACQUIRE **********/ in s_on_new_connection_fn()
345 JNIEnv *env = aws_jni_acquire_thread_env(callback_data->jvm); in s_on_new_connection_fn() local
346 if (env == NULL) { in s_on_new_connection_fn()
362 …connection_callback_data->java_listener_handler = (*env)->NewGlobalRef(env, callback_data->java_li… in s_on_new_connection_fn()
365 java_server_connection = (*env)->NewObject( in s_on_new_connection_fn()
366 env, in s_on_new_connection_fn()
370 if (aws_jni_check_and_clear_exception(env) || java_server_connection == NULL) { in s_on_new_connection_fn()
375 …connection_callback_data->java_server_connection = (*env)->NewGlobalRef(env, java_server_connectio… in s_on_new_connection_fn()
378 java_connection_handler = (*env)->CallObjectMethod( in s_on_new_connection_fn()
379 env, in s_on_new_connection_fn()
386 aws_jni_check_and_clear_exception(env); in s_on_new_connection_fn()
393 …connection_callback_data->java_connection_handler = (*env)->NewGlobalRef(env, java_connection_hand… in s_on_new_connection_fn()
404 (*env)->DeleteLocalRef(env, java_connection_handler); in s_on_new_connection_fn()
405 (*env)->DeleteLocalRef(env, java_server_connection); in s_on_new_connection_fn()
407 aws_jni_release_thread_env(callback_data->jvm, env); in s_on_new_connection_fn()
408 /********** JNI ENV RELEASE SUCCESS PATH **********/ in s_on_new_connection_fn()
415 (*env)->DeleteLocalRef(env, java_connection_handler); in s_on_new_connection_fn()
419 (*env)->DeleteLocalRef(env, java_server_connection); in s_on_new_connection_fn()
422 s_server_connection_data_destroy(env, connection_callback_data); in s_on_new_connection_fn()
424 aws_jni_release_thread_env(callback_data->jvm, env); in s_on_new_connection_fn()
425 /********** JNI ENV RELEASE ERROR PATH **********/ in s_on_new_connection_fn()
442 /********** JNI ENV ACQUIRE **********/ in s_on_connection_shutdown_fn()
443 JNIEnv *env = aws_jni_acquire_thread_env(callback_data->jvm); in s_on_connection_shutdown_fn() local
444 if (env == NULL) { in s_on_connection_shutdown_fn()
449 jobject java_listener_handler = (*env)->NewLocalRef(env, callback_data->java_listener_handler); in s_on_connection_shutdown_fn()
450 … jobject java_server_connection = (*env)->NewLocalRef(env, callback_data->java_server_connection); in s_on_connection_shutdown_fn()
456 (*env)->CallVoidMethod( in s_on_connection_shutdown_fn()
457 env, in s_on_connection_shutdown_fn()
462 aws_jni_check_and_clear_exception(env); in s_on_connection_shutdown_fn()
464 (*env)->DeleteLocalRef(env, java_server_connection); in s_on_connection_shutdown_fn()
465 (*env)->DeleteLocalRef(env, java_listener_handler); in s_on_connection_shutdown_fn()
469 s_server_connection_data_destroy(env, callback_data); in s_on_connection_shutdown_fn()
470 aws_jni_release_thread_env(jvm, env); in s_on_connection_shutdown_fn()
471 /********** JNI ENV RELEASE **********/ in s_on_connection_shutdown_fn()
476 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew() argument
486 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
493 …aws_jni_throw_runtime_exception(env, "ServerListener.server_listener_new: Invalid ServerBootstrap"… in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
498 … aws_jni_throw_runtime_exception(env, "ServerListener.server_listener_new: Invalid SocketOptions"); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
516 … aws_jni_throw_runtime_exception(env, "ServerListener.server_listener_new: Unable to allocate"); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
520 jint jvmresult = (*env)->GetJavaVM(env, &callback_data->jvm); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
522 … aws_jni_throw_runtime_exception(env, "ServerListener.server_listener_new: Unable to get JVM"); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
526 callback_data->java_server_listener = (*env)->NewWeakGlobalRef(env, jni_server_listener); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
528 …aws_jni_throw_runtime_exception(env, "ServerListener.server_listener_new: Unable to create global … in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
532 callback_data->java_listener_handler = (*env)->NewGlobalRef(env, jni_server_listener_handler); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
534 …aws_jni_throw_runtime_exception(env, "ServerListener.server_listener_new: Unable to create global … in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
538 const size_t host_name_len = (*env)->GetArrayLength(env, jni_host_name); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
539 jbyte *host_name = (*env)->GetPrimitiveArrayCritical(env, jni_host_name, NULL); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
541 (*env)->ReleasePrimitiveArrayCritical(env, jni_host_name, host_name, 0); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
544 … aws_jni_throw_runtime_exception(env, "ServerListener.server_listener_new: Unable to allocate"); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
569 …env, "ServerBootstrap.server_bootstrap_new: Unable to allocate new aws_event_stream_rpc_server_lis… in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
584 s_shutdown_callback_data_destroy(env, callback_data); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_serverListenerNew()
590 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerListener_getBoundPort() argument
593 (void)env; in Java_software_amazon_awssdk_crt_eventstream_ServerListener_getBoundPort()
595 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_getBoundPort()
600 aws_jni_throw_runtime_exception(env, "ServerListener.getBoundPort: Invalid serverListener"); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_getBoundPort()
609 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerListener_release() argument
612 (void)env; in Java_software_amazon_awssdk_crt_eventstream_ServerListener_release()
614 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerListener_release()
627 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_acquire() argument
630 (void)env; in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_acquire()
632 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_acquire()
645 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_release() argument
648 (void)env; in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_release()
650 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_release()
663 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_closeConnection() argument
667 (void)env; in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_closeConnection()
669 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_closeConnection()
682 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_isOpen() argument
685 (void)env; in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_isOpen()
687 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_isOpen()
704 static void s_destroy_message_flush_callback_args(JNIEnv *env, struct message_flush_callback_args *… in s_destroy_message_flush_callback_args() argument
710 (*env)->DeleteGlobalRef(env, callback_args->callback); in s_destroy_message_flush_callback_args()
719 /********** JNI ENV ACQUIRE **********/ in s_message_flush_fn()
720 JNIEnv *env = aws_jni_acquire_thread_env(callback_data->jvm); in s_message_flush_fn() local
721 if (env == NULL) { in s_message_flush_fn()
726 (*env)->CallVoidMethod( in s_message_flush_fn()
727 … env, callback_data->callback, event_stream_server_message_flush_properties.callback, error_code); in s_message_flush_fn()
728 aws_jni_check_and_clear_exception(env); in s_message_flush_fn()
731 s_destroy_message_flush_callback_args(env, callback_data); in s_message_flush_fn()
732 aws_jni_release_thread_env(jvm, env); in s_message_flush_fn()
733 /********** JNI ENV RELEASE **********/ in s_message_flush_fn()
738 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage() argument
747 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
757 …&marshalled_message, aws_jni_get_allocator(), env, headers, payload, NULL, message_flags, message_… in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
762 …aws_jni_throw_runtime_exception(env, "ServerConnection.sendProtocolMessage: native connection is N… in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
769 … aws_jni_throw_runtime_exception(env, "ServerConnection.sendProtocolMessage: allocation failed."); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
773 jint jvmresult = (*env)->GetJavaVM(env, &callback_data->jvm); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
775 … aws_jni_throw_runtime_exception(env, "ServerConnection.sendProtocolMessage: Unable to get JVM"); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
779 callback_data->callback = (*env)->NewGlobalRef(env, callback); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
782 env, "ServerConnection.sendProtocolMessage: Unable to create global ref to callback"); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
788 … aws_jni_throw_runtime_exception(env, "ServerConnection.sendProtocolMessage: send message failed"); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
798 s_destroy_message_flush_callback_args(env, callback_data); in Java_software_amazon_awssdk_crt_eventstream_ServerConnection_sendProtocolMessage()
806 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_acquire() argument
809 (void)env; in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_acquire()
811 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_acquire()
820 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_release() argument
823 (void)env; in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_release()
825 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_release()
834 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_isClosed() argument
837 (void)env; in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_isClosed()
839 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_isClosed()
853 JNIEnv *env, in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage() argument
862 aws_cache_jni_ids(env); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()
873 …&marshalled_message, aws_jni_get_allocator(), env, headers, payload, NULL, message_flags, message_… in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()
878 …aws_jni_throw_runtime_exception(env, "ServerConnection.sendContinuationMessage: native continuatio… in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()
885 env, "ServerConnectionContinuation.sendContinuationMessage: allocation failed."); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()
889 jint jvmresult = (*env)->GetJavaVM(env, &callback_data->jvm); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()
891 …aws_jni_throw_runtime_exception(env, "ServerConnectionContinuation.sendContinuationMessage: Unable… in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()
895 callback_data->callback = (*env)->NewGlobalRef(env, callback); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()
898 … env, "ServerConnection.sendContinuationMessage: Unable to create global ref to callback"); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()
905 env, "ServerConnectionContinuation.sendContinuationMessage: send message failed"); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()
914 s_destroy_message_flush_callback_args(env, callback_data); in Java_software_amazon_awssdk_crt_eventstream_ServerConnectionContinuation_sendContinuationMessage()