Home
last modified time | relevance | path

Searched refs:fd (Results 1 – 25 of 52) sorted by relevance

123

/spdk/lib/util/
H A Dfd.c19 dev_get_size(int fd) in dev_get_size() argument
24 if (ioctl(fd, DIOCGMEDIASIZE, &size) == 0) { in dev_get_size()
30 if (ioctl(fd, BLKGETSIZE64, &size) == 0) { in dev_get_size()
39 spdk_fd_get_blocklen(int fd) in spdk_fd_get_blocklen() argument
44 if (ioctl(fd, DIOCGSECTORSIZE, &blocklen) == 0) { in spdk_fd_get_blocklen()
50 if (ioctl(fd, DKIOCGETBLOCKSIZE, &blocklen) == 0) { in spdk_fd_get_blocklen()
56 if (ioctl(fd, BLKSSZGET, &blocklen) == 0) { in spdk_fd_get_blocklen()
65 spdk_fd_get_size(int fd) in spdk_fd_get_size() argument
69 if (fstat(fd, &st) != 0) { in spdk_fd_get_size()
78 return dev_get_size(fd); in spdk_fd_get_size()
H A Dfd_group.c38 int fd;
48 /* Number of fds registered in this group. The epoll file descriptor of this fd group
50 * well as from all its children fd group interrupt sources list.
93 rc = epoll_ctl(epfd, EPOLL_CTL_DEL, ehdlr->fd, NULL); in _fd_group_del_all()
103 SPDK_ERRLOG("Failed to remove fd: %d from group: %s\n", in _fd_group_del_all()
104 ehdlr->fd, strerror(errno)); in _fd_group_del_all()
118 rc = epoll_ctl(epfd, EPOLL_CTL_ADD, ehdlr->fd, &epevent); in _fd_group_del_all()
147 rc = epoll_ctl(epfd, EPOLL_CTL_ADD, ehdlr->fd, &epevent); in _fd_group_add_all()
155 SPDK_ERRLOG("Failed to add fd: %d to fd grou in _fd_group_add_all()
43 int fd; global() member
[all...]
/spdk/module/sock/posix/
H A Dposix.c44 int fd;
68 int fd;
234 return spdk_net_getaddr(sock->fd, saddr, slen, sport, caddr, clen, cport); in posix_sock_getaddr()
244 rc = spdk_net_getaddr(sock->fd, saddr, sizeof(saddr), NULL, NULL, 0, NULL); in posix_sock_getaddr()
382 rc = setsockopt(sock->fd, SOL_SOCKET, SO_RCVBUF, &sz, sizeof(sz)); in posix_sock_set_recvbuf()
409 rc = setsockopt(sock->fd, SOL_SOCKET, SO_SNDBUF, &sz, sizeof(sz)); in posix_sock_set_sendbuf()
432 rc = setsockopt(sock->fd, SOL_SOCKET, SO_ZEROCOPY, &flag, sizeof(flag)); in posix_sock_set_sendbuf()
443 rc = setsockopt(sock->fd, IPPROTO_TCP, TCP_QUICKACK, &flag, sizeof(flag)); in posix_sock_init()
449 spdk_sock_get_placement_id(sock->fd, sock->base.impl_opts.enable_placement_id, in posix_sock_init()
460 posix_sock_alloc(int fd, struc in posix_sock_init()
43 int fd; global() member
65 int fd; global() member
476 posix_sock_alloc(int fd,struct spdk_sock_impl_opts * impl_opts,bool enable_zero_copy) posix_sock_alloc() argument
497 int fd; posix_fd_create() local
816 ssl_sock_setup_connect(SSL_CTX * ctx,int fd) ssl_sock_setup_connect() argument
837 ssl_sock_setup_accept(SSL_CTX * ctx,int fd) ssl_sock_setup_accept() argument
957 int fd, flag; posix_sock_create() local
1124 int rc, fd; _posix_sock_accept() local
1791 int fd; _sock_group_impl_create() local
[all...]
/spdk/lib/vfio_user/host/
H A Dvfio_user.c44 vfio_user_write(int fd, void *buf, int len, int *fds, int num_fds) in vfio_user_write() argument
79 r = sendmsg(fd, &msgh, MSG_NOSIGNAL); in vfio_user_write()
133 vfio_user_read(int fd, struct vfio_user_request *req) in vfio_user_read() argument
138 ret = read_fd_message(fd, (char *)req, sizeof(struct vfio_user_header), req->fds, &req->fd_num); in vfio_user_read()
151 ret = read(fd, req->payload, sz_payload); in vfio_user_read()
186 ret = vfio_user_write(dev->fd, (void *)&req, req.hdr.msg_size, fds, max_fds); in vfio_user_dev_send_request()
188 ret = vfio_user_write(dev->fd, (void *)&req, req.hdr.msg_size, NULL, 0); in vfio_user_dev_send_request()
197 ret = vfio_user_read(dev->fd, &req); in vfio_user_dev_send_request()
282 &dma_map, sizeof(dma_map), sizeof(dma_map), &mr->fd, 1); in vfio_user_dev_dma_map_unmap()
288 &dma_unmap, sizeof(dma_unmap), sizeof(dma_unmap), &mr->fd, 1); in vfio_user_dev_dma_map_unmap()
[all …]
H A Dvfio_user_pci.c66 mr->fd, mr->vaddr, mr->iova, mr->size); in vfio_add_mr()
97 mr->fd, mr->vaddr, mr->iova, mr->size); in vfio_remove_mr()
143 mr->fd = spdk_mem_get_fd_and_offset(vaddr, &offset); in vfio_mr_map_notify()
144 if (mr->fd < 0) { in vfio_mr_map_notify()
249 vfio_device_map_region(struct vfio_device *device, struct vfio_pci_region *region, int fd) in vfio_device_map_region() argument
260 fd, region->offset); in vfio_device_map_region()
261 close(fd); in vfio_device_map_region()
391 close(device->fd); in spdk_vfio_user_setup()
405 close(dev->fd); in spdk_vfio_user_release()
H A Dvfio_user_internal.h24 int fd; member
43 int fd; member
/spdk/module/sock/uring/
H A During.c73 int fd;
238 return spdk_net_getaddr(sock->fd, saddr, slen, sport, caddr, clen, cport); in uring_sock_getaddr()
248 rc = spdk_net_getaddr(sock->fd, saddr, sizeof(saddr), NULL, NULL, 0, NULL); in uring_sock_getaddr()
382 rc = setsockopt(sock->fd, SOL_SOCKET, SO_RCVBUF, &sz, sizeof(sz)); in uring_sock_set_recvbuf()
409 rc = setsockopt(sock->fd, SOL_SOCKET, SO_SNDBUF, &sz, sizeof(sz));
420 uring_sock_alloc(int fd, struct spdk_sock_impl_opts *impl_opts, bool enable_zero_copy) in uring_sock_set_sendbuf()
434 sock->fd = fd; in uring_sock_set_sendbuf()
443 rc = setsockopt(sock->fd, IPPROTO_TCP, TCP_QUICKACK, &flag, sizeof(flag)); in uring_sock_alloc()
449 spdk_sock_get_placement_id(sock->fd, soc in uring_sock_alloc()
72 int fd; global() member
437 uring_sock_alloc(int fd,struct spdk_sock_impl_opts * impl_opts,bool enable_zero_copy) uring_sock_alloc() argument
496 int fd, flag; uring_sock_create() local
712 int rc, fd; uring_sock_accept() local
814 sock_readv(int fd,struct iovec * iov,int iovcnt) sock_readv() argument
[all...]
/spdk/python/spdk/rpc/
H A D__init__.py83 def _json_dump(config, fd, indent):
88 json.dump(config, fd, indent=indent)
89 fd.write('\n')
103 def save_config(client, fd, indent=2, subsystems=None):
106 fd: opened file descriptor where data will be saved
143 _json_dump(config, fd, indent)
146 def load_config(client, fd, include_aliases=False):
149 fd: opened file descriptor where data will be taken from
151 json_config = _json_load(fd)
200 def save_subsystem_config(client, fd, inden
82 _json_dump(config, fd, indent) global() argument
102 save_config(client, fd, indent=2) global() argument
123 load_config(client, fd, include_aliases=False) global() argument
177 save_subsystem_config(client, fd, indent=2, name=None) global() argument
192 load_subsystem_config(client, fd) global() argument
[all...]
/spdk/app/trace_record/
H A Dtrace_record.c26 int fd; member
161 port_ctx->fd = open(port_ctx->lcore_file, flags, 0600); in output_trace_files_prepare()
162 if (port_ctx->fd < 0) { in output_trace_files_prepare()
185 if (port_ctx->fd > 0) { in output_trace_files_prepare()
186 close(port_ctx->fd); in output_trace_files_prepare()
203 close(port_ctx->fd); in output_trace_files_finish()
273 circular_buffer_padding_backward(int fd, struct spdk_trace_history *in_history, in circular_buffer_padding_backward() argument
283 rc = cont_write(fd, &in_history->entries[cir_start], in circular_buffer_padding_backward()
294 circular_buffer_padding_across(int fd, struct spdk_trace_history *in_history, in circular_buffer_padding_across() argument
305 rc = cont_write(fd, &in_history->entries[cir_start], in circular_buffer_padding_across()
[all …]
/spdk/lib/idxd/
H A Didxd_kernel.c30 int fd; member
45 if (kernel_idxd->fd >= 0) { in kernel_idxd_device_destruct()
46 close(kernel_idxd->fd); in kernel_idxd_device_destruct()
104 kernel_idxd->fd = -1; in kernel_idxd_probe()
146 kernel_idxd->fd = open(path, O_RDWR); in kernel_idxd_probe()
147 if (kernel_idxd->fd < 0) { in kernel_idxd_probe()
154 MAP_SHARED | MAP_POPULATE, kernel_idxd->fd, 0); in kernel_idxd_probe()
/spdk/module/bdev/uring/
H A Dbdev_uring.c13 #include "spdk/fd.h"
56 int fd;
86 int fd; in bdev_uring_open()
88 fd = open(bdev->filename, O_RDWR | O_DIRECT | O_NOATIME); in bdev_uring_open()
89 if (fd < 0) { in bdev_uring_open()
91 fd = open(bdev->filename, O_RDWR | O_NOATIME); in bdev_uring_open()
92 if (fd < 0) { in bdev_uring_open()
95 bdev->fd = -1; in bdev_uring_open()
100 bdev->fd = fd; in bdev_uring_open()
55 int fd; global() member
85 int fd; bdev_uring_open() local
[all...]
/spdk/test/app/bdev_svc/
H A Dbdev_svc.c28 int fd; in bdev_svc_start() local
36 fd = open(g_path, O_CREAT | O_EXCL | O_RDWR, S_IFREG); in bdev_svc_start()
37 if (fd < 0) { in bdev_svc_start()
41 close(fd); in bdev_svc_start()
/spdk/module/bdev/aio/
H A Dbdev_aio.c15 #include "spdk/fd.h"
66 int fd; member
117 int fd; in bdev_aio_open()
123 fd = open(disk->filename, io_flag | O_DIRECT); in bdev_aio_open()
124 if (fd < 0) { in bdev_aio_open()
126 fd = open(disk->filename, io_flag); in bdev_aio_open()
127 if (fd < 0) { in bdev_aio_open()
130 disk->fd = -1; in bdev_aio_open()
135 disk->fd = fd; in bdev_aio_close()
114 int fd; bdev_aio_open() local
[all...]
/spdk/test/nvme/overhead/
H A Doverhead.c9 #include "spdk/fd.h"
43 int fd; member
172 int fd; in register_aio_file() local
176 fd = open(path, O_RDWR | O_DIRECT); in register_aio_file()
177 if (fd < 0) { in register_aio_file()
182 size = spdk_fd_get_size(fd); in register_aio_file()
185 close(fd); in register_aio_file()
189 blklen = spdk_fd_get_blocklen(fd); in register_aio_file()
192 close(fd); in register_aio_file()
198 close(fd); in register_aio_file()
218 aio_submit(io_context_t aio_ctx,struct iocb * iocb,int fd,enum io_iocb_cmd cmd,void * buf,unsigned long nbytes,uint64_t offset,void * cb_ctx) aio_submit() argument
[all...]
/spdk/include/spdk/
H A Dfd.h26 uint64_t spdk_fd_get_size(int fd);
35 uint32_t spdk_fd_get_blocklen(int fd);
/spdk/lib/virtio/
H A Dvirtio_vhost_user.c40 vhost_user_write(int fd, void *buf, int len, int *fds, int fd_num) in vhost_user_write() argument
76 r = sendmsg(fd, &msgh, 0); in vhost_user_write()
87 vhost_user_read(int fd, struct vhost_user_msg *msg) in vhost_user_read() argument
93 ret = recv(fd, (void *)msg, sz_hdr, 0); in vhost_user_read()
120 ret = recv(fd, (void *)((char *)msg + sz_hdr), sz_payload, 0); in vhost_user_read()
353 if (file->fd > 0) { in vhost_user_sock()
354 fds[fd_num++] = file->fd; in vhost_user_sock()
445 int fd; in vhost_user_setup() local
450 fd = socket(AF_UNIX, SOCK_STREAM, 0); in vhost_user_setup()
451 if (fd < in vhost_user_setup()
[all...]
/spdk/module/sock/
H A Dsock_kernel.h
/spdk/test/unit/lib/rpc/rpc.c/
H A Drpc_ut.c34 DECLARE_WRAPPER(close, int, (int fd));
35 DECLARE_WRAPPER(flock, int, (int fd, int operation));
37 DEFINE_WRAPPER(close, int, (int fd), (fd));
38 DEFINE_WRAPPER(flock, int, (int fd, int operation), (fd, operation));
/spdk/lib/ut_mock/
H A Dmock.c22 DEFINE_WRAPPER(writev, ssize_t, (int fd, const struct iovec *iov, int iovcnt), (fd, iov, iovcnt))
/spdk/lib/env_dpdk/
H A Dpci_event.c196 spdk_pci_get_event(int fd, struct spdk_pci_event *event) in spdk_pci_get_event() argument
204 ret = recv(fd, buf, SPDK_UEVENT_MSG_LEN - 1, MSG_DONTWAIT); in spdk_pci_get_event()
233 spdk_pci_get_event(int fd, struct spdk_pci_event *event) in spdk_pci_get_event() argument
/spdk/test/app/fuzz/llvm_vfio_fuzz/
H A Dllvm_vfio_fuzz.c126 int fd; in fuzz_vfio_user_dma_map() local
128 memcpy(&fd, &data[0], 4); in fuzz_vfio_user_dma_map()
138 &dma_map, sizeof(dma_map), sizeof(dma_map), &fd, 1); in fuzz_vfio_user_dma_map()
147 int fd; in fuzz_vfio_user_dma_unmap() local
149 memcpy(&fd, &data[0], 4); in fuzz_vfio_user_dma_unmap()
163 &dma_map, sizeof(dma_map), sizeof(dma_map), &fd, 1); in fuzz_vfio_user_dma_unmap()
166 &dma_unmap, sizeof(dma_unmap), sizeof(dma_unmap), &fd, 1); in fuzz_vfio_user_dma_unmap()
/spdk/test/bdev/bdevio/
H A Dtests.py76 def execute_script(parser, client, fd): argument
77 for rpc_call in map(str.rstrip, fd):
/spdk/python/spdk/spdkcli/
H A Dui_root.py87 with open(filename, "r") as fd:
88 rpc.load_config(self.client, fd)
91 with open(filename, "r") as fd:
92 rpc.load_subsystem_config(self.client, fd)
95 with open(filename, "w") as fd:
96 rpc.save_config(self.client, fd, indent)
99 with open(filename, "w") as fd:
100 rpc.save_subsystem_config(self.client, fd, indent, subsystem)
/spdk/test/app/fuzz/common/
H A Dfuzz_rpc.py93 def execute_script(parser, client, fd): argument
94 for rpc_call in map(str.rstrip, fd):
/spdk/test/nvmf/target/
H A Dmultitarget_rpc.py71 def execute_script(parser, client, fd): argument
72 for rpc_call in map(str.rstrip, fd):

123