int filterID;
virNetMessagePtr rx;
- int tx;
+ bool tx;
daemonClientStreamPtr next;
};
VIR_DEBUG("stream=%p proc=%d serial=%u",
stream, msg->header.proc, msg->header.serial);
- stream->tx = 1;
+ stream->tx = true;
daemonStreamUpdateEvents(stream);
daemonFreeClientStream(NULL, stream);
(events & VIR_STREAM_EVENT_HANGUP)) {
virNetMessagePtr msg;
events &= ~(VIR_STREAM_EVENT_HANGUP);
- stream->tx = 0;
+ stream->tx = false;
stream->recvEOF = true;
if (!(msg = virNetMessageNew(false))) {
daemonRemoveClientStream(client, stream);
}
if (transmit)
- stream->tx = 1;
+ stream->tx = true;
virMutexLock(&priv->lock);
stream->next = priv->streams;
stream->serial);
} else {
virNetMessagePtr msg;
- stream->tx = 0;
+ stream->tx = false;
if (ret == 0)
stream->recvEOF = true;
if (!(msg = virNetMessageNew(false)))