/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
D | error.h | 38 typedef struct grpc_error grpc_error; typedef 124 #define GRPC_ERROR_NONE ((grpc_error*)NULL) 125 #define GRPC_ERROR_RESERVED_1 ((grpc_error*)1) 126 #define GRPC_ERROR_OOM ((grpc_error*)2) 127 #define GRPC_ERROR_RESERVED_2 ((grpc_error*)3) 128 #define GRPC_ERROR_CANCELLED ((grpc_error*)4) 131 inline bool grpc_error_is_special(struct grpc_error* err) { in grpc_error_is_special() 140 const char* grpc_error_string(grpc_error* error); 143 grpc_error* grpc_error_create(const char* file, int line, 144 const grpc_slice& desc, grpc_error** referencing, [all …]
|
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); 95 grpc_error* grpc_set_socket_ipv6_recvpktinfo_if_possible(int fd); [all …]
|
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() 143 static void unref_errs(grpc_error* err) { in unref_errs() 155 static void unref_strs(grpc_error* err) { in unref_strs() 165 static void error_destroy(grpc_error* err) { in error_destroy() 175 void grpc_error_do_unref(grpc_error* err, const char* file, int line) { in grpc_error_do_unref() 186 void grpc_error_do_unref(grpc_error* err) { in grpc_error_do_unref() 193 static uint8_t get_placement(grpc_error** err, size_t size) { in get_placement() 203 grpc_error* orig = *err; in get_placement() 205 *err = static_cast<grpc_error*>(gpr_realloc( in get_placement() [all …]
|
D | tcp_custom.h | 43 grpc_error* error); 45 grpc_error* error); 47 size_t nread, grpc_error* error); 50 grpc_error* error); 54 grpc_error* (*init)(grpc_custom_socket* socket, int domain); 64 grpc_error* (*getpeername)(grpc_custom_socket* socket, 66 grpc_error* (*getsockname)(grpc_custom_socket* socket, 68 grpc_error* (*bind)(grpc_custom_socket* socket, const grpc_sockaddr* addr, 70 grpc_error* (*listen)(grpc_custom_socket* socket);
|
/external/grpc-grpc/src/core/lib/iomgr/ |
D | error.h | 38 typedef struct grpc_error grpc_error; typedef 122 #define GRPC_ERROR_NONE ((grpc_error*)NULL) 123 #define GRPC_ERROR_OOM ((grpc_error*)2) 124 #define GRPC_ERROR_CANCELLED ((grpc_error*)4) 131 const char* grpc_error_string(grpc_error* error); 134 grpc_error* grpc_error_create(const char* file, int line, grpc_slice desc, 135 grpc_error** referencing, size_t num_referencing); 161 grpc_error* grpc_error_ref(grpc_error* err, const char* file, int line); 162 void grpc_error_unref(grpc_error* err, const char* file, int line); 166 grpc_error* grpc_error_ref(grpc_error* err); [all …]
|
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 …]
|
D | error.cc | 124 bool grpc_error_is_special(grpc_error* err) { in grpc_error_is_special() 130 grpc_error* grpc_error_ref(grpc_error* err, const char* file, int line) { in grpc_error_ref() 141 grpc_error* grpc_error_ref(grpc_error* err) { in grpc_error_ref() 148 static void unref_errs(grpc_error* err) { in unref_errs() 162 static void unref_strs(grpc_error* err) { in unref_strs() 171 static void error_destroy(grpc_error* err) { in error_destroy() 180 void grpc_error_unref(grpc_error* err, const char* file, int line) { in grpc_error_unref() 192 void grpc_error_unref(grpc_error* err) { in grpc_error_unref() 200 static uint8_t get_placement(grpc_error** err, size_t size) { in get_placement() 210 grpc_error* orig = *err; in get_placement() [all …]
|
D | tcp_custom.h | 40 grpc_error* error); 42 grpc_error* error); 44 size_t nread, grpc_error* error); 47 grpc_error* error); 51 grpc_error* (*init)(grpc_custom_socket* socket, int domain); 61 grpc_error* (*getpeername)(grpc_custom_socket* socket, 63 grpc_error* (*getsockname)(grpc_custom_socket* socket, 65 grpc_error* (*bind)(grpc_custom_socket* socket, const grpc_sockaddr* addr, 67 grpc_error* (*listen)(grpc_custom_socket* socket);
|
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
D | hpack_parser.cc | 64 static grpc_error* parse_begin(grpc_chttp2_hpack_parser* p, const uint8_t* cur, 66 static grpc_error* parse_error(grpc_chttp2_hpack_parser* p, const uint8_t* cur, 67 const uint8_t* end, grpc_error* error); 68 static grpc_error* still_parse_error(grpc_chttp2_hpack_parser* p, 70 static grpc_error* parse_illegal_op(grpc_chttp2_hpack_parser* p, 73 static grpc_error* parse_string_prefix(grpc_chttp2_hpack_parser* p, 75 static grpc_error* parse_key_string(grpc_chttp2_hpack_parser* p, 77 static grpc_error* parse_value_string_with_indexed_key( 79 static grpc_error* parse_value_string_with_literal_key( 82 static grpc_error* parse_value0(grpc_chttp2_hpack_parser* p, const uint8_t* cur, [all …]
|
D | parsing.cc | 36 static grpc_error* init_frame_parser(grpc_chttp2_transport* t); 37 static grpc_error* init_header_frame_parser(grpc_chttp2_transport* t, 39 static grpc_error* init_data_frame_parser(grpc_chttp2_transport* t); 40 static grpc_error* init_rst_stream_parser(grpc_chttp2_transport* t); 41 static grpc_error* init_settings_frame_parser(grpc_chttp2_transport* t); 42 static grpc_error* init_window_update_frame_parser(grpc_chttp2_transport* t); 43 static grpc_error* init_ping_parser(grpc_chttp2_transport* t); 44 static grpc_error* init_goaway_parser(grpc_chttp2_transport* t); 45 static grpc_error* init_skip_frame_parser(grpc_chttp2_transport* t, 48 static grpc_error* parse_frame_slice(grpc_chttp2_transport* t, grpc_slice slice, [all …]
|
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
D | hpack_parser.cc | 70 static grpc_error* parse_begin(grpc_chttp2_hpack_parser* p, const uint8_t* cur, 72 static grpc_error* parse_error(grpc_chttp2_hpack_parser* p, const uint8_t* cur, 73 const uint8_t* end, grpc_error* error); 74 static grpc_error* still_parse_error(grpc_chttp2_hpack_parser* p, 76 static grpc_error* parse_illegal_op(grpc_chttp2_hpack_parser* p, 79 static grpc_error* parse_string_prefix(grpc_chttp2_hpack_parser* p, 81 static grpc_error* parse_key_string(grpc_chttp2_hpack_parser* p, 83 static grpc_error* parse_value_string_with_indexed_key( 85 static grpc_error* parse_value_string_with_literal_key( 88 static grpc_error* parse_value0(grpc_chttp2_hpack_parser* p, const uint8_t* cur, [all …]
|
D | parsing.cc | 39 static grpc_error* init_frame_parser(grpc_chttp2_transport* t); 40 static grpc_error* init_header_frame_parser(grpc_chttp2_transport* t, 42 static grpc_error* init_data_frame_parser(grpc_chttp2_transport* t); 43 static grpc_error* init_rst_stream_parser(grpc_chttp2_transport* t); 44 static grpc_error* init_settings_frame_parser(grpc_chttp2_transport* t); 45 static grpc_error* init_window_update_frame_parser(grpc_chttp2_transport* t); 46 static grpc_error* init_ping_parser(grpc_chttp2_transport* t); 47 static grpc_error* init_goaway_parser(grpc_chttp2_transport* t); 48 static grpc_error* init_skip_frame_parser(grpc_chttp2_transport* t, 51 static grpc_error* parse_frame_slice(grpc_chttp2_transport* t, [all …]
|
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
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() 123 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( 141 inline grpc_error* GRPC_MUST_USE_RESULT grpc_metadata_batch_add_tail( in grpc_metadata_batch_add_tail() [all …]
|
D | metadata_batch.cc | 94 grpc_error* grpc_attach_md_to_error(grpc_error* src, grpc_mdelem md) { in grpc_attach_md_to_error() 95 grpc_error* out = grpc_error_set_str( in grpc_attach_md_to_error() 102 static grpc_error* GPR_ATTRIBUTE_NOINLINE error_with_md(grpc_mdelem md) { in error_with_md() 107 static grpc_error* link_callout(grpc_metadata_batch* batch, in link_callout() 119 static grpc_error* maybe_link_callout(grpc_metadata_batch* batch, 123 static grpc_error* maybe_link_callout(grpc_metadata_batch* batch, in maybe_link_callout() 145 grpc_error* grpc_metadata_batch_add_head(grpc_metadata_batch* batch, in grpc_metadata_batch_add_head() 169 grpc_error* grpc_metadata_batch_link_head(grpc_metadata_batch* batch, in grpc_metadata_batch_link_head() 172 grpc_error* err = maybe_link_callout(batch, storage); in grpc_metadata_batch_link_head() 185 grpc_error* grpc_metadata_batch_link_head( in grpc_metadata_batch_link_head() [all …]
|
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/external/ |
D | aws_external_account_credentials.h | 31 Options options, std::vector<std::string> scopes, grpc_error** error); 35 grpc_error** error); 40 std::function<void(std::string, grpc_error*)> cb) override; 43 static void OnRetrieveRegion(void* arg, grpc_error* error); 44 void OnRetrieveRegionInternal(grpc_error* error); 47 static void OnRetrieveRoleName(void* arg, grpc_error* error); 48 void OnRetrieveRoleNameInternal(grpc_error* error); 51 static void OnRetrieveSigningKeys(void* arg, grpc_error* error); 52 void OnRetrieveSigningKeysInternal(grpc_error* error); 55 void FinishRetrieveSubjectToken(std::string subject_token, grpc_error* error); [all …]
|
/external/rust/crates/grpcio-sys/grpc/src/core/ext/xds/ |
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*> 95 std::vector<grpc_error*> error_list_call_credentials; in ParseJsonObjectCallCredentials() 99 std::vector<grpc_error*> error_list_sts_service = in ParseJsonObjectCallCredentials() 109 std::vector<grpc_error*> 112 std::vector<grpc_error*> error_list_google_grpc; in ParseJsonObjectGoogleGrpc() 127 std::vector<grpc_error*> error_list_call_credentials = in ParseJsonObjectGoogleGrpc() 140 std::vector<grpc_error*> 143 std::vector<grpc_error*> error_list_grpc_services; in ParseJsonObjectGrpcServices() [all …]
|
D | xds_bootstrap.h | 74 grpc_error** error); 77 XdsBootstrap(Json json, grpc_error** error); 90 grpc_error* ParseXdsServerList(Json* json); 91 grpc_error* ParseXdsServer(Json* json, size_t idx); 92 grpc_error* ParseChannelCredsArray(Json* json, XdsServer* server); 93 grpc_error* ParseChannelCreds(Json* json, size_t idx, XdsServer* server); 94 grpc_error* ParseServerFeaturesArray(Json* json, XdsServer* server); 95 grpc_error* ParseNode(Json* json); 96 grpc_error* ParseLocality(Json* json); 97 grpc_error* ParseCertificateProviders(Json* json); [all …]
|
D | xds_bootstrap.cc | 139 grpc_error** error) { in ReadFromFile() 163 grpc_error* error_out = GRPC_ERROR_CREATE_REFERENCING_FROM_COPIED_STRING( in ReadFromFile() 180 XdsBootstrap::XdsBootstrap(Json json, grpc_error** error) { in XdsBootstrap() 186 std::vector<grpc_error*> error_list; in XdsBootstrap() 195 grpc_error* parse_error = ParseXdsServerList(&it->second); in XdsBootstrap() 204 grpc_error* parse_error = ParseNode(&it->second); in XdsBootstrap() 215 grpc_error* parse_error = ParseCertificateProviders(&it->second); in XdsBootstrap() 224 grpc_error* XdsBootstrap::ParseXdsServerList(Json* json) { in ParseXdsServerList() 225 std::vector<grpc_error*> error_list; in ParseXdsServerList() 232 grpc_error* parse_error = ParseXdsServer(&child, i); in ParseXdsServerList() [all …]
|
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/ |
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 …]
|
/external/rust/crates/grpcio-sys/grpc/test/core/security/ |
D | aws_request_signer_test.cc | 68 grpc_error* error = GRPC_ERROR_NONE; in TEST() 86 grpc_error* error = GRPC_ERROR_NONE; in TEST() 103 grpc_error* error = GRPC_ERROR_NONE; in TEST() 120 grpc_error* error = GRPC_ERROR_NONE; in TEST() 137 grpc_error* error = GRPC_ERROR_NONE; in TEST() 152 grpc_error* error = GRPC_ERROR_NONE; in TEST() 167 grpc_error* error = GRPC_ERROR_NONE; in TEST() 182 grpc_error* error = GRPC_ERROR_NONE; in TEST() 197 grpc_error* error = GRPC_ERROR_NONE; in TEST() 212 grpc_error* error = GRPC_ERROR_NONE; in TEST() [all …]
|
/external/grpc-grpc/src/core/lib/transport/ |
D | metadata_batch.h | 70 grpc_error* grpc_metadata_batch_substitute(grpc_metadata_batch* batch, 82 grpc_error* grpc_metadata_batch_link_head(grpc_metadata_batch* batch, 91 grpc_error* grpc_metadata_batch_link_tail(grpc_metadata_batch* batch, 101 grpc_error* grpc_metadata_batch_add_head( 111 grpc_error* grpc_metadata_batch_add_tail( 115 grpc_error* grpc_attach_md_to_error(grpc_error* src, grpc_mdelem md); 118 grpc_error* error; 131 grpc_error* grpc_metadata_batch_filter(
|
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
D | security_handshaker.cc | 53 void Shutdown(grpc_error* why) override; 60 grpc_error* DoHandshakerNextLocked(const unsigned char* bytes_received, 63 grpc_error* OnHandshakeNextDoneLocked( 66 void HandshakeFailedLocked(grpc_error* error); 69 static void OnHandshakeDataReceivedFromPeerFn(void* arg, grpc_error* error); 70 static void OnHandshakeDataSentToPeerFn(void* arg, grpc_error* error); 72 grpc_error* error); 74 grpc_error* error); 78 static void OnPeerCheckedFn(void* arg, grpc_error* error); 79 void OnPeerCheckedInner(grpc_error* error); [all …]
|
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/client/ |
D | chttp2_connector.h | 36 void Shutdown(grpc_error* error) override; 39 static void Connected(void* arg, grpc_error* error); 41 static void OnHandshakeDone(void* arg, grpc_error* error); 42 static void OnReceiveSettings(void* arg, grpc_error* error); 43 static void OnTimeout(void* arg, grpc_error* error); 54 void MaybeNotify(grpc_error* error); 69 absl::optional<grpc_error*> notify_error_;
|
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
D | message_decompress_filter.cc | 92 static void OnRecvInitialMetadataReady(void* arg, grpc_error* error); 96 static void OnRecvMessageReady(void* arg, grpc_error* error); 97 static void OnRecvMessageNextDone(void* arg, grpc_error* error); 98 grpc_error* PullSliceFromRecvMessage(); 101 void ContinueRecvMessageReadyCallback(grpc_error* error); 105 static void OnRecvTrailingMetadataReady(void* arg, grpc_error* error); 109 grpc_error* error_ = GRPC_ERROR_NONE; 133 grpc_error* on_recv_trailing_metadata_ready_error_ = GRPC_ERROR_NONE; 152 void CallData::OnRecvInitialMetadataReady(void* arg, grpc_error* error) { in OnRecvInitialMetadataReady() 177 void CallData::OnRecvMessageReady(void* arg, grpc_error* error) { in OnRecvMessageReady() [all …]
|
/external/grpc-grpc/test/core/iomgr/ |
D | error_test.cc | 30 grpc_error* error = GRPC_ERROR_CREATE_FROM_STATIC_STRING("Test"); in test_set_get_int() 52 grpc_error* error = GRPC_ERROR_CREATE_FROM_STATIC_STRING("Test"); in test_set_get_str() 79 grpc_error* error1 = grpc_error_set_str( in test_copy_and_unref() 90 grpc_error* error3 = grpc_error_set_str( in test_copy_and_unref() 108 grpc_error* child = grpc_error_set_str( in test_create_referencing() 111 grpc_error* parent = in test_create_referencing() 120 grpc_error* children[3]; in test_create_referencing_many() 131 grpc_error* parent = in test_create_referencing_many() 142 grpc_error* error = in print_error_string() 153 grpc_error* children[2]; in print_error_string_reference() [all …]
|