External/libvirt
1
0
Fork 0
mirror of https://gitlab.com/libvirt/libvirt.git synced 2025-03-07 17:28:15 +00:00
Code

virNetClientStreamRecvPacket: Introduce @flags argument

Browse Source 
Signed-off-by: Michal Privoznik <mprivozn@redhat.com>
This commit is contained in:
Michal Privoznik 2016-05-20 13:04:29 +02:00
parent c331f56b93
commit 486656f168
3 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/remote/remote_driver.c
View File

@ -5665,7 +5665,8 @@ remoteStreamRecvFlags(virStreamPtr st,
priv->client, priv->client,
data, data,
nbytes, nbytes,
(st->flags & VIR_STREAM_NONBLOCK)); (st->flags & VIR_STREAM_NONBLOCK),
flags);
VIR_DEBUG("Done %d", rv); VIR_DEBUG("Done %d", rv);

10
src/rpc/virnetclientstream.c
View File

@ -457,13 +457,17 @@ int virNetClientStreamRecvPacket(virNetClientStreamPtr st,
virNetClientPtr client, virNetClientPtr client,
char *data, char *data,
size_t nbytes, size_t nbytes,
bool nonblock) bool nonblock,
unsigned int flags)
{ {
int rv = -1; int rv = -1;
size_t want; size_t want;
VIR_DEBUG("st=%p client=%p data=%p nbytes=%zu nonblock=%d", VIR_DEBUG("st=%p client=%p data=%p nbytes=%zu nonblock=%d flags=%x",
st, client, data, nbytes, nonblock); st, client, data, nbytes, nonblock, flags);
virCheckFlags(0, -1);
virObjectLock(st); virObjectLock(st);
if (!st->rx && !st->incomingEOF) { if (!st->rx && !st->incomingEOF) {
virNetMessagePtr msg; virNetMessagePtr msg;

3
src/rpc/virnetclientstream.h
View File

@ -59,7 +59,8 @@ int virNetClientStreamRecvPacket(virNetClientStreamPtr st,
virNetClientPtr client, virNetClientPtr client,
char *data, char *data,
size_t nbytes, size_t nbytes,
bool nonblock); bool nonblock,
unsigned int flags);
int virNetClientStreamSendHole(virNetClientStreamPtr st, int virNetClientStreamSendHole(virNetClientStreamPtr st,
virNetClientPtr client, virNetClientPtr client,