msg->header.serial != stream->serial)
goto cleanup;
- VIR_DEBUG("Incoming client=%p, rx=%p, serial=%u, proc=%d, status=%d",
- client, stream->rx, msg->header.proc,
+ VIR_DEBUG("Incoming client=%p, rx=%p, msg=%p, serial=%u, proc=%d, status=%d",
+ client, stream->rx, msg, msg->header.proc,
msg->header.serial, msg->header.status);
virNetMessageQueuePush(&stream->rx, msg);
{
virNetMessage *tmp = *queue;
+ VIR_DEBUG("queue=%p msg=%p", queue, msg);
+
if (tmp) {
while (tmp->next)
tmp = tmp->next;
{
virNetMessage *tmp = *queue;
+ VIR_DEBUG("queue serve start queue=%p *queue=%p", queue, *queue);
+
if (tmp) {
*queue = g_steal_pointer(&tmp->next);
}
+ VIR_DEBUG("queue serve end queue=%p *queue=%p", queue, *queue);
return tmp;
}