Lines Matching refs:fd
35 int fd, err; in tapdisk_uring_create_ctlfd() local
42 fd = socket(AF_UNIX, SOCK_STREAM, 0); in tapdisk_uring_create_ctlfd()
43 if (fd == -1) in tapdisk_uring_create_ctlfd()
56 err = bind(fd, &saddr, sizeof(struct sockaddr_un)); in tapdisk_uring_create_ctlfd()
62 err = listen(fd, 1); in tapdisk_uring_create_ctlfd()
68 ring->ctlfd = fd; in tapdisk_uring_create_ctlfd()
72 close(fd); in tapdisk_uring_create_ctlfd()
94 int fd, err; in tapdisk_uring_connect_ctlfd() local
101 fd = socket(AF_UNIX, SOCK_STREAM, 0); in tapdisk_uring_connect_ctlfd()
102 if (fd == -1) in tapdisk_uring_connect_ctlfd()
109 err = connect(fd, &saddr, sizeof(saddr)); in tapdisk_uring_connect_ctlfd()
115 ring->ctlfd = fd; in tapdisk_uring_connect_ctlfd()
119 close(fd); in tapdisk_uring_connect_ctlfd()
135 int fd, err; in tapdisk_uring_create_shmem() local
137 fd = shm_open(ring->shmem_path, O_CREAT | O_RDWR, 0750); in tapdisk_uring_create_shmem()
138 if (fd == -1) in tapdisk_uring_create_shmem()
141 err = ftruncate(fd, ring->shmem_size); in tapdisk_uring_create_shmem()
148 PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); in tapdisk_uring_create_shmem()
158 close(fd); in tapdisk_uring_create_shmem()
180 int fd, err; in tapdisk_uring_connect_shmem() local
183 fd = shm_open(ring->shmem_path, O_RDWR); in tapdisk_uring_connect_shmem()
184 if (fd == -1) in tapdisk_uring_connect_shmem()
188 PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); in tapdisk_uring_connect_shmem()
213 PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); in tapdisk_uring_connect_shmem()
223 close(fd); in tapdisk_uring_connect_shmem()
240 int fd, err; in tapdisk_uring_create() local
291 int fd, err; in tapdisk_uring_connect() local
331 tapdisk_ring_read_message(int fd, td_uring_message_t *message, int timeout) in tapdisk_ring_read_message() argument
349 FD_SET(fd, &readfds); in tapdisk_ring_read_message()
354 ret = select(fd + 1, &readfds, NULL, NULL, t); in tapdisk_ring_read_message()
357 else if (FD_ISSET(fd, &readfds)) { in tapdisk_ring_read_message()
358 ret = read(fd, message + offset, len - offset); in tapdisk_ring_read_message()
373 tapdisk_ring_write_message(int fd, td_uring_message_t *message, int timeout) in tapdisk_ring_write_message() argument
391 FD_SET(fd, &writefds); in tapdisk_ring_write_message()
396 ret = select(fd + 1, NULL, &writefds, NULL, t); in tapdisk_ring_write_message()
399 else if (FD_ISSET(fd, &writefds)) { in tapdisk_ring_write_message()
400 ret = write(fd, message + offset, len - offset); in tapdisk_ring_write_message()