| /third_party/grpc/src/core/lib/iomgr/ |
| D | ev_posix.h | 44 typedef struct grpc_fd grpc_fd; typedef
51 grpc_fd* (*fd_create)(int fd, const char* name, bool track_err);
52 int (*fd_wrapped_fd)(grpc_fd* fd);
53 void (*fd_orphan)(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
55 void (*fd_shutdown)(grpc_fd* fd, grpc_error* why);
56 void (*fd_notify_on_read)(grpc_fd* fd, grpc_closure* closure);
57 void (*fd_notify_on_write)(grpc_fd* fd, grpc_closure* closure);
58 void (*fd_notify_on_error)(grpc_fd* fd, grpc_closure* closure);
59 void (*fd_set_readable)(grpc_fd* fd);
60 void (*fd_set_writable)(grpc_fd* fd);
[all …]
|
| D | ev_poll_posix.cc | 62 grpc_fd* fd;
71 grpc_fd* fd;
78 struct grpc_fd { struct
149 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset, argument
159 static bool fd_is_orphaned(grpc_fd* fd);
162 static void fd_ref(grpc_fd* fd, const char* reason, const char* file, int line);
163 static void fd_unref(grpc_fd* fd, const char* reason, const char* file,
168 static void fd_ref(grpc_fd* fd);
169 static void fd_unref(grpc_fd* fd);
208 grpc_fd** fds;
[all …]
|
| D | ev_posix.cc | 253 grpc_fd* grpc_fd_create(int fd, const char* name, bool track_err) { in grpc_fd_create()
260 int grpc_fd_wrapped_fd(grpc_fd* fd) { in grpc_fd_wrapped_fd()
264 void grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd, in grpc_fd_orphan()
273 void grpc_fd_shutdown(grpc_fd* fd, grpc_error* why) { in grpc_fd_shutdown()
279 bool grpc_fd_is_shutdown(grpc_fd* fd) { in grpc_fd_is_shutdown()
283 void grpc_fd_notify_on_read(grpc_fd* fd, grpc_closure* closure) { in grpc_fd_notify_on_read()
287 void grpc_fd_notify_on_write(grpc_fd* fd, grpc_closure* closure) { in grpc_fd_notify_on_write()
291 void grpc_fd_notify_on_error(grpc_fd* fd, grpc_closure* closure) { in grpc_fd_notify_on_error()
295 void grpc_fd_set_readable(grpc_fd* fd) { g_event_engine->fd_set_readable(fd); } in grpc_fd_set_readable()
297 void grpc_fd_set_writable(grpc_fd* fd) { g_event_engine->fd_set_writable(fd); } in grpc_fd_set_writable()
[all …]
|
| D | ev_epollex_linux.cc | 99 grpc_fd* owner_fd; // Set to the owner_fd if the type is PO_FD
163 struct grpc_fd { struct
164 grpc_fd(int fd, const char* name, bool track_err) in grpc_fd() function
247 struct grpc_fd* freelist_next = nullptr; argument
310 grpc_fd** fds;
344 static grpc_fd* fd_freelist = nullptr;
350 static void ref_by(grpc_fd* fd, int n, const char* reason, const char* file,
369 static void ref_by(grpc_fd* fd, int n) {
376 grpc_fd* fd = static_cast<grpc_fd*>(arg);
387 static void unref_by(grpc_fd* fd, int n, const char* reason, const char* file,
[all …]
|
| D | ev_epoll1_linux.cc | 142 grpc_fd* fd;
143 grpc_fd* next;
144 grpc_fd* prev;
147 struct grpc_fd { struct
154 struct grpc_fd* freelist_next; argument
276 static grpc_fd* fd_freelist = nullptr;
280 static grpc_fd* fork_fd_list_head = nullptr;
293 grpc_fd* fd = fd_freelist; in fd_global_shutdown()
300 static void fork_fd_list_add_grpc_fd(grpc_fd* fd) { in fork_fd_list_add_grpc_fd()
315 static void fork_fd_list_remove_grpc_fd(grpc_fd* fd) { in fork_fd_list_remove_grpc_fd()
[all …]
|
| D | udp_server.h | 43 GrpcUdpHandler(grpc_fd* /* emfd */, void* /* user_data */) {} in GrpcUdpHandler() argument
69 virtual GrpcUdpHandler* CreateUdpHandler(grpc_fd* emfd, void* user_data) = 0;
|
| D | tcp_client_posix.cc | 55 grpc_fd* fd;
125 grpc_fd* fd, const grpc_channel_args* channel_args, const char* addr_str) { in grpc_tcp_client_create_from_fd()
137 grpc_fd* fd; in on_writable()
287 grpc_fd* fdobj = grpc_fd_create(fd, name.c_str(), true); in grpc_tcp_client_create_from_prepared_fd()
|
| D | tcp_posix.h | 45 grpc_endpoint* grpc_tcp_create(grpc_fd* fd, const grpc_channel_args* args,
|
| D | tcp_client_posix.h | 36 grpc_fd* fd, const grpc_channel_args* channel_args, const char* addr_str);
|
| D | tcp_server_utils_posix.h | 32 grpc_fd* emfd;
|
| D | udp_server.cc | 104 grpc_fd* emfd() const { return emfd_; } in emfd()
122 grpc_fd* emfd_;
|
| D | tcp_server_posix.cc | 248 grpc_fd* fdobj = grpc_fd_create(fd, name.c_str(), true); in on_read()
594 grpc_fd* fdobj = grpc_fd_create(fd, name.c_str(), true); in Handle()
|
| D | tcp_posix.cc | 359 grpc_fd* em_fd;
1697 grpc_endpoint* grpc_tcp_create(grpc_fd* em_fd, in grpc_tcp_create()
|
| /third_party/grpc/doc/core/ |
| D | grpc-polling-engines.md | 36 - **grpc_fd:** Structure representing a file descriptor
37 … more grpc_fds that are ‘polled’ for readable/writable/error events. One grpc_fd can be in multipl…
39 - **grpc_pollset_set:** A group of `grpc_fd`s, `grpc_pollset`s and `grpc_pollset_set`s (yes, a `grp…
43 #### grpc_fd subsubsection
45 - Signature: `grpc_fd_notify_on_(grpc_fd* fd, grpc_closure* closure)`
50 - Signature: `grpc_fd_shutdown(grpc_fd* fd)`
54 - Signature: `grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd, char* reason)`
55 - Release the `grpc_fd` structure and call `on_done` closure when the operation is complete
62 - Signature: `grpc_pollset_add_fd(grpc_pollset* ps, grpc_fd *fd)`
82 - Signature: `grpc_pollset_set_[add|del]_fd(grpc_pollset_set* pss, grpc_fd *fd)`
[all …]
|
| /third_party/grpc/test/core/iomgr/ |
| D | ev_epollex_linux_test.cc | 41 grpc_fd* grpc_fd1; in test_pollable_owner_fd()
42 grpc_fd* grpc_fd2; in test_pollable_owner_fd()
|
| D | fd_posix_test.cc | 92 grpc_fd* em_fd; /* listening fd */
107 grpc_fd* em_fd; /* fd to read upload bytes */
192 grpc_fd* listen_em_fd = sv->em_fd; in listen_cb()
271 grpc_fd* em_fd;
433 grpc_fd* em_fd; in test_grpc_fd_change()
|
| D | udp_server_test.cc | 65 TestGrpcUdpHandler(grpc_fd* emfd, void* user_data) in TestGrpcUdpHandler()
108 grpc_fd* emfd() { return emfd_; } in emfd()
111 grpc_fd* emfd_;
116 GrpcUdpHandler* CreateUdpHandler(grpc_fd* emfd, void* user_data) override { in CreateUdpHandler()
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver_posix.cc | 86 grpc_fd* fd_;
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_pollset.cc | 143 grpc_fd* fd = grpc_fd_create(wakeup_fd.read_fd, "xxx", false); in BM_PollAddFd()
222 grpc_fd* wakeup = grpc_fd_create(wakeup_fd.read_fd, "wakeup_read", false); in BM_SingleThreadPollOneFd()
|