Home
last modified time | relevance | path

Searched refs:cancel_stream (Results 1 – 13 of 13) sorted by relevance

/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc267 op.cancel_stream = true; in BM_StreamCreateDestroy()
269 op_payload.cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_StreamCreateDestroy()
343 op.cancel_stream = true; in BM_StreamCreateSendInitialMetadataDestroy()
344 op.payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_StreamCreateSendInitialMetadataDestroy()
378 op.cancel_stream = true; in BM_TransportEmptyOp()
379 op_payload.cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportEmptyOp()
454 op.cancel_stream = true; in BM_TransportStreamSend()
455 op.payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportStreamSend()
630 op.cancel_stream = true; in BM_TransportStreamRecv()
631 op.payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportStreamRecv()
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc56 batch->cancel_stream = true; in send_cancel_op_in_call_combiner()
57 batch->payload->cancel_stream.cancel_error = GRPC_ERROR_REF(error); in send_cancel_op_in_call_combiner()
227 if (op->cancel_stream) { in grpc_deadline_state_client_start_transport_stream_op_batch()
306 if (op->cancel_stream) { in server_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.h159 bool cancel_stream : 1; member
244 } cancel_stream; member
Dtransport_op_string.cc114 if (op->cancel_stream) { in grpc_transport_stream_op_batch_string()
117 grpc_error_string(op->payload->cancel_stream.cancel_error); in grpc_transport_stream_op_batch_string()
Dtransport.cc215 if (batch->cancel_stream) {
216 GRPC_ERROR_UNREF(batch->payload->cancel_stream.cancel_error);
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc355 if (batch->cancel_stream) { in compress_start_transport_stream_op_batch()
358 GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in compress_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc121 if (batch->cancel_stream) { in con_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc276 if (!batch->cancel_stream) { in auth_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc956 } else if (curr_op->cancel_stream && in op_can_be_run()
1303 } else if (stream_op->cancel_stream && in execute_stream_op()
1316 GRPC_ERROR_REF(stream_op->payload->cancel_stream.cancel_error); in execute_stream_op()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc934 if (op->cancel_stream) { in perform_stream_op()
937 cancel_stream_locked(s, op->payload->cancel_stream.cancel_error); in perform_stream_op()
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc677 op->cancel_stream = true; in cancel_with_error()
678 op->payload->cancel_stream.cancel_error = error; in cancel_with_error()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1404 if (op->cancel_stream) { in perform_stream_op_locked()
1406 grpc_chttp2_cancel_stream(t, s, op_payload->cancel_stream.cancel_error); in perform_stream_op_locked()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc3130 if (GPR_UNLIKELY(batch->cancel_stream)) { in cc_start_transport_stream_op_batch()
3138 GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in cc_start_transport_stream_op_batch()