Home
last modified time | relevance | path

Searched refs:fds (Results 1 – 25 of 139) sorted by relevance

123456

/openbmc/qemu/hw/remote/
H A Dmpqemu-link.c39 int *fds = NULL; in mpqemu_msg_send() local
51 fds = msg->fds; in mpqemu_msg_send()
71 fds, nfds, 0, errp)) { in mpqemu_msg_send()
95 static ssize_t mpqemu_read(QIOChannel *ioc, void *buf, size_t len, int **fds, in mpqemu_read() argument
113 ret = qio_channel_readv_full_all_eof(ioc, &iov, 1, fds, nfds, 0, errp); in mpqemu_read()
125 g_autofree int *fds = NULL; in mpqemu_msg_recv() local
130 len = mpqemu_read(ioc, msg, MPQEMU_MSG_HDR_SIZE, &fds, &nfds, errp); in mpqemu_msg_recv()
158 if (nfds > G_N_ELEMENTS(msg->fds)) { in mpqemu_msg_recv()
165 memcpy(msg->fds, fds, nfds * sizeof(int)); in mpqemu_msg_recv()
175 close(fds[nfds - 1]); in mpqemu_msg_recv()
[all …]
/openbmc/qemu/util/
H A Devent_notifier-posix.c37 int fds[2]; in event_notifier_init() local
52 if (!g_unix_open_pipe(fds, FD_CLOEXEC, NULL)) { in event_notifier_init()
55 if (!g_unix_set_fd_nonblocking(fds[0], true, NULL)) { in event_notifier_init()
59 if (!g_unix_set_fd_nonblocking(fds[1], true, NULL)) { in event_notifier_init()
63 e->rfd = fds[0]; in event_notifier_init()
64 e->wfd = fds[1]; in event_notifier_init()
73 close(fds[0]); in event_notifier_init()
74 close(fds[1]); in event_notifier_init()
H A Dcompatfd.c59 int fds[2]; in qemu_signalfd_compat() local
63 if (!g_unix_open_pipe(fds, FD_CLOEXEC, NULL)) { in qemu_signalfd_compat()
69 info->fd = fds[1]; in qemu_signalfd_compat()
74 return fds[0]; in qemu_signalfd_compat()
H A Dvhost-user-server.c61 close(vmsg->fds[i]); in vmsg_close_fds()
81 qemu_socket_set_nonblock(vmsg->fds[i]); in vmsg_unblock_fds()
119 const size_t max_fds = G_N_ELEMENTS(vmsg->fds); in vu_message_read()
132 int *fds = NULL; in vu_message_read() local
138 rc = qio_channel_readv_full(ioc, &iov, 1, &fds, &nfds, 0, &local_err); in vu_message_read()
161 g_free(fds); in vu_message_read()
164 memcpy(vmsg->fds + vmsg->fd_num, fds, nfds * sizeof(vmsg->fds[0])); in vu_message_read()
166 g_free(fds); in vu_message_read()
/openbmc/btbridge/
H A Dbtbridged.c78 struct pollfd fds[TOTAL_FDS]; member
270 r = ioctl(bt_fd->fds[BT_FD].fd, BT_BMC_IOCTL_SMS_ATN); in method_send_sms_atn()
273 MSG_ERR("Couldn't ioctl() to 0x%x, %s: %s\n", bt_fd->fds[BT_FD].fd, BT_BMC_PATH, strerror(r)); in method_send_sms_atn()
334 context->fds[BT_FD].events |= POLLOUT; in method_send_message()
367 r = timerfd_settime(context->fds[TIMER_FD].fd, TFD_TIMER_ABSTIME, &ts, NULL); in bt_host_write()
384 len = write(context->fds[BT_FD].fd, data, data[0] + 1); in bt_host_write()
429 context->fds[BT_FD].events = POLLIN; in bt_host_write()
438 if (context->fds[TIMER_FD].revents & POLLIN) { in dispatch_timer()
444 r = read(context->fds[TIMER_FD].fd, &counter, sizeof(counter)); in dispatch_timer()
479 context->fds[BT_FD].events |= POLLOUT; in dispatch_timer()
[all …]
/openbmc/phosphor-ipmi-flash/bmc/firmware-handler/
H A Dnet_handler.cpp74 struct pollfd fds; in copyFrom() local
75 fds.fd = *listenFd; in copyFrom()
76 fds.events = POLLIN; in copyFrom()
78 int ret = ::poll(&fds, 1, timeoutS * 1000); in copyFrom()
89 else if (fds.revents != POLLIN) in copyFrom()
91 fprintf(stderr, "Invalid poll state: 0x%x\n", fds.revents); in copyFrom()
/openbmc/qemu/hw/vfio-user/
H A Dproxy.c30 VFIOUserFDs *fds);
65 VFIOUserFDs *fds = msg->fds; in vfio_user_send_qio() local
74 if (fds != NULL && fds->send_fds != 0) { in vfio_user_send_qio()
75 numfds = fds->send_fds; in vfio_user_send_qio()
76 fdp = fds->fds; in vfio_user_send_qio()
91 VFIOUserFDs *fds) in vfio_user_getmsg() argument
104 msg->fds = fds; in vfio_user_getmsg()
121 if (msg->fds != NULL) { in vfio_user_recycle()
122 g_free(msg->fds); in vfio_user_recycle()
128 msg->fds = NULL; in vfio_user_recycle()
[all …]
H A Dproxy.h24 int *fds; member
38 VFIOUserFDs *fds; member
121 VFIOUserFDs *fds, int rsize, Error **errp);
123 VFIOUserFDs *fds, int rsize, Error **errp);
125 VFIOUserFDs *fds, Error **errp);
H A Dcontainer.c95 VFIOUserFDs *fds = NULL; in vfio_user_dma_map() local
127 fds = vfio_user_getfds(1); in vfio_user_dma_map()
128 fds->send_fds = 1; in vfio_user_dma_map()
129 fds->fds[0] = fd; in vfio_user_dma_map()
132 if (!vfio_user_send_nowait(container->proxy, &msgp->hdr, fds, in vfio_user_dma_map()
140 fds = fd != -1 ? &local_fds : NULL; in vfio_user_dma_map()
142 if (!vfio_user_send_wait(container->proxy, &msgp->hdr, fds, in vfio_user_dma_map()
/openbmc/qemu/contrib/ivshmem-client/
H A Dmain.c135 fd_set fds; in ivshmem_client_poll_events() local
140 FD_ZERO(&fds); in ivshmem_client_poll_events()
141 FD_SET(0, &fds); /* add stdin in fd_set */ in ivshmem_client_poll_events()
144 ivshmem_client_get_fds(client, &fds, &maxfd); in ivshmem_client_poll_events()
146 ret = select(maxfd, &fds, NULL, NULL, NULL); in ivshmem_client_poll_events()
159 if (FD_ISSET(0, &fds) && in ivshmem_client_poll_events()
165 if (ivshmem_client_handle_fds(client, &fds, maxfd) < 0) { in ivshmem_client_poll_events()
/openbmc/openbmc/meta-openembedded/meta-oe/dynamic-layers/selinux/recipes-devtool/android-tools/android-tools/debian/system/core/
H A Dfix-build-on-non-x86.patch8 const std::vector<int>& fds) {
9 size_t cmsg_space = CMSG_SPACE(sizeof(int) * fds.size());
10 size_t cmsg_len = CMSG_LEN(sizeof(int) * fds.size());
18 fds->clear();
/openbmc/openbmc/meta-openembedded/meta-oe/dynamic-layers/selinux/recipes-devtool/android-tools/android-tools/debian/
H A Dfix-build-on-non-x86.patch8 const std::vector<int>& fds) {
9 size_t cmsg_space = CMSG_SPACE(sizeof(int) * fds.size());
10 size_t cmsg_len = CMSG_LEN(sizeof(int) * fds.size());
18 fds->clear();
/openbmc/phosphor-mboxd/
H A Dmboxd_flash.c53 context->fds[MTD_FD].fd = fd; in init_flash_dev()
103 close(context->fds[MTD_FD].fd); in free_flash_dev()
184 rc = ioctl(context->fds[MTD_FD].fd, MEMERASE, in erase_flash()
205 rc = ioctl(context->fds[MTD_FD].fd, MEMERASE, &erase_info); in erase_flash()
239 if (lseek(context->fds[MTD_FD].fd, offset, SEEK_SET) != offset) { in copy_flash()
246 size_read = read(context->fds[MTD_FD].fd, mem, in copy_flash()
278 if (lseek(context->fds[MTD_FD].fd, offset, SEEK_SET) != offset) { in write_flash()
285 rc = write(context->fds[MTD_FD].fd, buf + buf_offset, count); in write_flash()
H A Dmboxd.c59 context->fds[i].events = POLLIN; in poll_loop()
63 rc = poll(context->fds, POLL_FDS, -1); in poll_loop()
71 if (context->fds[SIG_FD].revents & POLLIN) { /* Signal */ in poll_loop()
74 rc = read(context->fds[SIG_FD].fd, (void *) &info, in poll_loop()
105 if (context->fds[DBUS_FD].revents & POLLIN) { /* DBUS */ in poll_loop()
117 if (context->fds[MBOX_FD].revents & POLLIN) { /* MBOX */ in poll_loop()
161 context->fds[SIG_FD].fd = rc; in init_signals()
294 context->fds[i].fd = -1; in main()
H A Dmboxd_lpc.c56 context->fds[LPC_CTRL_FD].fd = fd; in __init_lpc_dev()
92 close(context->fds[LPC_CTRL_FD].fd); in free_lpc_dev()
129 if (ioctl(context->fds[LPC_CTRL_FD].fd, ASPEED_LPC_CTRL_IOCTL_MAP, &map) in point_to_flash()
169 if (ioctl(context->fds[LPC_CTRL_FD].fd, ASPEED_LPC_CTRL_IOCTL_MAP, in point_to_memory()
/openbmc/qemu/tests/qtest/
H A Dlibqmp.c99 static void socket_send_fds(int socket_fd, int *fds, size_t fds_num, in socket_send_fds() argument
112 if (fds && fds_num > 0) { in socket_send_fds()
122 memcpy(CMSG_DATA(cmsg), fds, fdsize); in socket_send_fds()
138 _qmp_fd_vsend_fds(int fd, int *fds, size_t fds_num, in _qmp_fd_vsend_fds() argument
167 if (fds && fds_num > 0) { in _qmp_fd_vsend_fds()
168 socket_send_fds(fd, fds, fds_num, str->str, str->len); in _qmp_fd_vsend_fds()
181 void qmp_fd_vsend_fds(int fd, int *fds, size_t fds_num, in qmp_fd_vsend_fds() argument
184 _qmp_fd_vsend_fds(fd, fds, fds_num, fmt, ap); in qmp_fd_vsend_fds()
/openbmc/qemu/include/hw/block/
H A Dfdc.h12 void isa_fdc_init_drives(ISADevice *fdc, DriveInfo **fds);
13 void fdctrl_init_sysbus(qemu_irq irq, hwaddr mmio_base, DriveInfo **fds);
15 DriveInfo **fds, qemu_irq *fdc_tc);
/openbmc/qemu/tests/tcg/multiarch/linux/
H A Dlinux-test.c338 int fds[2], fd_max, ret; in test_pipe() local
342 chk_error(pipe(fds)); in test_pipe()
343 chk_error(fcntl(fds[0], F_SETFL, O_NONBLOCK)); in test_pipe()
344 chk_error(fcntl(fds[1], F_SETFL, O_NONBLOCK)); in test_pipe()
349 fd_max = fds[0]; in test_pipe()
350 FD_SET(fds[0], &rfds); in test_pipe()
353 FD_SET(fds[1], &wfds); in test_pipe()
354 if (fds[1] > fd_max) in test_pipe()
355 fd_max = fds[1]; in test_pipe()
359 if (FD_ISSET(fds[0], &rfds)) { in test_pipe()
[all …]
/openbmc/qemu/io/
H A Dchannel.c54 int **fds, in qio_channel_readv_full() argument
61 if ((fds || nfds) && in qio_channel_readv_full()
75 return klass->io_readv(ioc, iov, niov, fds, nfds, flags, errp); in qio_channel_readv_full()
82 int *fds, in qio_channel_writev_full() argument
89 if (fds || nfds) { in qio_channel_writev_full()
109 return klass->io_writev(ioc, iov, niov, fds, nfds, flags, errp); in qio_channel_writev_full()
133 int **fds, size_t *nfds, in qio_channel_readv_full_all_eof() argument
141 int **local_fds = fds; in qio_channel_readv_full_all_eof()
149 if (fds) { in qio_channel_readv_full_all_eof()
150 *fds = NULL; in qio_channel_readv_full_all_eof()
[all …]
/openbmc/u-boot/tools/gdb/
H A Dserial.c85 fd_set fds; in serialreadchar() local
93 FD_ZERO(&fds); in serialreadchar()
94 FD_SET(fd, &fds); in serialreadchar()
98 if ((n = select(fd + 1, &fds, 0, 0, &tv)) < 0) in serialreadchar()
/openbmc/qemu/monitor/
H A Dfds.c54 QLIST_HEAD(, MonFdsetFd) fds;
76 QLIST_FOREACH(monfd, &mon->fds, next) { in monitor_add_fd()
95 QLIST_INSERT_HEAD(&mon->fds, monfd, next); in monitor_add_fd()
123 QLIST_FOREACH(monfd, &cur_mon->fds, next) { in qmp_closefd()
147 QLIST_FOREACH(monfd, &mon->fds, next) { in monitor_get_fd()
182 if (QLIST_EMPTY(&mon_fdset->fds) && QLIST_EMPTY(&mon_fdset->dup_fds)) { in monitor_fdset_free_if_empty()
277 QLIST_FOREACH_SAFE(mon_fdset_fd, &mon_fdset->fds, next, in qmp_remove_fd()
318 QLIST_FOREACH(mon_fdset_fd, &mon_fdset->fds, next) { in qmp_query_fdsets()
325 QAPI_LIST_PREPEND(fdset_info->fds, fdsetfd_info); in qmp_query_fdsets()
403 QLIST_INSERT_HEAD(&mon_fdset->fds, mon_fdset_fd, next); in monitor_fdset_add_fd()
[all …]
/openbmc/qemu/
H A Dos-posix.c216 int fds[2]; in os_daemonize() local
218 if (!g_unix_open_pipe(fds, FD_CLOEXEC, NULL)) { in os_daemonize()
227 close(fds[1]); in os_daemonize()
230 len = read(fds[0], &status, 1); in os_daemonize()
241 close(fds[0]); in os_daemonize()
242 daemon_pipe = fds[1]; in os_daemonize()
/openbmc/qemu/contrib/ivshmem-server/
H A Dmain.c149 fd_set fds; in ivshmem_server_poll_events() local
154 FD_ZERO(&fds); in ivshmem_server_poll_events()
156 ivshmem_server_get_fds(server, &fds, &maxfd); in ivshmem_server_poll_events()
158 ret = select(maxfd, &fds, NULL, NULL, NULL); in ivshmem_server_poll_events()
172 if (ivshmem_server_handle_fds(server, &fds, maxfd) < 0) { in ivshmem_server_poll_events()
/openbmc/hiomapd/
H A Dlpc.c56 context->fds[LPC_CTRL_FD].fd = fd; in __lpc_dev_init()
92 close(context->fds[LPC_CTRL_FD].fd); in lpc_dev_free()
129 if (ioctl(context->fds[LPC_CTRL_FD].fd, ASPEED_LPC_CTRL_IOCTL_MAP, &map) in lpc_map_flash()
170 if (ioctl(context->fds[LPC_CTRL_FD].fd, ASPEED_LPC_CTRL_IOCTL_MAP, in lpc_map_memory()
/openbmc/phosphor-mboxd/test/
H A Dmbox.c69 fd = context->fds[MBOX_FD].fd; in mbox_cmp()
96 fd = context->fds[MBOX_FD].fd; in mbox_rspcpy()
115 fd = context->fds[MBOX_FD].fd; in mbox_command_write()
185 rc = lseek(context->fds[MBOX_FD].fd, -1, SEEK_CUR); in mbox_command_dispatch()
189 rc = read(context->fds[MBOX_FD].fd, &status, sizeof(status)); in mbox_command_dispatch()
241 rc = close(test.context.fds[MBOX_FD].fd); in mbox_create_test_context()
243 test.context.fds[MBOX_FD].fd = test.mbox.fd; in mbox_create_test_context()

123456