Home
last modified time | relevance | path

Searched refs:GRPC_CLOSURE_RUN (Results 1 – 23 of 23) sorted by relevance

/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc59 GRPC_CLOSURE_RUN(calld->original_on_complete_for_send, GRPC_ERROR_REF(error)); in on_complete_for_send()
67 GRPC_CLOSURE_RUN(calld->original_recv_initial_metadata_ready, in recv_initial_metadata_ready()
/external/grpc-grpc/src/cpp/ext/filters/census/
Dclient_filter.cc61 GRPC_CLOSURE_RUN(calld->initial_on_done_recv_trailing_metadata_, in OnDoneRecvTrailingMetadataCb()
78 GRPC_CLOSURE_RUN(calld->initial_on_done_recv_message_, GRPC_ERROR_REF(error)); in OnDoneRecvMessageCb()
Dserver_filter.cc77 GRPC_CLOSURE_RUN(calld->initial_on_done_recv_message_, GRPC_ERROR_REF(error)); in OnDoneRecvMessageCb()
124 GRPC_CLOSURE_RUN(calld->initial_on_done_recv_initial_metadata_, in OnDoneRecvInitialMetadataCb()
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc304 GRPC_CLOSURE_RUN(calld->original_recv_initial_metadata_ready, err); in hs_recv_initial_metadata_ready()
319 GRPC_CLOSURE_RUN(calld->original_recv_message_ready, GRPC_ERROR_REF(err)); in hs_recv_message_ready()
337 GRPC_CLOSURE_RUN(calld->original_recv_trailing_metadata_ready, err); in hs_recv_trailing_metadata_ready()
/external/grpc-grpc/doc/core/
Dgrpc-error.md86 callbacks with `GRPC_CLOSURE_RUN` and `GRPC_CLOSURE_SCHED`. These functions are
91 GRPC_CLOSURE_RUN(exec_ctx, cb, error);
100 GRPC_CLOSURE_RUN(exec_ctx, cb, GRPC_ERROR_REF(error));
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_closure.cc89 GRPC_CLOSURE_RUN(&c, GRPC_ERROR_NONE); in BM_ClosureRunOnExecCtx()
101 GRPC_CLOSURE_RUN( in BM_ClosureCreateAndRun()
115 GRPC_CLOSURE_RUN( in BM_ClosureInitAndRun()
Dbm_chttp2_transport.cc276 GRPC_CLOSURE_RUN(next.get(), GRPC_ERROR_NONE); in BM_StreamCreateDestroy()
582 GRPC_CLOSURE_RUN(drain.get(), GRPC_ERROR_NONE); in BM_TransportStreamRecv()
603 GRPC_CLOSURE_RUN(drain.get(), GRPC_ERROR_NONE); in BM_TransportStreamRecv()
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc136 GRPC_CLOSURE_RUN(deadline_state->original_recv_trailing_metadata_ready, in recv_trailing_metadata_ready()
298 GRPC_CLOSURE_RUN(calld->next_recv_initial_metadata_ready, in recv_initial_metadata_ready()
/external/grpc-grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc187 GRPC_CLOSURE_RUN(calld->original_recv_initial_metadata_ready, in recv_initial_metadata_ready()
195 GRPC_CLOSURE_RUN(calld->original_recv_trailing_metadata_ready, err); in recv_trailing_metadata_ready()
/external/grpc-grpc/src/core/lib/iomgr/
Dclosure.h268 #define GRPC_CLOSURE_RUN(closure, error) \ macro
271 #define GRPC_CLOSURE_RUN(closure, error) grpc_closure_run(closure, error) macro
Dresource_quota.cc581 GRPC_CLOSURE_RUN(&slice_allocator->on_done, GRPC_ERROR_REF(error)); in ru_allocated_slices()
/external/grpc-grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc150 GRPC_CLOSURE_RUN(calld->next_recv_message_ready, error); in recv_message_ready()
161 GRPC_CLOSURE_RUN(calld->original_recv_trailing_metadata_ready, error); in recv_trailing_metadata_ready()
/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc160 GRPC_CLOSURE_RUN(calld->original_recv_initial_metadata_ready, error); in recv_initial_metadata_ready()
174 GRPC_CLOSURE_RUN(calld->original_recv_trailing_metadata_ready, error); in recv_trailing_metadata_ready()
181 GRPC_CLOSURE_RUN(calld->original_send_message_on_complete, in send_message_on_complete()
/external/grpc-grpc/src/core/ext/filters/workarounds/
Dworkaround_cronet_compression_filter.cc73 GRPC_CLOSURE_RUN(calld->next_recv_initial_metadata_ready, in recv_initial_metadata_ready()
/external/grpc-grpc/test/core/end2end/tests/
Dfilter_causes_close.cc201 GRPC_CLOSURE_RUN( in recv_im_ready()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.cc277 GRPC_CLOSURE_RUN(c, GRPC_ERROR_REF(error));
/external/grpc-grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.cc266 GRPC_CLOSURE_RUN(calld->original_recv_initial_metadata_ready_, in RecvInitialMetadataReady()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1082 GRPC_CLOSURE_RUN( in write_action_end_locked()
1209 GRPC_CLOSURE_RUN(c, error); in null_then_run_closure()
1250 GRPC_CLOSURE_RUN(closure, closure->error_data.error); in grpc_chttp2_complete_closure_step()
1720 GRPC_CLOSURE_RUN(&t->start_keepalive_ping_locked, in send_keepalive_ping_locked()
1722 GRPC_CLOSURE_RUN(&t->finish_keepalive_ping_locked, in send_keepalive_ping_locked()
1729 GRPC_CLOSURE_RUN(&t->start_keepalive_ping_locked, GRPC_ERROR_NONE); in send_keepalive_ping_locked()
1830 GRPC_CLOSURE_RUN(op->on_consumed, GRPC_ERROR_NONE); in perform_transport_op_locked()
/external/grpc-grpc/test/core/iomgr/
Dresource_quota_test.cc65 GRPC_CLOSURE_RUN(a->then, GRPC_ERROR_NONE); in reclaimer_cb()
80 GRPC_CLOSURE_RUN(static_cast<grpc_closure*>(arg), GRPC_ERROR_NONE); in unused_reclaimer_cb()
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc204 GRPC_CLOSURE_RUN(calld->original_send_message_on_complete, in send_message_on_complete()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc1635 GRPC_CLOSURE_RUN(recv_initial_metadata_ready, GRPC_ERROR_REF(error)); in invoke_recv_initial_metadata_callback()
1727 GRPC_CLOSURE_RUN(recv_message_ready, GRPC_ERROR_REF(error)); in invoke_recv_message_callback()
2620 GRPC_CLOSURE_RUN(calld->original_recv_trailing_metadata, error); in recv_trailing_metadata_ready_channelz()
3411 GRPC_CLOSURE_RUN(w->watcher_timer_init, GRPC_ERROR_NONE); in watch_connectivity_state_locked()
/external/grpc-grpc/src/core/lib/surface/
Dserver.cc736 GRPC_CLOSURE_RUN(calld->on_done_recv_initial_metadata, error); in server_on_recv_initial_metadata()
744 GRPC_CLOSURE_RUN(calld->original_recv_trailing_metadata_ready, err); in server_recv_trailing_metadata_ready()
Dcall.cc1439 GRPC_CLOSURE_RUN(saved_rsr_closure, GRPC_ERROR_REF(error)); in receiving_initial_metadata_ready()