Searched refs:stream_op (Results 1 – 3 of 3) sorted by relevance
993 grpc_transport_stream_op_batch* stream_op = &oas->op; in execute_stream_op() local998 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 …]
1485 grpc_transport_stream_op_batch* stream_op; in call_start_batch() local1512 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 …]
1360 static void perform_stream_op_locked(void* stream_op, in perform_stream_op_locked() argument1365 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() argument1793 grpc_transport_op* op = static_cast<grpc_transport_op*>(stream_op); in perform_transport_op_locked()