Browse Source

9pfs: make pdu_{,un}marshal proper functions

Factor out v9fs_iov_v{,un}marshal. Implement pdu_{,un}marshal with those
functions.

Signed-off-by: Wei Liu <wei.liu2@citrix.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Wei Liu 9 years ago
parent
commit
0e2082d9e5
4 changed files with 63 additions and 16 deletions
  1. 30 12
      fsdev/9p-iov-marshal.c
  2. 5 0
      fsdev/9p-iov-marshal.h
  3. 26 0
      hw/9pfs/virtio-9p.c
  4. 2 4
      hw/9pfs/virtio-9p.h

+ 30 - 12
fsdev/9p-iov-marshal.c

@@ -76,15 +76,13 @@ ssize_t v9fs_pack(struct iovec *in_sg, int in_num, size_t offset,
     return v9fs_packunpack((void *)src, in_sg, in_num, offset, size, 1);
     return v9fs_packunpack((void *)src, in_sg, in_num, offset, size, 1);
 }
 }
 
 
-ssize_t v9fs_iov_unmarshal(struct iovec *out_sg, int out_num, size_t offset,
-                           int bswap, const char *fmt, ...)
+ssize_t v9fs_iov_vunmarshal(struct iovec *out_sg, int out_num, size_t offset,
+                            int bswap, const char *fmt, va_list ap)
 {
 {
     int i;
     int i;
-    va_list ap;
     ssize_t copied = 0;
     ssize_t copied = 0;
     size_t old_offset = offset;
     size_t old_offset = offset;
 
 
-    va_start(ap, fmt);
     for (i = 0; fmt[i]; i++) {
     for (i = 0; fmt[i]; i++) {
         switch (fmt[i]) {
         switch (fmt[i]) {
         case 'b': {
         case 'b': {
@@ -180,25 +178,34 @@ ssize_t v9fs_iov_unmarshal(struct iovec *out_sg, int out_num, size_t offset,
             break;
             break;
         }
         }
         if (copied < 0) {
         if (copied < 0) {
-            va_end(ap);
             return copied;
             return copied;
         }
         }
         offset += copied;
         offset += copied;
     }
     }
-    va_end(ap);
 
 
     return offset - old_offset;
     return offset - old_offset;
 }
 }
 
 
-ssize_t v9fs_iov_marshal(struct iovec *in_sg, int in_num, size_t offset,
-                         int bswap, const char *fmt, ...)
+ssize_t v9fs_iov_unmarshal(struct iovec *out_sg, int out_num, size_t offset,
+                           int bswap, const char *fmt, ...)
 {
 {
-    int i;
+    ssize_t ret;
     va_list ap;
     va_list ap;
+
+    va_start(ap, fmt);
+    ret = v9fs_iov_vunmarshal(out_sg, out_num, offset, bswap, fmt, ap);
+    va_end(ap);
+
+    return ret;
+}
+
+ssize_t v9fs_iov_vmarshal(struct iovec *in_sg, int in_num, size_t offset,
+                          int bswap, const char *fmt, va_list ap)
+{
+    int i;
     ssize_t copied = 0;
     ssize_t copied = 0;
     size_t old_offset = offset;
     size_t old_offset = offset;
 
 
-    va_start(ap, fmt);
     for (i = 0; fmt[i]; i++) {
     for (i = 0; fmt[i]; i++) {
         switch (fmt[i]) {
         switch (fmt[i]) {
         case 'b': {
         case 'b': {
@@ -290,12 +297,23 @@ ssize_t v9fs_iov_marshal(struct iovec *in_sg, int in_num, size_t offset,
             break;
             break;
         }
         }
         if (copied < 0) {
         if (copied < 0) {
-            va_end(ap);
             return copied;
             return copied;
         }
         }
         offset += copied;
         offset += copied;
     }
     }
-    va_end(ap);
 
 
     return offset - old_offset;
     return offset - old_offset;
 }
 }
+
+ssize_t v9fs_iov_marshal(struct iovec *in_sg, int in_num, size_t offset,
+                         int bswap, const char *fmt, ...)
+{
+    ssize_t ret;
+    va_list ap;
+
+    va_start(ap, fmt);
+    ret = v9fs_iov_vmarshal(in_sg, in_num, offset, bswap, fmt, ap);
+    va_end(ap);
+
+    return ret;
+}

+ 5 - 0
fsdev/9p-iov-marshal.h

@@ -10,4 +10,9 @@ ssize_t v9fs_iov_unmarshal(struct iovec *out_sg, int out_num, size_t offset,
                            int bswap, const char *fmt, ...);
                            int bswap, const char *fmt, ...);
 ssize_t v9fs_iov_marshal(struct iovec *in_sg, int in_num, size_t offset,
 ssize_t v9fs_iov_marshal(struct iovec *in_sg, int in_num, size_t offset,
                          int bswap, const char *fmt, ...);
                          int bswap, const char *fmt, ...);
+
+ssize_t v9fs_iov_vunmarshal(struct iovec *out_sg, int out_num, size_t offset,
+                            int bswap, const char *fmt, va_list ap);
+ssize_t v9fs_iov_vmarshal(struct iovec *in_sg, int in_num, size_t offset,
+                          int bswap, const char *fmt, va_list ap);
 #endif
 #endif

+ 26 - 0
hw/9pfs/virtio-9p.c

@@ -39,6 +39,32 @@ enum {
     Oappend = 0x80,
     Oappend = 0x80,
 };
 };
 
 
+ssize_t pdu_marshal(V9fsPDU *pdu, size_t offset, const char *fmt, ...)
+{
+    ssize_t ret;
+    va_list ap;
+
+    va_start(ap, fmt);
+    ret = v9fs_iov_vmarshal(pdu->elem.in_sg, pdu->elem.in_num,
+                            offset, 1, fmt, ap);
+    va_end(ap);
+
+    return ret;
+}
+
+ssize_t pdu_unmarshal(V9fsPDU *pdu, size_t offset, const char *fmt, ...)
+{
+    ssize_t ret;
+    va_list ap;
+
+    va_start(ap, fmt);
+    ret = v9fs_iov_vunmarshal(pdu->elem.out_sg, pdu->elem.out_num,
+                              offset, 1, fmt, ap);
+    va_end(ap);
+
+    return ret;
+}
+
 static int omode_to_uflags(int8_t mode)
 static int omode_to_uflags(int8_t mode)
 {
 {
     int ret = 0;
     int ret = 0;

+ 2 - 4
hw/9pfs/virtio-9p.h

@@ -320,10 +320,8 @@ extern void v9fs_path_copy(V9fsPath *lhs, V9fsPath *rhs);
 extern int v9fs_name_to_path(V9fsState *s, V9fsPath *dirpath,
 extern int v9fs_name_to_path(V9fsState *s, V9fsPath *dirpath,
                              const char *name, V9fsPath *path);
                              const char *name, V9fsPath *path);
 
 
-#define pdu_marshal(pdu, offset, fmt, args...)  \
-    v9fs_iov_marshal(pdu->elem.in_sg, pdu->elem.in_num, offset, 1, fmt, ##args)
-#define pdu_unmarshal(pdu, offset, fmt, args...)  \
-    v9fs_iov_unmarshal(pdu->elem.out_sg, pdu->elem.out_num, offset, 1, fmt, ##args)
+ssize_t pdu_marshal(V9fsPDU *pdu, size_t offset, const char *fmt, ...);
+ssize_t pdu_unmarshal(V9fsPDU *pdu, size_t offset, const char *fmt, ...);
 
 
 #define TYPE_VIRTIO_9P "virtio-9p-device"
 #define TYPE_VIRTIO_9P "virtio-9p-device"
 #define VIRTIO_9P(obj) \
 #define VIRTIO_9P(obj) \