Searched refs:stream_op (Results 1 – 3 of 3) sorted by relevance
| /third_party/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 1028 grpc_transport_stream_op_batch* stream_op = &oas->op; in execute_stream_op() local
1033 if (stream_op->send_initial_metadata && in execute_stream_op()
1034 op_can_be_run(stream_op, s, &oas->state, OP_SEND_INITIAL_METADATA)) { in execute_stream_op()
1051 stream_op->payload->send_initial_metadata.send_initial_metadata, in execute_stream_op()
1067 if (!stream_op->send_message && !stream_op->send_trailing_metadata) { in execute_stream_op()
1072 } else if (stream_op->send_message && in execute_stream_op()
1073 op_can_be_run(stream_op, s, &oas->state, OP_SEND_MESSAGE)) { in execute_stream_op()
1086 stream_op->payload->send_message.send_message->length()) { in execute_stream_op()
1090 if (!stream_op->payload->send_message.send_message->Next( in execute_stream_op()
1091 stream_op->payload->send_message.send_message->length(), in execute_stream_op()
[all …]
|
| /third_party/grpc/src/core/lib/surface/ |
| D | call.cc | 1566 grpc_transport_stream_op_batch* stream_op; in call_start_batch() local
1595 stream_op = &bctl->op; in call_start_batch()
1658 stream_op->send_initial_metadata = true; in call_start_batch()
1703 stream_op->send_message = true; in call_start_batch()
1726 stream_op->send_trailing_metadata = true; in call_start_batch()
1752 stream_op->send_trailing_metadata = true; in call_start_batch()
1821 stream_op->recv_initial_metadata = true; in call_start_batch()
1844 stream_op->recv_message = true; in call_start_batch()
1877 stream_op->recv_trailing_metadata = true; in call_start_batch()
1907 stream_op->recv_trailing_metadata = true; in call_start_batch()
[all …]
|
| /third_party/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 1331 static void perform_stream_op_locked(void* stream_op, in perform_stream_op_locked() argument
1336 static_cast<grpc_transport_stream_op_batch*>(stream_op); in perform_stream_op_locked()
1753 static void perform_transport_op_locked(void* stream_op, in perform_transport_op_locked() argument
1755 grpc_transport_op* op = static_cast<grpc_transport_op*>(stream_op); in perform_transport_op_locked()
|