| /third_party/grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 40 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()
|
| /third_party/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 52 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()
|
| /third_party/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 50 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()
|
| /third_party/grpc/src/cpp/ext/filters/census/ |
| D | server_filter.cc | 133 op->op()->payload->recv_message.recv_message_ready; in StartTransportStreamOpBatch()
134 op->op()->payload->recv_message.recv_message_ready = &on_done_recv_message_; in StartTransportStreamOpBatch()
|
| D | client_filter.cc | 127 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()
|
| /third_party/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 1190 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()
1452 op->payload->recv_message.recv_message_ready, in perform_stream_op()
|
| /third_party/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_decompress_filter.cc | 338 batch->payload->recv_message.recv_message_ready; in DecompressStartTransportStreamOpBatch()
339 batch->payload->recv_message.recv_message_ready = &on_recv_message_ready_; in DecompressStartTransportStreamOpBatch()
|
| /third_party/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 490 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()
|
| /third_party/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.cc | 359 payload_.recv_message.recv_message_ready = GRPC_CLOSURE_INIT( in StartCall()
482 payload_.recv_message.recv_message_ready = GRPC_CLOSURE_INIT( in DoneReadingRecvMessage()
|
| /third_party/grpc/src/core/lib/transport/ |
| D | transport.h | 299 grpc_closure* recv_message_ready = nullptr; member
|
| D | transport.cc | 196 closures.Add(batch->payload->recv_message.recv_message_ready,
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 627 grpc_closure recv_message_ready; member
3537 batch->payload->recv_message.recv_message_ready == nullptr) && in MaybeClearPendingBatch()
3968 batch->payload->recv_message.recv_message_ready != nullptr; in InvokeRecvMessageCallback()
3980 grpc_closure* recv_message_ready = in InvokeRecvMessageCallback() local
3981 pending->batch->payload->recv_message.recv_message_ready; in InvokeRecvMessageCallback()
3982 pending->batch->payload->recv_message.recv_message_ready = nullptr; in InvokeRecvMessageCallback()
3986 Closure::Run(DEBUG_LOCATION, recv_message_ready, GRPC_ERROR_REF(error)); in InvokeRecvMessageCallback()
4115 GRPC_CLOSURE_INIT(&retry_state->recv_message_ready, in AddClosuresForDeferredRecvCallbacks()
4119 closures->Add(&retry_state->recv_message_ready, in AddClosuresForDeferredRecvCallbacks()
4501 GRPC_CLOSURE_INIT(&retry_state->recv_message_ready, RecvMessageReady, in AddRetriableRecvMessageOp()
[all …]
|
| /third_party/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 675 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()
|
| D | internal.h | 558 grpc_closure* recv_message_ready = nullptr; member
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 600 op.payload->recv_message.recv_message_ready = drain_start.get(); in BM_TransportStreamRecv()
|
| D | bm_call_create.cc | 621 closures.Add(op->payload->recv_message.recv_message_ready, GRPC_ERROR_NONE, in StartTransportStreamOp()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | call.cc | 1850 stream_op_payload->recv_message.recv_message_ready = in call_start_batch()
|