Home
last modified time | relevance | path

Searched refs:GRPC_ERROR_NONE (Results 1 – 25 of 198) sorted by relevance

12345678

/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_closure.cc89 GRPC_CLOSURE_RUN(&c, GRPC_ERROR_NONE); in BM_ClosureRunOnExecCtx()
103 GRPC_ERROR_NONE); in BM_ClosureCreateAndRun()
117 GRPC_ERROR_NONE); in BM_ClosureInitAndRun()
130 GRPC_CLOSURE_SCHED(&c, GRPC_ERROR_NONE); in BM_ClosureSchedOnExecCtx()
146 GRPC_CLOSURE_SCHED(&c1, GRPC_ERROR_NONE); in BM_ClosureSched2OnExecCtx()
147 GRPC_CLOSURE_SCHED(&c2, GRPC_ERROR_NONE); in BM_ClosureSched2OnExecCtx()
165 GRPC_CLOSURE_SCHED(&c1, GRPC_ERROR_NONE); in BM_ClosureSched3OnExecCtx()
166 GRPC_CLOSURE_SCHED(&c2, GRPC_ERROR_NONE); in BM_ClosureSched3OnExecCtx()
167 GRPC_CLOSURE_SCHED(&c3, GRPC_ERROR_NONE); in BM_ClosureSched3OnExecCtx()
183 DoNothing(nullptr, GRPC_ERROR_NONE); in BM_AcquireMutex()
[all …]
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dparsing.cc58 if (cur == end) return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
105 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
114 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
122 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
130 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
138 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
146 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
154 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
162 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
170 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
[all …]
Dframe_data.cc38 return GRPC_ERROR_NONE; in grpc_chttp2_data_parser_init()
69 return GRPC_ERROR_NONE; in grpc_chttp2_data_parser_begin_frame()
104 grpc_error* error = GRPC_ERROR_NONE; in grpc_deframe_unprocessed_incoming_frames()
204 GRPC_ERROR_UNREF(p->parsing_frame->Finished(GRPC_ERROR_NONE, true)); in grpc_deframe_unprocessed_incoming_frames()
216 return GRPC_ERROR_NONE; in grpc_deframe_unprocessed_incoming_frames()
227 if (GRPC_ERROR_NONE != in grpc_deframe_unprocessed_incoming_frames()
235 if (GRPC_ERROR_NONE != in grpc_deframe_unprocessed_incoming_frames()
236 (error = p->parsing_frame->Finished(GRPC_ERROR_NONE, true))) { in grpc_deframe_unprocessed_incoming_frames()
243 return GRPC_ERROR_NONE; in grpc_deframe_unprocessed_incoming_frames()
246 if (GRPC_ERROR_NONE != in grpc_deframe_unprocessed_incoming_frames()
[all …]
Dframe_goaway.cc54 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_begin_frame()
71 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
79 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
87 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
95 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
103 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
111 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
119 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
127 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
145 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
Dhpack_parser.cc648 if (err != GRPC_ERROR_NONE) return err; in on_hdr()
655 return GRPC_ERROR_NONE; in on_hdr()
695 return GRPC_ERROR_NONE; in parse_begin()
706 return GRPC_ERROR_NONE; in parse_stream_weight()
716 return GRPC_ERROR_NONE; in parse_stream_dep3()
726 return GRPC_ERROR_NONE; in parse_stream_dep2()
736 return GRPC_ERROR_NONE; in parse_stream_dep1()
746 return GRPC_ERROR_NONE; in parse_stream_dep0()
768 if (err != GRPC_ERROR_NONE) return err; in finish_indexed_field()
805 if (err != GRPC_ERROR_NONE) return parse_error(p, cur, end, err); in finish_lithdr_incidx()
[all …]
Dframe_settings.cc100 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_begin_frame()
108 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_begin_frame()
123 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
137 GRPC_ERROR_NONE); in grpc_chttp2_settings_parser_parse()
141 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
149 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
157 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
165 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
173 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
181 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
Dchttp2_transport.cc493 t->goaway_error = GRPC_ERROR_NONE; in init_transport()
589 GRPC_ERROR_NONE); in destroy_transport()
596 if (t->closed_with_error == GRPC_ERROR_NONE) { in close_transport_locked()
611 GPR_ASSERT(error != GRPC_ERROR_NONE); in close_transport_locked()
762 GRPC_CLOSURE_SCHED(s->destroy_stream_arg, GRPC_ERROR_NONE); in destroy_stream_locked()
784 GRPC_ERROR_NONE); in destroy_stream()
944 GRPC_ERROR_NONE); in grpc_chttp2_initiate_write()
957 if (t->closed_with_error == GRPC_ERROR_NONE && in grpc_chttp2_mark_stream_writable()
1010 if (t->closed_with_error != GRPC_ERROR_NONE) { in write_action_begin_locked()
1034 GRPC_ERROR_NONE); in write_action_begin_locked()
[all …]
/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_server_utils_posix_common.cc91 if (err == GRPC_ERROR_NONE) { in add_socket_to_server()
136 if (err != GRPC_ERROR_NONE) { in grpc_tcp_server_add_addr()
151 grpc_error* err = GRPC_ERROR_NONE; in grpc_tcp_server_prepare_socket()
158 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
162 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
164 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
167 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
169 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
172 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
175 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
[all …]
Dwakeup_fd_pipe.cc45 if (err != GRPC_ERROR_NONE) return err; in pipe_init()
47 if (err != GRPC_ERROR_NONE) return err; in pipe_init()
50 return GRPC_ERROR_NONE; in pipe_init()
60 if (r == 0) return GRPC_ERROR_NONE; in pipe_consume()
63 return GRPC_ERROR_NONE; in pipe_consume()
76 return GRPC_ERROR_NONE; in pipe_wakeup()
88 if (pipe_init(&fd) == GRPC_ERROR_NONE) { in pipe_check_availability()
Dsocket_utils_common_posix.cc67 return GRPC_ERROR_NONE; in grpc_set_socket_nonblocking()
85 return GRPC_ERROR_NONE; in grpc_set_socket_no_sigpipe_if_possible()
96 return GRPC_ERROR_NONE; in grpc_set_socket_ip_pktinfo_if_possible()
107 return GRPC_ERROR_NONE; in grpc_set_socket_ipv6_recvpktinfo_if_possible()
113 ? GRPC_ERROR_NONE in grpc_set_socket_sndbuf()
120 ? GRPC_ERROR_NONE in grpc_set_socket_rcvbuf()
141 return GRPC_ERROR_NONE; in grpc_set_socket_cloexec()
159 return GRPC_ERROR_NONE; in grpc_set_socket_reuse_addr()
181 return GRPC_ERROR_NONE; in grpc_set_socket_reuse_port()
223 return GRPC_ERROR_NONE; in grpc_set_socket_low_latency()
[all …]
Dtcp_client_posix.cc68 grpc_error* err = GRPC_ERROR_NONE; in prepare_socket()
73 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
75 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
78 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
81 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
84 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
92 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
161 if (error != GRPC_ERROR_NONE) { in on_writable()
225 if (error != GRPC_ERROR_NONE) { in on_writable()
270 if (error != GRPC_ERROR_NONE) { in grpc_tcp_client_prepare_fd()
[all …]
Dtcp_server_windows.cc115 return GRPC_ERROR_NONE; in tcp_server_create()
138 GRPC_CLOSURE_SCHED(s->shutdown_complete, GRPC_ERROR_NONE); in finish_shutdown_locked()
143 GRPC_ERROR_NONE); in finish_shutdown_locked()
155 GRPC_ERROR_NONE); in tcp_server_shutdown_starting_add()
191 grpc_error* error = GRPC_ERROR_NONE; in prepare_socket()
195 if (error != GRPC_ERROR_NONE) { in prepare_socket()
219 return GRPC_ERROR_NONE; in prepare_socket()
222 GPR_ASSERT(error != GRPC_ERROR_NONE); in prepare_socket()
251 grpc_error* error = GRPC_ERROR_NONE; in start_accept_locked()
254 return GRPC_ERROR_NONE; in start_accept_locked()
[all …]
Dresolve_address_custom.cc57 if (error != GRPC_ERROR_NONE) { in retry_named_port_failure()
75 if (error == GRPC_ERROR_NONE) { in grpc_custom_resolve_callback()
112 return GRPC_ERROR_NONE; in try_split_host_port()
125 if (err != GRPC_ERROR_NONE) { in blocking_resolve_address_impl()
140 if (err != GRPC_ERROR_NONE) { in blocking_resolve_address_impl()
143 err = GRPC_ERROR_NONE; in blocking_resolve_address_impl()
147 if (err == GRPC_ERROR_NONE) { in blocking_resolve_address_impl()
165 if (err != GRPC_ERROR_NONE) { in resolve_address_impl()
Dtcp_server_posix.cc101 return GRPC_ERROR_NONE; in tcp_server_create()
109 GRPC_CLOSURE_SCHED(s->shutdown_complete, GRPC_ERROR_NONE); in finish_shutdown()
186 if (err != GRPC_ERROR_NONE) { in on_read()
277 grpc_error* v6_err = GRPC_ERROR_NONE; in add_wildcard_addrs_to_server()
278 grpc_error* v4_err = GRPC_ERROR_NONE; in add_wildcard_addrs_to_server()
289 &dsmode, &sp)) == GRPC_ERROR_NONE) { in add_wildcard_addrs_to_server()
293 return GRPC_ERROR_NONE; in add_wildcard_addrs_to_server()
299 &dsmode, &sp2)) == GRPC_ERROR_NONE) { in add_wildcard_addrs_to_server()
307 if (v6_err != GRPC_ERROR_NONE) { in add_wildcard_addrs_to_server()
314 if (v4_err != GRPC_ERROR_NONE) { in add_wildcard_addrs_to_server()
[all …]
Dtcp_server_utils_posix_ifaddrs.cc65 if (err != GRPC_ERROR_NONE) { in get_unused_port()
86 : GRPC_ERROR_NONE; in get_unused_port()
97 grpc_error* err = GRPC_ERROR_NONE; in grpc_tcp_server_add_all_local_addrs()
103 if ((err = get_unused_port(&requested_port)) != GRPC_ERROR_NONE) { in grpc_tcp_server_add_all_local_addrs()
149 &new_sp)) != GRPC_ERROR_NONE) { in grpc_tcp_server_add_all_local_addrs()
172 if (err != GRPC_ERROR_NONE) { in grpc_tcp_server_add_all_local_addrs()
178 return GRPC_ERROR_NONE; in grpc_tcp_server_add_all_local_addrs()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc179 GRPC_CLOSURE_SCHED(s->closure_at_destroy, GRPC_ERROR_NONE); in really_destroy_stream()
210 grpc_error* error = GRPC_ERROR_NONE; in fill_in_metadata()
212 (elem != nullptr) && (error == GRPC_ERROR_NONE); elem = elem->next) { in fill_in_metadata()
259 s->cancel_self_error = GRPC_ERROR_NONE; in init_stream()
260 s->cancel_other_error = GRPC_ERROR_NONE; in init_stream()
261 s->write_buffer_cancel_error = GRPC_ERROR_NONE; in init_stream()
316 if (cs->write_buffer_cancel_error != GRPC_ERROR_NONE) { in init_stream()
318 cs->write_buffer_cancel_error = GRPC_ERROR_NONE; in init_stream()
419 if (other->cancel_other_error == GRPC_ERROR_NONE) { in fail_helper_locked()
423 } else if (s->write_buffer_cancel_error == GRPC_ERROR_NONE) { in fail_helper_locked()
[all …]
/external/grpc-grpc/test/core/http/
Dparser_test.cc55 GRPC_ERROR_NONE); in test_request_succeeds()
58 GPR_ASSERT(grpc_http_parser_eof(&parser) == GRPC_ERROR_NONE); in test_request_succeeds()
113 GRPC_ERROR_NONE); in test_succeeds()
116 GPR_ASSERT(grpc_http_parser_eof(&parser) == GRPC_ERROR_NONE); in test_succeeds()
156 grpc_error* error = GRPC_ERROR_NONE; in test_fails()
166 if (GRPC_ERROR_NONE == error) { in test_fails()
171 if (GRPC_ERROR_NONE == error) { in test_fails()
174 GPR_ASSERT(error != GRPC_ERROR_NONE); in test_fails()
189 grpc_error* error = GRPC_ERROR_NONE; in test_request_fails()
199 if (error == GRPC_ERROR_NONE) { in test_request_fails()
[all …]
/external/grpc-grpc/src/core/lib/http/
Dparser.cc78 return GRPC_ERROR_NONE; in handle_response_line()
141 return GRPC_ERROR_NONE; in handle_request_line()
162 grpc_error* error = GRPC_ERROR_NONE; in add_header()
211 if (error != GRPC_ERROR_NONE) { in add_header()
224 if (err != GRPC_ERROR_NONE) return err; in finish_line()
234 if (err != GRPC_ERROR_NONE) { in finish_line()
244 return GRPC_ERROR_NONE; in finish_line()
270 return GRPC_ERROR_NONE; in addbyte_body()
314 return GRPC_ERROR_NONE; in addbyte()
318 GPR_UNREACHABLE_CODE(return GRPC_ERROR_NONE); in addbyte()
[all …]
/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc148 return GRPC_ERROR_NONE; in client_filter_incoming_metadata()
154 if (error == GRPC_ERROR_NONE) { in recv_initial_metadata_ready()
166 if (error == GRPC_ERROR_NONE) { in recv_trailing_metadata_ready()
190 if (error == GRPC_ERROR_NONE) { in pull_slice_from_send_message()
206 if (error != GRPC_ERROR_NONE) return error; in read_all_available_send_message_data()
212 return GRPC_ERROR_NONE; in read_all_available_send_message_data()
219 if (error != GRPC_ERROR_NONE) { in on_send_message_next_done()
225 if (error != GRPC_ERROR_NONE) { in on_send_message_next_done()
329 grpc_error* error = GRPC_ERROR_NONE; in hc_start_transport_stream_op_batch()
352 if (error != GRPC_ERROR_NONE) goto done; in hc_start_transport_stream_op_batch()
[all …]
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc164 grpc_error* error = GRPC_ERROR_NONE; in process_send_initial_metadata()
178 if (error != GRPC_ERROR_NONE) return error; in process_send_initial_metadata()
186 if (error != GRPC_ERROR_NONE) return error; in process_send_initial_metadata()
283 if (error == GRPC_ERROR_NONE) { in pull_slice_from_send_message()
298 if (error != GRPC_ERROR_NONE) { in continue_reading_send_message()
316 if (error != GRPC_ERROR_NONE) { in on_send_message_next_done()
322 if (error != GRPC_ERROR_NONE) { in on_send_message_next_done()
371 } else if (calld->cancel_error != GRPC_ERROR_NONE) { in compress_start_transport_stream_op_batch()
383 if (error != GRPC_ERROR_NONE) { in compress_start_transport_stream_op_batch()
399 &calld->start_send_message_batch_in_call_combiner, GRPC_ERROR_NONE, in compress_start_transport_stream_op_batch()
[all …]
/external/grpc-grpc/src/core/lib/transport/
Dbyte_stream.cc63 if (shutdown_error_ != GRPC_ERROR_NONE) { in Pull()
69 return GRPC_ERROR_NONE; in Pull()
116 if (shutdown_error_ != GRPC_ERROR_NONE) return true; in Next()
123 if (shutdown_error_ != GRPC_ERROR_NONE) { in Pull()
130 return GRPC_ERROR_NONE; in Pull()
134 if (error == GRPC_ERROR_NONE) { in Pull()
Dmetadata_batch.cc105 return GRPC_ERROR_NONE; in maybe_link_callout()
110 return GRPC_ERROR_NONE; in maybe_link_callout()
156 if (err != GRPC_ERROR_NONE) { in grpc_metadata_batch_link_head()
162 return GRPC_ERROR_NONE; in grpc_metadata_batch_link_head()
193 if (err != GRPC_ERROR_NONE) { in grpc_metadata_batch_link_tail()
199 return GRPC_ERROR_NONE; in grpc_metadata_batch_link_tail()
241 grpc_error* error = GRPC_ERROR_NONE; in grpc_metadata_batch_substitute()
247 if (error != GRPC_ERROR_NONE) { in grpc_metadata_batch_substitute()
280 if (error == GRPC_ERROR_NONE) return; in add_error()
281 if (*composite == GRPC_ERROR_NONE) { in add_error()
[all …]
/external/grpc-grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc100 if (error == GRPC_ERROR_NONE) { in on_receive_settings()
111 if (error != GRPC_ERROR_NONE || connection_state->svr_state->shutdown) { in on_handshake_done()
114 if (error == GRPC_ERROR_NONE && args->endpoint != nullptr) { in on_handshake_done()
121 grpc_endpoint_shutdown(args->endpoint, GRPC_ERROR_NONE); in on_handshake_done()
174 grpc_endpoint_shutdown(tcp, GRPC_ERROR_NONE); in on_accept()
261 grpc_error* err = GRPC_ERROR_NONE; in grpc_chttp2_server_add_port()
270 if (err != GRPC_ERROR_NONE) { in grpc_chttp2_server_add_port()
279 if (err != GRPC_ERROR_NONE) { in grpc_chttp2_server_add_port()
294 if (errors[i] == GRPC_ERROR_NONE) { in grpc_chttp2_server_add_port()
333 GPR_ASSERT(err != GRPC_ERROR_NONE); in grpc_chttp2_server_add_port()
/external/grpc-grpc/test/core/iomgr/
Dwakeup_fd_cv_test.cc95 GPR_ASSERT(grpc_wakeup_fd_init(&fd[i]) == GRPC_ERROR_NONE); in test_many_fds()
107 GPR_ASSERT(grpc_wakeup_fd_init(&cvfd1) == GRPC_ERROR_NONE); in test_poll_cv_trigger()
108 GPR_ASSERT(grpc_wakeup_fd_init(&cvfd2) == GRPC_ERROR_NONE); in test_poll_cv_trigger()
109 GPR_ASSERT(grpc_wakeup_fd_init(&cvfd3) == GRPC_ERROR_NONE); in test_poll_cv_trigger()
140 GPR_ASSERT(grpc_wakeup_fd_wakeup(&cvfd1) == GRPC_ERROR_NONE); in test_poll_cv_trigger()
174 GPR_ASSERT(grpc_wakeup_fd_wakeup(&cvfd2) == GRPC_ERROR_NONE); in test_poll_cv_trigger()
207 GPR_ASSERT(grpc_wakeup_fd_consume_wakeup(&cvfd1) == GRPC_ERROR_NONE); in test_poll_cv_trigger()
208 GPR_ASSERT(grpc_wakeup_fd_consume_wakeup(&cvfd2) == GRPC_ERROR_NONE); in test_poll_cv_trigger()
Dload_file_test.cc51 GPR_ASSERT(error == GRPC_ERROR_NONE); in test_load_empty_file()
55 GPR_ASSERT(error == GRPC_ERROR_NONE); in test_load_empty_file()
80 GPR_ASSERT(error != GRPC_ERROR_NONE); in test_load_failure()
104 GPR_ASSERT(error == GRPC_ERROR_NONE); in test_load_small_file()
109 GPR_ASSERT(error == GRPC_ERROR_NONE); in test_load_small_file()
141 GPR_ASSERT(error == GRPC_ERROR_NONE); in test_load_big_file()

12345678