Home
last modified time | relevance | path

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

12345678910>>...26

/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/backends/
H A Dspdm-socket.c17 static bool read_bytes(const int socket, uint8_t *buffer, in read_bytes() argument
24 result = recv(socket, buffer + number_received, in read_bytes()
34 static bool read_data32(const int socket, uint32_t *data) in read_data32() argument
38 result = read_bytes(socket, (uint8_t *)data, sizeof(uint32_t)); in read_data32()
46 static bool read_multiple_bytes(const int socket, uint8_t *buffer, in read_multiple_bytes() argument
53 result = read_data32(socket, &length); in read_multiple_bytes()
70 return read_bytes(socket, buffer, length); in read_multiple_bytes()
73 static bool receive_platform_data(const int socket, in receive_platform_data() argument
83 result = read_data32(socket, &response); in receive_platform_data()
89 result = read_data32(socket, &transport_type); in receive_platform_data()
[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()
/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/qemu/hw/riscv/
H A Dvirt.c232 static void create_fdt_socket_cpus(RISCVVirtState *s, int socket, in create_fdt_socket_cpus() argument
241 for (cpu = s->soc[socket].num_harts - 1; cpu >= 0; cpu--) { in create_fdt_socket_cpus()
242 RISCVCPU *cpu_ptr = &s->soc[socket].harts[cpu]; in create_fdt_socket_cpus()
252 s->soc[socket].hartid_base + cpu); in create_fdt_socket_cpus()
281 s->soc[socket].hartid_base + cpu); in create_fdt_socket_cpus()
283 riscv_socket_fdt_write_id(ms, cpu_name, socket); in create_fdt_socket_cpus()
303 static void create_fdt_socket_memory(RISCVVirtState *s, int socket) in create_fdt_socket_memory() argument
310 addr = s->memmap[VIRT_DRAM].base + riscv_socket_mem_offset(ms, socket); in create_fdt_socket_memory()
311 size = riscv_socket_mem_size(ms, socket); in create_fdt_socket_memory()
316 riscv_socket_fdt_write_id(ms, mem_name, socket); in create_fdt_socket_memory()
[all …]
H A Dspike.c58 int cpu, socket; in create_fdt() local
99 for (socket = (riscv_socket_count(ms) - 1); socket >= 0; socket--) { in create_fdt()
100 clust_name = g_strdup_printf("/cpus/cpu-map/cluster%d", socket); in create_fdt()
103 clint_cells = g_new0(uint32_t, s->soc[socket].num_harts * 4); in create_fdt()
105 for (cpu = s->soc[socket].num_harts - 1; cpu >= 0; cpu--) { in create_fdt()
109 s->soc[socket].hartid_base + cpu); in create_fdt()
116 riscv_isa_write_fdt(&s->soc[socket].harts[cpu], fdt, cpu_name); in create_fdt()
120 s->soc[socket].hartid_base + cpu); in create_fdt()
122 riscv_socket_fdt_write_id(ms, cpu_name, socket); in create_fdt()
148 addr = memmap[SPIKE_DRAM].base + riscv_socket_mem_offset(ms, socket); in create_fdt()
[all …]
/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/docs/system/devices/
H A Dnet.rst12 socket host network backend).
96 connected to QEMU either by using a socket (``-netdev stream``) or by using
113 By default, passt will be started in the socket-based mode.
147 To use socket based passt interface:
152 passt --socket ~/passt.socket
154 …``--socket`` is not provided, passt will print the path of the UNIX domain socket QEMU can connect…
158 …net-pci,netdev=netdev0 -netdev stream,id=netdev0,server=off,addr.type=unix,addr.path=~/passt.socket
160 Where ``~/passt.socket`` is the UNIX socket created by passt to
168 passt --vhost-user --socket ~/passt.socket
173 …|qemu_system| [...OPTIONS...] -m $RAMSIZE -chardev socket,id=chr0,path=~/passt.socket -netdev vhos…
[all …]
/openbmc/qemu/qapi/
H A Dsockets.json19 # @unix: unix socket
45 # Captures a socket address or address range in the Internet
61 # @keep-alive: enable keep-alive when connecting to/listening on this socket.
66 # socket option is defined (this includes Linux, Windows, macOS, FreeBSD,
71 # where TCP_KEEPIDLE socket option is defined (this includes Linux,
100 # Captures a socket address in the local ("Unix socket") namespace.
104 # @abstract: if true, this is a Linux abstract socket address. @path
108 # @tight: if false, pad an abstract socket address with enough null
123 # Captures a socket address in the vsock namespace.
159 # @data: internet domain socket address
[all …]

12345678910>>...26