Home
last modified time | relevance | path

Searched refs:peer (Results 1 – 25 of 69) sorted by relevance

123

/qemu/contrib/ivshmem-client/
H A Divshmem-client.c86 g_free(peer); in ivshmem_client_free_peer()
108 if (peer == NULL || peer == &client->local) { in ivshmem_client_handle_server_msg()
120 if (peer == NULL) { in ivshmem_client_handle_server_msg()
121 peer = g_malloc0(sizeof(*peer)); in ivshmem_client_handle_server_msg()
122 peer->id = peer_id; in ivshmem_client_handle_server_msg()
130 PRId64 "\n", peer->vectors_count, fd, peer->id); in ivshmem_client_handle_server_msg()
131 if (peer->vectors_count >= G_N_ELEMENTS(peer->vectors)) { in ivshmem_client_handle_server_msg()
136 peer->vectors[peer->vectors_count] = fd; in ivshmem_client_handle_server_msg()
137 peer->vectors_count++; in ivshmem_client_handle_server_msg()
303 if (peer->vectors[i] >= maxfd || !FD_ISSET(peer->vectors[i], cur)) { in ivshmem_client_handle_event()
[all …]
H A Dmain.c80 IvshmemClientPeer *peer; in ivshmem_client_handle_stdin_command() local
107 peer = ivshmem_client_search_peer(client, peer_id); in ivshmem_client_handle_stdin_command()
108 if (peer == NULL) { in ivshmem_client_handle_stdin_command()
112 ivshmem_client_notify(client, peer, vector); in ivshmem_client_handle_stdin_command()
114 peer = ivshmem_client_search_peer(client, peer_id); in ivshmem_client_handle_stdin_command()
115 if (peer == NULL) { in ivshmem_client_handle_stdin_command()
119 ivshmem_client_notify_all_vects(client, peer); in ivshmem_client_handle_stdin_command()
177 const IvshmemClientPeer *peer, in ivshmem_client_notification_cb() argument
183 peer->id, vect); in ivshmem_client_notification_cb()
H A Divshmem-client.h58 const IvshmemClientPeer *peer,
162 const IvshmemClientPeer *peer, unsigned vector);
174 const IvshmemClientPeer *peer);
/qemu/contrib/ivshmem-server/
H A Divshmem-server.c80 close(peer->sock_fd); in ivshmem_server_free_peer()
92 g_free(peer); in ivshmem_server_free_peer()
111 ret = ivshmem_server_send_one_msg(peer->sock_fd, peer->id, -1); in ivshmem_server_send_initial_info()
153 peer = g_malloc0(sizeof(*peer)); in ivshmem_server_handle_new_conn()
154 peer->sock_fd = newfd; in ivshmem_server_handle_new_conn()
168 g_free(peer); in ivshmem_server_handle_new_conn()
206 ivshmem_server_send_one_msg(peer->sock_fd, peer->id, in ivshmem_server_handle_new_conn()
220 g_free(peer); in ivshmem_server_handle_new_conn()
389 IvshmemServerPeer *peer; in ivshmem_server_get_fds() local
424 if (peer->sock_fd < maxfd && FD_ISSET(peer->sock_fd, fds)) { in ivshmem_server_handle_fds()
[all …]
/qemu/net/
H A Dclients.h30 NetClientState *peer, Error **errp);
34 NetClientState *peer, Error **errp);
38 NetClientState *peer, Error **errp);
41 NetClientState *peer, Error **errp);
44 NetClientState *peer, Error **errp);
47 NetClientState *peer, Error **errp);
50 NetClientState *peer, Error **errp);
53 NetClientState *peer, Error **errp);
56 NetClientState *peer, Error **errp);
59 NetClientState *peer, Error **errp);
[all …]
H A Dnet.c279 if (peer) { in qemu_net_client_setup()
280 assert(!peer->peer); in qemu_net_client_setup()
281 nc->peer = peer; in qemu_net_client_setup()
282 peer->peer = nc; in qemu_net_client_setup()
398 if (nc->peer) { in qemu_free_net_client()
399 nc->peer->peer = NULL; in qemu_free_net_client()
429 if (nc->peer && nc->peer->info->type == NET_CLIENT_DRIVER_NIC) { in qemu_del_net_client()
441 nc->peer->info->link_status_changed(nc->peer); in qemu_del_net_client()
664 if (!nc->peer) { in qemu_purge_queued_packets()
1624 if (nc->peer) { in qmp_set_link()
[all …]
H A Dhub.c208 nc = port->nc.peer; in net_hub_port_find()
233 if (port->nc.peer) { in net_hub_info()
235 print_net_client(mon, port->nc.peer); in net_hub_info()
254 } else if (nc->peer != NULL && nc->peer->info->type == in net_hub_id_for_client()
256 port = DO_UPCAST(NetHubPort, nc, nc->peer); in net_hub_id_for_client()
268 NetClientState *peer, Error **errp) in net_init_hubport() argument
274 assert(!peer); in net_init_hubport()
297 NetClientState *peer; in net_hub_check_clients() local
303 peer = port->nc.peer; in net_hub_check_clients()
304 if (!peer) { in net_hub_check_clients()
[all …]
H A Dsocket.c329 static NetSocketState *net_socket_fd_init_dgram(NetClientState *peer, in net_socket_fd_init_dgram() argument
420 static NetSocketState *net_socket_fd_init_stream(NetClientState *peer, in net_socket_fd_init_stream() argument
428 nc = qemu_new_net_client(&net_socket_info, peer, model, name); in net_socket_fd_init_stream()
491 static int net_socket_listen_init(NetClientState *peer, in net_socket_listen_init() argument
529 nc = qemu_new_net_client(&net_socket_info, peer, model, name); in net_socket_listen_init()
540 static int net_socket_connect_init(NetClientState *peer, in net_socket_connect_init() argument
580 s = net_socket_fd_init_stream(peer, model, name, fd, connected); in net_socket_connect_init()
590 static int net_socket_mcast_init(NetClientState *peer, in net_socket_mcast_init() argument
635 static int net_socket_udp_init(NetClientState *peer, in net_socket_udp_init() argument
689 NetClientState *peer, Error **errp) in net_init_socket() argument
[all …]
H A Dnet-hmp-cmds.c32 NetClientState *nc, *peer; in hmp_info_network() local
38 peer = nc->peer; in hmp_info_network()
46 if (!peer || type == NET_CLIENT_DRIVER_NIC) { in hmp_info_network()
49 if (peer && type == NET_CLIENT_DRIVER_NIC) { in hmp_info_network()
51 print_net_client(mon, peer); in hmp_info_network()
H A Dvde.c77 static int net_vde_init(NetClientState *peer, const char *model, in net_vde_init() argument
99 nc = qemu_new_net_client(&net_vde_info, peer, model, name); in net_vde_init()
113 NetClientState *peer, Error **errp) in net_init_vde() argument
121 if (net_vde_init(peer, "vde", name, vde->sock, vde->port, vde->group, in net_init_vde()
H A Dstream.c303 static int net_stream_server_init(NetClientState *peer, in net_stream_server_init() argument
313 nc = qemu_new_net_client(&net_stream_info, peer, model, name); in net_stream_server_init()
397 static int net_stream_client_init(NetClientState *peer, in net_stream_client_init() argument
408 nc = qemu_new_net_client(&net_stream_info, peer, model, name); in net_stream_client_init()
427 NetClientState *peer, Error **errp) in net_init_stream() argument
435 return net_stream_client_init(peer, "stream", name, sock->addr, in net_init_stream()
444 return net_stream_server_init(peer, "stream", name, sock->addr, errp); in net_init_stream()
H A Dtap.c352 static TAPState *net_tap_fd_init(NetClientState *peer, in net_tap_fd_init() argument
361 nc = qemu_new_net_client(&net_tap_info, peer, model, name); in net_tap_fd_init()
577 NetClientState *peer, Error **errp) in net_init_bridge() argument
603 s = net_tap_fd_init(peer, "bridge", name, fd, vnet_hdr); in net_init_bridge()
654 TAPState *s = net_tap_fd_init(peer, model, name, fd, vnet_hdr); in net_init_tap_one()
760 NetClientState *peer, Error **errp) in net_init_tap() argument
781 if (peer && (tap->has_queues || tap->fds || tap->vhostfds)) { in net_init_tap()
814 net_init_tap_one(tap, peer, "tap", name, NULL, in net_init_tap()
877 net_init_tap_one(tap, peer, "tap", name, ifname, in net_init_tap()
923 net_init_tap_one(tap, peer, "bridge", name, ifname, in net_init_tap()
[all …]
H A Ddgram.c259 static NetDgramState *net_dgram_fd_init(NetClientState *peer, in net_dgram_fd_init() argument
268 nc = qemu_new_net_client(&net_dgram_socket_info, peer, model, name); in net_dgram_fd_init()
279 static int net_dgram_mcast_init(NetClientState *peer, in net_dgram_mcast_init() argument
385 s = net_dgram_fd_init(peer, model, name, fd, errp); in net_dgram_mcast_init()
422 NetClientState *peer, Error **errp) in net_init_dgram() argument
447 return net_dgram_mcast_init(peer, "dram", name, remote, local, in net_init_dgram()
579 s = net_dgram_fd_init(peer, "dgram", name, fd, errp); in net_init_dgram()
H A Dvmnet-shared.c86 NetClientState *peer, Error **errp) in net_init_vmnet_shared() argument
89 peer, "vmnet-shared", name); in net_init_vmnet_shared()
H A Dvmnet-host.c91 NetClientState *peer, Error **errp) in net_init_vmnet_host() argument
94 peer, "vmnet-host", name); in net_init_vmnet_host()
H A Dvhost-user.c333 static int net_vhost_user_init(NetClientState *peer, const char *device, in net_vhost_user_init() argument
348 nc = qemu_new_net_client(&net_vhost_user_info, peer, device, name); in net_vhost_user_init()
419 NetClientState *peer, Error **errp) in net_init_vhost_user() argument
441 return net_vhost_user_init(peer, "vhost_user", name, chr, queues); in net_init_vhost_user()
/qemu/ui/
H A Dclipboard.c10 void qemu_clipboard_peer_register(QemuClipboardPeer *peer) in qemu_clipboard_peer_register() argument
12 notifier_list_add(&clipboard_notifiers, &peer->notifier); in qemu_clipboard_peer_register()
15 void qemu_clipboard_peer_unregister(QemuClipboardPeer *peer) in qemu_clipboard_peer_unregister() argument
20 qemu_clipboard_peer_release(peer, i); in qemu_clipboard_peer_unregister()
22 notifier_remove(&peer->notifier); in qemu_clipboard_peer_unregister()
25 bool qemu_clipboard_peer_owns(QemuClipboardPeer *peer, in qemu_clipboard_peer_owns() argument
30 return info && info->owner == peer; in qemu_clipboard_peer_owns()
33 void qemu_clipboard_peer_release(QemuClipboardPeer *peer, in qemu_clipboard_peer_release() argument
38 if (qemu_clipboard_peer_owns(peer, selection)) { in qemu_clipboard_peer_release()
169 void qemu_clipboard_set_data(QemuClipboardPeer *peer, in qemu_clipboard_set_data() argument
[all …]
/qemu/hw/net/
H A Dvhost_net.c173 NetClientState *peer; in vhost_net_disable_notifiers_nvhosts() local
183 peer = qemu_get_peer(ncs, i); in vhost_net_disable_notifiers_nvhosts()
188 net = get_vhost_net(peer); in vhost_net_disable_notifiers_nvhosts()
214 net = get_vhost_net(peer); in vhost_net_disable_notifiers_nvhosts()
233 NetClientState *peer; in vhost_net_enable_notifiers() local
248 net = get_vhost_net(peer); in vhost_net_enable_notifiers()
489 NetClientState *peer; in vhost_net_start() local
508 net = get_vhost_net(peer); in vhost_net_start()
539 if (peer->vring_enable) { in vhost_net_start()
541 r = vhost_set_vring_enable(peer, peer->vring_enable); in vhost_net_start()
[all …]
H A Dvirtio-net.c129 if (!nc->peer) { in flush_or_purge_queued_packets()
168 if (nc->peer && nc->peer->info->type == NET_CLIENT_DRIVER_VHOST_VDPA) { in virtio_net_get_config()
211 if (nc->peer && nc->peer->info->type == NET_CLIENT_DRIVER_VHOST_VDPA) { in virtio_net_set_config()
565 if (!nc->peer) { in virtio_net_queue_reset()
607 if (!nc->peer) { in peer_test_vnet_hdr()
677 if (!peer) { in virtio_net_max_tx_queue_size()
681 switch(peer->info->type) { in virtio_net_max_tx_queue_size()
694 if (!nc->peer) { in peer_attach()
717 if (!nc->peer) { in peer_detach()
1528 if (nc->peer && nc->peer->info->type == NET_CLIENT_DRIVER_VHOST_VDPA) { in virtio_net_handle_mq()
[all …]
/qemu/net/can/
H A Dcan_core.c109 CanBusClientState *peer; in can_bus_client_send() local
114 QTAILQ_FOREACH(peer, &bus->clients, next) { in can_bus_client_send()
115 if (peer->info->can_receive(peer)) { in can_bus_client_send()
116 if (peer == client) { in can_bus_client_send()
120 if (peer->info->receive(peer, frames, frames_cnt) > 0) { in can_bus_client_send()
/qemu/include/ui/
H A Dclipboard.h135 void qemu_clipboard_peer_register(QemuClipboardPeer *peer);
144 void qemu_clipboard_peer_unregister(QemuClipboardPeer *peer);
154 bool qemu_clipboard_peer_owns(QemuClipboardPeer *peer,
165 void qemu_clipboard_peer_release(QemuClipboardPeer *peer,
268 void qemu_clipboard_set_data(QemuClipboardPeer *peer,
/qemu/docs/specs/
H A Divshmem-spec.rst65 bit 0: peer interrupt (rev 0)
69 bit 0: peer interrupt (rev 0)
75 bit 16..31: peer ID
86 Status Register bit 0 becomes 1 when an interrupt request from a peer
99 Doorbell Register: writing this register requests to interrupt a peer.
100 The written value's high 16 bits are the ID of the peer to interrupt,
109 If the peer with the requested ID isn't connected, or it has fewer
114 The peer's interrupt for this vector then becomes pending. There is
118 If the peer is a revision 0 device without MSI-X capability, its
200 a peer ID (number between 0 and 65535 other than the client's ID),
[all …]
/qemu/include/net/
H A Dnet.h101 NetClientState *peer; member
146 NetClientState *peer,
150 NetClientState *peer,
338 return nc->peer && !nc->peer->do_not_pad; in net_peer_needs_padding()
/qemu/util/
H A Dqemu-sockets.c499 struct addrinfo ai, *peer = NULL, *local = NULL; in inet_dgram_saddr() local
523 if ((rc = getaddrinfo(addr, port, &ai, &peer)) != 0) { in inet_dgram_saddr()
532 ai.ai_family = peer->ai_family; in inet_dgram_saddr()
556 sock = qemu_socket(peer->ai_family, peer->ai_socktype, peer->ai_protocol); in inet_dgram_saddr()
559 peer->ai_family); in inet_dgram_saddr()
571 if (connect(sock,peer->ai_addr,peer->ai_addrlen) < 0) { in inet_dgram_saddr()
578 freeaddrinfo(peer); in inet_dgram_saddr()
588 if (peer) { in inet_dgram_saddr()
589 freeaddrinfo(peer); in inet_dgram_saddr()
/qemu/tests/qemu-iotests/
H A D23389 --object tls-creds-x509,dir=${tls_dir}/server1,endpoint=server,id=tls0,verify-peer=on \
155 --object tls-creds-x509,dir=${tls_dir}/server1,endpoint=server,id=tls0,verify-peer=on \
175 --object tls-creds-x509,dir=${tls_dir}/server1,endpoint=server,id=tls0,verify-peer=on \
202 --object tls-creds-psk,dir=${tls_dir}/psk1,endpoint=server,id=tls0,verify-peer=on \

123