/external/rust/crates/grpcio-sys/grpc/test/core/security/ |
D | aws_request_signer_test.cc | 68 grpc_error* error = GRPC_ERROR_NONE; in TEST() 76 EXPECT_EQ(error, GRPC_ERROR_NONE); in TEST() 86 grpc_error* error = GRPC_ERROR_NONE; in TEST() 92 EXPECT_EQ(error, GRPC_ERROR_NONE); in TEST() 103 grpc_error* error = GRPC_ERROR_NONE; in TEST() 109 EXPECT_EQ(error, GRPC_ERROR_NONE); in TEST() 120 grpc_error* error = GRPC_ERROR_NONE; in TEST() 126 EXPECT_EQ(error, GRPC_ERROR_NONE); in TEST() 137 grpc_error* error = GRPC_ERROR_NONE; in TEST() 142 EXPECT_EQ(error, GRPC_ERROR_NONE); in TEST() [all …]
|
D | credentials_test.cc | 451 if (state->expected_error == GRPC_ERROR_NONE) { in check_request_metadata() 452 GPR_ASSERT(error == GRPC_ERROR_NONE); in check_request_metadata() 490 grpc_error* error = GRPC_ERROR_NONE; in run_request_metadata_test() 507 make_request_metadata_state(GRPC_ERROR_NONE, emd, GPR_ARRAY_SIZE(emd)); in test_google_iam_creds() 523 make_request_metadata_state(GRPC_ERROR_NONE, emd, GPR_ARRAY_SIZE(emd)); in test_access_token_creds() 580 make_request_metadata_state(GRPC_ERROR_NONE, emd, GPR_ARRAY_SIZE(emd)); in test_oauth2_google_iam_composite_creds() 688 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in compute_engine_httpcli_get_success_override() 697 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_done, GRPC_ERROR_NONE); in compute_engine_httpcli_get_failure_override() 732 make_request_metadata_state(GRPC_ERROR_NONE, emd, GPR_ARRAY_SIZE(emd)); in test_compute_engine_creds_success() 740 make_request_metadata_state(GRPC_ERROR_NONE, emd, GPR_ARRAY_SIZE(emd)); in test_compute_engine_creds_success() [all …]
|
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
D | parsing.cc | 61 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 …]
|
D | frame_data.cc | 61 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 …]
|
D | frame_goaway.cc | 52 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()
|
D | frame_settings.cc | 101 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()
|
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
D | parsing.cc | 58 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 …]
|
D | frame_data.cc | 38 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 …]
|
D | frame_goaway.cc | 54 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()
|
D | hpack_parser.cc | 648 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 …]
|
D | frame_settings.cc | 100 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()
|
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
D | tcp_server_utils_posix_common.cc | 92 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 …]
|
D | socket_utils_common_posix.cc | 63 return GRPC_ERROR_NONE; in grpc_set_socket_zerocopy() 86 return GRPC_ERROR_NONE; in grpc_set_socket_nonblocking() 107 return GRPC_ERROR_NONE; in grpc_set_socket_no_sigpipe_if_possible() 120 return GRPC_ERROR_NONE; in grpc_set_socket_ip_pktinfo_if_possible() 133 return GRPC_ERROR_NONE; in grpc_set_socket_ipv6_recvpktinfo_if_possible() 139 ? GRPC_ERROR_NONE in grpc_set_socket_sndbuf() 146 ? GRPC_ERROR_NONE in grpc_set_socket_rcvbuf() 167 return GRPC_ERROR_NONE; in grpc_set_socket_cloexec() 185 return GRPC_ERROR_NONE; in grpc_set_socket_reuse_addr() 207 return GRPC_ERROR_NONE; in grpc_set_socket_reuse_port() [all …]
|
D | wakeup_fd_pipe.cc | 45 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()
|
D | tcp_client_posix.cc | 69 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 …]
|
D | tcp_server_windows.cc | 120 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 …]
|
D | resolve_address_custom.cc | 58 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()
|
/external/grpc-grpc/src/core/lib/iomgr/ |
D | tcp_server_utils_posix_common.cc | 91 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 …]
|
D | wakeup_fd_pipe.cc | 45 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()
|
D | tcp_client_posix.cc | 68 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 …]
|
D | socket_utils_common_posix.cc | 67 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 …]
|
D | tcp_server_windows.cc | 115 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 …]
|
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
D | message_decompress_filter.cc | 109 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 …]
|
/external/grpc-grpc/src/core/ext/transport/inproc/ |
D | inproc_transport.cc | 179 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/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/ |
D | inproc_transport.cc | 186 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 …]
|