| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 267 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/ |
| D | deadline_filter.cc | 56 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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 69 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()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | transport.h | 171 cancel_stream(false), in grpc_transport_stream_op_batch()
208 bool cancel_stream : 1; member
323 } cancel_stream; member
|
| D | transport_op_string.cc | 109 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()
|
| D | transport.cc | 185 if (batch->cancel_stream) {
186 GRPC_ERROR_UNREF(batch->payload->cancel_stream.cancel_error);
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.h | 159 bool cancel_stream : 1; member
244 } cancel_stream; member
|
| D | transport_op_string.cc | 114 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()
|
| D | transport.cc | 215 if (batch->cancel_stream) {
216 GRPC_ERROR_UNREF(batch->payload->cancel_stream.cancel_error);
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 438 if (batch->cancel_stream) { in CompressStartTransportStreamOpBatch()
440 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in CompressStartTransportStreamOpBatch()
|
| /external/grpc-grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 355 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/ |
| D | connected_channel.cc | 121 if (batch->cancel_stream) { in con_start_transport_stream_op_batch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.cc | 422 batch->cancel_stream = true; in StartCancel()
423 batch->payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in StartCancel()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 123 if (batch->cancel_stream) { in connected_channel_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | client_auth_filter.cc | 276 if (!batch->cancel_stream) { in auth_start_transport_stream_op_batch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 990 } 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()
|
| /external/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 956 } 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/ |
| D | inproc_transport.cc | 934 if (op->cancel_stream) { in perform_stream_op()
937 cancel_stream_locked(s, op->payload->cancel_stream.cancel_error); in perform_stream_op()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 977 if (op->cancel_stream) { in perform_stream_op()
980 cancel_stream_locked(s, op->payload->cancel_stream.cancel_error); in perform_stream_op()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 2711 if (GPR_UNLIKELY(batch->cancel_stream)) { in StartTransportStreamOpBatch()
2719 GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in StartTransportStreamOpBatch()
3278 if (GPR_UNLIKELY(batch->cancel_stream)) { in StartTransportStreamOpBatch()
3285 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in StartTransportStreamOpBatch()
5098 if (GPR_UNLIKELY(batch->cancel_stream)) { in StartTransportStreamOpBatch()
5105 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in StartTransportStreamOpBatch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | call.cc | 719 op->cancel_stream = true; in cancel_with_error()
720 op->payload->cancel_stream.cancel_error = error; in cancel_with_error()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 677 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/ |
| D | chttp2_transport.cc | 1404 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/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 1368 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()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 3130 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()
|