Home
last modified time | relevance | path

Searched refs:GRPC_ERROR_REF (Results 1 – 25 of 73) sorted by relevance

123

/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc385 GRPC_CLOSURE_SCHED(op->on_complete, GRPC_ERROR_REF(error)); in complete_if_batch_end_locked()
392 GRPC_CLOSURE_SCHED(&s->op_closure, GRPC_ERROR_REF(error)); in maybe_schedule_op_closure_locked()
420 other->cancel_other_error = GRPC_ERROR_REF(error); in fail_helper_locked()
424 s->write_buffer_cancel_error = GRPC_ERROR_REF(error); in fail_helper_locked()
454 err = GRPC_ERROR_REF(error); in fail_helper_locked()
482 GRPC_ERROR_REF(error)); in fail_helper_locked()
506 GRPC_ERROR_REF(error)); in fail_helper_locked()
547 cancel_stream_locked(sender, GRPC_ERROR_REF(error)); in message_transfer_locked()
596 fail_helper_locked(s, GRPC_ERROR_REF(s->cancel_self_error)); in op_state_machine()
599 fail_helper_locked(s, GRPC_ERROR_REF(s->cancel_other_error)); in op_state_machine()
[all …]
/external/grpc-grpc/test/core/end2end/fixtures/
Dhttp_proxy_fixture.cc183 grpc_endpoint_shutdown(conn->client_endpoint, GRPC_ERROR_REF(error)); in proxy_connection_failed()
188 grpc_endpoint_shutdown(conn->server_endpoint, GRPC_ERROR_REF(error)); in proxy_connection_failed()
202 "HTTP proxy client write", GRPC_ERROR_REF(error)); in on_client_write_done()
227 "HTTP proxy server write", GRPC_ERROR_REF(error)); in on_server_write_done()
252 GRPC_ERROR_REF(error)); in on_client_read_done()
283 GRPC_ERROR_REF(error)); in on_server_read_done()
314 GRPC_ERROR_REF(error)); in on_write_response_done()
342 GRPC_ERROR_REF(error)); in on_server_connect_done()
388 GRPC_ERROR_REF(error)); in on_read_request_done()
398 GRPC_ERROR_REF(error)); in on_read_request_done()
[all …]
/external/grpc-grpc/src/core/ext/transport/chttp2/client/
Dchttp2_connector.cc82 grpc_handshake_manager_shutdown(c->handshake_mgr, GRPC_ERROR_REF(why)); in chttp2_connector_shutdown()
87 grpc_endpoint_shutdown(c->endpoint, GRPC_ERROR_REF(why)); in chttp2_connector_shutdown()
106 grpc_endpoint_shutdown(args->endpoint, GRPC_ERROR_REF(error)); in on_handshake_done()
112 error = GRPC_ERROR_REF(error); in on_handshake_done()
179 error = GRPC_ERROR_REF(error); in connected()
186 grpc_endpoint_shutdown(c->endpoint, GRPC_ERROR_REF(error)); in connected()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc128 GRPC_LOG_IF_ERROR("watch_completion_error", GRPC_ERROR_REF(error)); in partly_done()
142 GRPC_ERROR_REF(error); in partly_done()
150 GRPC_ERROR_REF(error); in partly_done()
167 partly_done(static_cast<state_watcher*>(pw), true, GRPC_ERROR_REF(error)); in watch_complete()
171 partly_done(static_cast<state_watcher*>(pw), false, GRPC_ERROR_REF(error)); in timeout_complete()
Dclient_channel.cc169 /* check= */ 0, GRPC_ERROR_REF(error)); in set_channel_connectivity_state_locked()
173 GRPC_ERROR_REF(error)); in set_channel_connectivity_state_locked()
193 GRPC_ERROR_REF(error), "lb_changed"); in on_lb_policy_state_changed_locked()
491 on_resolver_shutdown_locked(chand, GRPC_ERROR_REF(error)); in on_resolver_result_changed_locked()
575 GRPC_CLOSURE_SCHED(op->send_ping.on_initiate, GRPC_ERROR_REF(error)); in start_transport_op_locked()
596 GRPC_CLOSURE_SCHED(op->send_ping.on_initiate, GRPC_ERROR_REF(error)); in start_transport_op_locked()
609 GRPC_ERROR_REF(op->disconnect_with_error), "disconnect"); in start_transport_op_locked()
613 GRPC_ERROR_REF(op->disconnect_with_error)); in start_transport_op_locked()
1226 batch, GRPC_ERROR_REF(error), calld->call_combiner); in fail_pending_batch_in_call_combiner()
1254 closures.Add(&batch->handler_private.closure, GRPC_ERROR_REF(error), in pending_batches_fail()
[all …]
Dhttp_connect_handshaker.cc110 grpc_endpoint_shutdown(handshaker->args->endpoint, GRPC_ERROR_REF(error)); in handshake_failed_locked()
130 handshake_failed_locked(handshaker, GRPC_ERROR_REF(error)); in on_write_done()
151 handshake_failed_locked(handshaker, GRPC_ERROR_REF(error)); in on_read_done()
243 grpc_endpoint_shutdown(handshaker->args->endpoint, GRPC_ERROR_REF(why)); in http_connect_handshaker_shutdown()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.cc223 GRPC_ERROR_REF(error), "failing recv_initial_metadata_ready");
227 GRPC_ERROR_REF(error), "failing recv_message_ready");
232 GRPC_ERROR_REF(error), "failing recv_trailing_metadata_ready");
235 closures.Add(batch->on_complete, GRPC_ERROR_REF(error),
251 GRPC_CLOSURE_SCHED(op->inner_on_complete, GRPC_ERROR_REF(error));
277 GRPC_CLOSURE_RUN(c, GRPC_ERROR_REF(error));
Dbyte_stream.cc64 return GRPC_ERROR_REF(shutdown_error_); in Pull()
124 return GRPC_ERROR_REF(shutdown_error_); in Pull()
149 shutdown_error_ = GRPC_ERROR_REF(error); in Shutdown()
Dconnectivity_state.cc96 *error = GRPC_ERROR_REF(tracker->current_error); in grpc_connectivity_state_get()
143 GRPC_CLOSURE_SCHED(notify, GRPC_ERROR_REF(tracker->current_error)); in grpc_connectivity_state_notify_on_state_change()
192 GRPC_CLOSURE_SCHED(w->notify, GRPC_ERROR_REF(tracker->current_error)); in grpc_connectivity_state_set()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc594 end_all_the_calls(t, GRPC_ERROR_REF(error)); in close_transport_locked()
595 cancel_pings(t, GRPC_ERROR_REF(error)); in close_transport_locked()
612 t->closed_with_error = GRPC_ERROR_REF(error); in close_transport_locked()
613 connectivity_state_set(t, GRPC_CHANNEL_SHUTDOWN, GRPC_ERROR_REF(error), in close_transport_locked()
641 grpc_endpoint_shutdown(t->ep, GRPC_ERROR_REF(error)); in close_transport_locked()
1059 close_transport_locked(t, GRPC_ERROR_REF(error)); in write_action_end_locked()
1090 grpc_chttp2_end_write(t, GRPC_ERROR_REF(error)); in write_action_end_locked()
1149 GRPC_ERROR_REF(t->goaway_error), "got_goaway"); in grpc_chttp2_add_incoming_goaway()
1693 grpc_closure_list_fail_all(&pq->lists[j], GRPC_ERROR_REF(error)); in cancel_pings()
1702 GRPC_CLOSURE_SCHED(on_initiate, GRPC_ERROR_REF(t->closed_with_error)); in send_ping_locked()
[all …]
/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()
71 GRPC_ERROR_REF(error)); in timer_callback()
137 GRPC_ERROR_REF(error)); in recv_trailing_metadata_ready()
170 GRPC_ERROR_REF(error), in start_timer_after_init()
299 GRPC_ERROR_REF(error)); in recv_initial_metadata_ready()
/external/grpc-grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc117 calld->error = GRPC_ERROR_REF(error); in on_md_processing_done_inner()
161 GRPC_ERROR_REF(error)); in cancel_call()
188 GRPC_ERROR_REF(error)); in recv_initial_metadata_ready()
194 err = grpc_error_add_child(GRPC_ERROR_REF(err), GRPC_ERROR_REF(calld->error)); in recv_trailing_metadata_ready()
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc205 GRPC_ERROR_REF(error)); in send_message_on_complete()
272 calld->send_message_batch, GRPC_ERROR_REF(error), calld->call_combiner); in fail_send_message_batch_in_call_combiner()
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()
373 batch, GRPC_ERROR_REF(calld->cancel_error), calld->call_combiner); in compress_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc284 calld->recv_initial_metadata_ready_error = GRPC_ERROR_REF(err); in hs_recv_initial_metadata_ready()
298 GRPC_ERROR_REF(err), in hs_recv_initial_metadata_ready()
302 GRPC_ERROR_REF(err); in hs_recv_initial_metadata_ready()
319 GRPC_CLOSURE_RUN(calld->original_recv_message_ready, GRPC_ERROR_REF(err)); in hs_recv_message_ready()
335 GRPC_ERROR_REF(err), in hs_recv_trailing_metadata_ready()
336 GRPC_ERROR_REF(calld->recv_initial_metadata_ready_error)); in hs_recv_trailing_metadata_ready()
/external/grpc-grpc/src/core/lib/iomgr/
Dcfstream_handle.cc157 open_event_.SetShutdown(GRPC_ERROR_REF(error)); in Shutdown()
158 read_event_.SetShutdown(GRPC_ERROR_REF(error)); in Shutdown()
159 write_event_.SetShutdown(GRPC_ERROR_REF(error)); in Shutdown()
Derror.h163 #define GRPC_ERROR_REF(err) grpc_error_ref(err, __FILE__, __LINE__) macro
168 #define GRPC_ERROR_REF(err) grpc_error_ref(err) macro
Dcall_combiner.cc159 GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_REF(original_error)); in grpc_call_combiner_set_notify_on_cancel()
206 GRPC_CLOSURE_SCHED(notify_on_cancel, GRPC_ERROR_REF(error)); in grpc_call_combiner_cancel()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc201 GRPC_CLOSURE_SCHED(pick->on_complete, GRPC_ERROR_REF(error)); in ShutdownLocked()
204 GRPC_ERROR_REF(error), "shutdown"); in ShutdownLocked()
473 ? GRPC_ERROR_REF(error) in ProcessConnectivityChangeLocked()
495 GRPC_ERROR_REF(error), "selected_changed"); in ProcessConnectivityChangeLocked()
531 GRPC_ERROR_REF(error), "exhausted_subchannels"); in ProcessConnectivityChangeLocked()
541 GRPC_ERROR_REF(error), in ProcessConnectivityChangeLocked()
/external/grpc-grpc/src/core/lib/channel/
Dhandshaker.cc129 grpc_handshake_manager_shutdown(head, GRPC_ERROR_REF(why)); in grpc_handshake_manager_pending_list_shutdown_all()
184 GRPC_ERROR_REF(why)); in grpc_handshake_manager_shutdown()
234 grpc_endpoint_shutdown(mgr->args.endpoint, GRPC_ERROR_REF(error)); in call_next_handshaker_locked()
275 bool done = call_next_handshaker_locked(mgr, GRPC_ERROR_REF(error)); in call_next_handshaker()
/external/grpc-grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc144 calld->error = GRPC_ERROR_REF(error); in recv_message_ready()
147 GRPC_ERROR_REF(error); in recv_message_ready()
159 grpc_error_add_child(GRPC_ERROR_REF(error), GRPC_ERROR_REF(calld->error)); in recv_trailing_metadata_ready()
/external/grpc-grpc/doc/core/
Dgrpc-error.md37 may explicitly take ownership of it by manually calling GRPC_ERROR_REF.
100 GRPC_CLOSURE_RUN(exec_ctx, cb, GRPC_ERROR_REF(error));
119 some_function(GRPC_ERROR_REF(error));
146 some_function(GRPC_ERROR_REF(error));
148 some_other_function(GRPC_ERROR_REF(error));
/external/grpc-grpc/src/core/lib/http/
Dhttpcli.cc146 next_address(req, GRPC_ERROR_REF(error)); in on_read()
159 next_address(req, GRPC_ERROR_REF(error)); in done_write()
186 next_address(req, GRPC_ERROR_REF(error)); in on_connected()
219 finish(req, GRPC_ERROR_REF(error)); in on_resolved()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc59 GRPC_CLOSURE_RUN(calld->original_on_complete_for_send, GRPC_ERROR_REF(error)); in on_complete_for_send()
68 GRPC_ERROR_REF(error)); in recv_initial_metadata_ready()
/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc156 calld->recv_initial_metadata_error = GRPC_ERROR_REF(error); in recv_initial_metadata_ready()
158 GRPC_ERROR_REF(error); in recv_initial_metadata_ready()
170 GRPC_ERROR_REF(error); in recv_trailing_metadata_ready()
173 error, GRPC_ERROR_REF(calld->recv_initial_metadata_error)); in recv_trailing_metadata_ready()
182 GRPC_ERROR_REF(error)); in send_message_on_complete()
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc417 cancel_with_error(call, GRPC_ERROR_REF(error)); in grpc_call_create()
670 grpc_call_combiner_cancel(&c->call_combiner, GRPC_ERROR_REF(error)); in cancel_with_error()
1029 set_final_status(call, GRPC_ERROR_REF(error)); in recv_trailing_filter()
1132 grpc_error* error = GRPC_ERROR_REF( in post_batch_completion()
1252 GRPC_LOG_IF_ERROR("receiving_slice_ready", GRPC_ERROR_REF(error)); in receiving_slice_ready()
1300 reinterpret_cast<gpr_atm>(GRPC_ERROR_REF(error))); in receiving_stream_ready()
1302 cancel_with_error(call, GRPC_ERROR_REF(error)); in receiving_stream_ready()
1409 reinterpret_cast<gpr_atm>(GRPC_ERROR_REF(error))); in receiving_initial_metadata_ready()
1411 cancel_with_error(call, GRPC_ERROR_REF(error)); in receiving_initial_metadata_ready()
1439 GRPC_CLOSURE_RUN(saved_rsr_closure, GRPC_ERROR_REF(error)); in receiving_initial_metadata_ready()
[all …]

123