| /qemu/hw/net/ |
| H A D | net_rx_pkt.h | 23 /* defines to enable packet dump functions */
29 * Clean all rx packet resources
31 * @pkt: packet
37 * Init function for rx packet functionality
39 * @pkt: packet pointer
47 * @pkt: packet
55 * parse and set packet analysis results
57 * @pkt: packet
68 * fetches packet analysis results
70 * @pkt: packet
[all …]
|
| H A D | net_tx_pkt.h | 24 /* define to enable packet dump functions */
33 * Init function for tx packet functionality
35 * @pkt: packet pointer
41 * Clean all tx packet resources.
43 * @pkt: packet.
50 * @pkt: packet
58 * @pkt: packet
72 * @pkt: packet
83 * @pkt: packet
96 * @pkt: packet
[all …]
|
| H A D | trace-events | 6 allwinner_sun8i_emac_receive(uint32_t desc, uint32_t paddr, uint32_t bytes) "RX packet: desc=0x%" P…
7 allwinner_sun8i_emac_transmit(uint32_t desc, uint32_t paddr, uint32_t bytes) "TX packet: desc=0x%" …
65 net_rx_pkt_parsed(bool ip4, bool ip6, int l4proto, size_t l3o, size_t l4o, size_t l5o) "RX packet p…
67 net_rx_pkt_l4_csum_validate_not_xxp(void) "Not a TCP/UDP packet"
68 net_rx_pkt_l4_csum_validate_udp_with_no_checksum(void) "UDP packet without checksum"
73 net_rx_pkt_l4_csum_calc_ip4_udp(void) "IP4/UDP packet"
74 net_rx_pkt_l4_csum_calc_ip4_tcp(void) "IP4/TCP packet"
75 net_rx_pkt_l4_csum_calc_ip6_udp(void) "IP6/UDP packet"
76 net_rx_pkt_l4_csum_calc_ip6_tcp(void) "IP6/TCP packet"
81 net_rx_pkt_l4_csum_fix_tcp(uint32_t l4_cso) "TCP packet, L4 cso: %u"
[all …]
|
| /qemu/net/ |
| H A D | queue.c | 37 * the packet.
39 * If a sent callback isn't provided, we just drop the packet to avoid
83 NetPacket *packet, *next; in qemu_del_net_queue() local
85 QTAILQ_FOREACH_SAFE(packet, &queue->packets, entry, next) { in qemu_del_net_queue()
86 QTAILQ_REMOVE(&queue->packets, packet, entry); in qemu_del_net_queue()
87 g_free(packet); in qemu_del_net_queue()
100 NetPacket *packet; in qemu_net_queue_append() local
105 packet = g_malloc(sizeof(NetPacket) + size); in qemu_net_queue_append()
106 packet->sender = sender; in qemu_net_queue_append()
107 packet->flags = flags; in qemu_net_queue_append()
[all …]
|
| H A D | colo-compare.c | 74 * |packet | |packet + |packet | |packet +
79 * |packet | |packet + |packet | |packet +
84 * |packet | |packet + |packet | |packet +
196 static gint seq_sorter(Packet *a, Packet *b, gpointer data) in seq_sorter()
203 Packet *pkt = data; in fill_pkt_tcp_info()
221 * packet will be dropped
223 static int colo_insert_packet(GQueue *queue, Packet *pkt, uint32_t *max_ack) in colo_insert_packet()
247 Packet *pkt = NULL; in packet_enqueue()
285 "queue size too big, drop packet"); in packet_enqueue()
300 static void colo_release_primary_pkt(CompareState *s, Packet *pkt) in colo_release_primary_pkt()
[all …]
|
| H A D | colo.h | 37 typedef struct Packet { struct
45 /* Time of packet creation, in wall clock ms */
51 /* the sequence number of the last byte of the packet */
58 } Packet; argument
70 /* connection primary send queue: element type: Packet */
72 /* connection secondary send queue: element type: Packet */
92 int parse_packet_early(Packet *pkt);
94 Packet *pkt, bool reverse);
95 void fill_connection_key(Packet *pkt, ConnectionKey *key, bool reverse);
104 Packet *packet_new(const void *data, int size, int vnet_hdr_len);
[all …]
|
| H A D | colo.c | 43 int parse_packet_early(Packet *pkt) in parse_packet_early()
58 * The received remote packet maybe misconfiguration here, in parse_packet_early()
62 trace_colo_proxy_main_vnet_info("This received packet load wrong ", in parse_packet_early()
101 Packet *pkt, bool reverse) in extract_ip_and_port()
116 void fill_connection_key(Packet *pkt, ConnectionKey *key, bool reverse) in fill_connection_key()
165 Packet *packet_new(const void *data, int size, int vnet_hdr_len) in packet_new()
167 Packet *pkt = g_slice_new0(Packet); in packet_new()
181 Packet *packet_new_nocopy(void *data, int size, int vnet_hdr_len) in packet_new_nocopy()
183 Packet *pkt = g_slice_new0(Packet); in packet_new_nocopy()
195 Packet *pkt = opaque; in packet_destroy()
[all …]
|
| H A D | filter-rewriter.c | 58 * is not TCP packet
60 static int is_tcp_packet(Packet *pkt) in is_tcp_packet()
70 /* handle tcp packet from primary guest */
73 Packet *pkt, ConnectionKey *key) in handle_primary_tcp_pkt()
106 * ack packet sent by guest from primary node, in handle_primary_tcp_pkt()
140 * We got 'fin=1, ack=1' packet from server side, we need to in handle_primary_tcp_pkt()
141 * record the seq of 'fin=1, ack=1' packet. in handle_primary_tcp_pkt()
145 * packet from server side. From this point, we can ensure that there in handle_primary_tcp_pkt()
164 * packet, guest will apply the last ACK too. in handle_primary_tcp_pkt()
176 /* handle tcp packet from secondary guest */
[all …]
|
| /qemu/hw/usb/ |
| H A D | pcap.c | 2 * usb packet capture
32 uint32_t incl_len; /* number of octets of packet saved in file */
33 uint32_t orig_len; /* actual length of packet */
103 static void do_usb_pcap_header(FILE *fp, struct usbmon_packet *packet) in do_usb_pcap_header() argument
109 packet->ts_sec = tv.tv_sec; in do_usb_pcap_header()
110 packet->ts_usec = tv.tv_usec; in do_usb_pcap_header()
112 header.ts_sec = packet->ts_sec; in do_usb_pcap_header()
113 header.ts_usec = packet->ts_usec; in do_usb_pcap_header()
114 header.incl_len = packet->len_cap; in do_usb_pcap_header()
115 header.orig_len = packet->length + sizeof(*packet); in do_usb_pcap_header()
[all …]
|
| H A D | u2f-passthru.c | 82 /* Init packet sizes */
86 /* Cont packet sizes */
98 static inline uint32_t packet_get_cid(const void *packet) in packet_get_cid() argument
100 return *((uint32_t *)packet); in packet_get_cid()
103 static inline bool packet_is_init(const void *packet) in packet_is_init() argument
105 return ((uint8_t *)packet)[4] & (1 << 7); in packet_is_init()
259 const uint8_t packet[U2FHID_PACKET_SIZE]) in u2f_passthru_recv_from_host()
265 cid = packet_get_cid(packet); in u2f_passthru_recv_from_host()
268 if (!packet_is_init(packet)) { in u2f_passthru_recv_from_host()
271 packet_init = (struct packet_init *)packet; in u2f_passthru_recv_from_host()
[all …]
|
| H A D | combined-packet.c | 2 * QEMU USB packet combining code (for input pipelining)
35 /* Note will free combined when the last packet gets removed */
74 /* Send short or error packet to complete the transfer */ in usb_combined_input_packet_complete()
78 /* Report status on the last packet */ in usb_combined_input_packet_complete()
85 /* Note will free combined when the last packet gets removed! */ in usb_combined_input_packet_complete()
92 /* Note will free combined on the last packet! */ in usb_combined_input_packet_complete()
109 /* Note will free combined on the last packet! */ in usb_combined_packet_cancel()
119 * the last packet of such splits transfers have, thereby allowing input
147 * If the previous (combined) packet has the short_not_ok flag set in usb_ep_combine_input_packets()
149 * ending with short_not_ok packet. in usb_ep_combine_input_packets()
[all …]
|
| H A D | dev-storage.c | 182 USBPacket *p = s->packet; in usb_msd_packet_complete()
185 * Set s->packet to NULL before calling usb_packet_complete in usb_msd_packet_complete()
191 s->packet = NULL; in usb_msd_packet_complete()
199 if (s->packet) { in usb_msd_fatal_error()
245 USBPacket *p = s->packet; in usb_msd_transfer_data()
256 p = s->packet; in usb_msd_transfer_data()
267 USBPacket *p = s->packet; in usb_msd_command_complete()
276 if (s->packet) { in usb_msd_command_complete()
278 /* A deferred packet with no write data remaining must be in usb_msd_command_complete()
279 the status read packet. */ in usb_msd_command_complete()
[all …]
|
| /qemu/hw/vfio/ |
| H A D | migration-multifd.c | 108 VFIODeviceStatePacket *packet, in vfio_load_state_buffer_insert() argument
117 if (packet->idx >= vfio_state_buffers_size_get(&multifd->load_bufs)) { in vfio_load_state_buffer_insert()
118 vfio_state_buffers_size_set(&multifd->load_bufs, packet->idx + 1); in vfio_load_state_buffer_insert()
121 lb = vfio_state_buffers_at(&multifd->load_bufs, packet->idx); in vfio_load_state_buffer_insert()
124 vbasedev->name, packet->idx); in vfio_load_state_buffer_insert()
128 assert(packet->idx >= multifd->load_buf_idx); in vfio_load_state_buffer_insert()
130 lb->data = g_memdup2(&packet->data, packet_total_size - sizeof(*packet)); in vfio_load_state_buffer_insert()
131 lb->len = packet_total_size - sizeof(*packet); in vfio_load_state_buffer_insert()
143 VFIODeviceStatePacket *packet = (VFIODeviceStatePacket *)data; in vfio_multifd_load_state_buffer() local
147 "%s: got device state packet but not doing multifd transfer", in vfio_multifd_load_state_buffer()
[all …]
|
| /qemu/target/hexagon/ |
| H A D | decode.c | 91 void decode_send_insn_to(Packet *packet, int start, int newloc) in decode_send_insn_to() argument
107 tmpinsn = packet->insn[i]; in decode_send_insn_to()
108 packet->insn[i] = packet->insn[i + direction]; in decode_send_insn_to()
109 packet->insn[i + direction] = tmpinsn; in decode_send_insn_to()
115 decode_fill_newvalue_regno(Packet *packet) in decode_fill_newvalue_regno() argument
119 for (i = 1; i < packet->num_insns; i++) { in decode_fill_newvalue_regno()
120 if (GET_ATTRIB(packet->insn[i].opcode, A_DOTNEWVALUE) && in decode_fill_newvalue_regno()
121 !GET_ATTRIB(packet->insn[i].opcode, A_EXTENSION)) { in decode_fill_newvalue_regno()
123 g_assert(packet->insn[i].new_read_idx != -1); in decode_fill_newvalue_regno()
124 use_regidx = packet->insn[i].new_read_idx; in decode_fill_newvalue_regno()
[all …]
|
| H A D | README | 22 This has all the instruction and packet semantics
81 Packet *pkt)
101 when the packet commits (see "Packet Semantics" below).
186 the packet, and we mark the implicit writes. The analysis determines if the packet
226 gen_start_packet - initialize the data structures for packet semantics
227 gen_commit_packet - commit the register writes, stores, etc for a packet
228 decode_and_translate_packet - disassemble a packet and generate code
243 *** Packet Semantics ***
245 VLIW packet semantics differ from serial semantics in that all input operands
247 For example, this packet performs a swap of registers r0 and r1
[all …]
|
| /qemu/docs/ |
| H A D | colo-proxy.txt | 26 If the packet difference, notify COLO-frame to do checkpoint and send
27 all primary packet has queued. Otherwise just send the queued primary
28 packet and drop the queued secondary packet.
69 1.Guest receive packet route:
74 Mirror client will send packet to guest,at the
75 same time, copy and forward packet to secondary
81 If receive packet is TCP packet,we will adjust ack
85 2.Guest send packet route:
90 Redirect server filter receive primary guest packet
94 COLO-compare receive primary guest packet then
[all …]
|
| /qemu/migration/ |
| H A D | multifd-nocomp.c | 73 /* We need one extra place for the packet header */ in multifd_nocomp_send_setup()
91 p->iov[0].iov_base = p->packet; in multifd_ram_prepare_header()
138 ret = qio_channel_write_all(p->c, (void *)p->packet, in multifd_nocomp_send_prepare()
205 MultiFDPacket_t *packet = p->packet; in multifd_ram_fill_packet() local
209 packet->pages_alloc = cpu_to_be32(multifd_ram_page_count()); in multifd_ram_fill_packet()
210 packet->normal_pages = cpu_to_be32(pages->normal_num); in multifd_ram_fill_packet()
211 packet->zero_pages = cpu_to_be32(zero_num); in multifd_ram_fill_packet()
214 pstrcpy(packet->ramblock, sizeof(packet->ramblock), in multifd_ram_fill_packet()
222 packet->offset[i] = cpu_to_be64(temp); in multifd_ram_fill_packet()
231 MultiFDPacket_t *packet = p->packet; in multifd_ram_unfill_packet() local
[all …]
|
| H A D | multifd.h | 71 * If set it means that this packet contains device state
92 /* size of the next packet that contains pages */
114 /* size of the next packet that contains the actual data */
196 /* packet allocated len */
206 /* multifd flags for each packet */
224 /* pointers to the possible packet types */
225 MultiFDPacket_t *packet; member
227 /* size of the next packet that contains pages */
252 /* packet allocated len */
264 /* multifd flags for each packet */
[all …]
|
| H A D | multifd-device-state.c | 63 MultiFDPacketDeviceState_t *packet = p->packet_device_state; in multifd_device_state_fill_packet() local
65 packet->hdr.flags = cpu_to_be32(p->flags); in multifd_device_state_fill_packet()
66 strncpy(packet->idstr, device_state->idstr, sizeof(packet->idstr) - 1); in multifd_device_state_fill_packet()
67 packet->idstr[sizeof(packet->idstr) - 1] = 0; in multifd_device_state_fill_packet()
68 packet->instance_id = cpu_to_be32(device_state->instance_id); in multifd_device_state_fill_packet()
69 packet->next_packet_size = cpu_to_be32(p->next_packet_size); in multifd_device_state_fill_packet()
|
| H A D | multifd.c | 195 error_setg(errp, "multifd: received packet magic %x " in multifd_recv_initial_packet()
201 error_setg(errp, "multifd: received packet version %u " in multifd_recv_initial_packet()
226 /* Fills a RAM multifd packet */
229 MultiFDPacket_t *packet = p->packet; in multifd_send_fill_packet() local
233 memset(packet, 0, p->packet_len); in multifd_send_fill_packet()
235 packet->hdr.magic = cpu_to_be32(MULTIFD_MAGIC); in multifd_send_fill_packet()
236 packet->hdr.version = cpu_to_be32(MULTIFD_VERSION); in multifd_send_fill_packet()
238 packet->hdr.flags = cpu_to_be32(p->flags); in multifd_send_fill_packet()
239 packet->next_packet_size = cpu_to_be32(p->next_packet_size); in multifd_send_fill_packet()
242 packet->packet_num = cpu_to_be64(packet_num); in multifd_send_fill_packet()
[all …]
|
| /qemu/tests/qtest/ |
| H A D | e1000e-test.c | 39 static const struct eth_header packet = { variable
53 memwrite(data, &packet, sizeof(packet)); in e1000e_send_verify()
79 g_assert_false(memcmp(buffer, &packet, sizeof(packet))); in e1000e_send_verify()
89 struct eth_header test_iov = packet; in e1000e_receive_verify()
90 int len = htonl(sizeof(packet)); in e1000e_receive_verify()
97 .iov_len = sizeof(packet), in e1000e_receive_verify()
104 /* Send a dummy packet to device's socket*/ in e1000e_receive_verify()
105 ret = iov_send(test_sockets[0], iov, 2, 0, sizeof(len) + sizeof(packet)); in e1000e_receive_verify()
106 g_assert_cmpint(ret, == , sizeof(packet) + sizeof(len)); in e1000e_receive_verify()
127 g_assert_false(memcmp(buffer, &packet, sizeof(packet))); in e1000e_receive_verify()
|
| H A D | igb-test.c | 43 static const struct eth_header packet = { variable
57 memwrite(data, &packet, sizeof(packet)); in igb_send_verify()
82 g_assert_false(memcmp(buffer, &packet, sizeof(packet))); in igb_send_verify()
92 struct eth_header test_iov = packet; in igb_receive_verify()
93 int len = htonl(sizeof(packet)); in igb_receive_verify()
100 .iov_len = sizeof(packet), in igb_receive_verify()
107 /* Send a dummy packet to device's socket*/ in igb_receive_verify()
108 ret = iov_send(test_sockets[0], iov, 2, 0, sizeof(len) + sizeof(packet)); in igb_receive_verify()
109 g_assert_cmpint(ret, == , sizeof(packet) + sizeof(len)); in igb_receive_verify()
130 g_assert_false(memcmp(buffer, &packet, sizeof(packet))); in igb_receive_verify()
|
| /qemu/tests/tcg/multiarch/system/ |
| H A D | Makefile.softmmu-target | 38 run-gdbstub-untimely-packet: hello
42 --output untimely-packet.gdb.out \
43 --stderr untimely-packet.gdb.err \
46 …"-monitor none -display none -chardev file$(COMMA)path=untimely-packet.out$(COMMA)id=output $(QEMU…
49 (! grep -Fq 'Packet instead of Ack, ignoring it' untimely-packet.gdb.err), \
50 "GREP", file untimely-packet.gdb.err)
67 run-gdbstub-untimely-packet run-gdbstub-registers
|
| /qemu/docs/specs/ |
| H A D | rocker.rst | 156 DMA operations are used for packet DMA to/from the CPU, command and event
309 on context. TLV values containing network packet data will be in network-byte
311 packet data is network-byte order. For example, flow match fields (and masks)
313 network packet data. All non-network-packet TLV multi-byte values will be LE.
506 When a packet ingresses on a port and the source MAC/VLAN isn't known to the
522 CPU Packet Processing
529 Tx Packet Processing
533 TX descriptor buffer describes the packet location and size in host DMA-able
537 to head, DMA read descriptor buffer and packet data, perform offloading
538 functions, and finally frame packet on wire (network). Once packet processing
[all …]
|
| /qemu/include/hw/net/ |
| H A D | npcm7xx_emc.h | 67 /* Accept Broadcast Packet */
69 /* Accept Multicast Packet */
71 /* Accept Unicast Packet */
95 /* Accept CRC Error Packet */
97 /* Accept Control Packet */
99 /* Accept Runt Packet */
101 /* Accept Long Packet */
140 /* Packet Too Long Interrupt */
225 /* Runt packet */
231 /* Packet too long */
[all …]
|