Home
last modified time | relevance | path

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

1234567891011

/third_party/grpc/test/core/client_channel/
Dservice_config_test.cc156 grpc_error* error = GRPC_ERROR_NONE; in TEST_F()
164 grpc_error* error = GRPC_ERROR_NONE; in TEST_F()
166 EXPECT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in TEST_F()
176 grpc_error* error = GRPC_ERROR_NONE; in TEST_F()
178 ASSERT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in TEST_F()
192 grpc_error* error = GRPC_ERROR_NONE; in TEST_F()
208 grpc_error* error = GRPC_ERROR_NONE; in TEST_F()
224 grpc_error* error = GRPC_ERROR_NONE; in TEST_F()
240 grpc_error* error = GRPC_ERROR_NONE; in TEST_F()
256 grpc_error* error = GRPC_ERROR_NONE; in TEST_F()
[all …]
Dxds_bootstrap_test.cc80 grpc_error* error = GRPC_ERROR_NONE; in TEST()
82 ASSERT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in TEST()
84 EXPECT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in TEST()
120 grpc_error* error = GRPC_ERROR_NONE; in TEST()
122 ASSERT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in TEST()
124 EXPECT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in TEST()
131 grpc_error* error = GRPC_ERROR_NONE; in TEST()
133 ASSERT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in TEST()
136 ASSERT_TRUE(error != GRPC_ERROR_NONE); in TEST()
147 grpc_error* error = GRPC_ERROR_NONE; in TEST()
[all …]
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dparsing.cc61 if (cur == end) return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
106 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
115 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
123 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
131 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
139 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
147 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
155 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
163 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
171 return GRPC_ERROR_NONE; in grpc_chttp2_perform_read()
[all …]
Dframe_data.cc61 return GRPC_ERROR_NONE; in grpc_chttp2_data_parser_begin_frame()
96 grpc_error* error = GRPC_ERROR_NONE; in grpc_deframe_unprocessed_incoming_frames()
197 GRPC_ERROR_UNREF(p->parsing_frame->Finished(GRPC_ERROR_NONE, true)); in grpc_deframe_unprocessed_incoming_frames()
208 return GRPC_ERROR_NONE; in grpc_deframe_unprocessed_incoming_frames()
219 if (GRPC_ERROR_NONE != in grpc_deframe_unprocessed_incoming_frames()
227 if (GRPC_ERROR_NONE != in grpc_deframe_unprocessed_incoming_frames()
228 (error = p->parsing_frame->Finished(GRPC_ERROR_NONE, true))) { in grpc_deframe_unprocessed_incoming_frames()
235 return GRPC_ERROR_NONE; in grpc_deframe_unprocessed_incoming_frames()
238 if (GRPC_ERROR_NONE != in grpc_deframe_unprocessed_incoming_frames()
247 return GRPC_ERROR_NONE; in grpc_deframe_unprocessed_incoming_frames()
[all …]
Dframe_goaway.cc52 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_begin_frame()
70 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
78 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
86 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
94 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
102 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
110 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
118 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
126 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
145 return GRPC_ERROR_NONE; in grpc_chttp2_goaway_parser_parse()
Dhpack_parser.cc658 if (GPR_UNLIKELY(err != GRPC_ERROR_NONE)) return err; in on_hdr()
708 return GRPC_ERROR_NONE; in parse_begin()
719 return GRPC_ERROR_NONE; in parse_stream_weight()
729 return GRPC_ERROR_NONE; in parse_stream_dep3()
739 return GRPC_ERROR_NONE; in parse_stream_dep2()
749 return GRPC_ERROR_NONE; in parse_stream_dep1()
759 return GRPC_ERROR_NONE; in parse_stream_dep0()
784 if (GPR_UNLIKELY(err != GRPC_ERROR_NONE)) return err; in finish_indexed_field()
841 if (err != GRPC_ERROR_NONE) return parse_error(p, cur, end, err); in finish_lithdr_incidx()
853 if (err != GRPC_ERROR_NONE) return parse_error(p, cur, end, err); in finish_lithdr_incidx_v()
[all …]
Dframe_settings.cc101 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_begin_frame()
109 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_begin_frame()
124 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
140 GRPC_ERROR_NONE); in grpc_chttp2_settings_parser_parse()
144 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
152 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
160 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
168 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
176 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
184 return GRPC_ERROR_NONE; in grpc_chttp2_settings_parser_parse()
Dchttp2_transport.cc523 GRPC_ERROR_NONE); in destroy_transport()
530 if (t->closed_with_error == GRPC_ERROR_NONE) { in close_transport_locked()
545 GPR_ASSERT(error != GRPC_ERROR_NONE); in close_transport_locked()
689 grpc_core::ExecCtx::Run(DEBUG_LOCATION, destroy_stream_arg, GRPC_ERROR_NONE); in ~grpc_chttp2_stream()
728 GRPC_ERROR_NONE); in destroy_stream()
894 GRPC_ERROR_NONE); in grpc_chttp2_initiate_write()
907 if (t->closed_with_error == GRPC_ERROR_NONE && in grpc_chttp2_mark_stream_writable()
926 if (t->closed_with_error != GRPC_ERROR_NONE) { in write_action_begin_locked()
939 write_action(t, GRPC_ERROR_NONE); in write_action_begin_locked()
986 if (error != GRPC_ERROR_NONE) { in write_action_end_locked()
[all …]
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_closure.cc88 grpc_core::Closure::Run(DEBUG_LOCATION, &c, GRPC_ERROR_NONE); in BM_ClosureRun()
102 GRPC_ERROR_NONE); in BM_ClosureCreateAndRun()
117 GRPC_ERROR_NONE); in BM_ClosureInitAndRun()
130 grpc_core::ExecCtx::Run(DEBUG_LOCATION, &c, GRPC_ERROR_NONE); in BM_ClosureSchedOnExecCtx()
146 grpc_core::ExecCtx::Run(DEBUG_LOCATION, &c1, GRPC_ERROR_NONE); in BM_ClosureSched2OnExecCtx()
147 grpc_core::ExecCtx::Run(DEBUG_LOCATION, &c2, GRPC_ERROR_NONE); in BM_ClosureSched2OnExecCtx()
165 grpc_core::ExecCtx::Run(DEBUG_LOCATION, &c1, GRPC_ERROR_NONE); in BM_ClosureSched3OnExecCtx()
166 grpc_core::ExecCtx::Run(DEBUG_LOCATION, &c2, GRPC_ERROR_NONE); in BM_ClosureSched3OnExecCtx()
167 grpc_core::ExecCtx::Run(DEBUG_LOCATION, &c3, GRPC_ERROR_NONE); in BM_ClosureSched3OnExecCtx()
183 DoNothing(nullptr, GRPC_ERROR_NONE); in BM_AcquireMutex()
[all …]
/third_party/grpc/src/core/lib/iomgr/
Dtcp_server_utils_posix_common.cc92 if (err == GRPC_ERROR_NONE) { in add_socket_to_server()
135 if (err != GRPC_ERROR_NONE) { in grpc_tcp_server_add_addr()
150 grpc_error* err = GRPC_ERROR_NONE; in grpc_tcp_server_prepare_socket()
156 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
161 if (err != GRPC_ERROR_NONE) { in grpc_tcp_server_prepare_socket()
168 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
170 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
173 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()
178 if (err != GRPC_ERROR_NONE) goto error; in grpc_tcp_server_prepare_socket()
[all …]
Dsocket_utils_common_posix.cc63 return GRPC_ERROR_NONE; in grpc_set_socket_zerocopy()
87 return GRPC_ERROR_NONE; in grpc_set_socket_nonblocking()
108 return GRPC_ERROR_NONE; in grpc_set_socket_no_sigpipe_if_possible()
121 return GRPC_ERROR_NONE; in grpc_set_socket_ip_pktinfo_if_possible()
134 return GRPC_ERROR_NONE; in grpc_set_socket_ipv6_recvpktinfo_if_possible()
140 ? GRPC_ERROR_NONE in grpc_set_socket_sndbuf()
147 ? GRPC_ERROR_NONE in grpc_set_socket_rcvbuf()
168 return GRPC_ERROR_NONE; in grpc_set_socket_cloexec()
186 return GRPC_ERROR_NONE; in grpc_set_socket_reuse_addr()
208 return GRPC_ERROR_NONE; in grpc_set_socket_reuse_port()
[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()
Dtcp_client_posix.cc69 grpc_error* err = GRPC_ERROR_NONE; in prepare_socket()
74 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
76 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
79 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()
87 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
90 if (err != GRPC_ERROR_NONE) goto error; in prepare_socket()
156 if (error != GRPC_ERROR_NONE) { in on_writable()
221 if (error != GRPC_ERROR_NONE) { in on_writable()
[all …]
Dtcp_server_windows.cc120 return GRPC_ERROR_NONE; in tcp_server_create()
144 GRPC_ERROR_NONE); in finish_shutdown_locked()
150 GRPC_ERROR_NONE); in finish_shutdown_locked()
162 GRPC_ERROR_NONE); in tcp_server_shutdown_starting_add()
198 grpc_error* error = GRPC_ERROR_NONE; in prepare_socket()
202 if (error != GRPC_ERROR_NONE) { in prepare_socket()
226 return GRPC_ERROR_NONE; in prepare_socket()
229 GPR_ASSERT(error != GRPC_ERROR_NONE); in prepare_socket()
257 grpc_error* error = GRPC_ERROR_NONE; in start_accept_locked()
260 return GRPC_ERROR_NONE; in start_accept_locked()
[all …]
Dresolve_address_custom.cc58 if (error != GRPC_ERROR_NONE) { in retry_named_port_failure()
78 if (error == GRPC_ERROR_NONE) { in grpc_custom_resolve_callback()
106 return GRPC_ERROR_NONE; in try_split_host_port()
117 if (err != GRPC_ERROR_NONE) { in blocking_resolve_address_impl()
127 if (err != GRPC_ERROR_NONE) { in blocking_resolve_address_impl()
130 err = GRPC_ERROR_NONE; in blocking_resolve_address_impl()
134 if (err == GRPC_ERROR_NONE) { in blocking_resolve_address_impl()
148 if (err != GRPC_ERROR_NONE) { in resolve_address_impl()
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc109 grpc_error* error_ = GRPC_ERROR_NONE;
133 grpc_error* on_recv_trailing_metadata_ready_error_ = GRPC_ERROR_NONE;
154 if (error == GRPC_ERROR_NONE) { in OnRecvInitialMetadataReady()
172 GRPC_ERROR_NONE, in MaybeResumeOnRecvMessageReady()
179 if (error == GRPC_ERROR_NONE) { in OnRecvMessageReady()
194 return calld->ContinueRecvMessageReadyCallback(GRPC_ERROR_NONE); in OnRecvMessageReady()
202 GPR_DEBUG_ASSERT(calld->error_ == GRPC_ERROR_NONE); in OnRecvMessageReady()
222 if (error != GRPC_ERROR_NONE) { in ContinueReadingRecvMessage()
235 if (error == GRPC_ERROR_NONE) { in PullSliceFromRecvMessage()
243 if (error != GRPC_ERROR_NONE) { in OnRecvMessageNextDone()
[all …]
/third_party/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc186 if (cs->write_buffer_cancel_error != GRPC_ERROR_NONE) { in inproc_stream()
188 cs->write_buffer_cancel_error = GRPC_ERROR_NONE; in inproc_stream()
242 grpc_error* write_buffer_cancel_error = GRPC_ERROR_NONE;
273 grpc_error* cancel_self_error = GRPC_ERROR_NONE;
274 grpc_error* cancel_other_error = GRPC_ERROR_NONE;
310 grpc_error* error = GRPC_ERROR_NONE; in fill_in_metadata()
312 (elem != nullptr) && (error == GRPC_ERROR_NONE); elem = elem->next) { in fill_in_metadata()
398 if (s && (error != GRPC_ERROR_NONE || s->ops_needed)) { in maybe_process_ops_locked()
425 if (other->cancel_other_error == GRPC_ERROR_NONE) { in fail_helper_locked()
429 } else if (s->write_buffer_cancel_error == GRPC_ERROR_NONE) { in fail_helper_locked()
[all …]
/third_party/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc84 grpc_error* recv_initial_metadata_error = GRPC_ERROR_NONE;
91 grpc_error* recv_trailing_metadata_error = GRPC_ERROR_NONE;
182 return GRPC_ERROR_NONE; in client_filter_incoming_metadata()
188 if (error == GRPC_ERROR_NONE) { in recv_initial_metadata_ready()
215 if (error == GRPC_ERROR_NONE) { in recv_trailing_metadata_ready()
240 if (error == GRPC_ERROR_NONE) { in pull_slice_from_send_message()
256 if (error != GRPC_ERROR_NONE) return error; in read_all_available_send_message_data()
262 return GRPC_ERROR_NONE; in read_all_available_send_message_data()
269 if (error != GRPC_ERROR_NONE) { in on_send_message_next_done()
275 if (error != GRPC_ERROR_NONE) { in on_send_message_next_done()
[all …]
/third_party/grpc/test/core/http/
Dparser_test.cc58 GRPC_ERROR_NONE); in test_request_succeeds()
61 GPR_ASSERT(grpc_http_parser_eof(&parser) == GRPC_ERROR_NONE); in test_request_succeeds()
116 GRPC_ERROR_NONE); in test_succeeds()
119 GPR_ASSERT(grpc_http_parser_eof(&parser) == GRPC_ERROR_NONE); in test_succeeds()
159 grpc_error* error = GRPC_ERROR_NONE; in test_fails()
169 if (GRPC_ERROR_NONE == error) { in test_fails()
174 if (GRPC_ERROR_NONE == error) { in test_fails()
177 GPR_ASSERT(error != GRPC_ERROR_NONE); in test_fails()
192 grpc_error* error = GRPC_ERROR_NONE; in test_request_fails()
202 if (error == GRPC_ERROR_NONE) { in test_request_fails()
[all …]
/third_party/grpc/test/core/channel/
Dchannelz_test.cc108 grpc_error* error = GRPC_ERROR_NONE; in ValidateGetTopChannels()
110 ASSERT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in ValidateGetTopChannels()
128 grpc_error* error = GRPC_ERROR_NONE; in ValidateGetServers()
130 ASSERT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in ValidateGetServers()
210 grpc_error* error = GRPC_ERROR_NONE; in ValidateCounters()
212 ASSERT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in ValidateCounters()
368 grpc_error* error = GRPC_ERROR_NONE; in TEST_F()
370 ASSERT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in TEST_F()
379 error = GRPC_ERROR_NONE; in TEST_F()
381 ASSERT_EQ(error, GRPC_ERROR_NONE) << grpc_error_string(error); in TEST_F()
[all …]
/third_party/grpc/test/core/security/
Djwt_verifier_test.cc210 grpc_error* error = GRPC_ERROR_NONE; in test_claims_success()
212 if (error != GRPC_ERROR_NONE) { in test_claims_success()
215 GPR_ASSERT(error == GRPC_ERROR_NONE); in test_claims_success()
232 grpc_error* error = GRPC_ERROR_NONE; in test_expired_claims_failure()
234 if (error != GRPC_ERROR_NONE) { in test_expired_claims_failure()
237 GPR_ASSERT(error == GRPC_ERROR_NONE); in test_expired_claims_failure()
260 grpc_error* error = GRPC_ERROR_NONE; in test_invalid_claims_failure()
262 if (error != GRPC_ERROR_NONE) { in test_invalid_claims_failure()
265 GPR_ASSERT(error == GRPC_ERROR_NONE); in test_invalid_claims_failure()
273 grpc_error* error = GRPC_ERROR_NONE; in test_bad_audience_claims_failure()
[all …]
/third_party/grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc100 grpc_error* error = GRPC_ERROR_NONE; in UpdateConfig()
102 if (error != GRPC_ERROR_NONE) { in UpdateConfig()
113 if (error != GRPC_ERROR_NONE) { in UpdateConfig()
237 if (error == GRPC_ERROR_NONE) { in OnReceiveSettings()
251 if (error != GRPC_ERROR_NONE || self->listener_->shutdown_) { in OnHandshakeDone()
258 if (error == GRPC_ERROR_NONE && args->endpoint != nullptr) { in OnHandshakeDone()
265 grpc_endpoint_shutdown(args->endpoint, GRPC_ERROR_NONE); in OnHandshakeDone()
281 if (channel_init_err == GRPC_ERROR_NONE) { in OnHandshakeDone()
352 if (error != GRPC_ERROR_NONE) return error; in Create()
359 if (error != GRPC_ERROR_NONE) return error; in Create()
[all …]
/third_party/grpc/src/core/lib/transport/
Dmetadata_batch.cc114 return GRPC_ERROR_NONE; in link_callout()
128 return GRPC_ERROR_NONE; in maybe_link_callout()
173 if (err != GRPC_ERROR_NONE) { in grpc_metadata_batch_link_head()
179 return GRPC_ERROR_NONE; in grpc_metadata_batch_link_head()
191 if (GPR_UNLIKELY(err != GRPC_ERROR_NONE)) { in grpc_metadata_batch_link_head()
197 return GRPC_ERROR_NONE; in grpc_metadata_batch_link_head()
228 if (err != GRPC_ERROR_NONE) { in grpc_metadata_batch_link_tail()
234 return GRPC_ERROR_NONE; in grpc_metadata_batch_link_tail()
243 if (GPR_UNLIKELY(err != GRPC_ERROR_NONE)) { in grpc_metadata_batch_link_tail()
249 return GRPC_ERROR_NONE; in grpc_metadata_batch_link_tail()
[all …]
/third_party/grpc/src/core/lib/http/
Dparser.cc90 return GRPC_ERROR_NONE; in handle_response_line()
161 return GRPC_ERROR_NONE; in handle_request_line()
182 grpc_error* error = GRPC_ERROR_NONE; in add_header()
231 if (error != GRPC_ERROR_NONE) { in add_header()
244 if (err != GRPC_ERROR_NONE) return err; in finish_line()
254 if (err != GRPC_ERROR_NONE) { in finish_line()
264 return GRPC_ERROR_NONE; in finish_line()
289 return GRPC_ERROR_NONE; in addbyte_body()
334 return GRPC_ERROR_NONE; in addbyte()
338 GPR_UNREACHABLE_CODE(return GRPC_ERROR_NONE); in addbyte()
[all …]
/third_party/grpc/test/core/iomgr/
Dbuffer_list_test.cc32 GPR_ASSERT(error == GRPC_ERROR_NONE); in TestShutdownFlushesListVerifier()
53 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestShutdownFlushesList()
64 GPR_ASSERT(error == GRPC_ERROR_NONE); in TestVerifierCalledOnAckVerifier()
92 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestVerifierCalledOnAck()
113 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestRepeatedShutdown()
114 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestRepeatedShutdown()
115 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestRepeatedShutdown()

1234567891011