/dports/devel/grpc130/grpc-1.30.2/src/core/lib/iomgr/ |
H A D | error.h | 38 typedef struct grpc_error grpc_error; typedef 126 #define GRPC_ERROR_OOM ((grpc_error*)2) 174 grpc_error* grpc_error_do_ref(grpc_error* err, const char* file, int line); 176 inline grpc_error* grpc_error_ref(grpc_error* err, const char* file, int line) { in grpc_error_ref() 187 grpc_error* grpc_error_do_ref(grpc_error* err); 189 inline grpc_error* grpc_error_ref(grpc_error* err) { in grpc_error_ref() 207 grpc_error* error = GRPC_ERROR_NONE; in grpc_error_create_from_vector() 220 grpc_error* grpc_error_set_int(grpc_error* src, grpc_error_ints which, 227 grpc_error* grpc_error_set_str(grpc_error* src, grpc_error_strs which, 245 grpc_error* grpc_error_add_child(grpc_error* src, [all …]
|
H A D | socket_utils_posix.h | 48 grpc_error* grpc_set_socket_zerocopy(int fd); 51 grpc_error* grpc_set_socket_nonblocking(int fd, int non_blocking); 54 grpc_error* grpc_set_socket_cloexec(int fd, int close_on_exec); 57 grpc_error* grpc_set_socket_reuse_addr(int fd, int reuse); 63 grpc_error* grpc_set_socket_low_latency(int fd, int low_latency); 66 grpc_error* grpc_set_socket_reuse_port(int fd, int reuse); 72 grpc_error* grpc_set_socket_tcp_user_timeout( 87 grpc_error* grpc_set_socket_no_sigpipe_if_possible(int fd); 91 grpc_error* grpc_set_socket_ip_pktinfo_if_possible(int fd); 107 grpc_error* grpc_apply_socket_mutator_in_args(int fd, [all …]
|
H A D | error.cc | 127 grpc_error* grpc_error_do_ref(grpc_error* err, const char* file, int line) { in grpc_error_do_ref() 137 grpc_error* grpc_error_do_ref(grpc_error* err) { in grpc_error_do_ref() 202 grpc_error* orig = *err; in get_placement() 272 static void internal_add_error(grpc_error** err, grpc_error* new_err) { in internal_add_error() 326 grpc_error* err = static_cast<grpc_error*>( in grpc_error_create() 392 static grpc_error* copy_error_and_unref(grpc_error* in) { in copy_error_and_unref() 394 grpc_error* out; in copy_error_and_unref() 419 out = static_cast<grpc_error*>( in copy_error_and_unref() 441 grpc_error* grpc_error_set_int(grpc_error* src, grpc_error_ints which, in grpc_error_set_int() 479 grpc_error* grpc_error_set_str(grpc_error* src, grpc_error_strs which, in grpc_error_set_str() [all …]
|
/dports/devel/grpc134/grpc-1.34.1/src/core/lib/iomgr/ |
H A D | error.h | 38 typedef struct grpc_error grpc_error; typedef 126 #define GRPC_ERROR_OOM ((grpc_error*)2) 174 grpc_error* grpc_error_do_ref(grpc_error* err, const char* file, int line); 176 inline grpc_error* grpc_error_ref(grpc_error* err, const char* file, int line) { in grpc_error_ref() 187 grpc_error* grpc_error_do_ref(grpc_error* err); 189 inline grpc_error* grpc_error_ref(grpc_error* err) { in grpc_error_ref() 207 grpc_error* error = GRPC_ERROR_NONE; in grpc_error_create_from_vector() 220 grpc_error* grpc_error_set_int(grpc_error* src, grpc_error_ints which, 227 grpc_error* grpc_error_set_str(grpc_error* src, grpc_error_strs which, 245 grpc_error* grpc_error_add_child(grpc_error* src, [all …]
|
H A D | socket_utils_posix.h | 48 grpc_error* grpc_set_socket_zerocopy(int fd); 51 grpc_error* grpc_set_socket_nonblocking(int fd, int non_blocking); 54 grpc_error* grpc_set_socket_cloexec(int fd, int close_on_exec); 57 grpc_error* grpc_set_socket_reuse_addr(int fd, int reuse); 63 grpc_error* grpc_set_socket_low_latency(int fd, int low_latency); 66 grpc_error* grpc_set_socket_reuse_port(int fd, int reuse); 72 grpc_error* grpc_set_socket_tcp_user_timeout( 87 grpc_error* grpc_set_socket_no_sigpipe_if_possible(int fd); 91 grpc_error* grpc_set_socket_ip_pktinfo_if_possible(int fd); 107 grpc_error* grpc_apply_socket_mutator_in_args(int fd, [all …]
|
H A D | error.cc | 127 grpc_error* grpc_error_do_ref(grpc_error* err, const char* file, int line) { in grpc_error_do_ref() 137 grpc_error* grpc_error_do_ref(grpc_error* err) { in grpc_error_do_ref() 202 grpc_error* orig = *err; in get_placement() 272 static void internal_add_error(grpc_error** err, grpc_error* new_err) { in internal_add_error() 326 grpc_error* err = static_cast<grpc_error*>( in grpc_error_create() 392 static grpc_error* copy_error_and_unref(grpc_error* in) { in copy_error_and_unref() 394 grpc_error* out; in copy_error_and_unref() 419 out = static_cast<grpc_error*>( in copy_error_and_unref() 442 grpc_error* grpc_error_set_int(grpc_error* src, grpc_error_ints which, in grpc_error_set_int() 480 grpc_error* grpc_error_set_str(grpc_error* src, grpc_error_strs which, in grpc_error_set_str() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/iomgr/ |
H A D | error.h | 39 typedef struct grpc_error grpc_error; typedef 125 #define GRPC_ERROR_OOM ((grpc_error*)2) 173 grpc_error* grpc_error_do_ref(grpc_error* err, const char* file, int line); 175 inline grpc_error* grpc_error_ref(grpc_error* err, const char* file, int line) { in grpc_error_ref() 186 grpc_error* grpc_error_do_ref(grpc_error* err); 188 inline grpc_error* grpc_error_ref(grpc_error* err) { in grpc_error_ref() 206 grpc_error* error = GRPC_ERROR_NONE; in grpc_error_create_from_vector() 219 grpc_error* grpc_error_set_int(grpc_error* src, grpc_error_ints which, 226 grpc_error* grpc_error_set_str(grpc_error* src, grpc_error_strs which, 244 grpc_error* grpc_error_add_child(grpc_error* src, [all …]
|
H A D | socket_utils_posix.h | 39 grpc_error* grpc_set_socket_nonblocking(int fd, int non_blocking); 42 grpc_error* grpc_set_socket_cloexec(int fd, int close_on_exec); 45 grpc_error* grpc_set_socket_reuse_addr(int fd, int reuse); 51 grpc_error* grpc_set_socket_low_latency(int fd, int low_latency); 54 grpc_error* grpc_set_socket_reuse_port(int fd, int reuse); 60 grpc_error* grpc_set_socket_tcp_user_timeout( 75 grpc_error* grpc_set_socket_no_sigpipe_if_possible(int fd); 79 grpc_error* grpc_set_socket_ip_pktinfo_if_possible(int fd); 83 grpc_error* grpc_set_socket_ipv6_recvpktinfo_if_possible(int fd); 86 grpc_error* grpc_set_socket_sndbuf(int fd, int buffer_size_bytes); [all …]
|
H A D | error.cc | 125 grpc_error* grpc_error_do_ref(grpc_error* err, const char* file, int line) { in grpc_error_do_ref() 135 grpc_error* grpc_error_do_ref(grpc_error* err) { in grpc_error_do_ref() 200 grpc_error* orig = *err; in get_placement() 270 static void internal_add_error(grpc_error** err, grpc_error* new_err) { in internal_add_error() 324 grpc_error* err = static_cast<grpc_error*>( in grpc_error_create() 390 static grpc_error* copy_error_and_unref(grpc_error* in) { in copy_error_and_unref() 392 grpc_error* out; in copy_error_and_unref() 417 out = static_cast<grpc_error*>( in copy_error_and_unref() 439 grpc_error* grpc_error_set_int(grpc_error* src, grpc_error_ints which, in grpc_error_set_int() 478 grpc_error* grpc_error_set_str(grpc_error* src, grpc_error_strs which, in grpc_error_set_str() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/transport/chttp2/transport/ |
H A D | hpack_parser.cc | 78 static grpc_error* parse_value_string_with_indexed_key( 772 grpc_error* err = on_hdr<false>(p, md); in finish_indexed_field() 821 grpc_error* err = on_hdr<true>( in finish_lithdr_incidx() 833 grpc_error* err = in finish_lithdr_incidx_v() 885 grpc_error* err = on_hdr<false>( in finish_lithdr_notidx() 897 grpc_error* err = on_hdr<false>( in finish_lithdr_notidx_v() 949 grpc_error* err = on_hdr<false>( in finish_lithdr_nvridx() 961 grpc_error* err = on_hdr<false>( in finish_lithdr_nvridx_v() 1013 grpc_error* err = in finish_max_tbl_size() 1424 grpc_error* err = huff_nibble(p, *cur >> 4); in add_huff_bytes() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/health/ |
H A D | health_check_client.h | 78 static void StartBatchInCallCombiner(void* arg, grpc_error* error); 80 static void CallEndedRetry(void* arg, grpc_error* error); 83 static void OnComplete(void* arg, grpc_error* error); 85 static void RecvMessageReady(void* arg, grpc_error* error); 87 static void StartCancel(void* arg, grpc_error* error); 88 static void OnCancelComplete(void* arg, grpc_error* error); 90 static void OnByteStreamNext(void* arg, grpc_error* error); 92 grpc_error* PullSliceFromRecvMessage(); 93 void DoneReadingRecvMessage(grpc_error* error); 152 static void OnRetryTimer(void* arg, grpc_error* error); [all …]
|
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/transport/chttp2/transport/ |
H A D | hpack_parser.cc | 765 static grpc_error* GPR_ATTRIBUTE_NOINLINE 783 grpc_error* err = on_hdr<false>(p, md); in finish_indexed_field() 838 grpc_error* err = on_hdr<true>( in finish_lithdr_incidx() 850 grpc_error* err = on_hdr<true>( in finish_lithdr_incidx_v() 902 grpc_error* err = on_hdr<false>( in finish_lithdr_notidx() 914 grpc_error* err = on_hdr<false>( in finish_lithdr_notidx_v() 966 grpc_error* err = on_hdr<false>( in finish_lithdr_nvridx() 978 grpc_error* err = on_hdr<false>( in finish_lithdr_nvridx_v() 1030 grpc_error* err = in finish_max_tbl_size() 1441 grpc_error* err = huff_nibble(p, *cur >> 4); in add_huff_bytes() [all …]
|
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/transport/chttp2/transport/ |
H A D | hpack_parser.cc | 763 static grpc_error* GPR_ATTRIBUTE_NOINLINE 781 grpc_error* err = on_hdr<false>(p, md); in finish_indexed_field() 836 grpc_error* err = on_hdr<true>( in finish_lithdr_incidx() 848 grpc_error* err = on_hdr<true>( in finish_lithdr_incidx_v() 900 grpc_error* err = on_hdr<false>( in finish_lithdr_notidx() 912 grpc_error* err = on_hdr<false>( in finish_lithdr_notidx_v() 964 grpc_error* err = on_hdr<false>( in finish_lithdr_nvridx() 976 grpc_error* err = on_hdr<false>( in finish_lithdr_nvridx_v() 1028 grpc_error* err = in finish_max_tbl_size() 1441 grpc_error* err = huff_nibble(p, *cur >> 4); in add_huff_bytes() [all …]
|
H A D | parsing.cc | 37 static grpc_error* init_frame_parser(grpc_chttp2_transport* t); 44 static grpc_error* init_ping_parser(grpc_chttp2_transport* t); 49 static grpc_error* parse_frame_slice(grpc_chttp2_transport* t, 52 grpc_error* grpc_chttp2_perform_read(grpc_chttp2_transport* t, in grpc_chttp2_perform_read() 57 grpc_error* err; in grpc_chttp2_perform_read() 349 grpc_error* err = GRPC_ERROR_NONE; in init_data_frame_parser() 485 static grpc_error* GPR_ATTRIBUTE_NOINLINE 520 grpc_error* error = in on_initial_header() 570 grpc_error* error = in on_trailing_header() 620 grpc_error* err = init_skip_frame_parser(t, 1); in init_header_frame_parser() [all …]
|
/dports/devel/grpc130/grpc-1.30.2/test/core/client_channel/ |
H A D | service_config_test.cc | 156 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 164 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 176 grpc_error* error = GRPC_ERROR_NONE; 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() 272 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 285 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() [all …]
|
/dports/devel/grpc134/grpc-1.34.1/test/core/client_channel/ |
H A D | service_config_test.cc | 53 grpc_error** error) override { in ParseGlobalParams() 89 grpc_error** error) override { in ParsePerMethodParams() 126 grpc_error** error) override { in ParsePerMethodParams() 134 grpc_error** error) override { in ParseGlobalParams() 161 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 170 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 182 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 198 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 215 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 232 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() [all …]
|
/dports/devel/grpc134/grpc-1.34.1/src/core/lib/transport/ |
H A D | metadata_batch.h | 74 grpc_error* grpc_metadata_batch_substitute(grpc_metadata_batch* batch, 86 grpc_error* grpc_metadata_batch_link_head(grpc_metadata_batch* batch, 89 grpc_error* grpc_metadata_batch_link_head( 98 grpc_error* grpc_metadata_batch_link_tail(grpc_metadata_batch* batch, 101 grpc_error* grpc_metadata_batch_link_tail( 111 grpc_error* grpc_metadata_batch_add_head( 117 inline grpc_error* GRPC_MUST_USE_RESULT grpc_metadata_batch_add_head( in grpc_metadata_batch_add_head() 137 grpc_error* grpc_metadata_batch_add_tail( 155 grpc_error* grpc_attach_md_to_error(grpc_error* src, grpc_mdelem md); 158 grpc_error* error; [all …]
|
/dports/devel/grpc130/grpc-1.30.2/src/core/lib/transport/ |
H A D | metadata_batch.h | 74 grpc_error* grpc_metadata_batch_substitute(grpc_metadata_batch* batch, 86 grpc_error* grpc_metadata_batch_link_head(grpc_metadata_batch* batch, 89 grpc_error* grpc_metadata_batch_link_head( 98 grpc_error* grpc_metadata_batch_link_tail(grpc_metadata_batch* batch, 101 grpc_error* grpc_metadata_batch_link_tail( 111 grpc_error* grpc_metadata_batch_add_head( 117 inline grpc_error* GRPC_MUST_USE_RESULT grpc_metadata_batch_add_head( in grpc_metadata_batch_add_head() 137 grpc_error* grpc_metadata_batch_add_tail( 155 grpc_error* grpc_attach_md_to_error(grpc_error* src, grpc_mdelem md); 158 grpc_error* error; [all …]
|
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/xds/ |
H A D | google_mesh_ca_certificate_provider_factory.cc | 55 std::vector<grpc_error*> 58 std::vector<grpc_error*> error_list_sts_service; in ParseJsonObjectStsService() 92 std::vector<grpc_error*> 109 std::vector<grpc_error*> 112 std::vector<grpc_error*> error_list_google_grpc; in ParseJsonObjectGoogleGrpc() 140 std::vector<grpc_error*> 161 std::vector<grpc_error*> 164 std::vector<grpc_error*> error_list_server; in ParseJsonObjectServer() 205 std::vector<grpc_error*> error_list; in Parse() 209 std::vector<grpc_error*> error_list_server = in Parse() [all …]
|
H A D | xds_bootstrap.h | 75 grpc_error** error); 78 XdsBootstrap(Json json, grpc_error** error); 91 grpc_error* ParseXdsServerList(Json* json); 92 grpc_error* ParseXdsServer(Json* json, size_t idx); 93 grpc_error* ParseChannelCredsArray(Json* json, XdsServer* server); 94 grpc_error* ParseChannelCreds(Json* json, size_t idx, XdsServer* server); 95 grpc_error* ParseServerFeaturesArray(Json* json, XdsServer* server); 96 grpc_error* ParseNode(Json* json); 97 grpc_error* ParseLocality(Json* json); 98 grpc_error* ParseCertificateProviders(Json* json); [all …]
|
H A D | xds_bootstrap.cc | 186 std::vector<grpc_error*> error_list; in XdsBootstrap() 225 std::vector<grpc_error*> error_list; in ParseXdsServerList() 241 std::vector<grpc_error*> error_list; in ParseXdsServer() 288 std::vector<grpc_error*> error_list; in ParseChannelCredsArray() 309 std::vector<grpc_error*> error_list; in ParseChannelCreds() 355 std::vector<grpc_error*> error_list; in ParseServerFeaturesArray() 375 grpc_error* XdsBootstrap::ParseNode(Json* json) { in ParseNode() 376 std::vector<grpc_error*> error_list; in ParseNode() 420 std::vector<grpc_error*> error_list; in ParseLocality() 453 std::vector<grpc_error*> error_list; in ParseCertificateProviders() [all …]
|
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/health/ |
H A D | health_check_client.h | 73 static void StartBatchInCallCombiner(void* arg, grpc_error* error); 78 static void OnComplete(void* arg, grpc_error* error); 79 static void RecvInitialMetadataReady(void* arg, grpc_error* error); 80 static void RecvMessageReady(void* arg, grpc_error* error); 81 static void RecvTrailingMetadataReady(void* arg, grpc_error* error); 82 static void StartCancel(void* arg, grpc_error* error); 83 static void OnCancelComplete(void* arg, grpc_error* error); 85 static void OnByteStreamNext(void* arg, grpc_error* error); 87 grpc_error* PullSliceFromRecvMessage(); 88 void DoneReadingRecvMessage(grpc_error* error); [all …]
|
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/health/ |
H A D | health_check_client.h | 73 static void StartBatchInCallCombiner(void* arg, grpc_error* error); 78 static void OnComplete(void* arg, grpc_error* error); 79 static void RecvInitialMetadataReady(void* arg, grpc_error* error); 80 static void RecvMessageReady(void* arg, grpc_error* error); 81 static void RecvTrailingMetadataReady(void* arg, grpc_error* error); 82 static void StartCancel(void* arg, grpc_error* error); 83 static void OnCancelComplete(void* arg, grpc_error* error); 85 static void OnByteStreamNext(void* arg, grpc_error* error); 87 grpc_error* PullSliceFromRecvMessage(); 88 void DoneReadingRecvMessage(grpc_error* error); [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/client_channel/ |
H A D | service_config_test.cc | 160 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 170 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 177 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 193 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 209 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 216 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 229 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 239 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 252 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() 267 grpc_error* error = GRPC_ERROR_NONE; in TEST_F() [all …]
|
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/http/message_compress/ |
H A D | message_decompress_filter.cc | 74 static void OnRecvMessageReady(void* arg, grpc_error* error); 75 static void OnRecvMessageNextDone(void* arg, grpc_error* error); 76 grpc_error* PullSliceFromRecvMessage(); 79 void ContinueRecvMessageReadyCallback(grpc_error* error); 87 grpc_error* error_ = GRPC_ERROR_NONE; 154 void CallData::OnRecvMessageReady(void* arg, grpc_error* error) { in OnRecvMessageReady() 185 grpc_error* error = PullSliceFromRecvMessage(); in ContinueReadingRecvMessage() 196 grpc_error* CallData::PullSliceFromRecvMessage() { in PullSliceFromRecvMessage() 198 grpc_error* error = (*recv_message_)->Pull(&incoming_slice); in PullSliceFromRecvMessage() 263 grpc_error* error = on_recv_trailing_metadata_ready_error_; in MaybeResumeOnRecvTrailingMetadataReady() [all …]
|