Home
last modified time | relevance | path

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

/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/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/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/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/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/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/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/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/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
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc572 op.payload->recv_message.recv_message_ready = drain_start.get(); in BM_TransportStreamRecv()
Dbm_call_create.cc634 closures.Add(op->payload->recv_message.recv_message_ready, GRPC_ERROR_NONE, in StartTransportStreamOp()
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc1758 stream_op_payload->recv_message.recv_message_ready = in call_start_batch()