Home
last modified time | relevance | path

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

/third_party/grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc268 op.cancel_stream = true; in BM_StreamCreateDestroy()
270 op_payload.cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_StreamCreateDestroy()
353 op.cancel_stream = true; in BM_StreamCreateSendInitialMetadataDestroy()
354 op.payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_StreamCreateSendInitialMetadataDestroy()
388 op.cancel_stream = true; in BM_TransportEmptyOp()
389 op_payload.cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportEmptyOp()
472 op.cancel_stream = true; in BM_TransportStreamSend()
473 op.payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportStreamSend()
658 op.cancel_stream = true; in BM_TransportStreamRecv()
659 op.payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportStreamRecv()
/third_party/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc69 batch->cancel_stream = true; in SendCancelOpInCallCombiner()
70 batch->payload->cancel_stream.cancel_error = GRPC_ERROR_REF(error); in SendCancelOpInCallCombiner()
228 if (op->cancel_stream) { in grpc_deadline_state_client_start_transport_stream_op_batch()
309 if (op->cancel_stream) { in deadline_server_start_transport_stream_op_batch()
/third_party/grpc/src/core/lib/transport/
Dtransport.h171 cancel_stream(false), in grpc_transport_stream_op_batch()
208 bool cancel_stream : 1; member
323 } cancel_stream; member
Dtransport_op_string.cc109 if (op->cancel_stream) { in grpc_transport_stream_op_batch_string()
112 grpc_error_string(op->payload->cancel_stream.cancel_error))); in grpc_transport_stream_op_batch_string()
Dtransport.cc185 if (batch->cancel_stream) {
186 GRPC_ERROR_UNREF(batch->payload->cancel_stream.cancel_error);
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc438 if (batch->cancel_stream) { in CompressStartTransportStreamOpBatch()
440 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in CompressStartTransportStreamOpBatch()
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc422 batch->cancel_stream = true; in StartCancel()
423 batch->payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in StartCancel()
/third_party/grpc/src/core/lib/channel/
Dconnected_channel.cc123 if (batch->cancel_stream) { in connected_channel_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc990 } else if (curr_op->cancel_stream && in op_can_be_run()
1339 } else if (stream_op->cancel_stream && in execute_stream_op()
1352 GRPC_ERROR_REF(stream_op->payload->cancel_stream.cancel_error); in execute_stream_op()
/third_party/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc977 if (op->cancel_stream) { in perform_stream_op()
980 cancel_stream_locked(s, op->payload->cancel_stream.cancel_error); in perform_stream_op()
/third_party/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc2711 if (GPR_UNLIKELY(batch->cancel_stream)) { in StartTransportStreamOpBatch()
2719 GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in StartTransportStreamOpBatch()
3284 if (GPR_UNLIKELY(batch->cancel_stream)) { in StartTransportStreamOpBatch()
3291 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in StartTransportStreamOpBatch()
5104 if (GPR_UNLIKELY(batch->cancel_stream)) { in StartTransportStreamOpBatch()
5111 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in StartTransportStreamOpBatch()
/third_party/grpc/src/core/lib/surface/
Dcall.cc719 op->cancel_stream = true; in cancel_with_error()
720 op->payload->cancel_stream.cancel_error = error; in cancel_with_error()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1368 if (op->cancel_stream) { in perform_stream_op_locked()
1370 grpc_chttp2_cancel_stream(t, s, op_payload->cancel_stream.cancel_error); in perform_stream_op_locked()