| /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);
|
| D | socket_utils_common_posix.cc | 51 grpc_error* grpc_set_socket_nonblocking(int fd, int non_blocking) { in grpc_set_socket_nonblocking()
70 grpc_error* grpc_set_socket_no_sigpipe_if_possible(int fd) { in grpc_set_socket_no_sigpipe_if_possible()
88 grpc_error* grpc_set_socket_ip_pktinfo_if_possible(int fd) { in grpc_set_socket_ip_pktinfo_if_possible()
99 grpc_error* grpc_set_socket_ipv6_recvpktinfo_if_possible(int fd) { in grpc_set_socket_ipv6_recvpktinfo_if_possible()
110 grpc_error* grpc_set_socket_sndbuf(int fd, int buffer_size_bytes) { in grpc_set_socket_sndbuf()
117 grpc_error* grpc_set_socket_rcvbuf(int fd, int buffer_size_bytes) { in grpc_set_socket_rcvbuf()
125 grpc_error* grpc_set_socket_cloexec(int fd, int close_on_exec) { in grpc_set_socket_cloexec()
145 grpc_error* grpc_set_socket_reuse_addr(int fd, int reuse) { in grpc_set_socket_reuse_addr()
163 grpc_error* grpc_set_socket_reuse_port(int fd, int reuse) { in grpc_set_socket_reuse_port()
210 grpc_error* grpc_set_socket_low_latency(int fd, int low_latency) { in grpc_set_socket_low_latency()
[all …]
|
| D | wakeup_fd_posix.h | 68 grpc_error* (*init)(grpc_wakeup_fd* fd_info);
69 grpc_error* (*consume)(grpc_wakeup_fd* fd_info);
70 grpc_error* (*wakeup)(grpc_wakeup_fd* fd_info);
86 grpc_error* grpc_wakeup_fd_init(grpc_wakeup_fd* fd_info) GRPC_MUST_USE_RESULT;
87 grpc_error* grpc_wakeup_fd_consume_wakeup(grpc_wakeup_fd* fd_info)
89 grpc_error* grpc_wakeup_fd_wakeup(grpc_wakeup_fd* fd_info) GRPC_MUST_USE_RESULT;
|
| D | tcp_uv.cc | 59 grpc_error* accept_error;
69 static grpc_error* tcp_error_create(const char* desc, int status) { in tcp_error_create()
73 grpc_error* error = GRPC_ERROR_CREATE_FROM_STATIC_STRING(desc); in tcp_error_create()
99 grpc_error* error = GRPC_ERROR_NONE; in uv_read_callback()
130 grpc_error* error; in uv_socket_read()
188 static grpc_error* uv_socket_init_helper(uv_socket_t* uv_socket, int domain) { in uv_socket_init_helper()
216 static grpc_error* uv_socket_init(grpc_custom_socket* socket, int domain) { in uv_socket_init()
218 grpc_error* error = uv_socket_init_helper(uv_socket, domain); in uv_socket_init()
227 static grpc_error* uv_socket_getpeername(grpc_custom_socket* socket, in uv_socket_getpeername()
236 static grpc_error* uv_socket_getsockname(grpc_custom_socket* socket, in uv_socket_getsockname()
[all …]
|
| D | combiner.cc | 66 static void combiner_run(grpc_closure* closure, grpc_error* error);
67 static void combiner_exec(grpc_closure* closure, grpc_error* error);
68 static void combiner_finally_exec(grpc_closure* closure, grpc_error* error);
75 static void offload(void* arg, grpc_error* error);
158 static void combiner_exec(grpc_closure* cl, grpc_error* error) { in combiner_exec()
199 static void offload(void* arg, grpc_error* error) { in offload()
256 grpc_error* cl_err = cl->error_data.error; in grpc_combiner_continue_exec_ctx()
272 grpc_error* error = c->error_data.error; in grpc_combiner_continue_exec_ctx()
323 static void enqueue_finally(void* closure, grpc_error* error);
325 static void combiner_finally_exec(grpc_closure* closure, grpc_error* error) { in combiner_finally_exec()
[all …]
|
| /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 …]
|
| D | internal.h | 217 grpc_error* Pull(grpc_slice* slice) override;
218 void Shutdown(grpc_error* error) override;
237 void PublishError(grpc_error* error);
239 grpc_error* Push(grpc_slice slice, grpc_slice* slice_out);
241 grpc_error* Finished(grpc_error* error, bool reset_on_error);
246 static void NextLocked(void* arg, grpc_error* error_ignored);
247 static void OrphanLocked(void* arg, grpc_error* error_ignored);
301 grpc_error* closed_with_error;
354 grpc_error* goaway_error;
422 grpc_error* (*parser)(void* parser_user_data, grpc_chttp2_transport* t,
[all …]
|
| D | chttp2_transport.cc | 100 static void write_action_begin_locked(void* t, grpc_error* error);
101 static void write_action(void* t, grpc_error* error);
102 static void write_action_end_locked(void* t, grpc_error* error);
104 static void read_action_locked(void* t, grpc_error* error);
106 static void complete_fetch_locked(void* gs, grpc_error* error);
112 grpc_error* error);
119 grpc_error* error, const char* reason);
121 static void benign_reclaimer_locked(void* t, grpc_error* error);
122 static void destructive_reclaimer_locked(void* t, grpc_error* error);
127 static void close_transport_locked(grpc_chttp2_transport* t, grpc_error* error);
[all …]
|
| D | frame_data.h | 50 grpc_error* error;
57 grpc_error* grpc_chttp2_data_parser_init(grpc_chttp2_data_parser* parser);
62 grpc_error* grpc_chttp2_data_parser_begin_frame(grpc_chttp2_data_parser* parser,
69 grpc_error* grpc_chttp2_data_parser_parse(void* parser,
79 grpc_error* grpc_deframe_unprocessed_incoming_frames(
|
| /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(
|
| D | metadata_batch.cc | 88 grpc_error* grpc_attach_md_to_error(grpc_error* src, grpc_mdelem md) { in grpc_attach_md_to_error()
89 grpc_error* out = grpc_error_set_str( in grpc_attach_md_to_error()
96 static grpc_error* maybe_link_callout(grpc_metadata_batch* batch,
100 static grpc_error* maybe_link_callout(grpc_metadata_batch* batch, in maybe_link_callout()
129 grpc_error* grpc_metadata_batch_add_head(grpc_metadata_batch* batch, in grpc_metadata_batch_add_head()
152 grpc_error* grpc_metadata_batch_link_head(grpc_metadata_batch* batch, in grpc_metadata_batch_link_head()
155 grpc_error* err = maybe_link_callout(batch, storage); in grpc_metadata_batch_link_head()
165 grpc_error* grpc_metadata_batch_add_tail(grpc_metadata_batch* batch, in grpc_metadata_batch_add_tail()
189 grpc_error* grpc_metadata_batch_link_tail(grpc_metadata_batch* batch, in grpc_metadata_batch_link_tail()
192 grpc_error* err = maybe_link_callout(batch, storage); in grpc_metadata_batch_link_tail()
[all …]
|
| D | byte_stream.h | 55 virtual grpc_error* Pull(grpc_slice* slice) GRPC_ABSTRACT;
64 virtual void Shutdown(grpc_error* error) GRPC_ABSTRACT;
98 grpc_error* Pull(grpc_slice* slice) override;
99 void Shutdown(grpc_error* error) override;
104 grpc_error* shutdown_error_ = GRPC_ERROR_NONE;
133 grpc_error* Pull(grpc_slice* slice) override;
134 void Shutdown(grpc_error* error) override;
143 grpc_error* shutdown_error_ = GRPC_ERROR_NONE;
|
| D | error_utils.cc | 27 static grpc_error* recursively_find_error_with_field(grpc_error* error, in recursively_find_error_with_field()
39 grpc_error* result = recursively_find_error_with_field(lerr->err, which); in recursively_find_error_with_field()
46 void grpc_error_get_status(grpc_error* error, grpc_millis deadline, in grpc_error_get_status()
52 grpc_error* found_error = in grpc_error_get_status()
104 bool grpc_error_has_clear_grpc_status(grpc_error* error) { in grpc_error_has_clear_grpc_status()
|
| /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 …]
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | grpc_gevent.pxd.pxi | 23 struct grpc_error:
27 grpc_error* grpc_socket_error(char* error)
49 grpc_error* (*resolve)(char* host, char* port, grpc_resolved_addresses** res);
54 grpc_error* error);
61 grpc_error* error)
63 grpc_error* error)
65 size_t nread, grpc_error* error)
68 grpc_error* error)
72 grpc_error* (*init)(grpc_custom_socket* socket, int domain);
82 grpc_error* (*getpeername)(grpc_custom_socket* socket,
[all …]
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_error.cc | 34 void operator()(grpc_error* error) { GRPC_ERROR_UNREF(error); } in operator ()()
36 typedef std::unique_ptr<grpc_error, ErrorDeleter> ErrorPtr;
82 grpc_error* error = GRPC_ERROR_CREATE_FROM_STATIC_STRING("Error"); in BM_ErrorCreateAndSetIntLoop()
94 grpc_error* error = GRPC_ERROR_CREATE_FROM_STATIC_STRING("Error"); in BM_ErrorCreateAndSetStrLoop()
107 grpc_error* error = GRPC_ERROR_CREATE_FROM_STATIC_STRING("Error"); in BM_ErrorRefUnref()
162 grpc_error* error() const { return GRPC_ERROR_NONE; } in error()
171 grpc_error* error() const { return GRPC_ERROR_CANCELLED; } in error()
180 grpc_error* error() const { return error_.get(); } in error()
190 grpc_error* error() const { return error_.get(); } in error()
202 grpc_error* error() const { return error_.get(); } in error()
[all …]
|
| /external/grpc-grpc/doc/core/ |
| D | grpc-error.md | 5 `grpc_error` is the c-core's opaque representation of an error. It holds a
25 This document serves as a detailed overview of grpc_error's ownership rules. It
43 * If `grpc_error` is returned by a function, the caller owns a ref to that
45 * If a `grpc_error` is passed to a `grpc_closure` callback function, then that
47 * if a `grpc_error` is passed to *any other function*, then that function
52 > If `grpc_error` is returned by a function, the caller owns a ref to that
59 grpc_error* error1 = GRPC_ERROR_CREATE_FROM_STATIC_STRING("Some error occurred");
60 grpc_error* error2 = some_operation_that_might_fail(...);
68 > If a `grpc_error` is passed to a `grpc_closure` callback function, then that
74 void (*cb)(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error);
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| D | round_robin.cc | 61 bool PickLocked(PickState* pick, grpc_error** error) override;
62 void CancelPickLocked(PickState* pick, grpc_error* error) override;
65 grpc_error* error) override;
69 grpc_error** connectivity_error) override;
121 grpc_connectivity_state connectivity_state, grpc_error* error);
125 grpc_connectivity_state connectivity_state, grpc_error* error) override;
166 grpc_error* transient_failure_error);
184 grpc_error* last_transient_failure_error_ = GRPC_ERROR_NONE;
259 grpc_error* error = GRPC_ERROR_NONE; in HandOffPendingPicksLocked()
269 grpc_error* error = GRPC_ERROR_CREATE_FROM_STATIC_STRING("Channel shutdown"); in ShutdownLocked()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 54 grpc_error* recv_initial_metadata_ready_error;
76 static grpc_error* hs_filter_outgoing_metadata(grpc_call_element* elem, in hs_filter_outgoing_metadata()
92 static void hs_add_error(const char* error_name, grpc_error** cumulative, in hs_add_error()
93 grpc_error* new_err) { in hs_add_error()
101 static grpc_error* hs_filter_incoming_metadata(grpc_call_element* elem, in hs_filter_incoming_metadata()
104 grpc_error* error = GRPC_ERROR_NONE; in hs_filter_incoming_metadata()
278 static void hs_recv_initial_metadata_ready(void* user_data, grpc_error* err) { in hs_recv_initial_metadata_ready()
307 static void hs_recv_message_ready(void* user_data, grpc_error* err) { in hs_recv_message_ready()
331 static void hs_recv_trailing_metadata_ready(void* user_data, grpc_error* err) { in hs_recv_trailing_metadata_ready()
340 static grpc_error* hs_mutate_op(grpc_call_element* elem, in hs_mutate_op()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 62 grpc_error* cancel_error;
104 static grpc_error* process_send_initial_metadata(
107 static grpc_error* process_send_initial_metadata( in process_send_initial_metadata()
164 grpc_error* error = GRPC_ERROR_NONE; in process_send_initial_metadata()
200 static void send_message_on_complete(void* arg, grpc_error* error) { in send_message_on_complete()
268 grpc_error* error) { in fail_send_message_batch_in_call_combiner()
278 static grpc_error* pull_slice_from_send_message(call_data* calld) { in pull_slice_from_send_message()
280 grpc_error* error = in pull_slice_from_send_message()
297 grpc_error* error = pull_slice_from_send_message(calld); in continue_reading_send_message()
313 static void on_send_message_next_done(void* arg, grpc_error* error) { in on_send_message_next_done()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 127 bool PickLocked(PickState* pick, grpc_error** error) override;
128 void CancelPickLocked(PickState* pick, grpc_error* error) override;
131 grpc_error* error) override;
135 grpc_error** connectivity_error) override;
204 static void MaybeSendClientLoadReportLocked(void* arg, grpc_error* error);
205 static void ClientLoadReportDoneLocked(void* arg, grpc_error* error);
206 static void OnInitialRequestSentLocked(void* arg, grpc_error* error);
207 static void OnBalancerMessageReceivedLocked(void* arg, grpc_error* error);
208 static void OnBalancerStatusReceivedLocked(void* arg, grpc_error* error);
257 static void OnFallbackTimerLocked(void* arg, grpc_error* error);
[all …]
|