| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_posix.h | 40 typedef struct grpc_fd grpc_fd; typedef
46 grpc_fd* (*fd_create)(int fd, const char* name, bool track_err);
47 int (*fd_wrapped_fd)(grpc_fd* fd);
48 void (*fd_orphan)(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
50 void (*fd_shutdown)(grpc_fd* fd, grpc_error* why);
51 void (*fd_notify_on_read)(grpc_fd* fd, grpc_closure* closure);
52 void (*fd_notify_on_write)(grpc_fd* fd, grpc_closure* closure);
53 void (*fd_notify_on_error)(grpc_fd* fd, grpc_closure* closure);
54 void (*fd_set_readable)(grpc_fd* fd);
55 void (*fd_set_writable)(grpc_fd* fd);
[all …]
|
| D | ev_epollsig_linux.cc | 116 #define FD_FROM_PO(po) ((grpc_fd*)(po))
118 struct grpc_fd { struct
137 struct grpc_fd* freelist_next; argument
148 static void fd_ref(grpc_fd* fd, const char* reason, const char* file, int line); argument
149 static void fd_unref(grpc_fd* fd, const char* reason, const char* file,
154 static void fd_ref(grpc_fd* fd);
155 static void fd_unref(grpc_fd* fd);
208 grpc_fd** fds;
339 static void polling_island_add_fds_locked(polling_island* pi, grpc_fd** fds, in polling_island_add_fds_locked()
376 pi->fds = static_cast<grpc_fd**>( in polling_island_add_fds_locked()
[all …]
|
| D | ev_posix.cc | 248 grpc_fd* grpc_fd_create(int fd, const char* name, bool track_err) { in grpc_fd_create()
255 int grpc_fd_wrapped_fd(grpc_fd* fd) { in grpc_fd_wrapped_fd()
259 void grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd, in grpc_fd_orphan()
268 void grpc_fd_shutdown(grpc_fd* fd, grpc_error* why) { in grpc_fd_shutdown()
274 bool grpc_fd_is_shutdown(grpc_fd* fd) { in grpc_fd_is_shutdown()
278 void grpc_fd_notify_on_read(grpc_fd* fd, grpc_closure* closure) { in grpc_fd_notify_on_read()
282 void grpc_fd_notify_on_write(grpc_fd* fd, grpc_closure* closure) { in grpc_fd_notify_on_write()
286 void grpc_fd_notify_on_error(grpc_fd* fd, grpc_closure* closure) { in grpc_fd_notify_on_error()
290 void grpc_fd_set_readable(grpc_fd* fd) { g_event_engine->fd_set_readable(fd); } in grpc_fd_set_readable()
292 void grpc_fd_set_writable(grpc_fd* fd) { g_event_engine->fd_set_writable(fd); } in grpc_fd_set_writable()
[all …]
|
| D | ev_poll_posix.cc | 60 grpc_fd* fd;
69 grpc_fd* fd;
76 struct grpc_fd { struct
147 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset, argument
157 static bool fd_is_orphaned(grpc_fd* fd);
160 static void fd_ref(grpc_fd* fd, const char* reason, const char* file, int line);
161 static void fd_unref(grpc_fd* fd, const char* reason, const char* file,
166 static void fd_ref(grpc_fd* fd);
167 static void fd_unref(grpc_fd* fd);
206 grpc_fd** fds;
[all …]
|
| D | ev_epoll1_linux.cc | 136 grpc_fd* fd;
137 grpc_fd* next;
138 grpc_fd* prev;
141 struct grpc_fd { struct
148 struct grpc_fd* freelist_next; argument
266 static grpc_fd* fd_freelist = nullptr;
270 static grpc_fd* fork_fd_list_head = nullptr;
279 grpc_fd* fd = fd_freelist; in fd_global_shutdown()
286 static void fork_fd_list_add_grpc_fd(grpc_fd* fd) { in fork_fd_list_add_grpc_fd()
301 static void fork_fd_list_remove_grpc_fd(grpc_fd* fd) { in fork_fd_list_remove_grpc_fd()
[all …]
|
| D | ev_epollex_linux.cc | 109 grpc_fd* owner_fd; // Set to the owner_fd if the type is PO_FD
198 struct grpc_fd { struct
221 struct grpc_fd* freelist_next; argument
284 grpc_fd** fds;
318 static grpc_fd* fd_freelist = nullptr;
324 static void ref_by(grpc_fd* fd, int n, const char* reason, const char* file,
335 static void ref_by(grpc_fd* fd, int n) {
345 static void invalidate_fd(grpc_fd* fd) {
362 grpc_fd* fd = static_cast<grpc_fd*>(arg);
382 static void unref_by(grpc_fd* fd, int n, const char* reason, const char* file,
[all …]
|
| D | tcp_client_posix.h | 36 grpc_fd* fd, const grpc_channel_args* channel_args, const char* addr_str);
51 grpc_fd** fdobj);
64 grpc_pollset_set* interested_parties, grpc_closure* closure, grpc_fd* fdobj,
|
| D | tcp_client_posix.cc | 54 grpc_fd* fd;
130 grpc_fd* fd, const grpc_channel_args* channel_args, const char* addr_str) { in grpc_tcp_client_create_from_fd()
142 grpc_fd* fd; in on_writable()
255 grpc_fd** fdobj) { in grpc_tcp_client_prepare_fd()
292 grpc_pollset_set* interested_parties, grpc_closure* closure, grpc_fd* fdobj, in grpc_tcp_client_create_from_prepared_fd()
347 grpc_fd* fdobj = nullptr; in tcp_connect()
|
| D | udp_server.h | 42 GrpcUdpHandler(grpc_fd* emfd, void* user_data) {} in GrpcUdpHandler()
70 virtual GrpcUdpHandler* CreateUdpHandler(grpc_fd* emfd,
|
| D | ev_epollsig_linux.h | 30 void* grpc_fd_get_polling_island(grpc_fd* fd);
|
| D | tcp_posix.h | 45 grpc_endpoint* grpc_tcp_create(grpc_fd* fd, const grpc_channel_args* args,
|
| D | tcp_server_utils_posix.h | 32 grpc_fd* emfd;
|
| D | udp_server.cc | 99 grpc_fd* emfd() const { return emfd_; } in emfd()
117 grpc_fd* emfd_;
|
| D | tcp_posix.cc | 75 grpc_fd* em_fd;
1006 grpc_endpoint* grpc_tcp_create(grpc_fd* em_fd, in grpc_tcp_create()
|
| D | tcp_server_posix.cc | 229 grpc_fd* fdobj = grpc_fd_create(fd, name, true); in on_read()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | udp_server_test.cc | 63 TestGrpcUdpHandler(grpc_fd* emfd, void* user_data) in TestGrpcUdpHandler()
106 grpc_fd* emfd() { return emfd_; } in emfd()
109 grpc_fd* emfd_;
114 GrpcUdpHandler* CreateUdpHandler(grpc_fd* emfd, void* user_data) override { in CreateUdpHandler()
|
| 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 | ev_epollsig_linux_test.cc | 45 grpc_fd* fd;
223 grpc_fd* wakeup_desc;
|
| D | pollset_set_test.cc | 98 grpc_fd* fd;
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_pollset.cc | 144 grpc_fd* fd = grpc_fd_create(wakeup_fd.read_fd, "xxx", false); in BM_PollAddFd()
225 grpc_fd* wakeup = grpc_fd_create(wakeup_fd.read_fd, "wakeup_read", false); in BM_SingleThreadPollOneFd()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver_posix.cc | 85 grpc_fd* fd_;
|