Home
last modified time | relevance | path

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

123

/f-stack/dpdk/drivers/net/virtio/virtio_user/
H A Dvhost_user.c46 int fds[VHOST_MEMORY_MAX_NREGIONS]; member
78 memcpy(CMSG_DATA(cmsg), fds, fd_size); in vhost_user_write()
130 int *fds; member
161 if (wa->fds[i] != fd) in update_memory_region()
191 wa->fds[i] = fd; in update_memory_region()
215 wa.fds = fds; in prepare_vhost_memory_user()
260 int fds[VHOST_MEMORY_MAX_NREGIONS]; in vhost_user_sock() local
312 if (prepare_vhost_memory_user(&msg, fds) < 0) in vhost_user_sock()
324 fds[fd_num++] = *((int *)arg); in vhost_user_sock()
352 fds[fd_num++] = file->fd; in vhost_user_sock()
[all …]
/f-stack/dpdk/lib/librte_power/
H A Dguest_channel.c163 struct pollfd fds; in power_guest_channel_read_msg() local
168 fds.fd = global_fds[lcore_id]; in power_guest_channel_read_msg()
169 fds.events = POLLIN; in power_guest_channel_read_msg()
171 ret = poll(&fds, 1, TIMEOUT); in power_guest_channel_read_msg()
/f-stack/dpdk/lib/librte_eal/linux/
H A Deal_vfio_mp_sync.c56 reply.fds[0] = fd; in vfio_mp_primary()
67 reply.fds[0] = fd; in vfio_mp_primary()
78 reply.fds[0] = fd; in vfio_mp_primary()
H A Deal_memalloc.c269 fd = fd_list[list_idx].fds[seg_idx]; in get_seg_memfd()
280 fd_list[list_idx].fds[seg_idx] = fd; in get_seg_memfd()
329 fd = fd_list[list_idx].fds[seg_idx]; in get_seg_fd()
360 fd_list[list_idx].fds[seg_idx] = fd; in get_seg_fd()
700 fd_list[list_idx].fds[seg_idx] = -1; in alloc_seg()
774 fd_list[list_idx].fds[seg_idx] = -1; in free_seg()
1463 fd_list[list_idx].fds = data; in alloc_list()
1466 fd_list[list_idx].fds = NULL; in alloc_list()
1511 fd_list[list_idx].fds[seg_idx] = fd; in eal_memalloc_set_seg_fd()
1554 fd = fd_list[list_idx].fds[seg_idx]; in eal_memalloc_get_seg_fd()
[all …]
/f-stack/app/redis-5.0.5/src/
H A Drio.c205 retval = write(r->io.fdset.fds[j],p+nwritten,count-nwritten); in rioFdsetWrite()
266 void rioInitWithFdset(rio *r, int *fds, int numfds) { in rioInitWithFdset() argument
270 r->io.fdset.fds = zmalloc(sizeof(int)*numfds); in rioInitWithFdset()
272 memcpy(r->io.fdset.fds,fds,sizeof(int)*numfds); in rioInitWithFdset()
281 zfree(r->io.fdset.fds); in rioFreeFdset()
H A Daof.c1505 int fds[6] = {-1, -1, -1, -1, -1, -1}; in aofCreatePipes() local
1508 if (pipe(fds) == -1) goto error; /* parent -> children data. */ in aofCreatePipes()
1512 if (anetNonBlock(NULL,fds[0]) != ANET_OK) goto error; in aofCreatePipes()
1513 if (anetNonBlock(NULL,fds[1]) != ANET_OK) goto error; in aofCreatePipes()
1516 server.aof_pipe_write_data_to_child = fds[1]; in aofCreatePipes()
1517 server.aof_pipe_read_data_from_parent = fds[0]; in aofCreatePipes()
1518 server.aof_pipe_write_ack_to_parent = fds[3]; in aofCreatePipes()
1519 server.aof_pipe_read_ack_from_child = fds[2]; in aofCreatePipes()
1520 server.aof_pipe_write_ack_to_child = fds[5]; in aofCreatePipes()
1521 server.aof_pipe_read_ack_from_parent = fds[4]; in aofCreatePipes()
[all …]
H A Drio.h78 int *fds; /* File descriptors. */ member
129 void rioInitWithFdset(rio *r, int *fds, int numfds);
/f-stack/dpdk/lib/librte_vhost/
H A Dvhost_user.h152 int fds[VHOST_MEMORY_MAX_NREGIONS]; member
167 int read_fd_message(int sockfd, char *buf, int buflen, int *fds, int max_fds,
169 int send_fd_message(int sockfd, char *buf, int buflen, int *fds, int fd_num);
H A Dsocket.c102 read_fd_message(int sockfd, char *buf, int buflen, int *fds, int max_fds, in read_fd_message() argument
141 memcpy(fds, CMSG_DATA(cmsg), got_fds * sizeof(int)); in read_fd_message()
148 fds[got_fds++] = -1; in read_fd_message()
154 send_fd_message(int sockfd, char *buf, int buflen, int *fds, int fd_num) in send_fd_message() argument
171 if (fds && fd_num > 0) { in send_fd_message()
183 memcpy(CMSG_DATA(cmsg), fds, fdsize); in send_fd_message()
H A Dvhost_user.c103 int fd = msg->fds[i]; in close_msg_fds()
108 msg->fds[i] = -1; in close_msg_fds()
1089 msg->fds[i] = -1; in vhost_user_set_mem_table()
1512 fd = msg->fds[0]; in vhost_user_set_inflight_fd()
1611 file.fd = msg->fds[0]; in vhost_user_set_vring_call()
1641 close(msg->fds[0]); in vhost_user_set_vring_err()
1855 file.fd = msg->fds[0]; in vhost_user_set_vring_kick()
2077 int fd = msg->fds[0]; in vhost_user_set_log_base()
2154 close(msg->fds[0]); in vhost_user_set_log_fd()
2226 int fd = msg->fds[0]; in vhost_user_set_req_fd()
[all …]
/f-stack/freebsd/contrib/libnv/
H A Dnvlist.c781 int *fds; in nvlist_descriptors() local
784 fds = nv_malloc(sizeof(fds[0]) * (nitems + 1)); in nvlist_descriptors()
785 if (fds == NULL) in nvlist_descriptors()
792 return (fds); in nvlist_descriptors()
1259 int *fds; in nvlist_send() local
1270 if (fds == NULL) in nvlist_send()
1291 nv_free(fds); in nvlist_send()
1304 int *fds; in nvlist_recv() local
1322 fds = NULL; in nvlist_recv()
1328 fds = nv_malloc(nfds * sizeof(fds[0])); in nvlist_recv()
[all …]
H A Dnvpair_impl.h101 const unsigned char *ptr, size_t *leftp, const int *fds, size_t nfds);
111 const unsigned char *ptr, size_t *leftp, const int *fds, size_t nfds);
H A Dbsd_nvpair.c832 size_t *leftp, const int *fds, size_t nfds) in nvpair_unpack_descriptor() argument
862 nvp->nvp_data = (uint64_t)fds[idx]; in nvpair_unpack_descriptor()
1063 array[ii] = (uint64_t)fds[idx]; in nvpair_unpack_descriptor_array()
1499 int *fds; in nvpair_create_descriptor_array() local
1508 fds = nv_malloc(sizeof(value[0]) * nitems); in nvpair_create_descriptor_array()
1509 if (fds == NULL) in nvpair_create_descriptor_array()
1513 fds[ii] = -1; in nvpair_create_descriptor_array()
1516 if (fds[ii] == -1) in nvpair_create_descriptor_array()
1528 if (fds[ii - 1] != -1) in nvpair_create_descriptor_array()
1529 close(fds[ii - 1]); in nvpair_create_descriptor_array()
[all …]
/f-stack/dpdk/drivers/raw/ifpga/base/
H A Difpga_feature_dev.c343 unsigned int count, s32 *fds) in vfio_msix_enable_block() argument
364 opae_memcpy(fd_ptr, fds, sizeof(int) * count); in vfio_msix_enable_block()
374 unsigned int count, s32 *fds) in fpga_msix_set_block() argument
385 ctx[start].idx, count, fds); in fpga_msix_set_block()
388 ctx[i].eventfd = fds[i]; in fpga_msix_set_block()
H A Difpga_feature_dev.h203 unsigned int count, s32 *fds);
/f-stack/freebsd/kern/
H A Dsys_generic.c1615 if (fds->revents != 0) in pollout()
1617 fds++; in pollout()
1635 for (i = 0; i < nfd; i++, fds++) { in pollscan()
1636 if (fds->fd < 0) { in pollscan()
1637 fds->revents = 0; in pollscan()
1645 fds->revents = POLLNVAL; in pollscan()
1653 selfdalloc(td, fds); in pollscan()
1654 fds->revents = fo_poll(fp, fds->events, in pollscan()
1664 if ((fds->revents & POLLHUP) != 0) in pollscan()
1665 fds->revents &= ~POLLOUT; in pollscan()
[all …]
/f-stack/dpdk/lib/librte_eal/include/
H A Drte_eal.h170 int fds[RTE_MP_MAX_FD_NUM]; member
/f-stack/dpdk/drivers/net/mlx4/
H A Dmlx4_mp.c83 mp_res.fds[0] = priv->ctx->cmd_fd; in mp_primary_handle()
308 ret = mp_res->fds[0]; in mlx4_mp_req_verbs_cmd_fd()
/f-stack/dpdk/lib/librte_eal/common/
H A Deal_common_proc.c269 char control[CMSG_SPACE(sizeof(m->msg.fds))]; in read_msg()
271 int buflen = sizeof(*m) - sizeof(m->msg.fds); in read_msg()
300 memcpy(m->msg.fds, CMSG_DATA(cmsg), sizeof(m->msg.fds)); in read_msg()
683 iov.iov_len = sizeof(m) - sizeof(msg->fds); in send_msg()
696 memcpy(CMSG_DATA(cmsg), msg->fds, fd_size); in send_msg()
/f-stack/app/micro_thread/
H A Dmt_sys_hook.h52 typedef int (*func_poll)(struct pollfd fds[], nfds_t nfds, int timeout);
/f-stack/freebsd/net/
H A Dnetmap_user.h541 win_nm_poll(struct pollfd *fds, int nfds, int timeout) in win_nm_poll() argument
545 if (nfds != 1 || fds == NULL || (h = win_get_netmap_handle(fds->fd)) == NULL) {; in win_nm_poll()
546 return poll(fds, nfds, timeout); in win_nm_poll()
551 prd.events = fds->events; in win_nm_poll()
/f-stack/freebsd/sys/
H A Dfiledesc.h247 int fdallocn(struct thread *td, int minfd, int *fds, int n);
253 int fdcopy_remapped(struct filedesc *fdp, const int *fds, size_t nfds,
/f-stack/dpdk/drivers/common/mlx5/
H A Dmlx5_common_mp.c136 ret = mp_res->fds[0]; in mlx5_mp_req_verbs_cmd_fd()
/f-stack/lib/
H A Dff_api.h106 int ff_poll(struct pollfd fds[], nfds_t nfds, int timeout);
/f-stack/dpdk/drivers/net/af_xdp/
H A Drte_eth_af_xdp.c101 struct pollfd fds[1]; member
273 (void)poll(rxq->fds, 1, 1000); in af_xdp_rx_zc()
344 (void)poll(rxq->fds, 1, 1000); in af_xdp_rx_cp()
1214 rxq->fds[0].fd = xsk_socket__fd(rxq->xsk);
1215 rxq->fds[0].events = POLLIN;

123