Home
last modified time | relevance | path

Searched refs:recv_message_ready (Results 1 – 25 of 30) sorted by relevance

12

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc40 static void recv_message_ready(void* user_data, grpc_error* error);
147 GRPC_CLOSURE_INIT(&recv_message_ready, ::recv_message_ready, elem, in call_data()
179 grpc_closure recv_message_ready; member
197 static void recv_message_ready(void* user_data, grpc_error* error) { in recv_message_ready() function
278 op->payload->recv_message.recv_message_ready; in message_size_start_transport_stream_op_batch()
280 op->payload->recv_message.recv_message_ready = &calld->recv_message_ready; in message_size_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc101 grpc_closure recv_message_ready; member
125 static void recv_message_ready(void* user_data, grpc_error* error) { in recv_message_ready() function
188 op->payload->recv_message.recv_message_ready; in start_transport_stream_op_batch()
190 op->payload->recv_message.recv_message_ready = &calld->recv_message_ready; in start_transport_stream_op_batch()
212 GRPC_CLOSURE_INIT(&calld->recv_message_ready, recv_message_ready, elem, in init_call_elem()
/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc53 callback_state recv_message_ready; member
111 callback_state* state = &calld->recv_message_ready; in con_start_transport_stream_op_batch()
113 &batch->payload->recv_message.recv_message_ready); in con_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc62 grpc_closure recv_message_ready; member
380 op->payload->recv_message.recv_message_ready; in hs_mutate_op()
381 op->payload->recv_message.recv_message_ready = &calld->recv_message_ready; in hs_mutate_op()
421 GRPC_CLOSURE_INIT(&calld->recv_message_ready, hs_recv_message_ready, elem, in hs_init_call_elem()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dconnected_channel.cc52 callback_state recv_message_ready; member
113 callback_state* state = &calld->recv_message_ready; in connected_channel_start_transport_stream_op_batch()
115 &batch->payload->recv_message.recv_message_ready); in connected_channel_start_transport_stream_op_batch()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc50 GRPC_CLOSURE_INIT(&recv_message_ready, hs_recv_message_ready, elem, in call_data()
85 grpc_closure recv_message_ready; member
454 op->payload->recv_message.recv_message_ready; in hs_mutate_op()
455 op->payload->recv_message.recv_message_ready = &calld->recv_message_ready; in hs_mutate_op()
/external/grpc-grpc/src/cpp/ext/filters/census/
Dclient_filter.cc117 op->op()->payload->recv_message.recv_message_ready; in StartTransportStreamOpBatch()
118 op->op()->payload->recv_message.recv_message_ready = &on_done_recv_message_; in StartTransportStreamOpBatch()
Dserver_filter.cc142 op->op()->payload->recv_message.recv_message_ready; in StartTransportStreamOpBatch()
143 op->op()->payload->recv_message.recv_message_ready = &on_done_recv_message_; in StartTransportStreamOpBatch()
/external/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/
Dclient_filter.cc127 op->op()->payload->recv_message.recv_message_ready; in StartTransportStreamOpBatch()
128 op->op()->payload->recv_message.recv_message_ready = &on_done_recv_message_; in StartTransportStreamOpBatch()
Dserver_filter.cc144 op->op()->payload->recv_message.recv_message_ready; in StartTransportStreamOpBatch()
145 op->op()->payload->recv_message.recv_message_ready = &on_done_recv_message_; in StartTransportStreamOpBatch()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc338 batch->payload->recv_message.recv_message_ready; in DecompressStartTransportStreamOpBatch()
339 batch->payload->recv_message.recv_message_ready = &on_recv_message_ready_; in DecompressStartTransportStreamOpBatch()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc866 grpc_closure recv_message_ready; member
1328 batch->payload->recv_message.recv_message_ready == nullptr) && in maybe_clear_pending_batch()
1708 batch->payload->recv_message.recv_message_ready != nullptr; in invoke_recv_message_callback()
1721 grpc_closure* recv_message_ready = in invoke_recv_message_callback() local
1722 pending->batch->payload->recv_message.recv_message_ready; in invoke_recv_message_callback()
1723 pending->batch->payload->recv_message.recv_message_ready = nullptr; in invoke_recv_message_callback()
1727 GRPC_CLOSURE_RUN(recv_message_ready, GRPC_ERROR_REF(error)); in invoke_recv_message_callback()
1732 static void recv_message_ready(void* arg, grpc_error* error) { in recv_message_ready() function
1868 GRPC_CLOSURE_INIT(&retry_state->recv_message_ready, in add_closures_for_deferred_recv_callbacks()
1872 closures->Add(&retry_state->recv_message_ready, in add_closures_for_deferred_recv_callbacks()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc1190 DEBUG_LOCATION, stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1198 DEBUG_LOCATION, stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1207 DEBUG_LOCATION, stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1215 DEBUG_LOCATION, stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1258 stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1306 DEBUG_LOCATION, stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1451 op->payload->recv_message.recv_message_ready, in perform_stream_op()
/external/grpc-grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc1146 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1153 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1161 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1168 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1211 stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1266 GRPC_CLOSURE_SCHED(stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1410 GRPC_CLOSURE_SCHED(op->payload->recv_message.recv_message_ready, in perform_stream_op()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.h220 grpc_closure* recv_message_ready; member
Dtransport.cc226 closures.Add(batch->payload->recv_message.recv_message_ready,
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc490 s->recv_message_op->payload->recv_message.recv_message_ready, in fail_helper_locked()
573 receiver->recv_message_op->payload->recv_message.recv_message_ready, in message_transfer_locked()
769 s->recv_message_op->payload->recv_message.recv_message_ready, in op_state_machine_locked()
856 s->recv_message_op->payload->recv_message.recv_message_ready, in op_state_machine_locked()
1106 op->payload->recv_message.recv_message_ready, in perform_stream_op()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc481 s->recv_message_op->payload->recv_message.recv_message_ready, in fail_helper_locked()
562 receiver->recv_message_op->payload->recv_message.recv_message_ready, in message_transfer_locked()
753 s->recv_message_op->payload->recv_message.recv_message_ready, in op_state_machine()
814 s->recv_message_op->payload->recv_message.recv_message_ready, in op_state_machine()
1061 GRPC_CLOSURE_SCHED(op->payload->recv_message.recv_message_ready, in perform_stream_op()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport.h299 grpc_closure* recv_message_ready = nullptr; member
Dtransport.cc196 closures.Add(batch->payload->recv_message.recv_message_ready,
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc359 payload_.recv_message.recv_message_ready = GRPC_CLOSURE_INIT( in StartCall()
482 payload_.recv_message.recv_message_ready = GRPC_CLOSURE_INIT( in DoneReadingRecvMessage()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc627 grpc_closure recv_message_ready; member
3531 batch->payload->recv_message.recv_message_ready == nullptr) && in MaybeClearPendingBatch()
3962 batch->payload->recv_message.recv_message_ready != nullptr; in InvokeRecvMessageCallback()
3974 grpc_closure* recv_message_ready = in InvokeRecvMessageCallback() local
3975 pending->batch->payload->recv_message.recv_message_ready; in InvokeRecvMessageCallback()
3976 pending->batch->payload->recv_message.recv_message_ready = nullptr; in InvokeRecvMessageCallback()
3980 Closure::Run(DEBUG_LOCATION, recv_message_ready, GRPC_ERROR_REF(error)); in InvokeRecvMessageCallback()
4109 GRPC_CLOSURE_INIT(&retry_state->recv_message_ready, in AddClosuresForDeferredRecvCallbacks()
4113 closures->Add(&retry_state->recv_message_ready, in AddClosuresForDeferredRecvCallbacks()
4495 GRPC_CLOSURE_INIT(&retry_state->recv_message_ready, RecvMessageReady, in AddRetriableRecvMessageOp()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc675 GPR_ASSERT(recv_message_ready == nullptr); in ~grpc_chttp2_stream()
1542 GPR_ASSERT(s->recv_message_ready == nullptr); in perform_stream_op_locked()
1544 s->recv_message_ready = op_payload->recv_message.recv_message_ready; in perform_stream_op_locked()
1835 if (s->recv_message_ready != nullptr) { in grpc_chttp2_maybe_complete_recv_message()
1908 null_then_sched_closure(&s->recv_message_ready); in grpc_chttp2_maybe_complete_recv_message()
1911 null_then_sched_closure(&s->recv_message_ready); in grpc_chttp2_maybe_complete_recv_message()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc748 GPR_ASSERT(s->recv_message_ready == nullptr); in destroy_stream_locked()
1613 GPR_ASSERT(s->recv_message_ready == nullptr); in perform_stream_op_locked()
1615 s->recv_message_ready = op_payload->recv_message.recv_message_ready; in perform_stream_op_locked()
1874 if (s->recv_message_ready != nullptr) { in grpc_chttp2_maybe_complete_recv_message()
1947 null_then_run_closure(&s->recv_message_ready, GRPC_ERROR_NONE); in grpc_chttp2_maybe_complete_recv_message()
1950 null_then_run_closure(&s->recv_message_ready, GRPC_ERROR_NONE); in grpc_chttp2_maybe_complete_recv_message()
Dinternal.h515 grpc_closure* recv_message_ready; member

12