| /external/grpc-grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 106 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message; member
128 if (*calld->recv_message != nullptr && calld->limits.max_recv_size >= 0 && in recv_message_ready()
129 (*calld->recv_message)->length() > in recv_message_ready()
134 (*calld->recv_message)->length(), calld->limits.max_recv_size); in recv_message_ready()
186 if (op->recv_message) { in start_transport_stream_op_batch()
188 op->payload->recv_message.recv_message_ready; in start_transport_stream_op_batch()
189 calld->recv_message = op->payload->recv_message.recv_message; in start_transport_stream_op_batch()
190 op->payload->recv_message.recv_message_ready = &calld->recv_message_ready; in start_transport_stream_op_batch()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | retry_streaming.cc | 185 op->data.recv_message.recv_message = &response_payload_recv; in test_retry_streaming()
230 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming()
252 op->data.recv_message.recv_message = &request2_payload_recv; in test_retry_streaming()
313 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming()
324 op->data.recv_message.recv_message = &request2_payload_recv; in test_retry_streaming()
348 op->data.recv_message.recv_message = &request3_payload_recv; in test_retry_streaming()
|
| D | retry_streaming_succeeds_before_replay_finished.cc | 179 op->data.recv_message.recv_message = &response_payload_recv; in test_retry_streaming_succeeds_before_replay_finished()
224 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming_succeeds_before_replay_finished()
246 op->data.recv_message.recv_message = &request2_payload_recv; in test_retry_streaming_succeeds_before_replay_finished()
268 op->data.recv_message.recv_message = &request3_payload_recv; in test_retry_streaming_succeeds_before_replay_finished()
333 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming_succeeds_before_replay_finished()
|
| D | retry_streaming_after_commit.cc | 178 op->data.recv_message.recv_message = &response_payload_recv; in test_retry_streaming_after_commit()
218 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming_after_commit()
258 op->data.recv_message.recv_message = &request2_payload_recv; in test_retry_streaming_after_commit()
290 op->data.recv_message.recv_message = &response2_payload_recv; in test_retry_streaming_after_commit()
|
| D | cancel_after_round_trip.cc | 179 op->data.recv_message.recv_message = &response_payload_recv; in test_cancel_after_round_trip()
197 op->data.recv_message.recv_message = &request_payload_recv; in test_cancel_after_round_trip()
234 op->data.recv_message.recv_message = &response_payload_recv; in test_cancel_after_round_trip()
|
| D | cancel_after_client_done.cc | 161 op->data.recv_message.recv_message = &response_payload_recv; in test_cancel_after_accept_and_writes_closed()
178 op->data.recv_message.recv_message = &request_payload_recv; in test_cancel_after_accept_and_writes_closed()
|
| D | cancel_after_accept.cc | 184 op->data.recv_message.recv_message = &response_payload_recv; in test_cancel_after_accept()
201 op->data.recv_message.recv_message = &request_payload_recv; in test_cancel_after_accept()
|
| D | call_creds.cc | 209 op->data.recv_message.recv_message = &response_payload_recv; in request_response_with_payload_and_call_creds()
251 op->data.recv_message.recv_message = &request_payload_recv; in request_response_with_payload_and_call_creds()
439 op->data.recv_message.recv_message = &response_payload_recv; in test_request_with_server_rejecting_client_creds()
|
| D | simple_metadata.cc | 166 op->data.recv_message.recv_message = &response_payload_recv; in test_request_response_with_metadata_and_payload()
197 op->data.recv_message.recv_message = &request_payload_recv; in test_request_response_with_metadata_and_payload()
|
| D | payload.cc | 164 op->data.recv_message.recv_message = &response_payload_recv; in request_response_with_payload()
194 op->data.recv_message.recv_message = &request_payload_recv; in request_response_with_payload()
|
| D | binary_metadata.cc | 172 op->data.recv_message.recv_message = &response_payload_recv; in test_request_response_with_metadata_and_payload()
203 op->data.recv_message.recv_message = &request_payload_recv; in test_request_response_with_metadata_and_payload()
|
| D | write_buffering.cc | 174 op->data.recv_message.recv_message = &request_payload_recv1; in test_invoke_request_with_payload()
205 op->data.recv_message.recv_message = &request_payload_recv2; in test_invoke_request_with_payload()
|
| D | stream_compression_payload.cc | 167 op->data.recv_message.recv_message = &response_payload_recv; in request_response_with_payload()
197 op->data.recv_message.recv_message = &request_payload_recv; in request_response_with_payload()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | channel_filter.h | 195 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message() const { in recv_message() function
196 return op_->recv_message ? op_->payload->recv_message.recv_message in recv_message()
200 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message) { in set_recv_message() argument
201 op_->recv_message = true; in set_recv_message()
202 op_->payload->recv_message.recv_message = recv_message; in set_recv_message()
|
| /external/grpc-grpc/src/cpp/ext/filters/census/ |
| D | client_filter.cc | 114 if (op->recv_message() != nullptr) { in StartTransportStreamOpBatch()
115 recv_message_ = op->op()->payload->recv_message.recv_message; in StartTransportStreamOpBatch()
117 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()
|
| D | server_filter.cc | 139 if (op->recv_message() != nullptr) { in StartTransportStreamOpBatch()
140 recv_message_ = op->op()->payload->recv_message.recv_message; in StartTransportStreamOpBatch()
142 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/http/server/ |
| D | http_server_filter.cc | 63 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message; member
290 calld->recv_message->reset(calld->read_stream.get()); in hs_recv_initial_metadata_ready()
316 calld->recv_message->reset(calld->read_stream.get()); in hs_recv_message_ready()
377 if (op->recv_message) { in hs_mutate_op()
378 calld->recv_message = op->payload->recv_message.recv_message; in hs_mutate_op()
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()
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 102 grpc_slice_buffer recv_message; member
173 grpc_slice_buffer_destroy_internal(&s->recv_message); in really_destroy_stream()
481 s->recv_message_op->payload->recv_message.recv_message_ready, in fail_helper_locked()
533 grpc_slice_buffer_destroy_internal(&receiver->recv_message); in message_transfer_locked()
535 grpc_slice_buffer_init(&receiver->recv_message); in message_transfer_locked()
552 grpc_slice_buffer_add(&receiver->recv_message, message_slice); in message_transfer_locked()
556 receiver->recv_stream.Init(&receiver->recv_message, 0); in message_transfer_locked()
557 receiver->recv_message_op->payload->recv_message.recv_message->reset( in message_transfer_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()
[all …]
|
| /external/grpc-grpc/test/core/end2end/fixtures/ |
| D | proxy.cc | 201 op.data.recv_message.recv_message = &pc->c2p_msg; in on_p2s_sent_message()
261 op.data.recv_message.recv_message = &pc->p2s_msg; in on_c2p_sent_message()
369 op.data.recv_message.recv_message = &pc->c2p_msg; in on_new_call()
377 op.data.recv_message.recv_message = &pc->p2s_msg; in on_new_call()
|
| /external/grpc-grpc/test/core/fling/ |
| D | client.cc | 68 op->data.recv_message.recv_message = &response_payload_recv; in init_ping_pong_request()
116 stream_step_ops[1].data.recv_message.recv_message = &response_payload_recv; in init_ping_pong_stream()
|
| D | server.cc | 98 op->data.recv_message.recv_message = &terminal_buffer; in handle_unary_method()
136 read_op.data.recv_message.recv_message = &payload_buffer; in start_read_op()
|
| /external/grpc-grpc/src/csharp/ext/ |
| D | grpc_csharp_ext.c | 61 grpc_byte_buffer* recv_message; member
209 grpc_byte_buffer_destroy(ctx->recv_message); in grpcsharp_batch_context_reset()
255 if (!ctx->recv_message) { in grpcsharp_batch_context_recv_message_length()
259 GPR_ASSERT(grpc_byte_buffer_reader_init(&reader, ctx->recv_message)); in grpcsharp_batch_context_recv_message_length()
276 GPR_ASSERT(grpc_byte_buffer_reader_init(&reader, ctx->recv_message)); in grpcsharp_batch_context_recv_message_to_buffer()
595 ops[4].data.recv_message.recv_message = &(ctx->recv_message); in grpcsharp_call_start_unary()
635 ops[2].data.recv_message.recv_message = &(ctx->recv_message); in grpcsharp_call_start_client_streaming()
816 ops[0].data.recv_message.recv_message = &(ctx->recv_message); in grpcsharp_call_recv_message()
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.h | 152 bool recv_message : 1; member
218 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message; member
221 } recv_message; member
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_call_create.cc | 204 op->data.recv_message.recv_message = &response_payload_recv; in BM_LameChannelCallCreateCore()
283 op->data.recv_message.recv_message = &response_payload_recv; in BM_LameChannelCallCreateCoreSeparateBatch()
633 if (op->recv_message) { in StartTransportStreamOp()
634 closures.Add(op->payload->recv_message.recv_message_ready, GRPC_ERROR_NONE, in StartTransportStreamOp()
749 grpc_byte_buffer* recv_message = nullptr; in BM_IsolatedCall_Unary() local
766 ops[4].data.recv_message.recv_message = &recv_message; in BM_IsolatedCall_Unary()
|
| /external/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 952 } else if (curr_op->recv_message && in op_can_be_run()
971 if (!curr_op->recv_message && in op_can_be_run()
1141 } else if (stream_op->recv_message && in execute_stream_op()
1146 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()
1208 stream_op->payload->recv_message.recv_message->reset( in execute_stream_op()
1211 stream_op->payload->recv_message.recv_message_ready, in execute_stream_op()
1264 stream_op->payload->recv_message.recv_message->reset( in execute_stream_op()
[all …]
|