Home
last modified time | relevance | path

Searched refs:cancel_error (Results 1 – 22 of 22) sorted by relevance

/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc62 grpc_error* cancel_error; member
356 GRPC_ERROR_UNREF(calld->cancel_error); in compress_start_transport_stream_op_batch()
357 calld->cancel_error = in compress_start_transport_stream_op_batch()
358 GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in compress_start_transport_stream_op_batch()
365 GRPC_ERROR_REF(calld->cancel_error), "failing send_message op"); in compress_start_transport_stream_op_batch()
368 GRPC_ERROR_REF(calld->cancel_error)); in compress_start_transport_stream_op_batch()
371 } else if (calld->cancel_error != GRPC_ERROR_NONE) { in compress_start_transport_stream_op_batch()
373 batch, GRPC_ERROR_REF(calld->cancel_error), calld->call_combiner); in compress_start_transport_stream_op_batch()
429 calld->cancel_error = GRPC_ERROR_NONE; in init_call_elem()
446 GRPC_ERROR_UNREF(calld->cancel_error); in destroy_call_elem()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc269 op_payload.cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_StreamCreateDestroy()
344 op.payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_StreamCreateSendInitialMetadataDestroy()
379 op_payload.cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportEmptyOp()
455 op.payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportStreamSend()
631 op.payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in BM_TransportStreamRecv()
/external/grpc-grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc156 grpc_error* cancel_error; member
1289 error = GRPC_ERROR_REF(stream_state->cancel_error); in execute_stream_op()
1314 if (!stream_state->cancel_error) { in execute_stream_op()
1315 stream_state->cancel_error = in execute_stream_op()
1316 GRPC_ERROR_REF(stream_op->payload->cancel_stream.cancel_error); in execute_stream_op()
1323 GRPC_ERROR_REF(stream_state->cancel_error)); in execute_stream_op()
1376 s->state.cancel_error = nullptr; in init_stream()
1432 GRPC_ERROR_UNREF(s->state.cancel_error); in destroy_stream()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc168 grpc_error* cancel_error = GRPC_ERROR_NONE; member
1322 error = GRPC_ERROR_REF(stream_state->cancel_error); in execute_stream_op()
1350 if (!stream_state->cancel_error) { in execute_stream_op()
1351 stream_state->cancel_error = in execute_stream_op()
1352 GRPC_ERROR_REF(stream_op->payload->cancel_stream.cancel_error); in execute_stream_op()
1359 GRPC_ERROR_REF(stream_state->cancel_error)); in execute_stream_op()
1419 GRPC_ERROR_UNREF(state.cancel_error); in ~stream_obj()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport_op_string.cc112 grpc_error_string(op->payload->cancel_stream.cancel_error))); in grpc_transport_stream_op_batch_string()
Dtransport.h322 grpc_error* cancel_error = GRPC_ERROR_NONE; member
Dtransport.cc186 GRPC_ERROR_UNREF(batch->payload->cancel_stream.cancel_error);
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc930 grpc_error* cancel_error; member
1511 if (calld->cancel_error != GRPC_ERROR_NONE) { in maybe_retry()
3119 if (GPR_UNLIKELY(calld->cancel_error != GRPC_ERROR_NONE)) { in cc_start_transport_stream_op_batch()
3122 chand, calld, grpc_error_string(calld->cancel_error)); in cc_start_transport_stream_op_batch()
3126 batch, GRPC_ERROR_REF(calld->cancel_error), calld->call_combiner); in cc_start_transport_stream_op_batch()
3136 GRPC_ERROR_UNREF(calld->cancel_error); in cc_start_transport_stream_op_batch()
3137 calld->cancel_error = in cc_start_transport_stream_op_batch()
3138 GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in cc_start_transport_stream_op_batch()
3141 calld, grpc_error_string(calld->cancel_error)); in cc_start_transport_stream_op_batch()
3147 pending_batches_fail(elem, GRPC_ERROR_REF(calld->cancel_error), in cc_start_transport_stream_op_batch()
[all …]
/external/grpc-grpc/src/core/lib/transport/
Dtransport.h243 grpc_error* cancel_error; member
Dtransport_op_string.cc117 grpc_error_string(op->payload->cancel_stream.cancel_error); in grpc_transport_stream_op_batch_string()
Dtransport.cc216 GRPC_ERROR_UNREF(batch->payload->cancel_stream.cancel_error);
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc57 batch->payload->cancel_stream.cancel_error = GRPC_ERROR_REF(error); in send_cancel_op_in_call_combiner()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc70 batch->payload->cancel_stream.cancel_error = GRPC_ERROR_REF(error); in SendCancelOpInCallCombiner()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc440 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in CompressStartTransportStreamOpBatch()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc423 batch->payload->cancel_stream.cancel_error = GRPC_ERROR_CANCELLED; in StartCancel()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc980 cancel_stream_locked(s, op->payload->cancel_stream.cancel_error); in perform_stream_op()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc937 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/
Dclient_channel.cc2719 GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in StartTransportStreamOpBatch()
3285 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in StartTransportStreamOpBatch()
5105 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in StartTransportStreamOpBatch()
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc678 op->payload->cancel_stream.cancel_error = error; in cancel_with_error()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dcall.cc720 op->payload->cancel_stream.cancel_error = error; in cancel_with_error()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1370 grpc_chttp2_cancel_stream(t, s, op_payload->cancel_stream.cancel_error); in perform_stream_op_locked()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1406 grpc_chttp2_cancel_stream(t, s, op_payload->cancel_stream.cancel_error); in perform_stream_op_locked()