Home
last modified time | relevance | path

Searched refs:async_callback (Results 1 – 18 of 18) sorted by relevance

/aosp_15_r20/external/aws-crt-java/src/native/
H A Dhttp_request_response.c814 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 Dmqtt_connection.c41 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 Dhttp2_stream_manager.c288 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 Dsecagg_server_prng_running_state.cc101 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 Dsecagg_scheduler.h164 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 Dsecagg_server_r2_masked_input_coll_state.cc194 std::function<void()> async_callback) { in SetAsyncCallback() argument
196 return accumulator_->SetAsyncObserver(async_callback); in SetAsyncCallback()
H A Dsecagg_server.cc253 bool SecAggServer::SetAsyncCallback(std::function<void()> async_callback) { in SetAsyncCallback() argument
254 return state_->SetAsyncCallback(async_callback); in SetAsyncCallback()
H A Dsecagg_server_r2_masked_input_coll_state.h68 bool SetAsyncCallback(std::function<void()> async_callback) override;
H A Dsecagg_server_prng_running_state.h64 bool SetAsyncCallback(std::function<void()> async_callback) override;
H A Dsecagg_server.h194 bool SetAsyncCallback(std::function<void()> async_callback);
H A Dsecagg_server_state.h226 virtual bool SetAsyncCallback(std::function<void()> async_callback);
H A Dsecagg_server_state.cc243 bool SecAggServerState::SetAsyncCallback(std::function<void()> async_callback) { in SetAsyncCallback() argument
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/client/
H A Dlocal_client.h106 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 DProtectedTest.cpp193 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 DReadWritePixelsGpuTest.cpp665 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 DGrFinishedFlushTest.cpp163 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 DVkProtectedContextTest.cpp307 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 DReadWritePixelsGraphiteTest.cpp517 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()