/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()
|