Home
last modified time | relevance | path

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

1234567

/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dcfstream_handle.cc86 handle->open_event_.SetShutdown(GRPC_ERROR_REF(error)); in ReadCallback()
87 handle->write_event_.SetShutdown(GRPC_ERROR_REF(error)); in ReadCallback()
88 handle->read_event_.SetShutdown(GRPC_ERROR_REF(error)); in ReadCallback()
121 handle->open_event_.SetShutdown(GRPC_ERROR_REF(error)); in WriteCallback()
122 handle->write_event_.SetShutdown(GRPC_ERROR_REF(error)); in WriteCallback()
123 handle->read_event_.SetShutdown(GRPC_ERROR_REF(error)); in WriteCallback()
175 open_event_.SetShutdown(GRPC_ERROR_REF(error)); in Shutdown()
176 read_event_.SetShutdown(GRPC_ERROR_REF(error)); in Shutdown()
177 write_event_.SetShutdown(GRPC_ERROR_REF(error)); in Shutdown()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/tls/
Dgrpc_tls_certificate_distributor.cc124 watcher_ptr->OnError(GRPC_ERROR_REF(*root_cert_error), in SetErrorForCert()
125 GRPC_ERROR_REF(identity_cert_error_to_report)); in SetErrorForCert()
147 watcher_ptr->OnError(GRPC_ERROR_REF(root_cert_error_to_report), in SetErrorForCert()
148 GRPC_ERROR_REF(*identity_cert_error)); in SetErrorForCert()
162 watcher_info.root_cert_name.has_value() ? GRPC_ERROR_REF(error) in SetError()
164 watcher_info.identity_cert_name.has_value() ? GRPC_ERROR_REF(error) in SetError()
169 cert_info.SetRootError(GRPC_ERROR_REF(error)); in SetError()
170 cert_info.SetIdentityError(GRPC_ERROR_REF(error)); in SetError()
205 root_error = GRPC_ERROR_REF(cert_info.root_cert_error); in WatchTlsCertificates()
217 identity_error = GRPC_ERROR_REF(cert_info.identity_cert_error); in WatchTlsCertificates()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/client/
Dchttp2_connector.cc82 handshake_mgr_->Shutdown(GRPC_ERROR_REF(error)); in Shutdown()
87 grpc_endpoint_shutdown(endpoint_, GRPC_ERROR_REF(error)); in Shutdown()
103 error = GRPC_ERROR_REF(error); in Connected()
106 grpc_endpoint_shutdown(self->endpoint_, GRPC_ERROR_REF(error)); in Connected()
156 grpc_endpoint_shutdown(args->endpoint, GRPC_ERROR_REF(error)); in OnHandshakeDone()
163 error = GRPC_ERROR_REF(error); in OnHandshakeDone()
212 self->MaybeNotify(GRPC_ERROR_REF(error)); in OnReceiveSettings()
/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/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/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc393 GRPC_ERROR_REF(error)); in complete_if_batch_end_locked()
426 other->cancel_other_error = GRPC_ERROR_REF(error); in fail_helper_locked()
430 s->write_buffer_cancel_error = GRPC_ERROR_REF(error); in fail_helper_locked()
460 err = GRPC_ERROR_REF(error); in fail_helper_locked()
491 GRPC_ERROR_REF(error)); in fail_helper_locked()
517 GRPC_ERROR_REF(error)); in fail_helper_locked()
557 cancel_stream_locked(sender, GRPC_ERROR_REF(error)); in message_transfer_locked()
601 fail_helper_locked(s, GRPC_ERROR_REF(s->cancel_self_error)); in op_state_machine_locked()
604 fail_helper_locked(s, GRPC_ERROR_REF(s->cancel_other_error)); in op_state_machine_locked()
607 fail_helper_locked(s, GRPC_ERROR_REF(error)); in op_state_machine_locked()
[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/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc528 end_all_the_calls(t, GRPC_ERROR_REF(error)); in close_transport_locked()
529 cancel_pings(t, GRPC_ERROR_REF(error)); in close_transport_locked()
546 t->closed_with_error = GRPC_ERROR_REF(error); in close_transport_locked()
575 grpc_endpoint_shutdown(t->ep, GRPC_ERROR_REF(error)); in close_transport_locked()
579 GRPC_ERROR_REF(error)); in close_transport_locked()
976 GRPC_ERROR_REF(error)); in write_action_end()
987 close_transport_locked(t, GRPC_ERROR_REF(error)); in write_action_end_locked()
1026 grpc_chttp2_end_write(t, GRPC_ERROR_REF(error)); in write_action_end_locked()
1299 GRPC_ERROR_REF(error)); in complete_fetch()
1622 grpc_closure_list_fail_all(&pq->lists[j], GRPC_ERROR_REF(error)); in cancel_pings()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport.cc193 GRPC_ERROR_REF(error), "failing recv_initial_metadata_ready");
197 GRPC_ERROR_REF(error), "failing recv_message_ready");
202 GRPC_ERROR_REF(error), "failing recv_trailing_metadata_ready");
205 closures.Add(batch->on_complete, GRPC_ERROR_REF(error),
225 GRPC_ERROR_REF(error));
248 grpc_core::Closure::Run(DEBUG_LOCATION, c, GRPC_ERROR_REF(error));
Dbyte_stream.cc64 return GRPC_ERROR_REF(shutdown_error_); in Pull()
122 return GRPC_ERROR_REF(shutdown_error_); in Pull()
147 shutdown_error_ = GRPC_ERROR_REF(error); in Shutdown()
/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()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc165 Closure::Run(DEBUG_LOCATION, closure, GRPC_ERROR_REF(error)); in OnRecvInitialMetadataReady()
207 GRPC_ERROR_REF(calld->error_)); in OnRecvMessageReady()
214 calld->ContinueRecvMessageReadyCallback(GRPC_ERROR_REF(error)); in OnRecvMessageReady()
244 return calld->ContinueRecvMessageReadyCallback(GRPC_ERROR_REF(error)); in OnRecvMessageNextDone()
283 ContinueRecvMessageReadyCallback(GRPC_ERROR_REF(error_)); in FinishRecvMessage()
309 calld->on_recv_trailing_metadata_ready_error_ = GRPC_ERROR_REF(error); in OnRecvTrailingMetadataReady()
316 error = grpc_error_add_child(GRPC_ERROR_REF(error), calld->error_); in OnRecvTrailingMetadataReady()
Dmessage_compress_filter.cc289 GRPC_ERROR_REF(error)); in SendMessageOnComplete()
355 calld->send_message_batch_, GRPC_ERROR_REF(error), in FailSendMessageBatchInCallCombiner()
440 cancel_error_ = GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); in CompressStartTransportStreamOpBatch()
447 GRPC_ERROR_REF(cancel_error_), "failing send_message op"); in CompressStartTransportStreamOpBatch()
450 GRPC_ERROR_REF(cancel_error_)); in CompressStartTransportStreamOpBatch()
455 batch, GRPC_ERROR_REF(cancel_error_), call_combiner_); in CompressStartTransportStreamOpBatch()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc135 GRPC_LOG_IF_ERROR("watch_completion_error", GRPC_ERROR_REF(error)); in partly_done()
149 GRPC_ERROR_REF(error); in partly_done()
157 GRPC_ERROR_REF(error); in partly_done()
182 partly_done(static_cast<state_watcher*>(pw), true, GRPC_ERROR_REF(error)); in watch_complete()
186 partly_done(static_cast<state_watcher*>(pw), false, GRPC_ERROR_REF(error)); in timeout_complete()
Dhttp_connect_handshaker.cc122 grpc_endpoint_shutdown(args_->endpoint, GRPC_ERROR_REF(error)); in HandshakeFailedLocked()
143 GRPC_ERROR_REF(error)); in OnWriteDoneScheduler()
153 handshaker->HandshakeFailedLocked(GRPC_ERROR_REF(error)); in OnWriteDone()
177 GRPC_ERROR_REF(error)); in OnReadDoneScheduler()
187 handshaker->HandshakeFailedLocked(GRPC_ERROR_REF(error)); in OnReadDone()
272 grpc_endpoint_shutdown(args_->endpoint, GRPC_ERROR_REF(why)); in 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()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc210 error = grpc_error_add_child(GRPC_ERROR_REF(error), new_error); in recv_message_ready()
212 calld->error = GRPC_ERROR_REF(error); in recv_message_ready()
214 GRPC_ERROR_REF(error); in recv_message_ready()
241 calld->recv_trailing_metadata_error = GRPC_ERROR_REF(error); in recv_trailing_metadata_ready()
248 grpc_error_add_child(GRPC_ERROR_REF(error), GRPC_ERROR_REF(calld->error)); in recv_trailing_metadata_ready()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dhandshaker.cc90 head->Shutdown(GRPC_ERROR_REF(why)); in ShutdownAllPending()
118 handshakers_[index_ - 1]->Shutdown(GRPC_ERROR_REF(why)); in Shutdown()
151 grpc_endpoint_shutdown(args_.endpoint, GRPC_ERROR_REF(error)); in CallNextHandshakerLocked()
191 done = mgr->CallNextHandshakerLocked(GRPC_ERROR_REF(error)); in CallNextHandshakerFn()
/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/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()
83 deadline_state->call_combiner->Cancel(GRPC_ERROR_REF(error)); in TimerCallback()
144 GRPC_ERROR_REF(error)); in recv_trailing_metadata_ready()
181 GRPC_ERROR_REF(error), in start_timer_after_init()
302 GRPC_ERROR_REF(error)); in recv_initial_metadata_ready()
/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/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc154 calld->recv_initial_metadata_error = GRPC_ERROR_REF(error); in on_md_processing_done_inner()
207 GRPC_ERROR_REF(error)); in cancel_call()
242 grpc_core::Closure::Run(DEBUG_LOCATION, closure, GRPC_ERROR_REF(error)); in recv_initial_metadata_ready()
249 calld->recv_trailing_metadata_error = GRPC_ERROR_REF(err); in recv_trailing_metadata_ready()
257 GRPC_ERROR_REF(err), GRPC_ERROR_REF(calld->recv_initial_metadata_error)); in recv_trailing_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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc339 calld->recv_initial_metadata_ready_error = GRPC_ERROR_REF(err); in hs_recv_initial_metadata_ready()
353 GRPC_ERROR_REF(err), in hs_recv_initial_metadata_ready()
357 GRPC_ERROR_REF(err); in hs_recv_initial_metadata_ready()
383 GRPC_ERROR_REF(err)); in hs_recv_message_ready()
399 calld->recv_trailing_metadata_ready_error = GRPC_ERROR_REF(err); in hs_recv_trailing_metadata_ready()
407 GRPC_ERROR_REF(err), in hs_recv_trailing_metadata_ready()
408 GRPC_ERROR_REF(calld->recv_initial_metadata_ready_error)); in hs_recv_trailing_metadata_ready()

1234567