Home
last modified time | relevance | path

Searched refs:cancel_error (Results 1 – 11 of 11) 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/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/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/grpc-grpc/src/core/lib/surface/
Dcall.cc678 op->payload->cancel_stream.cancel_error = error; in cancel_with_error()
/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()