| /external/grpc-grpc/src/cpp/ext/filters/census/ |
| client_filter.cc | 114 if (op->recv_message() != nullptr) {
115 recv_message_ = op->op()->payload->recv_message.recv_message;
117 op->op()->payload->recv_message.recv_message_ready;
118 op->op()->payload->recv_message.recv_message_ready = &on_done_recv_message_;
|
| server_filter.cc | 139 if (op->recv_message() != nullptr) {
140 recv_message_ = op->op()->payload->recv_message.recv_message;
142 op->op()->payload->recv_message.recv_message_ready;
143 op->op()->payload->recv_message.recv_message_ready = &on_done_recv_message_;
|
| /external/grpc-grpc/src/core/ext/filters/message_size/ |
| message_size_filter.cc | 106 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message; member in struct:__anon23000::call_data
128 if (*calld->recv_message != nullptr && calld->limits.max_recv_size >= 0 &&
129 (*calld->recv_message)->length() >
134 (*calld->recv_message)->length(), calld->limits.max_recv_size);
186 if (op->recv_message) {
188 op->payload->recv_message.recv_message_ready;
189 calld->recv_message = op->payload->recv_message.recv_message;
190 op->payload->recv_message.recv_message_ready = &calld->recv_message_ready
[all...] |
| /external/grpc-grpc/src/cpp/common/ |
| channel_filter.h | 195 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message() const { function in class:grpc::TransportStreamOpBatch
196 return op_->recv_message ? op_->payload->recv_message.recv_message
200 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message) {
201 op_->recv_message = true;
202 op_->payload->recv_message.recv_message = recv_message;
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| retry_streaming.cc | 185 op->data.recv_message.recv_message = &response_payload_recv;
230 op->data.recv_message.recv_message = &request_payload_recv;
252 op->data.recv_message.recv_message = &request2_payload_recv;
313 op->data.recv_message.recv_message = &request_payload_recv;
324 op->data.recv_message.recv_message = &request2_payload_recv
[all...] |
| retry_streaming_succeeds_before_replay_finished.cc | 179 op->data.recv_message.recv_message = &response_payload_recv;
224 op->data.recv_message.recv_message = &request_payload_recv;
246 op->data.recv_message.recv_message = &request2_payload_recv;
268 op->data.recv_message.recv_message = &request3_payload_recv;
333 op->data.recv_message.recv_message = &request_payload_recv
[all...] |
| cancel_after_round_trip.cc | 179 op->data.recv_message.recv_message = &response_payload_recv;
197 op->data.recv_message.recv_message = &request_payload_recv;
234 op->data.recv_message.recv_message = &response_payload_recv;
|
| retry_streaming_after_commit.cc | 178 op->data.recv_message.recv_message = &response_payload_recv;
218 op->data.recv_message.recv_message = &request_payload_recv;
258 op->data.recv_message.recv_message = &request2_payload_recv;
290 op->data.recv_message.recv_message = &response2_payload_recv;
|
| cancel_after_client_done.cc | 161 op->data.recv_message.recv_message = &response_payload_recv;
178 op->data.recv_message.recv_message = &request_payload_recv;
|
| binary_metadata.cc | 172 op->data.recv_message.recv_message = &response_payload_recv;
203 op->data.recv_message.recv_message = &request_payload_recv;
|
| cancel_after_accept.cc | 184 op->data.recv_message.recv_message = &response_payload_recv;
201 op->data.recv_message.recv_message = &request_payload_recv;
|
| invoke_large_request.cc | 166 op->data.recv_message.recv_message = &response_payload_recv;
196 op->data.recv_message.recv_message = &request_payload_recv;
|
| load_reporting_hook.cc | 175 op->data.recv_message.recv_message = &response_payload_recv;
205 op->data.recv_message.recv_message = &request_payload_recv;
|
| payload.cc | 164 op->data.recv_message.recv_message = &response_payload_recv;
194 op->data.recv_message.recv_message = &request_payload_recv;
|
| ping_pong_streaming.cc | 183 op->data.recv_message.recv_message = &response_payload_recv;
194 op->data.recv_message.recv_message = &request_payload_recv;
|
| retry.cc | 173 op->data.recv_message.recv_message = &response_payload_recv;
271 op->data.recv_message.recv_message = &request_payload_recv;
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| http_server_filter.cc | 47 // If we see the recv_message contents in the GET query string, we
60 // State for intercepting recv_message.
63 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message; member in struct:__anon22995::call_data
286 // We've already seen the recv_message callback, but we previously
288 // Replace the recv_message byte stream if needed.
290 calld->recv_message->reset(calld->read_stream.get());
313 // replace the recv_message byte stream if needed and invoke the
314 // original recv_message callback immediately.
316 calld->recv_message->reset(calld->read_stream.get());
377 if (op->recv_message) {
[all...] |
| /external/grpc-grpc/src/core/lib/transport/ |
| transport.h | 128 The recv ops (recv_initial_metadata, recv_message, and
152 bool recv_message : 1; member in struct:grpc_transport_stream_op_batch
218 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message; member in struct:grpc_transport_stream_op_batch_payload::__anon23256
221 } recv_message; member in struct:grpc_transport_stream_op_batch_payload
|
| /external/grpc-grpc/src/core/lib/surface/ |
| call_log_batch.cc | 87 gpr_asprintf(&tmp, "RECV_MESSAGE ptr=%p",
88 op->data.recv_message.recv_message);
|
| /external/grpc-grpc/test/core/bad_client/tests/ |
| duplicate_header.cc | 86 op->data.recv_message.recv_message = &request_payload_recv;
|
| /external/grpc-grpc/test/core/fling/ |
| client.cc | 68 op->data.recv_message.recv_message = &response_payload_recv;
116 stream_step_ops[1].data.recv_message.recv_message = &response_payload_recv;
|
| server.cc | 98 op->data.recv_message.recv_message = &terminal_buffer;
136 read_op.data.recv_message.recv_message = &payload_buffer;
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| inproc_transport.cc | 102 grpc_slice_buffer recv_message; member in struct:inproc_stream
173 grpc_slice_buffer_destroy_internal(&s->recv_message);
481 s->recv_message_op->payload->recv_message.recv_message_ready,
533 grpc_slice_buffer_destroy_internal(&receiver->recv_message);
535 grpc_slice_buffer_init(&receiver->recv_message);
552 grpc_slice_buffer_add(&receiver->recv_message, message_slice);
556 receiver->recv_stream.Init(&receiver->recv_message, 0);
557 receiver->recv_message_op->payload->recv_message.recv_message->reset(
562 receiver->recv_message_op->payload->recv_message.recv_message_ready
[all...] |
| /external/grpc-grpc/test/core/end2end/fixtures/ |
| proxy.cc | 201 op.data.recv_message.recv_message = &pc->c2p_msg;
261 op.data.recv_message.recv_message = &pc->p2s_msg;
369 op.data.recv_message.recv_message = &pc->c2p_msg;
377 op.data.recv_message.recv_message = &pc->p2s_msg;
|
| /external/grpc-grpc/test/core/end2end/fuzzers/ |
| client_fuzzer.cc | 102 op->data.recv_message.recv_message = &response_payload_recv;
|
