Home
last modified time | relevance | path

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

12345678910>>...25

/f-stack/app/micro_thread/
H A Dff_hook.cpp45 int ff_hook_close(int fd) in ff_hook_close() argument
47 if (ff_fdisused(fd)) { in ff_hook_close()
48 return ff_close(fd); in ff_hook_close()
56 if (ff_fdisused(fd)) { in ff_hook_connect()
65 if (ff_fdisused(fd)) { in ff_hook_read()
74 if (ff_fdisused(fd)) { in ff_hook_write()
83 if (ff_fdisused(fd)) { in ff_hook_sendto()
92 if (ff_fdisused(fd)) { in ff_hook_recvfrom()
100 if (ff_fdisused(fd)) { in ff_hook_recv()
108 if (ff_fdisused(fd)) { in ff_hook_send()
[all …]
H A Dmt_sys_hook.cpp59 if ((fd < 0) || (fd >= MT_HOOK_MAX_FD)) { in mt_hook_find_fd()
71 void mt_hook_new_fd(int fd) in mt_hook_new_fd() argument
73 if ((fd < 0) || (fd >= MT_HOOK_MAX_FD)) { in mt_hook_new_fd()
83 void mt_hook_free_fd(int fd) in mt_hook_free_fd() argument
85 if ((fd < 0) || (fd >= MT_HOOK_MAX_FD)) { in mt_hook_free_fd()
133 if (fd < 0) in socket()
135 return fd; in socket()
138 mt_hook_new_fd(fd); in socket()
144 return fd; in socket()
147 int close(int fd) in close() argument
[all …]
H A Dff_hook.h26 int ff_hook_close(int fd);
28 int ff_hook_connect(int fd, const struct sockaddr *address, socklen_t addrlen_len);
30 ssize_t ff_hook_read(int fd, void *buf, size_t nbyte);
32 ssize_t ff_hook_write(int fd, const void *buf, size_t nbyte);
35 ssize_t ff_hook_recv(int fd, void *buffer, size_t length, int flags);
36 ssize_t ff_hook_send(int fd, const void *buf, size_t nbyte, int flags);
38 int ff_hook_ioctl(int fd, int cmd, void *arg);
40 int ff_hook_fcntl(int fd, int cmd, void *arg);
42 int ff_hook_listen(int fd, int backlog);
44 int ff_hook_bind(int fd, const struct sockaddr *addr, socklen_t addrlen);
[all …]
H A Decho.cpp8 int set_fd_nonblock(int fd) in set_fd_nonblock() argument
11 return ioctl(fd, FIONBIO, &nonblock); in set_fd_nonblock()
16 int fd; in create_tcp_sock() local
18 if (fd < 0) { in create_tcp_sock()
22 if (set_fd_nonblock(fd) == -1) { in create_tcp_sock()
27 return fd; in create_tcp_sock()
59 int fd = create_tcp_sock(); in echo_server() local
60 if (fd < 0) { in echo_server()
66 close(fd); in echo_server()
71 if (listen(fd, 1024) < 0) { in echo_server()
[all …]
/f-stack/freebsd/net/route/
H A Dfib_algo.c390 _ALGO_PRINTF(fd->fd_fibnum, fd->fd_family, fd->fd_flm->flm_name, in fib_printf()
647 struct fib_data *fd = w->fd; in sync_algo_end_cb() local
668 w->result = fd->fd_flm->flm_dump_end_cb(fd->fd_algo_data, &fd->fd_dp); in sync_algo_end_cb()
712 .fd = fd, in sync_algo()
828 FD_PRINTF(LOG_INFO, fd, "destroy fd %p", fd); in destroy_fd_instance()
832 fd->fd_flm->flm_destroy_cb(fd->fd_algo_data); in destroy_fd_instance()
930 result = flm->flm_init_cb(fd->fd_fibnum, fd, old_algo_data, &fd->fd_algo_data); in try_setup_fd_instance()
938 fd->fd_rs = rib_subscribe_locked(fd->fd_rh, in try_setup_fd_instance()
1267 curvnet, fd->fd_dp.f, fd->fd_dp.arg); in replace_rtables_family()
1282 new_fdh->fdh_idx[fd->fd_fibnum] = fd->fd_dp; in replace_rtables_family()
[all …]
/f-stack/app/redis-5.0.5/tests/support/
H A Dredis.tcl46 set ::redis::fd($id) $fd
73 if {$fd eq {}} {
109 fileevent $fd readable [list ::redis::redis_readable $fd $id]
135 flush $fd
139 catch {close $fd}
152 return $fd
164 redis_write $fd $buf
165 redis_write $fd "\r\n"
166 flush $fd
203 set type [read $fd 1]
[all …]
/f-stack/dpdk/app/test/
H A Dtest_eal_fs.c63 fclose(fd); in test_parse_sysfs_value()
64 fd = NULL; in test_parse_sysfs_value()
83 fclose(fd); in test_parse_sysfs_value()
84 fd = NULL; in test_parse_sysfs_value()
103 fclose(fd); in test_parse_sysfs_value()
104 fd = NULL; in test_parse_sysfs_value()
118 fclose(fd); in test_parse_sysfs_value()
119 fd = NULL; in test_parse_sysfs_value()
134 fd = NULL; in test_parse_sysfs_value()
148 fd = NULL; in test_parse_sysfs_value()
[all …]
/f-stack/dpdk/lib/librte_vhost/
H A Dfd_man.c38 pfdset->fd[dst] = pfdset->fd[src]; in fdset_move()
49 if (pfdset->fd[i].fd != -1) in fdset_shrink_nolock()
79 for (i = 0; i < pfdset->num && pfdset->fd[i].fd != fd; i++) in fdset_find_fd()
92 pfdentry->fd = fd; in fdset_add_fd()
97 pfd->fd = fd; in fdset_add_fd()
112 pfdset->fd[i].fd = -1; in fdset_init()
168 pfdset->fd[i].fd = -1; in fdset_del()
169 pfdset->fd[i].rcb = pfdset->fd[i].wcb = NULL; in fdset_del()
203 pfdset->fd[i].fd = -1; in fdset_try_del()
204 pfdset->fd[i].rcb = pfdset->fd[i].wcb = NULL; in fdset_try_del()
[all …]
/f-stack/app/redis-5.0.5/tests/integration/
H A Dredis-cli.tcl9 set _ $fd
12 proc close_cli {fd} {
13 close $fd
16 proc read_cli {fd} {
17 set buf [read $fd]
27 puts $fd $buf
28 flush $fd
33 write_cli $fd $cmd
41 set fd [open_cli]
43 close_cli $fd
[all …]
/f-stack/dpdk/drivers/bus/fslmc/portal/
H A Ddpaa2_hw_pvt.h257 #define DPAA2_SET_FD_LEN(fd, length) ((fd)->simple.len = length) argument
258 #define DPAA2_SET_FD_BPID(fd, bpid) ((fd)->simple.bpid_offset |= bpid) argument
268 #define DPAA2_RESET_FD_FRC(fd) ((fd)->simple.frc = 0) argument
269 #define DPAA2_SET_FD_FRC(fd, _frc) ((fd)->simple.frc = _frc) argument
270 #define DPAA2_RESET_FD_CTRL(fd) ((fd)->simple.ctrl = 0) argument
272 #define DPAA2_SET_FD_ASAL(fd, asal) ((fd)->simple.ctrl |= (asal << 16)) argument
307 (((((uint64_t)((fd)->simple.addr_hi)) << 32) + (fd)->simple.addr_lo))
309 #define DPAA2_GET_FD_LEN(fd) ((fd)->simple.len) argument
313 #define DPAA2_GET_FD_FRC(fd) ((fd)->simple.frc) argument
315 (((uint64_t)((fd)->simple.flc_hi) << 32) + (fd)->simple.flc_lo)
[all …]
/f-stack/freebsd/contrib/ncsw/inc/Peripherals/
H A Ddpaa_ext.h118 #define DPAA_FD_GET_ADDRH(fd) ((t_DpaaFD *)fd)->addrh /**< Macro to g… argument
119 #define DPAA_FD_GET_ADDRL(fd) ((t_DpaaFD *)fd)->addrl … argument
120 …efine DPAA_FD_GET_PHYS_ADDR(fd) ((physAddress_t)(((uint64_t)DPAA_FD_GET_ADDRH(fd) << 32) | (ui… argument
121 #define DPAA_FD_GET_FORMAT(fd) ((((t_DpaaFD *)fd)->length & DPAA_FD_FORMAT_MASK) >> (31-2)) … argument
122 #define DPAA_FD_GET_OFFSET(fd) ((((t_DpaaFD *)fd)->length & DPAA_FD_OFFSET_MASK) >> (31-11))… argument
123 #define DPAA_FD_GET_LENGTH(fd) (((t_DpaaFD *)fd)->length & DPAA_FD_LENGTH_MASK) … argument
127 #define DPAA_FD_SET_ADDRH(fd,val) ((t_DpaaFD *)fd)->addrh = (val) /**< Macro to set … argument
128 #define DPAA_FD_SET_ADDRL(fd,val) ((t_DpaaFD *)fd)->addrl = (val) … argument
135 #define DPAA_FD_SET_FORMAT(fd,val) (((t_DpaaFD *)fd)->length = ((((t_DpaaFD *)fd)->length & ~DPA… argument
136 #define DPAA_FD_SET_OFFSET(fd,val) (((t_DpaaFD *)fd)->length = ((((t_DpaaFD *)fd)->length & ~DPA… argument
[all …]
/f-stack/freebsd/contrib/openzfs/cmd/zed/
H A Dzed_file.c88 zed_file_lock(int fd) in zed_file_lock() argument
92 if (fd < 0) { in zed_file_lock()
115 zed_file_unlock(int fd) in zed_file_unlock() argument
119 if (fd < 0) { in zed_file_unlock()
141 zed_file_is_locked(int fd) in zed_file_is_locked() argument
145 if (fd < 0) { in zed_file_is_locked()
174 int fd; in zed_file_close_from() local
185 for (fd = lowfd; fd < maxfd; fd++) in zed_file_close_from()
186 (void) close(fd); in zed_file_close_from()
203 if (fd < 0) { in zed_file_close_on_exec()
[all …]
/f-stack/freebsd/contrib/openzfs/lib/libzfs/os/linux/
H A Dlibzfs_pool_os.c63 int fd, error; in zpool_relabel_disk() local
79 (void) fsync(fd); in zpool_relabel_disk()
82 (void) close(fd); in zpool_relabel_disk()
101 int fd; in read_efi_label() local
118 (void) close(fd); in read_efi_label()
160 int fd, err; in zpool_label_disk_check() local
177 (void) close(fd); in zpool_label_disk_check()
191 int fd; in zpool_label_name() local
194 if (fd >= 0) { in zpool_label_name()
198 close(fd); in zpool_label_name()
[all …]
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/tests/functional/tmpfile/
H A Dtmpfile_001_pos.c44 int i, fd; in main() local
63 if (fd < 0) { in main()
68 if (write(fd, buf1, BSZ) < 0) { in main()
70 close(fd); in main()
74 if (pread(fd, buf2, BSZ, 0) < 0) { in main()
76 close(fd); in main()
82 close(fd); in main()
90 close(fd); in main()
96 close(fd); in main()
102 close(fd); in main()
[all …]
/f-stack/app/redis-5.0.5/deps/hiredis/adapters/
H A Divykis.h9 struct iv_fd fd; member
29 iv_fd_set_handler_in(&e->fd, NULL); in redisIvykisDelRead()
39 iv_fd_set_handler_out(&e->fd, NULL); in redisIvykisDelWrite()
45 iv_fd_unregister(&e->fd); in redisIvykisCleanup()
70 IV_FD_INIT(&e->fd); in redisIvykisAttach()
71 e->fd.fd = c->fd; in redisIvykisAttach()
72 e->fd.handler_in = redisIvykisReadEvent; in redisIvykisAttach()
73 e->fd.handler_out = redisIvykisWriteEvent; in redisIvykisAttach()
74 e->fd.handler_err = NULL; in redisIvykisAttach()
75 e->fd.cookie = e->context; in redisIvykisAttach()
[all …]
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/cmd/mmapwrite/
H A Dmmapwrite.c60 int fd = -1; in normal_writer() local
65 if (fd == -1) { in normal_writer()
71 write_num = write(fd, buf, 1); in normal_writer()
76 lseek(fd, page_size, SEEK_CUR); in normal_writer()
87 int fd = -1; in map_writer() local
100 if (fd == -1) { in map_writer()
104 ret = ftruncate(fd, page_size); in map_writer()
112 fd = open(file_path, O_RDWR, 0777); in map_writer()
113 if (fd == -1) { in map_writer()
123 if (fd != -1) in map_writer()
[all …]
/f-stack/freebsd/kern/
H A Dsys_capability.c322 fd = uap->fd; in sys___cap_rights_get()
324 AUDIT_ARG_FD(fd); in sys___cap_rights_get()
367 KASSERT(fd >= 0 && fd < fdp->fd_nfiles, in cap_ioctl_check()
426 AUDIT_ARG_FD(fd); in kern_cap_ioctls_limit()
495 int error, fd; in sys_cap_ioctls_get() local
497 fd = uap->fd; in sys_cap_ioctls_get()
570 KASSERT(fd >= 0 && fd < fdp->fd_nfiles, in cap_fcntl_check()
582 int fd; in sys_cap_fcntls_limit() local
584 fd = uap->fd; in sys_cap_fcntls_limit()
621 int fd; in sys_cap_fcntls_get() local
[all …]
/f-stack/dpdk/lib/librte_eal/linux/
H A Deal_vfio_mp_sync.c28 int fd = -1; in vfio_mp_primary() local
47 if (fd < 0 && fd != -ENOENT) in vfio_mp_primary()
49 else if (fd == -ENOENT) in vfio_mp_primary()
56 reply.fds[0] = fd; in vfio_mp_primary()
61 fd = rte_vfio_get_container_fd(); in vfio_mp_primary()
62 if (fd < 0) in vfio_mp_primary()
67 reply.fds[0] = fd; in vfio_mp_primary()
72 fd = vfio_get_default_container_fd(); in vfio_mp_primary()
73 if (fd < 0) in vfio_mp_primary()
78 reply.fds[0] = fd; in vfio_mp_primary()
[all …]
/f-stack/app/redis-5.0.5/src/
H A Danet.h58 int anetRead(int fd, char *buf, int count);
66 int anetWrite(int fd, char *buf, int count);
67 int anetNonBlock(char *err, int fd);
68 int anetBlock(char *err, int fd);
69 int anetEnableTcpNoDelay(char *err, int fd);
70 int anetDisableTcpNoDelay(char *err, int fd);
71 int anetTcpKeepAlive(char *err, int fd);
72 int anetSendTimeout(char *err, int fd, long long ms);
74 int anetKeepAlive(char *err, int fd, int interval);
77 int anetFormatPeer(int fd, char *fmt, size_t fmt_len);
[all …]
H A Danet.c94 return anetSetBlock(err,fd,1); in anetNonBlock()
97 int anetBlock(char *err, int fd) { in anetBlock() argument
98 return anetSetBlock(err,fd,0); in anetBlock()
541 int fd; in anetGenericAccept() local
543 fd = accept(s,sa,len); in anetGenericAccept()
544 if (fd == -1) { in anetGenericAccept()
554 return fd; in anetGenericAccept()
558 int fd; in anetTcpAccept() local
573 return fd; in anetTcpAccept()
577 int fd; in anetUnixAccept() local
[all …]
H A Dae_evport.c109 static int aeApiLookupPending(aeApiState *state, int fd) { in aeApiLookupPending() argument
113 if (state->pending_fds[i] == fd) in aeApiLookupPending()
135 rv = port_associate(portfd, PORT_SOURCE_FD, fd, events, in aeApiAssociate()
152 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent() argument
164 fullmask = mask | eventLoop->events[fd].mask; in aeApiAddEvent()
165 pfd = aeApiLookupPending(state, fd); in aeApiAddEvent()
188 fprintf(stderr, "del fd %d mask 0x%x\n", fd, mask); in aeApiDelEvent()
190 pfd = aeApiLookupPending(state, fd); in aeApiDelEvent()
217 fullmask = eventLoop->events[fd].mask; in aeApiDelEvent()
230 } else if (aeApiAssociate("aeApiDelEvent", state->portfd, fd, in aeApiDelEvent()
[all …]
/f-stack/tools/libutil/
H A Dflopen.c53 int fd, operation, serrno, trunc; in vflopenat() local
77 if (flock(fd, operation) == -1) { in vflopenat()
80 (void)close(fd); in vflopenat()
86 (void)close(fd); in vflopenat()
89 if (fstat(fd, &fsb) == -1) { in vflopenat()
92 (void)close(fd); in vflopenat()
99 (void)close(fd); in vflopenat()
102 if (trunc && ftruncate(fd, 0) != 0) { in vflopenat()
105 (void)close(fd); in vflopenat()
116 (void)close(fd); in vflopenat()
[all …]
H A Duucplock.c57 static int put_pid (int fd, pid_t pid);
58 static pid_t get_pid (int fd,int *err);
67 int fd, tmpfd, i; in uu_lock() local
97 close(fd); in uu_lock()
118 (void)close(fd); in uu_lock()
130 int fd, err; in uu_lock_txfr() local
137 if (get_pid(fd, &err) != getpid()) in uu_lock_txfr()
140 lseek(fd, (off_t)0, SEEK_SET); in uu_lock_txfr()
143 close(fd); in uu_lock_txfr()
199 put_pid(int fd, pid_t pid) in put_pid() argument
[all …]
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/cmd/file_trunc/
H A Dfile_trunc.c64 static void do_write(int fd);
65 static void do_trunc(int fd);
80 int fd = -1; in main() local
85 if (fd < 0) { in main()
91 (void) do_write(fd); in main()
92 (void) do_trunc(fd); in main()
95 (void) close(fd); in main()
170 do_write(int fd) in do_write() argument
190 if (write(fd, buf, bsize) < bsize) { in do_write()
201 if (read(fd, rbuf, bsize) < bsize) { in do_write()
[all …]
/f-stack/app/nginx-1.16.1/src/core/
H A Dngx_open_file_cache.c192 clnf->fd = of->fd; in ngx_open_cached_file()
242 of->fd = file->fd; in ngx_open_cached_file()
286 of->fd = file->fd; in ngx_open_cached_file()
399 file->fd = of->fd; in ngx_open_cached_file()
541 return fd; in ngx_openat_file_owner()
617 ngx_fd_t fd; in ngx_open_file_wrapper() local
629 return fd; in ngx_open_file_wrapper()
775 return fd; in ngx_open_file_wrapper()
800 ngx_fd_t fd; in ngx_file_info_wrapper() local
913 of->fd = fd; in ngx_open_and_stat_file()
[all …]

12345678910>>...25