| /aosp_15_r20/external/aws-crt-java/src/native/ |
| H A D | http_request_response.c | 814 jobject async_callback; member
822 if (callback_data->async_callback) { in s_cleanup_http2_callback_data()
823 (*env)->DeleteGlobalRef(env, callback_data->async_callback); in s_cleanup_http2_callback_data()
832 jobject async_callback) { in s_new_http2_callback_data() argument
838 … callback_data->async_callback = async_callback ? (*env)->NewGlobalRef(env, async_callback) : NULL; in s_new_http2_callback_data()
839 AWS_FATAL_ASSERT(callback_data->async_callback != NULL); in s_new_http2_callback_data()
858 …(*env)->CallVoidMethod(env, callback_data->async_callback, async_callback_properties.on_failure, c… in s_on_settings_completed()
861 … (*env)->CallVoidMethod(env, callback_data->async_callback, async_callback_properties.on_success); in s_on_settings_completed()
945 …(*env)->CallVoidMethod(env, callback_data->async_callback, async_callback_properties.on_failure, c… in s_on_ping_completed()
952 callback_data->async_callback, in s_on_ping_completed()
|
| H A D | mqtt_connection.c | 41 jobject async_callback; member
106 jobject async_callback, in s_mqtt_jni_async_callback_new() argument
117 callback->async_callback = async_callback ? (*env)->NewGlobalRef(env, async_callback) : NULL; in s_mqtt_jni_async_callback_new()
130 if (callback->async_callback) { in s_mqtt_jni_async_callback_destroy()
131 (*env)->DeleteGlobalRef(env, callback->async_callback); in s_mqtt_jni_async_callback_destroy()
343 …ction_interrupted_internal(connect_callback->connection, 0, connect_callback->async_callback, env); in s_on_connection_disconnected()
712 if (callback->async_callback) { in s_deliver_ack_success()
713 (*env)->CallVoidMethod(env, callback->async_callback, async_callback_properties.on_success); in s_deliver_ack_success()
723 if (callback->async_callback) { in s_deliver_ack_failure()
725 …(*env)->CallVoidMethod(env, callback->async_callback, async_callback_properties.on_failure, jni_re… in s_deliver_ack_failure()
[all …]
|
| H A D | http2_stream_manager.c | 288 jobject async_callback) { in s_new_sm_acquire_stream_callback_data() argument
294 …callback_data->java_async_callback = async_callback ? (*env)->NewGlobalRef(env, async_callback) : … in s_new_sm_acquire_stream_callback_data()
|
| /aosp_15_r20/external/federated-compute/fcp/secagg/server/ |
| H A D | secagg_server_prng_running_state.cc | 101 std::function<void()> async_callback) { in SetAsyncCallback() argument
103 FCP_CHECK(async_callback != nullptr) << "async_callback is expected"; in SetAsyncCallback()
107 impl()->scheduler()->ScheduleCallback(async_callback); in SetAsyncCallback()
109 prng_done_callback_ = async_callback; in SetAsyncCallback()
|
| H A D | secagg_scheduler.h | 164 bool SetAsyncObserver(std::function<void()> async_callback) { in SetAsyncObserver() argument
178 async_callback_ = async_callback; in SetAsyncObserver()
183 RunSequential([async_callback, shared_this] { async_callback(); }); in SetAsyncObserver()
|
| H A D | secagg_server_r2_masked_input_coll_state.cc | 194 std::function<void()> async_callback) { in SetAsyncCallback() argument
196 return accumulator_->SetAsyncObserver(async_callback); in SetAsyncCallback()
|
| H A D | secagg_server.cc | 253 bool SecAggServer::SetAsyncCallback(std::function<void()> async_callback) { in SetAsyncCallback() argument
254 return state_->SetAsyncCallback(async_callback); in SetAsyncCallback()
|
| H A D | secagg_server_r2_masked_input_coll_state.h | 68 bool SetAsyncCallback(std::function<void()> async_callback) override;
|
| H A D | secagg_server_prng_running_state.h | 64 bool SetAsyncCallback(std::function<void()> async_callback) override;
|
| H A D | secagg_server.h | 194 bool SetAsyncCallback(std::function<void()> async_callback);
|
| H A D | secagg_server_state.h | 226 virtual bool SetAsyncCallback(std::function<void()> async_callback);
|
| H A D | secagg_server_state.cc | 243 bool SecAggServerState::SetAsyncCallback(std::function<void()> async_callback) { in SetAsyncCallback() argument
|
| /aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/client/ |
| H A D | local_client.h | 106 std::function<StatusOr<T>(const ExecutableRunOptions&)> async_callback) { in AsyncCallAndBlockHostUntilDone() argument
111 StatusOr<T> result = async_callback(options); in AsyncCallAndBlockHostUntilDone()
|
| /aosp_15_r20/external/skia/tests/ |
| H A D | ProtectedTest.cpp | 193 static void async_callback(void* c, std::unique_ptr<const SkSurface::AsyncReadResult> result) { in async_callback() function
225 async_callback, &cbContext); in DEF_GANESH_TEST_FOR_ALL_CONTEXTS()
|
| H A D | ReadWritePixelsGpuTest.cpp | 665 static void async_callback(void* c, std::unique_ptr<const SkImage::AsyncReadResult> result) { in async_callback() function
689 async_callback, &context); in DEF_GANESH_TEST_FOR_RENDERING_CONTEXTS()
763 async_callback, &asyncContext); in image_async_read_pixels()
892 &async_callback, &cbContext); in DEF_GANESH_TEST()
898 SkImage::RescaleMode::kNearest, &async_callback, &cbContext); in DEF_GANESH_TEST()
904 SkImage::RescaleMode::kNearest, &async_callback, &cbContext); in DEF_GANESH_TEST()
1466 async_callback, in DEF_GANESH_TEST_FOR_GL_CONTEXT()
|
| H A D | GrFinishedFlushTest.cpp | 163 static void async_callback(void* c, std::unique_ptr<const SkImage::AsyncReadResult> result) { in async_callback() function
216 async_callback, in DEF_GANESH_TEST_FOR_RENDERING_CONTEXTS()
|
| H A D | VkProtectedContextTest.cpp | 307 void async_callback(void* c, std::unique_ptr<const SkSurface::AsyncReadResult> result) { in async_callback() function
336 &async_callback, in async_read_from_protected_surface()
352 &async_callback, in async_read_from_protected_surface()
|
| /aosp_15_r20/external/skia/tests/graphite/ |
| H A D | ReadWritePixelsGraphiteTest.cpp | 517 static void async_callback(void* c, std::unique_ptr<const SkImage::AsyncReadResult> result) { in async_callback() function
555 async_callback, in DEF_CONDITIONAL_GRAPHITE_TEST_FOR_RENDERING_CONTEXTS()
624 async_callback, in DEF_CONDITIONAL_GRAPHITE_TEST_FOR_RENDERING_CONTEXTS()
|