Searched refs:stream_op (Results 1 – 6 of 6) sorted by relevance
| /external/rust/crates/grpcio-sys/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 …]
|
| /external/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 993 grpc_transport_stream_op_batch* stream_op = &oas->op; in execute_stream_op() local
998 if (stream_op->send_initial_metadata && in execute_stream_op()
999 op_can_be_run(stream_op, s, &oas->state, OP_SEND_INITIAL_METADATA)) { in execute_stream_op()
1015 convert_metadata_to_cronet_headers(stream_op->payload->send_initial_metadata in execute_stream_op()
1033 if (!stream_op->send_message && !stream_op->send_trailing_metadata) { in execute_stream_op()
1038 } else if (stream_op->send_message && in execute_stream_op()
1039 op_can_be_run(stream_op, s, &oas->state, OP_SEND_MESSAGE)) { in execute_stream_op()
1049 if (1 != stream_op->payload->send_message.send_message->Next( in execute_stream_op()
1050 stream_op->payload->send_message.send_message->length(), in execute_stream_op()
1056 stream_op->payload->send_message.send_message->Pull(&slice)) { in execute_stream_op()
[all …]
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 1485 grpc_transport_stream_op_batch* stream_op; in call_start_batch() local
1512 stream_op = &bctl->op; in call_start_batch()
1567 stream_op->send_initial_metadata = true; in call_start_batch()
1613 stream_op->send_message = true; in call_start_batch()
1636 stream_op->send_trailing_metadata = true; in call_start_batch()
1662 stream_op->send_trailing_metadata = true; in call_start_batch()
1729 stream_op->recv_initial_metadata = true; in call_start_batch()
1752 stream_op->recv_message = true; in call_start_batch()
1785 stream_op->recv_trailing_metadata = true; in call_start_batch()
1815 stream_op->recv_trailing_metadata = true; in call_start_batch()
[all …]
|
| /external/rust/crates/grpcio-sys/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 …]
|
| /external/rust/crates/grpcio-sys/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()
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 1360 static void perform_stream_op_locked(void* stream_op, in perform_stream_op_locked() argument
1365 static_cast<grpc_transport_stream_op_batch*>(stream_op); in perform_stream_op_locked()
1791 static void perform_transport_op_locked(void* stream_op, in perform_transport_op_locked() argument
1793 grpc_transport_op* op = static_cast<grpc_transport_op*>(stream_op); in perform_transport_op_locked()
|