Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 561) sorted by relevance

12345678910>>...23

/openbmc/qemu/hw/ppc/
H A Drs6000_mc.c53 int socket; in rs6000mc_port0803_read() local
56 for (socket = 0; socket < 6; socket++) { in rs6000mc_port0803_read()
57 if (s->simm_size[socket] == 32) { in rs6000mc_port0803_read()
58 val |= (1 << socket); in rs6000mc_port0803_read()
72 int socket; in rs6000mc_port0804_read() local
75 for (socket = 0; socket < 6; socket++) { in rs6000mc_port0804_read()
76 if (s->simm_size[socket]) { in rs6000mc_port0804_read()
77 val &= ~(1 << socket); in rs6000mc_port0804_read()
100 uint8_t socket = val >> 5; in rs6000mc_port0820_write() local
104 s->end_address[socket] = end_address; in rs6000mc_port0820_write()
[all …]
/openbmc/qemu/python/qemu/machine/
H A Dconsole_socket.py17 import socket
23 class ConsoleSocket(socket.socket):
48 socket.socket.__init__(self, socket.AF_UNIX, socket.SOCK_STREAM)
52 socket.socket.__init__(self, fileno=sock_fd)
74 except socket.timeout:
85 socket.socket.setblocking(self, False)
86 socket.socket.settimeout(self, 1)
99 socket.socket.close(self)
106 data = socket.socket.recv(self, 1)
118 return socket.socket.recv(self, bufsize, flags)
[all …]
H A Dqtest.py21 import socket
56 sock: Optional[socket.socket] = None, argument
75 def _get_sock(self) -> socket.socket:
78 family = socket.AF_INET
80 family = socket.AF_UNIX
81 return socket.socket(family, socket.SOCK_STREAM)
148 Tuple[socket.socket, socket.socket]] = None
163 self._qtest_sock_pair = socket.socketpair()
/openbmc/openbmc/poky/bitbake/lib/bb/asyncrpc/
H A Dserv.py12 import socket
30 def __init__(self, socket, proto_name, logger): argument
31 self.socket = socket
39 "address": socket.address,
45 await self.socket.close()
52 self.logger.info("Client %r connected" % (self.socket.address,))
55 client_protocol = await self.socket.recv()
74 header = await self.socket.recv()
83 await self.socket.send("%s: %s" % (k, v))
84 await self.socket.send("")
[all …]
H A Dclient.py11 import socket
59 self.socket = None
84 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM, 0)
131 await self.socket.send("%s %s" % (self.proto_name, self.proto_version))
132 await self.socket.send(
136 await self.socket.send("%s: %s" % (k, v))
139 await self.socket.send("")
144 line = await self.socket.recv()
156 if self.socket is None:
157 self.socket = await self._connect_sock()
[all …]
H A Dconnection.py106 def __init__(self, socket, timeout): argument
107 self.socket = socket
112 return ":".join(str(s) for s in self.socket.remote_address)
125 await self.socket.send(msg)
134 return await self.socket.recv()
137 return await asyncio.wait_for(self.socket.recv(), self.timeout)
144 if self.socket is not None:
145 await self.socket.close()
146 self.socket = None
/openbmc/openbmc/poky/meta/lib/oeqa/utils/
H A Dnetwork.py7 import socket
10 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM if not udp else socket.SOCK_DGRAM)
/openbmc/openbmc/poky/bitbake/lib/toaster/toastermain/management/commands/
H A Dchecksocket.py13 import socket
41 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
42 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
44 except (socket.error, OverflowError) as err:
/openbmc/qemu/migration/
H A Dcpr-transfer.c25 addr->u.socket.type == SOCKET_ADDRESS_TYPE_UNIX) { in cpr_transfer_output()
29 SocketAddress *saddr = &addr->u.socket; in cpr_transfer_output()
34 trace_cpr_transfer_output(addr->u.socket.u.q_unix.path); in cpr_transfer_output()
49 (addr->u.socket.type == SOCKET_ADDRESS_TYPE_UNIX || in cpr_transfer_input()
50 addr->u.socket.type == SOCKET_ADDRESS_TYPE_FD)) { in cpr_transfer_input()
53 SocketAddress *saddr = &addr->u.socket; in cpr_transfer_input()
65 addr->u.socket.type == SOCKET_ADDRESS_TYPE_UNIX ? in cpr_transfer_input()
66 addr->u.socket.u.q_unix.path : addr->u.socket.u.fd.str); in cpr_transfer_input()
/openbmc/boost-dbus/include/dbus/detail/
H A Dwatch_timeout.hpp28 boost::asio::generic::stream_protocol::socket &socket = in operator ()() local
29 *static_cast<boost::asio::generic::stream_protocol::socket *>(data); in operator ()()
31 watch_toggled(dbus_watch, &socket.get_io_service()); in operator ()()
41 auto socket = in watch_toggled() local
42 static_cast<boost::asio::generic::stream_protocol::socket *>(watch_data); in watch_toggled()
45 socket->async_read_some(boost::asio::null_buffers(), in watch_toggled()
49 socket->async_write_some(boost::asio::null_buffers(), in watch_toggled()
53 socket->cancel(); in watch_toggled()
70 boost::asio::generic::stream_protocol::socket &socket = in add_watch() local
71 *new boost::asio::generic::stream_protocol::socket(io); in add_watch()
[all …]
/openbmc/libpldm/src/transport/
H A Dmctp-demux.c28 int socket; member
50 fd = socket(AF_UNIX, SOCK_SEQPACKET, 0); in pldm_transport_mctp_demux_open()
77 pollfd->fd = ctx->socket; in pldm_transport_mctp_demux_init_pollfd()
148 length = recv(demux->socket, NULL, 0, MSG_PEEK | MSG_TRUNC); in pldm_transport_mctp_demux_recv()
160 recv(demux->socket, buf, length, 0); in pldm_transport_mctp_demux_recv()
174 bytes = recvmsg(demux->socket, &msg, 0); in pldm_transport_mctp_demux_recv()
231 ssize_t rc = sendmsg(demux->socket, &msg, 0); in pldm_transport_mctp_demux_send()
256 demux->socket = pldm_transport_mctp_demux_open(); in pldm_transport_mctp_demux_init()
257 if (demux->socket == -1) { in pldm_transport_mctp_demux_init()
262 if (pldm_socket_sndbuf_init(&demux->socket_send_buf, demux->socket)) { in pldm_transport_mctp_demux_init()
[all …]
H A Dsocket.c11 int pldm_socket_sndbuf_init(struct pldm_socket_sndbuf *ctx, int socket) in pldm_socket_sndbuf_init() argument
18 if (socket == -1) { in pldm_socket_sndbuf_init()
21 ctx->socket = socket; in pldm_socket_sndbuf_init()
69 int rc = setsockopt(ctx->socket, SOL_SOCKET, SO_SNDBUF, &(msg_len), in pldm_socket_sndbuf_accomodate()
85 int rc = getsockopt(ctx->socket, SOL_SOCKET, SO_SNDBUF, &(buf_size), in pldm_socket_sndbuf_get()
H A Daf-mctp.c37 int socket; member
59 pollfd->fd = ctx->socket; in pldm_transport_af_mctp_init_pollfd()
122 length = recv(af_mctp->socket, NULL, 0, MSG_PEEK | MSG_TRUNC); in pldm_transport_af_mctp_recv()
132 length = recvfrom(af_mctp->socket, msg, length, MSG_TRUNC, in pldm_transport_af_mctp_recv()
230 ssize_t rc = sendto(af_mctp->socket, pldm_msg, msg_len, 0, in pldm_transport_af_mctp_send()
259 af_mctp->socket = socket(AF_MCTP, SOCK_DGRAM, 0); in pldm_transport_af_mctp_init()
260 if (af_mctp->socket == -1) { in pldm_transport_af_mctp_init()
266 af_mctp->socket)) { in pldm_transport_af_mctp_init()
267 close(af_mctp->socket); in pldm_transport_af_mctp_init()
282 close(ctx->socket); in pldm_transport_af_mctp_destroy()
[all …]
/openbmc/openbmc/meta-openembedded/meta-networking/recipes-support/open-isns/files/
H A D0001-isnsd.socket-use-run-instead-of-var-run.patch4 Subject: [PATCH] isnsd.socket: use /run instead of /var/run
10 isnsd.socket | 2 +-
13 diff --git a/isnsd.socket b/isnsd.socket
15 --- a/isnsd.socket
16 +++ b/isnsd.socket
/openbmc/qemu/chardev/
H A Dtrace-events20 # char-socket.c
21 chr_socket_poll_err(void *chrdev, const char *label) "chardev socket poll error %p (%s)"
22 chr_socket_recv_err(void *chrdev, const char *label, const char *err) "chardev socket recv error %p…
23 chr_socket_recv_eof(void *chrdev, const char *label) "chardev socket recv end-of-file %p (%s)"
24 chr_socket_write_err(void *chrdev, const char *label, const char *err) "chardev socket write error …
25 chr_socket_disconnect(void *chrdev, const char *label) "chardev socket disconnect %p (%s)"
26 chr_socket_hangup(void *chrdev, const char *label) "chardev socket hangup %p (%s)"
27 chr_socket_ws_handshake_err(void *chrdev, const char *label, const char *err) "chardev socket webso…
28 chr_socket_tls_handshake_err(void *chrdev, const char *label, const char *err) "chardev socket TLS …
29 chr_socket_tls_init_err(void *chrdev, const char *label, const char *err) "chardev socket TLS init …
/openbmc/openbmc/meta-openembedded/meta-networking/recipes-protocols/openflow/openflow/
H A D0001-socket-util-Include-sys-stat.h-for-fchmod.patch4 Subject: [PATCH] socket-util: Include sys/stat.h for fchmod
9 lib/socket-util.c | 1 +
12 diff --git a/lib/socket-util.c b/lib/socket-util.c
14 --- a/lib/socket-util.c
15 +++ b/lib/socket-util.c
/openbmc/openbmc/meta-openembedded/meta-oe/recipes-dbs/mysql/mariadb/
H A Dmysql-systemd-start46 socket=$(get_option mysqld socket "$datadir/mysql.sock")
47 case $socket in
48 /*) adminsocket="$socket" ;;
49 *) adminsocket="$datadir/$socket" ;;
54 …mariadb-admin --no-defaults --socket="$adminsocket" --user=UNKNOWN_MYSQL_USER ping >/dev/null 2>&1…
/openbmc/obmc-console/
H A Dmeson.build22 'conf/obmc-console@.socket.in',
23 rename: ['obmc-console@.service', 'obmc-console@.socket'],
43 'conf/obmc-console-ssh.socket.in',
44 rename: ['obmc-console-ssh.socket'],
48 'conf/obmc-console-ssh@.service.d/use-socket.conf.in',
49 rename: ['use-socket.conf'],
71 'console-socket.c',
75 'socket-handler.c',
96 'console-socket.c',
/openbmc/phosphor-net-ipmid/
H A Dsocket_channel.hpp44 explicit Channel(std::shared_ptr<boost::asio::ip::udp::socket> socket) : in Channel() argument
45 socket(socket) in Channel()
144 std::vector<uint8_t> packet(socket->available()); in read()
150 ssize_t bytesReceived = recvmsg(socket->native_handle(), &msg, 0); in read()
221 int ret = sendmsg(socket->native_handle(), &msg, 0); in write()
234 return socket->native_handle(); in getHandle()
238 std::shared_ptr<boost::asio::ip::udp::socket> socket; member in udpsocket::Channel
/openbmc/bmcweb/http/routing/
H A Dwebsocketrule.cpp21 boost::asio::ip::tcp::socket&& adaptor) in handleUpgrade()
25 crow::websocket::ConnectionImpl<boost::asio::ip::tcp::socket>> in handleUpgrade()
27 crow::websocket::ConnectionImpl<boost::asio::ip::tcp::socket>>( in handleUpgrade()
35 boost::asio::ssl::stream<boost::asio::ip::tcp::socket>&& adaptor) in handleUpgrade()
39 boost::asio::ssl::stream<boost::asio::ip::tcp::socket>>> in handleUpgrade()
41 boost::asio::ssl::stream<boost::asio::ip::tcp::socket>>>( in handleUpgrade()
H A Dsserule.cpp45 boost::asio::ip::tcp::socket&& adaptor) in handleUpgrade()
48 crow::sse_socket::ConnectionImpl<boost::asio::ip::tcp::socket>> in handleUpgrade()
50 crow::sse_socket::ConnectionImpl<boost::asio::ip::tcp::socket>>( in handleUpgrade()
56 boost::asio::ssl::stream<boost::asio::ip::tcp::socket>&& adaptor) in handleUpgrade()
59 boost::asio::ssl::stream<boost::asio::ip::tcp::socket>>> in handleUpgrade()
61 boost::asio::ssl::stream<boost::asio::ip::tcp::socket>>>( in handleUpgrade()
/openbmc/qemu/tests/qemu-iotests/
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 …]
H A D14724 import socket
222 socket.getaddrinfo("::0", "0", socket.AF_INET6,
223 socket.SOCK_STREAM, socket.IPPROTO_TCP,
224 socket.AI_ADDRCONFIG | socket.AI_CANONNAME)
225 except socket.gaierror:
262 sockfd = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
/openbmc/qemu/tests/functional/qemu_test/
H A Dports.py12 import socket
37 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
/openbmc/qemu/docs/tools/
H A Dqemu-vmsr-helper.rst24 socket which will accept incoming connections for communication with QEMU.
28 support" to find out how to configure QEMU to connect to the socket created by
31 After connecting to the socket, :program:`qemu-vmsr-helper` can
35 :program:`qemu-vmsr-helper` can also use the systemd socket activation
36 protocol. In this case, the systemd socket unit should specify a
37 Unix stream socket, like this::
65 .. option:: -k, --socket=PATH
67 path to the socket. By default the socket is created in

12345678910>>...23