falso
/
qemu-irix
mirror of https://github.com/n64decomp/qemu-irix.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

net: Fix send queue ordering 

Ensure that packets enqueued for delayed delivery are dequeued in FIFO
order. At least one simplistic guest TCP/IP stack became unhappy due to
sporadically reordered packet streams.

At this chance, switch the send queue implementation to TAILQ.

Signed-off-by: Jan Kiszka <jan.kiszka@siemens.com>
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
This commit is contained in:
Jan Kiszka 2009-08-26 12:47:04 +02:00 committed by Aurelien Jarno
parent 6fe270e6e4
commit 67867f3837
2 changed files with 15 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
net.c
View File

@ -465,33 +465,28 @@ qemu_deliver_packet(VLANClientState *sender, const uint8_t *buf, int size)
void qemu_purge_queued_packets(VLANClientState *vc) void qemu_purge_queued_packets(VLANClientState *vc)
{ {
VLANPacket **pp = &vc->vlan->send_queue; VLANPacket *packet, *next;
while (*pp != NULL) {
VLANPacket *packet = *pp;
TAILQ_FOREACH_SAFE(packet, &vc->vlan->send_queue, entry, next) {
if (packet->sender == vc) { if (packet->sender == vc) {
*pp = packet->next; TAILQ_REMOVE(&vc->vlan->send_queue, packet, entry);
qemu_free(packet); qemu_free(packet);
} else {
pp = &packet->next;
} }
} }
} }
void qemu_flush_queued_packets(VLANClientState *vc) void qemu_flush_queued_packets(VLANClientState *vc)
{ {
VLANPacket *packet; while (!TAILQ_EMPTY(&vc->vlan->send_queue)) {
VLANPacket *packet;
while ((packet = vc->vlan->send_queue) != NULL) {
int ret; int ret;
vc->vlan->send_queue = packet->next; packet = TAILQ_FIRST(&vc->vlan->send_queue);
TAILQ_REMOVE(&vc->vlan->send_queue, packet, entry);
ret = qemu_deliver_packet(packet->sender, packet->data, packet->size); ret = qemu_deliver_packet(packet->sender, packet->data, packet->size);
if (ret == 0 && packet->sent_cb != NULL) { if (ret == 0 && packet->sent_cb != NULL) {
packet->next = vc->vlan->send_queue; TAILQ_INSERT_HEAD(&vc->vlan->send_queue, packet, entry);
vc->vlan->send_queue = packet;
break; break;
} }
@ -509,12 +504,12 @@ static void qemu_enqueue_packet(VLANClientState *sender,
VLANPacket *packet; VLANPacket *packet;
packet = qemu_malloc(sizeof(VLANPacket) + size); packet = qemu_malloc(sizeof(VLANPacket) + size);
packet->next = sender->vlan->send_queue;
packet->sender = sender; packet->sender = sender;
packet->size = size; packet->size = size;
packet->sent_cb = sent_cb; packet->sent_cb = sent_cb;
memcpy(packet->data, buf, size); memcpy(packet->data, buf, size);
sender->vlan->send_queue = packet;
TAILQ_INSERT_TAIL(&sender->vlan->send_queue, packet, entry);
} }
ssize_t qemu_send_packet_async(VLANClientState *sender, ssize_t qemu_send_packet_async(VLANClientState *sender,
@ -626,7 +621,6 @@ static ssize_t qemu_enqueue_packet_iov(VLANClientState *sender,
max_len = calc_iov_length(iov, iovcnt); max_len = calc_iov_length(iov, iovcnt);
packet = qemu_malloc(sizeof(VLANPacket) + max_len); packet = qemu_malloc(sizeof(VLANPacket) + max_len);
packet->next = sender->vlan->send_queue;
packet->sender = sender; packet->sender = sender;
packet->sent_cb = sent_cb; packet->sent_cb = sent_cb;
packet->size = 0; packet->size = 0;
@ -638,7 +632,7 @@ static ssize_t qemu_enqueue_packet_iov(VLANClientState *sender,
packet->size += len; packet->size += len;
} }
sender->vlan->send_queue = packet; TAILQ_INSERT_TAIL(&sender->vlan->send_queue, packet, entry);
return packet->size; return packet->size;
} }
@ -2359,6 +2353,7 @@ VLANState *qemu_find_vlan(int id, int allocate)
} }
vlan = qemu_mallocz(sizeof(VLANState)); vlan = qemu_mallocz(sizeof(VLANState));
vlan->id = id; vlan->id = id;
TAILQ_INIT(&vlan->send_queue);
vlan->next = NULL; vlan->next = NULL;
pvlan = &first_vlan; pvlan = &first_vlan;
while (*pvlan != NULL) while (*pvlan != NULL)

5
net.h
View File

@ -1,6 +1,7 @@
#ifndef QEMU_NET_H #ifndef QEMU_NET_H
#define QEMU_NET_H #define QEMU_NET_H
#include "sys-queue.h"
#include "qemu-common.h" #include "qemu-common.h"
/* VLANs support */ /* VLANs support */
@ -35,7 +36,7 @@ typedef struct VLANPacket VLANPacket;
typedef void (NetPacketSent) (VLANClientState *, ssize_t); typedef void (NetPacketSent) (VLANClientState *, ssize_t);
struct VLANPacket { struct VLANPacket {
struct VLANPacket *next; TAILQ_ENTRY(VLANPacket) entry;
VLANClientState *sender; VLANClientState *sender;
int size; int size;
NetPacketSent *sent_cb; NetPacketSent *sent_cb;
@ -47,7 +48,7 @@ struct VLANState {
VLANClientState *first_client; VLANClientState *first_client;
struct VLANState *next; struct VLANState *next;
unsigned int nb_guest_devs, nb_host_devs; unsigned int nb_guest_devs, nb_host_devs;
VLANPacket *send_queue; TAILQ_HEAD(send_queue, VLANPacket) send_queue;
int delivering; int delivering;
}; };