Home
last modified time | relevance | path

Searched refs:sock (Results 1 – 25 of 30) sorted by relevance

12

/f-stack/app/micro_thread/
H A Dmt_api.cpp49 if ((sock < 0) || (ioctl(sock, FIONBIO, &flags) < 0)) in mt_udpsendrcv()
78 if (sock > 0) in mt_udpsendrcv()
80 close(sock); in mt_udpsendrcv()
81 sock = -1; in mt_udpsendrcv()
146 sock = osfd; in mt_tcp_get_keep_conn()
225 int sock = -1; in mt_tcpsendrcv() local
289 int sock; in mt_tcpsendrcv_short() local
291 if (sock < 0) in mt_tcpsendrcv_short()
328 if (sock >= 0) in mt_tcpsendrcv_short()
403 if (sock < 0) in mt_tcpsend_short()
[all …]
H A Dmt_concurrent.cpp95 int sock = -1, has_ok = 0; in mt_multi_newsock() local
121 sock = net_handler->CreateSocket(); in mt_multi_newsock()
122 if (sock < 0) in mt_multi_newsock()
125 MTLOG_ERROR("Get sock data failed, ret %d, errno %d!!", sock, errno); in mt_multi_newsock()
H A Dmt_net.cpp1509 void CDestLinks::FreeSockLink(CSockLink* sock) in FreeSockLink() argument
1511 if ((sock == NULL) || (sock->GetParentsPtr() != (void*)this)) in FreeSockLink()
1513 MTLOG_ERROR("invalid socklink %p, error", sock); in FreeSockLink()
1517 TAILQ_REMOVE(&_sock_list, sock, _link_entry); in FreeSockLink()
1522 sock->Reset(); in FreeSockLink()
1523 CNetMgr::Instance()->FreeSockLink(sock); in FreeSockLink()
/f-stack/dpdk/usertools/
H A Ddpdk-telemetry.py21 def read_socket(sock, buf_len, echo=True): argument
23 reply = sock.recv(buf_len).decode()
28 sock.close()
41 sock.connect(path)
44 sock.close()
46 json_reply = read_socket(sock, 1024)
50 sock.send("/".encode())
51 CMDS = read_socket(sock, output_buf_len, False)["/"]
57 sock.send(text.encode())
58 read_socket(sock, output_buf_len)
[all …]
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/tests/functional/cli_root/zfs_diff/
H A Dsocket.c31 struct sockaddr_un sock; in main() local
40 size = sizeof (sock.sun_path); in main()
41 strncpy(sock.sun_path, (char *)path, size - 1); in main()
42 sock.sun_path[size - 1] = '\0'; in main()
44 sock.sun_family = AF_UNIX; in main()
49 if (bind(fd, (struct sockaddr *)&sock, sizeof (struct sockaddr_un))) { in main()
/f-stack/dpdk/app/test/
H A Dtest_telemetry_data.c25 static int sock; variable
56 bytes = read(sock, buf, sizeof(buf) - 1); in test_output()
308 int sock, bytes; in connect_to_socket() local
312 if (sock < 0) { in connect_to_socket()
325 close(sock); in connect_to_socket()
333 close(sock); in connect_to_socket()
338 return sock; in connect_to_socket()
347 sock = connect_to_socket(); in test_telemetry_data()
348 if (sock <= 0) in test_telemetry_data()
365 close(sock); in test_telemetry_data()
[all …]
/f-stack/tools/ndp/
H A Dndp.c854 int sock; in getnbrinfo() local
869 close(sock); in getnbrinfo()
999 int i, sock; in ifinfo() local
1146 close(sock); in ifinfo()
1335 int sock; in pfx_flush() local
1343 close(sock); in pfx_flush()
1350 int sock; in rtr_flush() local
1358 close(sock); in rtr_flush()
1365 int sock; in harmonize_rtr() local
1382 int sock; in setdefif() local
[all …]
/f-stack/dpdk/lib/librte_telemetry/
H A Dtelemetry.c43 int sock; member
345 int s_accepted = accept(s->sock, NULL, NULL); in socket_listener()
389 int sock = socket(AF_UNIX, SOCK_SEQPACKET, 0); in create_socket() local
390 if (sock < 0) { in create_socket()
408 if (listen(sock, 1) < 0) { in create_socket()
415 return sock; in create_socket()
418 close(sock); in create_socket()
442 v1_socket.sock = create_socket(v1_socket.path); in telemetry_legacy_init()
443 if (v1_socket.sock < 0) in telemetry_legacy_init()
471 v2_socket.sock = create_socket(v2_socket.path); in telemetry_v2_init()
[all …]
/f-stack/dpdk/drivers/net/memif/
H A Dmemif_socket.c867 struct memif_socket *sock; in memif_socket_create() local
874 if (sock == NULL) { in memif_socket_create()
879 sock->listener = listener; in memif_socket_create()
880 strlcpy(sock->filename, key, MEMIF_SOCKET_UN_SIZE); in memif_socket_create()
881 TAILQ_INIT(&sock->dev_queue); in memif_socket_create()
912 sock->intr_handle.fd = sockfd; in memif_socket_create()
913 sock->intr_handle.type = RTE_INTR_HANDLE_EXT; in memif_socket_create()
915 memif_listener_handler, sock); in memif_socket_create()
923 return sock; in memif_socket_create()
927 if (sock != NULL) in memif_socket_create()
[all …]
/f-stack/app/nginx-1.16.1/src/event/modules/
H A Dngx_ff_module.c232 int sock; in socket() local
246 sock = ff_socket(domain, type, protocol); in socket()
248 if (sock != -1) { in socket()
249 sock = convert_fstack_fd(sock); in socket()
252 return sock; in socket()
/f-stack/tools/arp/
H A Darp.c860 int sock; in get_ether_addr() local
863 sock = socket(AF_INET, SOCK_DGRAM, 0); in get_ether_addr()
864 if (sock < 0) in get_ether_addr()
869 if (ioctl(sock, SIOCGIFCONF, &ifc) < 0) { in get_ether_addr()
893 if (ioctl(sock, SIOCGIFFLAGS, &ifreq) < 0) in get_ether_addr()
900 if (ioctl(sock, SIOCGIFNETMASK, &ifreq) < 0) in get_ether_addr()
933 close(sock); in get_ether_addr()
/f-stack/dpdk/drivers/net/vdev_netvsc/
H A Dvdev_netvsc.c234 int sock; in vdev_netvsc_has_route() local
246 sock = socket(AF_NETLINK, SOCK_RAW, NETLINK_ROUTE); in vdev_netvsc_has_route()
247 if (sock == -1) { in vdev_netvsc_has_route()
254 res = bind(sock, (struct sockaddr *)&sa, sizeof(sa)); in vdev_netvsc_has_route()
267 res = send(sock, &msg, msg.nlhdr.nlmsg_len, 0); in vdev_netvsc_has_route()
275 len = recv(sock, buf, sizeof(buf), 0); in vdev_netvsc_has_route()
304 close(sock); in vdev_netvsc_has_route()
/f-stack/dpdk/drivers/vdpa/mlx5/
H A Dmlx5_vdpa.c230 int sock; in mlx5_vdpa_mtu_set() local
247 sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_IP); in mlx5_vdpa_mtu_set()
248 if (sock == -1) { in mlx5_vdpa_mtu_set()
250 return sock; in mlx5_vdpa_mtu_set()
253 ret = ioctl(sock, SIOCGIFMTU, &request); in mlx5_vdpa_mtu_set()
262 ret = ioctl(sock, SIOCSIFMTU, &request); in mlx5_vdpa_mtu_set()
268 close(sock); in mlx5_vdpa_mtu_set()
/f-stack/tools/ifconfig/
H A Difbridge.c89 do_cmd(int sock, u_long op, void *arg, size_t argsize, int set) in do_cmd() argument
101 return (ioctl(sock, set ? SIOCSDRVSPEC : SIOCGDRVSPEC, &ifd)); in do_cmd()
104 return (ioctl_va(sock, set ? SIOCSDRVSPEC : SIOCGDRVSPEC, &ifd, in do_cmd()
110 do_bridgeflag(int sock, const char *ifs, int flag, int set) in do_bridgeflag() argument
116 if (do_cmd(sock, BRDGGIFFLGS, &req, sizeof(req), 0) < 0) in do_bridgeflag()
124 if (do_cmd(sock, BRDGSIFFLGS, &req, sizeof(req), 1) < 0) in do_bridgeflag()
H A Difvxlan.c82 do_cmd(int sock, u_long op, void *arg, size_t argsize, int set) in do_cmd() argument
94 return (ioctl(sock, set ? SIOCSDRVSPEC : SIOCGDRVSPEC, &ifd)); in do_cmd()
97 return (ioctl_va(sock, set ? SIOCSDRVSPEC : SIOCGDRVSPEC, &ifd, in do_cmd()
103 vxlan_exists(int sock) in vxlan_exists() argument
109 return (do_cmd(sock, VXLAN_CMD_GET_CONFIG, &cfg, sizeof(cfg), 0) != -1); in vxlan_exists()
H A Difconfig.c792 static int sock = -1; in group_member() local
809 if (sock == -1) { in group_member()
810 sock = socket(AF_LOCAL, SOCK_DGRAM, 0); in group_member()
811 if (sock == -1) in group_member()
816 if (ioctl(sock, SIOCGIFGROUP, (caddr_t)&ifgr) == -1) { in group_member()
831 if (ioctl(sock, SIOCGIFGROUP, (caddr_t)&ifgr) == -1) in group_member()
835 if (ioctl_va(sock, SIOCGIFGROUP, (caddr_t)&ifgr, 3, offset, ifgr.ifgr_groups, clen) == -1) in group_member()
/f-stack/freebsd/sys/
H A Dnv.h104 int nvlist_send(int sock, const nvlist_t *nvl);
105 nvlist_t *nvlist_recv(int sock, int flags);
106 nvlist_t *nvlist_xfer(int sock, nvlist_t *nvl, int flags);
/f-stack/freebsd/contrib/ipfilter/netinet/
H A Dip_fil_freebsd.c973 struct sockaddr *sock, *mask; local
992 sock = ifa->ifa_addr;
993 while (sock != NULL && ifa != NULL) {
994 sin = (struct sockaddr_in *)sock;
1007 sock = ifa->ifa_addr;
1015 sock = ifa->ifa_broadaddr;
1017 sock = ifa->ifa_dstaddr;
1019 if (sock == NULL)
1024 return ipf_ifpfillv6addr(atype, (struct sockaddr_in6 *)sock,
1029 return ipf_ifpfillv4addr(atype, (struct sockaddr_in *)sock,
/f-stack/tools/libnetgraph/
H A DMakefile24 SRCS= sock.c msg.c debug.c compat.c
/f-stack/dpdk/drivers/net/mlx4/
H A Dmlx4_ethdev.c150 int sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_IP); in mlx4_ifreq() local
153 if (sock == -1) { in mlx4_ifreq()
158 if (!ret && ioctl(sock, req, ifr) == -1) { in mlx4_ifreq()
162 close(sock); in mlx4_ifreq()
/f-stack/freebsd/contrib/libnv/
H A Dnvlist.c1256 nvlist_send(int sock, const nvlist_t *nvl) in nvlist_send() argument
1280 if (buf_send(sock, data, datasize) == -1) in nvlist_send()
1284 if (fd_send(sock, fds, nfds) == -1) in nvlist_send()
1298 nvlist_recv(int sock, int flags) in nvlist_recv() argument
1306 if (buf_recv(sock, &nvlhdr, sizeof(nvlhdr)) == -1) in nvlist_recv()
1324 if (buf_recv(sock, buf + sizeof(nvlhdr), size - sizeof(nvlhdr)) == -1) in nvlist_recv()
1331 if (fd_recv(sock, fds, nfds) == -1) in nvlist_recv()
1355 nvlist_xfer(int sock, nvlist_t *nvl, int flags) in nvlist_xfer() argument
1358 if (nvlist_send(sock, nvl) < 0) { in nvlist_xfer()
1363 return (nvlist_recv(sock, flags)); in nvlist_xfer()
/f-stack/dpdk/drivers/net/mlx5/linux/
H A Dmlx5_ethdev_os.c188 int sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_IP); in mlx5_ifreq() local
191 if (sock == -1) { in mlx5_ifreq()
198 ret = ioctl(sock, req, ifr); in mlx5_ifreq()
203 close(sock); in mlx5_ifreq()
206 close(sock); in mlx5_ifreq()
/f-stack/dpdk/doc/guides/nics/
H A Dmemif.rst45 "socket=/tmp/memif.sock", "Socket filename", "/tmp/memif.sock", "string len 108"
256 0 yes (1) /run/vpp/memif.sock
261 #./dpdk-testpmd --vdev=net_memif,socket=/run/vpp/memif.sock -- -i
/f-stack/app/redis-5.0.5/deps/hiredis/
H A DMakefile34 unixsocket /tmp/hiredis-test-redis.sock
151 $(PRE) ./hiredis-test -h 127.0.0.1 -p $(REDIS_PORT) -s /tmp/hiredis-test-redis.sock || \
/f-stack/dpdk/drivers/net/af_xdp/
H A Drte_eth_af_xdp.c1464 int sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_IP); local
1466 if (sock < 0)
1470 if (ioctl(sock, SIOCGIFINDEX, &ifr))
1475 if (ioctl(sock, SIOCGIFHWADDR, &ifr))
1480 close(sock);
1484 close(sock);

12