Home
last modified time | relevance | path

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

12345

/openbmc/dbus-sensors/src/
H A DMctpAsioEndpoint.cpp27 struct sockaddr_mctp* sock = in MctpAsioEndpoint() local
29 sock->smctp_addr.s_addr = eid; in MctpAsioEndpoint()
30 sock->smctp_family = AF_MCTP; in MctpAsioEndpoint()
31 sock->smctp_type = msgType; in MctpAsioEndpoint()
32 sock->smctp_tag = MCTP_TAG_OWNER; in MctpAsioEndpoint()
33 sock->smctp_network = MCTP_NET_ANY; in MctpAsioEndpoint()
42 const struct sockaddr_mctp* sock = getSockAddr(); in eid() local
43 if (sock == nullptr) in eid()
47 return sock->smctp_addr.s_addr; in eid()
52 const struct sockaddr_mctp* sock = getSockAddr(); in type() local
[all …]
/openbmc/openbmc/meta-security/recipes-mac/smack/tcp-smack-test/
H A Dtcp_server.c33 int sock; in main() local
57 if((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) in main()
64 if(fsetxattr(sock, attr_in, label_in, strlen(label_in),0) < 0) in main()
75 if(setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout)) < 0) in main()
81 if(bind(sock, (struct sockaddr*) &server_addr, sizeof(server_addr)) < 0) in main()
87 listen(sock, 1); in main()
90 clientsock = accept(sock,(struct sockaddr*) &client_addr, &client_length); in main()
95 close(sock); in main()
103 close(sock); in main()
111 close(sock); in main()
[all …]
H A Dtcp_client.c34 int sock; in main() local
60 if((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) in main()
67 if(fsetxattr(sock, attr_out, label_out, strlen(label_out), 0) < 0) in main()
73 if(fsetxattr(sock, attr_in, label_in, strlen(label_in), 0) < 0) in main()
84 if(setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout)) < 0) in main()
90 if (connect(sock, (struct sockaddr *)&server_addr,sizeof(struct sockaddr)) == -1) in main()
93 close(sock); in main()
98 if(write(sock, message, strlen(message)) < 0) in main()
101 close(sock); in main()
104 close(sock); in main()
/openbmc/pldm/oem/ibm/libpldmresponder/
H A Dutils.cpp29 int sock; in setupUnixSocket() local
44 if ((sock = socket(AF_UNIX, SOCK_STREAM | SOCK_NONBLOCK, 0)) == -1) in setupUnixSocket()
50 if (bind(sock, (struct sockaddr*)&addr, sizeof(addr)) == -1) in setupUnixSocket()
54 close(sock); in setupUnixSocket()
58 if (listen(sock, 1) == -1) in setupUnixSocket()
61 close(sock); in setupUnixSocket()
71 FD_SET(sock, &rfd); in setupUnixSocket()
72 int nfd = sock + 1; in setupUnixSocket()
81 close(sock); in setupUnixSocket()
85 if ((retval > 0) && (FD_ISSET(sock, &rfd))) in setupUnixSocket()
[all …]
/openbmc/qemu/tests/
H A Dvhost-user-bridge.c52 typedef void (*CallbackFunc)(int sock, void *ctx);
71 int sock; member
97 dispatcher_add(Dispatcher *dispr, int sock, void *ctx, CallbackFunc cb) in dispatcher_add() argument
99 if (sock >= FD_SETSIZE) { in dispatcher_add()
101 "Error: Failed to add new event. sock %d should be less than %d\n", in dispatcher_add()
102 sock, FD_SETSIZE); in dispatcher_add()
106 dispr->events[sock].ctx = ctx; in dispatcher_add()
107 dispr->events[sock].callback = cb; in dispatcher_add()
109 FD_SET(sock, &dispr->fdset); in dispatcher_add()
110 if (sock > disp in dispatcher_add()
119 dispatcher_remove(Dispatcher * dispr,int sock) dispatcher_remove() argument
157 int sock; dispatcher_wait() local
271 vubr_backend_recv_cb(int sock,void * ctx) vubr_backend_recv_cb() argument
373 vubr_receive_cb(int sock,void * ctx) vubr_receive_cb() argument
389 watch_cb(int sock,void * ctx) watch_cb() argument
504 vubr_accept_cb(int sock,void * ctx) vubr_accept_cb() argument
690 int sock; vubr_backend_udp_setup() local
[all...]
/openbmc/openbmc/meta-security/recipes-mac/smack/udp-smack-test/
H A Dudp_server.c31 int sock,ret; in main() local
52 sock = socket(AF_INET,SOCK_DGRAM,0); in main()
53 if(sock < 0) in main()
60 if(fsetxattr(sock, attr, label, strlen(label), 0) < 0) in main()
72 if(setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout)) < 0) in main()
78 if(bind(sock, (struct sockaddr*) &server_addr, sizeof(server_addr)) < 0) in main()
85 ret = recvfrom(sock, message, sizeof(message), 0, (struct sockaddr*)&client_addr, in main()
87 close(sock); in main()
H A Dudp_client.c32 int sock, ret; in main() local
46 sock = socket(AF_INET, SOCK_DGRAM,0); in main()
47 if(sock < 0) in main()
54 if(fsetxattr(sock, attr, label, strlen(label),0) < 0) in main()
66 ret = sendto(sock, message, strlen(message),0,(const struct sockaddr*)&server_addr, in main()
69 close(sock); in main()
/openbmc/qemu/tests/qemu-iotests/
H A Dnbd-fault-injector.py79 def recvall(sock, bufsize): argument
83 chunk = sock.recv(bufsize - received)
105 def __init__(self, sock, rules): argument
106 self.sock = sock
114 self.sock.close()
123 self.sock.sendall(buf[:bufsize])
128 data = recvall(self.sock, bufsize)
133 self.sock.close()
191 def run_server(sock, rules, use_export): argument
193 conn, _ = sock.accept()
[all …]
H A D083.out113 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
117 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
121 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
125 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
129 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
133 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
137 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
141 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
145 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
149 qemu-io: can't open device nbd+unix:///foo?socket=SOCK_DIR/nbd.sock
[all …]
/openbmc/slpd-lite/test/
H A Dtest-suite.py9 sock = socket.socket(AF_INET, SOCK_DGRAM) variable
26 ret = sock.sendto(payload, addr)
42 ret = sock.sendto(payload, addr)
58 ret = sock.sendto(payload, addr)
74 ret = sock.sendto(payload, addr)
90 ret = sock.sendto(payload, addr)
107 ret = sock.sendto(payload, addr)
127 ret = sock.sendto(payload, addr)
/openbmc/google-misc/subprojects/dhcp-done/
H A Ddhcp-done.cpp32 auto sock = in createListener() local
34 setFileFlags(sock, getFileFlags(sock).set(stdplus::fd::FileFlag::NonBlock)); in createListener()
38 bind(sock, addr); in createListener()
39 listen(sock, 10); in createListener()
40 return sock; in createListener()
/openbmc/qemu/util/
H A Dqemu-sockets.c217 static int inet_set_sockopts(int sock, InetSocketAddress *saddr, Error **errp) in inet_set_sockopts() argument
221 int ret = setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, in inet_set_sockopts()
232 ret = setsockopt(sock, IPPROTO_TCP, TCP_KEEPCNT, &keep_count, in inet_set_sockopts()
244 ret = setsockopt(sock, IPPROTO_TCP, TCP_KEEPIDLE, &keep_idle, in inet_set_sockopts()
256 ret = setsockopt(sock, IPPROTO_TCP, TCP_KEEPINTVL, &keep_interval, in inet_set_sockopts()
423 int sock, rc; in inet_connect_addr() local
425 sock = qemu_socket(addr->ai_family, addr->ai_socktype, addr->ai_protocol); in inet_connect_addr()
426 if (sock < 0) { in inet_connect_addr()
435 if (connect(sock, addr->ai_addr, addr->ai_addrlen) < 0) { in inet_connect_addr()
443 close(sock); in inet_connect_addr()
[all …]
/openbmc/phosphor-networkd/src/
H A Dnetlink.cpp84 static void requestSend(int sock, void* data, size_t size) in requestSend() argument
99 if (sendmsg(sock, &hdr, 0) < 0) in requestSend()
110 auto sock = socket(SocketDomain::Netlink, SocketType::Raw, in makeSocket() local
115 bind(sock, local); in makeSocket()
117 return sock; in makeSocket()
122 auto sock = makeSocket(protocol); in performRequest() local
123 requestSend(sock.get(), data, size); in performRequest()
124 receive(sock.get(), cb); in performRequest()
129 size_t receive(int sock, ReceiveCallback cb) in receive() argument
153 ssize_t recvd = recvmsg(sock, &hdr, 0); in receive()
H A Drtnetlink_server.cpp109 auto sock = socket(SocketDomain::Netlink, SocketType::Raw, in makeSock() local
112 sock.fcntlSetfl(sock.fcntlGetfl().set(FileFlag::NonBlock)); in makeSock()
118 bind(sock, local); in makeSock()
120 return sock; in makeSock()
124 sock(makeSock()), in Server()
125 io(event, sock.get(), EPOLLIN | EPOLLET, [&](auto&&... args) { in Server()
H A Dsystem_queries.cpp152 int sock = socket(AF_NETLINK, SOCK_RAW, NETLINK_ROUTE); in deleteLinkLocalIPv4ViaNetlink() local
153 if (sock < 0) in deleteLinkLocalIPv4ViaNetlink()
165 if (bind(sock, reinterpret_cast<sockaddr*>(&nladdr), in deleteLinkLocalIPv4ViaNetlink()
169 close(sock); in deleteLinkLocalIPv4ViaNetlink()
194 const ssize_t sent = send(sock, &req, req.nlh.nlmsg_len, 0); in deleteLinkLocalIPv4ViaNetlink()
199 close(sock); in deleteLinkLocalIPv4ViaNetlink()
204 ssize_t len = recv(sock, resp.data(), resp.size(), 0); in deleteLinkLocalIPv4ViaNetlink()
205 close(sock); in deleteLinkLocalIPv4ViaNetlink()
/openbmc/openbmc/meta-openembedded/meta-oe/recipes-support/libteam/libteam/
H A D0001-teamd-Pass-correct-parameter-type-to-accept-API.patch13 | 280 | sock = accept(ctx->usock.sock, &addr, &alen);
32 - sock = accept(ctx->usock.sock, &addr, &alen);
33 + sock = accept(ctx->usock.sock, (struct sockaddr *)&addr, &alen);
34 if (sock == -1) {
/openbmc/qemu/tests/qtest/
H A Dnetdev-socket.c41 static int inet_get_free_port_socket_ipv4(int sock) in inet_get_free_port_socket_ipv4() argument
50 if (bind(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0) { in inet_get_free_port_socket_ipv4()
55 if (getsockname(sock, (struct sockaddr *)&addr, &len) < 0) { in inet_get_free_port_socket_ipv4()
62 static int inet_get_free_port_socket_ipv6(int sock) in inet_get_free_port_socket_ipv6() argument
71 if (bind(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0) { in inet_get_free_port_socket_ipv6()
76 if (getsockname(sock, (struct sockaddr *)&addr, &len) < 0) { in inet_get_free_port_socket_ipv6()
85 g_autofree int *sock = g_new(int, nb); in inet_get_free_port_multiple() local
89 sock[i] = socket(ipv6 ? AF_INET6 : AF_INET, SOCK_STREAM, 0); in inet_get_free_port_multiple()
90 if (sock[i] < 0) { in inet_get_free_port_multiple()
93 port[i] = ipv6 ? inet_get_free_port_socket_ipv6(sock[i]) : in inet_get_free_port_multiple()
[all …]
/openbmc/openbmc/poky/meta/recipes-bsp/acpid/acpid/
H A D0001-Replace-stat64-with-stat.patch14 sock.c | 4 ++--
17 diff --git a/sock.c b/sock.c
19 --- a/sock.c
20 +++ b/sock.c
/openbmc/openbmc/meta-openembedded/meta-oe/recipes-support/openct/openct/
H A D0001-Fix-incompatible-pointer-type-error-with-gcc-option.patch9 | 239 | sock->fd = ifd_get_eventfd(reader, &sock->events);
42 sock->fd = -1;
45 - sock->fd = ifd_get_eventfd(reader, &sock->events);
46 + sock->fd = ifd_get_eventfd(reader, (short int *)&sock->events);
48 if (sock->fd == -1) {
/openbmc/openbmc/poky/meta/recipes-support/apr/apr/
H A D0004-Fix-packet-discards-HTTP-redirect.patch26 @@ -85,6 +85,10 @@ apr_status_t apr_socket_recv(apr_socket_t *sock, char *buf, apr_size_t *len)
27 && (sock->timeout > 0)) {
29 arv = apr_wait_for_io_or_timeout(NULL, sock, 1);
30 + if ((arv == APR_TIMEUP) && (sock->timeout == 0)) {
/openbmc/qemu/python/qemu/machine/
H A Dqtest.py56 sock: Optional[socket.socket] = None,
58 if address is None and sock is None:
60 if address is not None and sock is not None:
63 if sock is not None and server:
67 self._sock = sock or self._get_sock()
166 self._qtest = QEMUQtestProtocol(sock=self._qtest_sock_pair[1])
/openbmc/libmctp/utils/
H A Dmctp-demux-daemon.c60 int sock; member
72 int sock; member
101 close(client->sock); in client_remove_inactive()
148 rc = sendmsg(client->sock, &msghdr, 0); in rx_message()
300 ctx->sock = socket(AF_UNIX, SOCK_SEQPACKET, 0); in socket_init()
301 if (ctx->sock < 0) { in socket_init()
306 rc = bind(ctx->sock, (struct sockaddr *)&addr, in socket_init()
313 rc = listen(ctx->sock, 1); in socket_init()
322 close(ctx->sock); in socket_init()
331 fd = accept4(ctx->sock, NULL, 0, SOCK_NONBLOCK); in socket_process()
[all …]
/openbmc/qemu/python/tests/
H A Dprotocol.py137 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
138 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
139 sock.bind(('127.0.0.1', 0))
140 sock.listen(1)
141 address = sock.getsockname()
143 socks.append(sock)
148 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
149 sock.connect(address)
150 socks.append(sock)
155 for sock in socks:
[all …]
/openbmc/openbmc/poky/bitbake/lib/toaster/toastermain/management/commands/
H A Dchecksocket.py41 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
42 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
43 sock.bind(tuple(splitted))
/openbmc/qemu/net/
H A Dvde.c78 const char *name, const char *sock, in net_vde_init() argument
85 char *init_sock = (char *)sock; in net_vde_init()
101 qemu_set_info_str(nc, "sock=%s,fd=%d", sock, vde_datafd(vde)); in net_vde_init()
121 if (net_vde_init(peer, "vde", name, vde->sock, vde->port, vde->group, in net_init_vde()

12345