Re: [libvirt] [PATCH v3 16/31] daemon: Introduce virNetServerProgramSendStreamHole

[John Ferlan]

On 05/16/2017 10:03 AM, Michal Privoznik wrote:
> This is just a helper function that takes in a length value,
> encodes it into XDR and sends to client.
> 
> Signed-off-by: Michal Privoznik 
> ---
>  src/libvirt_remote.syms   |  1 +
>  src/rpc/virnetserverprogram.c | 35 +++
>  src/rpc/virnetserverprogram.h |  8 
>  3 files changed, 44 insertions(+)
> 

Reviewed-by: John Ferlan 

John

--
libvir-list mailing list
libvir-list@redhat.com
https://www.redhat.com/mailman/listinfo/libvir-list

[libvirt] [PATCH v3 16/31] daemon: Introduce virNetServerProgramSendStreamHole

[Michal Privoznik]

This is just a helper function that takes in a length value,
encodes it into XDR and sends to client.

Signed-off-by: Michal Privoznik 
---
 src/libvirt_remote.syms   |  1 +
 src/rpc/virnetserverprogram.c | 35 +++
 src/rpc/virnetserverprogram.h |  8 
 3 files changed, 44 insertions(+)

diff --git a/src/libvirt_remote.syms b/src/libvirt_remote.syms
index ca1f3ac86..bb6a8d465 100644
--- a/src/libvirt_remote.syms
+++ b/src/libvirt_remote.syms
@@ -178,6 +178,7 @@ virNetServerProgramNew;
 virNetServerProgramSendReplyError;
 virNetServerProgramSendStreamData;
 virNetServerProgramSendStreamError;
+virNetServerProgramSendStreamHole;
 virNetServerProgramUnknownError;
 
 
diff --git a/src/rpc/virnetserverprogram.c b/src/rpc/virnetserverprogram.c
index d1597f438..556c91605 100644
--- a/src/rpc/virnetserverprogram.c
+++ b/src/rpc/virnetserverprogram.c
@@ -548,6 +548,41 @@ int 
virNetServerProgramSendStreamData(virNetServerProgramPtr prog,
 }
 
 
+int virNetServerProgramSendStreamHole(virNetServerProgramPtr prog,
+  virNetServerClientPtr client,
+  virNetMessagePtr msg,
+  int procedure,
+  unsigned int serial,
+  long long length,
+  unsigned int flags)
+{
+virNetStreamHole data;
+
+VIR_DEBUG("client=%p msg=%p length=%lld", client, msg, length);
+
+memset(, 0, sizeof(data));
+data.length = length;
+data.flags = flags;
+
+msg->header.prog = prog->program;
+msg->header.vers = prog->version;
+msg->header.proc = procedure;
+msg->header.type = VIR_NET_STREAM_HOLE;
+msg->header.serial = serial;
+msg->header.status = VIR_NET_CONTINUE;
+
+if (virNetMessageEncodeHeader(msg) < 0)
+return -1;
+
+if (virNetMessageEncodePayload(msg,
+   (xdrproc_t) xdr_virNetStreamHole,
+   ) < 0)
+return -1;
+
+return virNetServerClientSendMessage(client, msg);
+}
+
+
 void virNetServerProgramDispose(void *obj ATTRIBUTE_UNUSED)
 {
 }
diff --git a/src/rpc/virnetserverprogram.h b/src/rpc/virnetserverprogram.h
index 531fca024..1731c9e1d 100644
--- a/src/rpc/virnetserverprogram.h
+++ b/src/rpc/virnetserverprogram.h
@@ -104,4 +104,12 @@ int 
virNetServerProgramSendStreamData(virNetServerProgramPtr prog,
   const char *data,
   size_t len);
 
+int virNetServerProgramSendStreamHole(virNetServerProgramPtr prog,
+  virNetServerClientPtr client,
+  virNetMessagePtr msg,
+  int procedure,
+  unsigned int serial,
+  long long length,
+  unsigned int flags);
+
 #endif /* __VIR_NET_SERVER_PROGRAM_H__ */
-- 
2.13.0

--
libvir-list mailing list
libvir-list@redhat.com
https://www.redhat.com/mailman/listinfo/libvir-list