| /f-stack/app/nginx-1.16.1/src/event/modules/ |
| H A D | ngx_ff_module.c | 259 sockfd = restore_fstack_fd(sockfd); in bind()
270 sockfd = restore_fstack_fd(sockfd); in connect()
282 sockfd = restore_fstack_fd(sockfd); in getpeername()
295 sockfd = restore_fstack_fd(sockfd); in getsockname()
307 sockfd = restore_fstack_fd(sockfd); in send()
319 sockfd = restore_fstack_fd(sockfd); in sendto()
331 sockfd = restore_fstack_fd(sockfd); in sendmsg()
341 sockfd = restore_fstack_fd(sockfd); in recvmsg()
352 sockfd = restore_fstack_fd(sockfd); in recv()
373 sockfd = restore_fstack_fd(sockfd); in listen()
[all …]
|
| /f-stack/app/redis-5.0.5/src/ |
| H A D | anet_ff.c | 181 if (ff_fdisused(sockfd)) { in bind()
196 if (ff_fdisused(sockfd)) { in connect()
211 if (ff_fdisused(sockfd)) { in send()
226 if (ff_fdisused(sockfd)) { in recv()
241 if (ff_fdisused(sockfd)) { in listen()
257 if (ff_fdisused(sockfd)) { in setsockopt()
272 if (ff_fdisused(sockfd)) { in accept()
287 if (ff_fdisused(sockfd)) { in accept4()
295 close(int sockfd) in close() argument
302 if (ff_fdisused(sockfd)) { in close()
[all …]
|
| /f-stack/example/ |
| H A D | main_epoll.c | 24 int sockfd; variable
67 if (events[i].data.fd == sockfd) { in loop()
69 int nclientfd = ff_accept(sockfd, NULL, NULL); in loop()
108 sockfd = ff_socket(AF_INET, SOCK_STREAM, 0); in main()
109 printf("sockfd:%d\n", sockfd); in main()
110 if (sockfd < 0) { in main()
116 ff_ioctl(sockfd, FIONBIO, &on); in main()
124 int ret = ff_bind(sockfd, (struct linux_sockaddr *)&my_addr, sizeof(my_addr)); in main()
130 ret = ff_listen(sockfd, MAX_EVENTS); in main()
137 ev.data.fd = sockfd; in main()
[all …]
|
| H A D | main.c | 23 int sockfd; variable
75 } else if (clientfd == sockfd || clientfd == sockfd6) { in loop()
77 } else if (clientfd == sockfd) { in loop()
116 sockfd = ff_socket(AF_INET, SOCK_STREAM, 0); in main()
117 if (sockfd < 0) { in main()
118 printf("ff_socket failed, sockfd:%d, errno:%d, %s\n", sockfd, errno, strerror(errno)); in main()
128 int ret = ff_bind(sockfd, (struct linux_sockaddr *)&my_addr, sizeof(my_addr)); in main()
130 printf("ff_bind failed, sockfd:%d, errno:%d, %s\n", sockfd, errno, strerror(errno)); in main()
134 ret = ff_listen(sockfd, MAX_EVENTS); in main()
136 printf("ff_listen failed, sockfd:%d, errno:%d, %s\n", sockfd, errno, strerror(errno)); in main()
[all …]
|
| H A D | main_zc.c | 23 int sockfd; variable
155 } else if (clientfd == sockfd || clientfd == sockfd6) { in loop()
157 } else if (clientfd == sockfd) { in loop()
239 sockfd = ff_socket(AF_INET, SOCK_STREAM, 0); in main()
240 if (sockfd < 0) { in main()
241 printf("ff_socket failed, sockfd:%d, errno:%d, %s\n", sockfd, errno, strerror(errno)); in main()
251 int ret = ff_bind(sockfd, (struct linux_sockaddr *)&my_addr, sizeof(my_addr)); in main()
253 printf("ff_bind failed, sockfd:%d, errno:%d, %s\n", sockfd, errno, strerror(errno)); in main()
257 ret = ff_listen(sockfd, MAX_EVENTS); in main()
259 printf("ff_listen failed, sockfd:%d, errno:%d, %s\n", sockfd, errno, strerror(errno)); in main()
[all …]
|
| /f-stack/dpdk/drivers/net/af_packet/ |
| H A D | rte_eth_af_packet.c | 42 int sockfd; member
57 int sockfd; member
279 int sockfd; in eth_dev_stop() local
283 sockfd = internals->rx_queue[i].sockfd; in eth_dev_stop()
285 close(sockfd); in eth_dev_stop()
288 if (sockfd != internals->tx_queue[i].sockfd) { in eth_dev_stop()
289 sockfd = internals->tx_queue[i].sockfd; in eth_dev_stop()
291 close(sockfd); in eth_dev_stop()
501 int sockfd = internals->rx_queue[0].sockfd; in eth_dev_macaddr_set() local
909 if (*sockfd < 0) in rte_eth_from_packet()
[all …]
|
| /f-stack/tools/libnetgraph/ |
| H A D | netgraph.h | 79 int ng_connect(int sockfd, const struct sockaddr *addr,
81 int ng_bind(int sockfd, const struct sockaddr *addr,
83 ssize_t ng_sendto(int sockfd, const void *buf, size_t len, int flags,
85 ssize_t ng_recvfrom(int sockfd, void *buf, size_t len, int flags,
|
| H A D | compat.c | 160 ng_bind(int sockfd, const struct sockaddr *addr, in ng_bind() argument
166 ba.s = sockfd; in ng_bind()
176 ng_connect(int sockfd, const struct sockaddr *addr, in ng_connect() argument
182 ca.s = sockfd; in ng_connect()
192 ng_sendto(int sockfd, const void *buf, size_t len, int flags, in ng_sendto() argument
198 sa.s = sockfd; in ng_sendto()
210 ng_recvfrom(int sockfd, void *buf, size_t len, int flags, in ng_recvfrom() argument
216 ra.s = sockfd; in ng_recvfrom()
|
| /f-stack/dpdk/drivers/net/memif/ |
| H A D | memif_socket.c | 808 int sockfd; in memif_listener_handler() local
817 if (sockfd < 0) { in memif_listener_handler()
857 close(sockfd); in memif_listener_handler()
858 sockfd = -1; in memif_listener_handler()
869 int sockfd; in memif_socket_create() local
885 if (sockfd < 0) in memif_socket_create()
929 if (sockfd >= 0) in memif_socket_create()
930 close(sockfd); in memif_socket_create()
1062 int sockfd; in memif_connect_client() local
1119 close(sockfd); in memif_connect_client()
[all …]
|
| /f-stack/app/micro_thread/ |
| H A D | mt_sys_hook.cpp | 336 int listen(int sockfd, int backlog) in listen() argument
341 return mt_real_func(listen)(sockfd, backlog); in listen()
344 return ff_hook_listen(sockfd, backlog); in listen()
347 int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen) in bind() argument
352 return mt_real_func(bind)(sockfd, addr, addrlen); in bind()
355 return ff_hook_bind(sockfd, addr, addrlen); in bind()
|
| H A D | mt_sys_hook.h | 37 typedef int (*func_bind)(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
38 typedef int (*func_listen)(int sockfd, int backlog);
|
| /f-stack/lib/ |
| H A D | ff_ngctl.c | 98 ngctl_close(int sockfd) in ngctl_close() argument
100 int error = kern_close(curthread, sockfd); in ngctl_close()
|
| /f-stack/tools/ipfw/ |
| H A D | compat.c | 117 int ff_getsockopt(int sockfd, int level, int optname, in ff_getsockopt() argument
123 int ff_setsockopt(int sockfd, int level, int optname, in ff_setsockopt() argument
|
| H A D | ipfw2.h | 456 int ff_getsockopt(int sockfd, int level, int optname,
458 int ff_setsockopt(int sockfd, int level, int optname,
|
| /f-stack/dpdk/lib/librte_vhost/ |
| H A D | vhost_user.h | 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 D | socket.c | 102 read_fd_message(int sockfd, char *buf, int buflen, int *fds, int max_fds, in read_fd_message() argument
123 ret = recvmsg(sockfd, &msgh, 0); in read_fd_message()
154 send_fd_message(int sockfd, char *buf, int buflen, int *fds, int fd_num) in send_fd_message() argument
190 ret = sendmsg(sockfd, &msgh, MSG_NOSIGNAL); in send_fd_message()
|
| H A D | vhost_user.c | 94 static int send_vhost_reply(int sockfd, struct VhostUserMsg *msg);
95 static int read_vhost_message(int sockfd, struct VhostUserMsg *msg);
2560 read_vhost_message(int sockfd, struct VhostUserMsg *msg) in read_vhost_message() argument
2564 ret = read_fd_message(sockfd, (char *)msg, VHOST_USER_HDR_SIZE, in read_vhost_message()
2580 ret = read(sockfd, &msg->payload, msg->size); in read_vhost_message()
2594 send_vhost_message(int sockfd, struct VhostUserMsg *msg) in send_vhost_message() argument
2599 return send_fd_message(sockfd, (char *)msg, in send_vhost_message()
2604 send_vhost_reply(int sockfd, struct VhostUserMsg *msg) in send_vhost_reply() argument
2614 return send_vhost_message(sockfd, msg); in send_vhost_reply()
|
| /f-stack/tools/compat/ |
| H A D | rtioctl.h | 37 int rt_setsockopt(int sockfd, int level, int optname,
|
| H A D | rtioctl.c | 58 rt_setsockopt(int sockfd, int level, int optname, in rt_setsockopt() argument
|
| /f-stack/dpdk/drivers/net/nfp/ |
| H A D | nfp_net.c | 3205 err = send(sockfd, tmpbuf, len, 0); in nfp_cpp_bridge_serve_read()
3243 err = recv(sockfd, &cmd, 4, 0); in nfp_cpp_bridge_serve_ioctl()
3265 err = send(sockfd, &tmp, 4, 0); in nfp_cpp_bridge_serve_ioctl()
3275 err = send(sockfd, &tmp, 4, 0); in nfp_cpp_bridge_serve_ioctl()
3301 int sockfd, datafd, op, ret; in nfp_cpp_bridge_service_func() local
3305 if (sockfd < 0) { in nfp_cpp_bridge_service_func()
3321 close(sockfd); in nfp_cpp_bridge_service_func()
3325 ret = listen(sockfd, 20); in nfp_cpp_bridge_service_func()
3329 close(sockfd); in nfp_cpp_bridge_service_func()
3339 close(sockfd); in nfp_cpp_bridge_service_func()
[all …]
|
| /f-stack/freebsd/sys/ |
| H A D | file.h | 117 typedef int fo_sendfile_t(struct file *fp, int sockfd, struct uio *hdr_uio,
404 fo_sendfile(struct file *fp, int sockfd, struct uio *hdr_uio, in fo_sendfile() argument
409 return ((*fp->f_ops->fo_sendfile)(fp, sockfd, hdr_uio, trl_uio, offset, in fo_sendfile()
|
| /f-stack/doc/ |
| H A D | F-Stack_API_Reference.md | 68 …sockopt() and setsockopt() manipulate options for the socket denoted by the file descriptor sockfd.
93 …ff_getpeername() returns the address of the peer connected to the socket sockfd, in the buffer poi…
101 …ff_getsockname() returns the current address to which the socket sockfd is bound, in the buffer po…
|
| /f-stack/freebsd/netinet/libalias/ |
| H A D | alias_db.c | 323 int sockfd; /* socket descriptor */ member
638 if (GetSocket(la, port_net, &lnk->sockfd, lnk->link_type)) { in GetNewPort()
665 GetSocket(struct libalias *la, u_short port_net, int *sockfd, int link_type) in GetSocket() argument
687 fprintf(stderr, "socket() error %d\n", *sockfd); in GetSocket()
700 *sockfd = sock; in GetSocket()
869 if (lnk->sockfd != -1) { in DeleteLink()
871 close(lnk->sockfd); in DeleteLink()
936 lnk->sockfd = -1; in AddLink()
|
| /f-stack/freebsd/kern/ |
| H A D | kern_sendfile.c | 677 vn_sendfile(struct file *fp, int sockfd, struct uio *hdr_uio, in vn_sendfile() argument
716 error = sendfile_getsock(td, sockfd, &sock_fp, &so); in vn_sendfile()
1211 error = kern_writev(td, sockfd, trl_uio); in vn_sendfile()
|
| /f-stack/app/nginx-1.16.1/src/core/ |
| H A D | ngx_connection.c | 15 extern int is_fstack_fd(int sockfd);
|