Home
last modified time | relevance | path

Searched refs:fd_info (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dwakeup_fd_posix.cc58 grpc_error* grpc_wakeup_fd_init(grpc_wakeup_fd* fd_info) { in grpc_wakeup_fd_init() argument
60 return grpc_cv_wakeup_fd_vtable.init(fd_info); in grpc_wakeup_fd_init()
62 return wakeup_fd_vtable->init(fd_info); in grpc_wakeup_fd_init()
65 grpc_error* grpc_wakeup_fd_consume_wakeup(grpc_wakeup_fd* fd_info) { in grpc_wakeup_fd_consume_wakeup() argument
67 return grpc_cv_wakeup_fd_vtable.consume(fd_info); in grpc_wakeup_fd_consume_wakeup()
69 return wakeup_fd_vtable->consume(fd_info); in grpc_wakeup_fd_consume_wakeup()
72 grpc_error* grpc_wakeup_fd_wakeup(grpc_wakeup_fd* fd_info) { in grpc_wakeup_fd_wakeup() argument
74 return grpc_cv_wakeup_fd_vtable.wakeup(fd_info); in grpc_wakeup_fd_wakeup()
76 return wakeup_fd_vtable->wakeup(fd_info); in grpc_wakeup_fd_wakeup()
79 void grpc_wakeup_fd_destroy(grpc_wakeup_fd* fd_info) { in grpc_wakeup_fd_destroy() argument
[all …]
Dwakeup_fd_pipe.cc36 static grpc_error* pipe_init(grpc_wakeup_fd* fd_info) { in pipe_init() argument
48 fd_info->read_fd = pipefd[0]; in pipe_init()
49 fd_info->write_fd = pipefd[1]; in pipe_init()
53 static grpc_error* pipe_consume(grpc_wakeup_fd* fd_info) { in pipe_consume() argument
58 r = read(fd_info->read_fd, buf, sizeof(buf)); in pipe_consume()
72 static grpc_error* pipe_wakeup(grpc_wakeup_fd* fd_info) { in pipe_wakeup() argument
74 while (write(fd_info->write_fd, &c, 1) != 1 && errno == EINTR) in pipe_wakeup()
79 static void pipe_destroy(grpc_wakeup_fd* fd_info) { in pipe_destroy() argument
80 if (fd_info->read_fd != 0) close(fd_info->read_fd); in pipe_destroy()
81 if (fd_info->write_fd != 0) close(fd_info->write_fd); in pipe_destroy()
Dwakeup_fd_posix.h68 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);
71 void (*destroy)(grpc_wakeup_fd* fd_info);
84 #define GRPC_WAKEUP_FD_GET_READ_FD(fd_info) ((fd_info)->read_fd) argument
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;
90 void grpc_wakeup_fd_destroy(grpc_wakeup_fd* fd_info);
Dwakeup_fd_cv.cc42 static grpc_error* cv_fd_init(grpc_wakeup_fd* fd_info) { in cv_fd_init() argument
63 fd_info->read_fd = GRPC_IDX_TO_FD(idx); in cv_fd_init()
64 fd_info->write_fd = -1; in cv_fd_init()
69 static grpc_error* cv_fd_wakeup(grpc_wakeup_fd* fd_info) { in cv_fd_wakeup() argument
72 g_cvfds.cvfds[GRPC_FD_TO_IDX(fd_info->read_fd)].is_set = 1; in cv_fd_wakeup()
73 cvn = g_cvfds.cvfds[GRPC_FD_TO_IDX(fd_info->read_fd)].cvs; in cv_fd_wakeup()
82 static grpc_error* cv_fd_consume(grpc_wakeup_fd* fd_info) { in cv_fd_consume() argument
84 g_cvfds.cvfds[GRPC_FD_TO_IDX(fd_info->read_fd)].is_set = 0; in cv_fd_consume()
89 static void cv_fd_destroy(grpc_wakeup_fd* fd_info) { in cv_fd_destroy() argument
90 if (fd_info->read_fd == 0) { in cv_fd_destroy()
[all …]
Dwakeup_fd_eventfd.cc34 static grpc_error* eventfd_create(grpc_wakeup_fd* fd_info) { in eventfd_create() argument
39 fd_info->read_fd = efd; in eventfd_create()
40 fd_info->write_fd = -1; in eventfd_create()
44 static grpc_error* eventfd_consume(grpc_wakeup_fd* fd_info) { in eventfd_consume() argument
48 err = eventfd_read(fd_info->read_fd, &value); in eventfd_consume()
56 static grpc_error* eventfd_wakeup(grpc_wakeup_fd* fd_info) { in eventfd_wakeup() argument
60 err = eventfd_write(fd_info->read_fd, 1); in eventfd_wakeup()
68 static void eventfd_destroy(grpc_wakeup_fd* fd_info) { in eventfd_destroy() argument
69 if (fd_info->read_fd != 0) close(fd_info->read_fd); in eventfd_destroy()
/external/libevent/
Devport.c89 struct fd_info { struct
133 sizeof(struct fd_info), /* fdinfo length */
233 reassociate(struct evport_data *epdp, struct fd_info *fdip, int fd) in reassociate()
289 struct fd_info *fdi = NULL; in evport_dispatch()
328 struct fd_info *fdi = pevt->portev_user; in evport_dispatch()
382 struct fd_info *fdi = p; in evport_add()
399 struct fd_info *fdi = p; in evport_del()
/external/mesa3d/src/intel/vulkan/
Danv_device.c1773 const VkImportMemoryFdInfoKHR *fd_info = in anv_AllocateMemory() local
1779 if (fd_info && fd_info->handleType) { in anv_AllocateMemory()
1781 assert(fd_info->handleType == in anv_AllocateMemory()
1783 fd_info->handleType == in anv_AllocateMemory()
1787 fd_info->fd, &mem->bo); in anv_AllocateMemory()
1822 close(fd_info->fd); in anv_AllocateMemory()