Archipelago » qemu

9pfs-nested-$(CONFIG_VIRTFS) = virtio-9p-debug.o

9pfs-nested-$(CONFIG_VIRTFS) +=  virtio-9p-local.o virtio-9p-xattr.o

9pfs-nested-$(CONFIG_VIRTFS) +=   virtio-9p-xattr-user.o virtio-9p-posix-acl.o

hw-obj-$(CONFIG_REALLY_VIRTFS) += $(addprefix 9pfs/, $(9pfs-nested-y))

$(addprefix 9pfs/, $(9pfs-nested-y)): CFLAGS +=  -I$(SRC_PATH)/hw/

obj-$(CONFIG_REALLY_VIRTFS) += 9pfs/virtio-9p.o

9pfs/virtio-9p.o: CFLAGS +=  -I$(SRC_PATH)/hw/

	rm -f *.d */*.d tcg/*.o ide/*.o 9pfs/*.o

mkdir -p $target_dir/9pfs

  mkdir -p $d/9pfs

/*

 * Virtio 9p

 *

 * Copyright IBM, Corp. 2010

 *

 * Authors:

 *  Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>

 *

 * This work is licensed under the terms of the GNU GPL, version 2.  See

 * the COPYING file in the top-level directory.

 *

 */

#ifndef _FILEOP_H

#define _FILEOP_H

#include <sys/types.h>

#include <dirent.h>

#include <sys/time.h>

#include <utime.h>

#include <sys/stat.h>

#include <sys/uio.h>

#include <sys/vfs.h>

#define SM_LOCAL_MODE_BITS    0600

#define SM_LOCAL_DIR_MODE_BITS    0700

typedef enum

{

    /*

     * Server will try to set uid/gid.

     * On failure ignore the error.

     */

    SM_NONE = 0,

    /*

     * uid/gid set on fileserver files

     */

    SM_PASSTHROUGH = 1,

    /*

     * uid/gid part of xattr

     */

    SM_MAPPED,

} SecModel;

typedef struct FsCred

{

    uid_t   fc_uid;

    gid_t   fc_gid;

    mode_t  fc_mode;

    dev_t   fc_rdev;

} FsCred;

struct xattr_operations;

typedef struct FsContext

{

    char *fs_root;

    SecModel fs_sm;

    uid_t uid;

    struct xattr_operations **xops;

} FsContext;

void cred_init(FsCred *);

typedef struct FileOperations

{

    int (*lstat)(FsContext *, const char *, struct stat *);

    ssize_t (*readlink)(FsContext *, const char *, char *, size_t);

    int (*chmod)(FsContext *, const char *, FsCred *);

    int (*chown)(FsContext *, const char *, FsCred *);

    int (*mknod)(FsContext *, const char *, FsCred *);

    int (*utimensat)(FsContext *, const char *, const struct timespec *);

    int (*remove)(FsContext *, const char *);

    int (*symlink)(FsContext *, const char *, const char *, FsCred *);

    int (*link)(FsContext *, const char *, const char *);

    int (*setuid)(FsContext *, uid_t);

    int (*close)(FsContext *, int);

    int (*closedir)(FsContext *, DIR *);

    DIR *(*opendir)(FsContext *, const char *);

    int (*open)(FsContext *, const char *, int);

    int (*open2)(FsContext *, const char *, int, FsCred *);

    void (*rewinddir)(FsContext *, DIR *);

    off_t (*telldir)(FsContext *, DIR *);

    struct dirent *(*readdir)(FsContext *, DIR *);

    void (*seekdir)(FsContext *, DIR *, off_t);

    ssize_t (*preadv)(FsContext *, int, const struct iovec *, int, off_t);

    ssize_t (*pwritev)(FsContext *, int, const struct iovec *, int, off_t);

    int (*mkdir)(FsContext *, const char *, FsCred *);

    int (*fstat)(FsContext *, int, struct stat *);

    int (*rename)(FsContext *, const char *, const char *);

    int (*truncate)(FsContext *, const char *, off_t);

    int (*fsync)(FsContext *, int, int);

    int (*statfs)(FsContext *s, const char *path, struct statfs *stbuf);

    ssize_t (*lgetxattr)(FsContext *, const char *,

                         const char *, void *, size_t);

    ssize_t (*llistxattr)(FsContext *, const char *, void *, size_t);

    int (*lsetxattr)(FsContext *, const char *,

                     const char *, void *, size_t, int);

    int (*lremovexattr)(FsContext *, const char *, const char *);

    void *opaque;

} FileOperations;

static inline const char *rpath(FsContext *ctx, const char *path)

{

    /* FIXME: so wrong... */

    static char buffer[4096];

    snprintf(buffer, sizeof(buffer), "%s/%s", ctx->fs_root, path);

    return buffer;

}

#endif

#include "file-op-9p.h"

/*

 * Virtio 9p PDU debug

 *

 * Copyright IBM, Corp. 2010

 *

 * Authors:

 *  Anthony Liguori   <aliguori@us.ibm.com>

 *

 * This work is licensed under the terms of the GNU GPL, version 2.  See

 * the COPYING file in the top-level directory.

 *

 */

#include "virtio.h"

#include "pc.h"

#include "virtio-9p.h"

#include "virtio-9p-debug.h"

#define BUG_ON(cond) assert(!(cond))

static FILE *llogfile;

static struct iovec *get_sg(V9fsPDU *pdu, int rx)

{

    if (rx) {

        return pdu->elem.in_sg;

    }

    return pdu->elem.out_sg;

}

static int get_sg_count(V9fsPDU *pdu, int rx)

{

    if (rx) {

        return pdu->elem.in_num;

    }

    return pdu->elem.out_num;

}

static void pprint_int8(V9fsPDU *pdu, int rx, size_t *offsetp,

                        const char *name)

{

    size_t copied;

    int count = get_sg_count(pdu, rx);

    size_t offset = *offsetp;

    struct iovec *sg = get_sg(pdu, rx);

    int8_t value;

    copied = do_pdu_unpack(&value, sg, count, offset, sizeof(value));

    BUG_ON(copied != sizeof(value));

    offset += sizeof(value);

    fprintf(llogfile, "%s=0x%x", name, value);

    *offsetp = offset;

}

static void pprint_int16(V9fsPDU *pdu, int rx, size_t *offsetp,

                        const char *name)

{

    size_t copied;

    int count = get_sg_count(pdu, rx);

    struct iovec *sg = get_sg(pdu, rx);

    size_t offset = *offsetp;

    int16_t value;

    copied = do_pdu_unpack(&value, sg, count, offset, sizeof(value));

    BUG_ON(copied != sizeof(value));

    offset += sizeof(value);

    fprintf(llogfile, "%s=0x%x", name, value);

    *offsetp = offset;

}

static void pprint_int32(V9fsPDU *pdu, int rx, size_t *offsetp,

                        const char *name)

{

    size_t copied;

    int count = get_sg_count(pdu, rx);

    struct iovec *sg = get_sg(pdu, rx);

    size_t offset = *offsetp;

    int32_t value;

    copied = do_pdu_unpack(&value, sg, count, offset, sizeof(value));

    BUG_ON(copied != sizeof(value));

    offset += sizeof(value);

    fprintf(llogfile, "%s=0x%x", name, value);

    *offsetp = offset;

}

static void pprint_int64(V9fsPDU *pdu, int rx, size_t *offsetp,

                        const char *name)

{

    size_t copied;

    int count = get_sg_count(pdu, rx);

    struct iovec *sg = get_sg(pdu, rx);

    size_t offset = *offsetp;

    int64_t value;

    copied = do_pdu_unpack(&value, sg, count, offset, sizeof(value));

    BUG_ON(copied != sizeof(value));

    offset += sizeof(value);

    fprintf(llogfile, "%s=0x%" PRIx64, name, value);

    *offsetp = offset;

}

static void pprint_str(V9fsPDU *pdu, int rx, size_t *offsetp, const char *name)

{

    int sg_count = get_sg_count(pdu, rx);

    struct iovec *sg = get_sg(pdu, rx);

    size_t offset = *offsetp;

    uint16_t tmp_size, size;

    size_t result;

    size_t copied = 0;

    int i = 0;

    /* get the size */

    copied = do_pdu_unpack(&tmp_size, sg, sg_count, offset, sizeof(tmp_size));

    BUG_ON(copied != sizeof(tmp_size));

    size = le16_to_cpupu(&tmp_size);

    offset += copied;

    fprintf(llogfile, "%s=", name);

    for (i = 0; size && i < sg_count; i++) {

        size_t len;

        if (offset >= sg[i].iov_len) {

            /* skip this sg */

            offset -= sg[i].iov_len;

            continue;

        } else {

            len = MIN(sg[i].iov_len - offset, size);

            result = fwrite(sg[i].iov_base + offset, 1, len, llogfile);

            BUG_ON(result != len);

            size -= len;

            copied += len;

            if (size) {

                offset = 0;

                continue;

            }

        }

    }

    *offsetp += copied;

}

static void pprint_qid(V9fsPDU *pdu, int rx, size_t *offsetp, const char *name)

{

    fprintf(llogfile, "%s={", name);

    pprint_int8(pdu, rx, offsetp, "type");

    pprint_int32(pdu, rx, offsetp, ", version");

    pprint_int64(pdu, rx, offsetp, ", path");

    fprintf(llogfile, "}");

}

static void pprint_stat(V9fsPDU *pdu, int rx, size_t *offsetp, const char *name)

{

    fprintf(llogfile, "%s={", name);

    pprint_int16(pdu, rx, offsetp, "size");

    pprint_int16(pdu, rx, offsetp, ", type");

    pprint_int32(pdu, rx, offsetp, ", dev");

    pprint_qid(pdu, rx, offsetp, ", qid");

    pprint_int32(pdu, rx, offsetp, ", mode");

    pprint_int32(pdu, rx, offsetp, ", atime");

    pprint_int32(pdu, rx, offsetp, ", mtime");

    pprint_int64(pdu, rx, offsetp, ", length");

    pprint_str(pdu, rx, offsetp, ", name");

    pprint_str(pdu, rx, offsetp, ", uid");

    pprint_str(pdu, rx, offsetp, ", gid");

    pprint_str(pdu, rx, offsetp, ", muid");

    pprint_str(pdu, rx, offsetp, ", extension");

    pprint_int32(pdu, rx, offsetp, ", uid");

    pprint_int32(pdu, rx, offsetp, ", gid");

    pprint_int32(pdu, rx, offsetp, ", muid");

    fprintf(llogfile, "}");

}

static void pprint_stat_dotl(V9fsPDU *pdu, int rx, size_t *offsetp,

                                                  const char *name)

{

    fprintf(llogfile, "%s={", name);

    pprint_qid(pdu, rx, offsetp, "qid");

    pprint_int32(pdu, rx, offsetp, ", st_mode");

    pprint_int64(pdu, rx, offsetp, ", st_nlink");

    pprint_int32(pdu, rx, offsetp, ", st_uid");

    pprint_int32(pdu, rx, offsetp, ", st_gid");

    pprint_int64(pdu, rx, offsetp, ", st_rdev");

    pprint_int64(pdu, rx, offsetp, ", st_size");

    pprint_int64(pdu, rx, offsetp, ", st_blksize");

    pprint_int64(pdu, rx, offsetp, ", st_blocks");

    pprint_int64(pdu, rx, offsetp, ", atime");

    pprint_int64(pdu, rx, offsetp, ", atime_nsec");

    pprint_int64(pdu, rx, offsetp, ", mtime");

    pprint_int64(pdu, rx, offsetp, ", mtime_nsec");

    pprint_int64(pdu, rx, offsetp, ", ctime");

    pprint_int64(pdu, rx, offsetp, ", ctime_nsec");

    fprintf(llogfile, "}");

}

static void pprint_strs(V9fsPDU *pdu, int rx, size_t *offsetp, const char *name)

{

    int sg_count = get_sg_count(pdu, rx);

    struct iovec *sg = get_sg(pdu, rx);

    size_t offset = *offsetp;

    uint16_t tmp_count, count, i;

    size_t copied = 0;

    fprintf(llogfile, "%s={", name);

    /* Get the count */

    copied = do_pdu_unpack(&tmp_count, sg, sg_count, offset, sizeof(tmp_count));

    BUG_ON(copied != sizeof(tmp_count));

    count = le16_to_cpupu(&tmp_count);

    offset += copied;

    for (i = 0; i < count; i++) {

        char str[512];

        if (i) {

            fprintf(llogfile, ", ");

        }

        snprintf(str, sizeof(str), "[%d]", i);

        pprint_str(pdu, rx, &offset, str);

    }

    fprintf(llogfile, "}");

    *offsetp = offset;

}

static void pprint_qids(V9fsPDU *pdu, int rx, size_t *offsetp, const char *name)

{

    int sg_count = get_sg_count(pdu, rx);

    struct iovec *sg = get_sg(pdu, rx);

    size_t offset = *offsetp;

    uint16_t tmp_count, count, i;

    size_t copied = 0;

    fprintf(llogfile, "%s={", name);

    copied = do_pdu_unpack(&tmp_count, sg, sg_count, offset, sizeof(tmp_count));

    BUG_ON(copied != sizeof(tmp_count));

    count = le16_to_cpupu(&tmp_count);

    offset += copied;

    for (i = 0; i < count; i++) {

        char str[512];

        if (i) {

            fprintf(llogfile, ", ");

        }

        snprintf(str, sizeof(str), "[%d]", i);

        pprint_qid(pdu, rx, &offset, str);

    }

    fprintf(llogfile, "}");

    *offsetp = offset;

}

static void pprint_sg(V9fsPDU *pdu, int rx, size_t *offsetp, const char *name)

{

    struct iovec *sg = get_sg(pdu, rx);

    unsigned int count;

    int i;

    if (rx) {

        count = pdu->elem.in_num;

    } else {

        count = pdu->elem.out_num;

    }

    fprintf(llogfile, "%s={", name);

    for (i = 0; i < count; i++) {

        if (i) {

            fprintf(llogfile, ", ");

        }

        fprintf(llogfile, "(%p, 0x%zx)", sg[i].iov_base, sg[i].iov_len);

    }

    fprintf(llogfile, "}");

}

/* FIXME: read from a directory fid returns serialized stat_t's */

#ifdef DEBUG_DATA

static void pprint_data(V9fsPDU *pdu, int rx, size_t *offsetp, const char *name)

{

    struct iovec *sg = get_sg(pdu, rx);

    size_t offset = *offsetp;

    unsigned int count;

    int32_t size;

    int total, i, j;

    ssize_t len;

    if (rx) {

        count = pdu->elem.in_num;

    } else

        count = pdu->elem.out_num;

    }

    BUG_ON((offset + sizeof(size)) > sg[0].iov_len);

    memcpy(&size, sg[0].iov_base + offset, sizeof(size));

    offset += sizeof(size);

    fprintf(llogfile, "size: %x\n", size);

    sg[0].iov_base += 11; /* skip header */

    sg[0].iov_len -= 11;

    total = 0;

    for (i = 0; i < count; i++) {

        total += sg[i].iov_len;

        if (total >= size) {

            /* trim sg list so writev does the right thing */

            sg[i].iov_len -= (total - size);

            i++;

            break;

        }

    }

    fprintf(llogfile, "%s={\"", name);

    fflush(llogfile);

    for (j = 0; j < i; j++) {

        if (j) {

            fprintf(llogfile, "\", \"");

            fflush(llogfile);

        }

        do {

            len = writev(fileno(llogfile), &sg[j], 1);

        } while (len == -1 && errno == EINTR);

        fprintf(llogfile, "len == %ld: %m\n", len);

        BUG_ON(len != sg[j].iov_len);

    }

    fprintf(llogfile, "\"}");

    sg[0].iov_base -= 11;

    sg[0].iov_len += 11;

}

#endif

void pprint_pdu(V9fsPDU *pdu)

{

    size_t offset = 7;

    if (llogfile == NULL) {

        llogfile = fopen("/tmp/pdu.log", "w");

    }

    BUG_ON(!llogfile);

    switch (pdu->id) {

    case P9_TREADDIR:

        fprintf(llogfile, "TREADDIR: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_int64(pdu, 0, &offset, ", initial offset");

        pprint_int32(pdu, 0, &offset, ", max count");

        break;

    case P9_RREADDIR:

        fprintf(llogfile, "RREADDIR: (");

        pprint_int32(pdu, 1, &offset, "count");

#ifdef DEBUG_DATA

        pprint_data(pdu, 1, &offset, ", data");

#endif

        break;

    case P9_TMKDIR:

        fprintf(llogfile, "TMKDIR: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_str(pdu, 0, &offset, "name");

        pprint_int32(pdu, 0, &offset, "mode");

        pprint_int32(pdu, 0, &offset, "gid");

        break;

    case P9_RMKDIR:

        fprintf(llogfile, "RMKDIR: (");

        pprint_qid(pdu, 0, &offset, "qid");

        break;

    case P9_TVERSION:

        fprintf(llogfile, "TVERSION: (");

        pprint_int32(pdu, 0, &offset, "msize");

        pprint_str(pdu, 0, &offset, ", version");

        break;

    case P9_RVERSION:

        fprintf(llogfile, "RVERSION: (");

        pprint_int32(pdu, 1, &offset, "msize");

        pprint_str(pdu, 1, &offset, ", version");

        break;

    case P9_TGETATTR:

        fprintf(llogfile, "TGETATTR: (");

        pprint_int32(pdu, 0, &offset, "fid");

        break;

    case P9_RGETATTR:

        fprintf(llogfile, "RGETATTR: (");

        pprint_stat_dotl(pdu, 1, &offset, "getattr");

        break;

    case P9_TAUTH:

        fprintf(llogfile, "TAUTH: (");

        pprint_int32(pdu, 0, &offset, "afid");

        pprint_str(pdu, 0, &offset, ", uname");

        pprint_str(pdu, 0, &offset, ", aname");

        pprint_int32(pdu, 0, &offset, ", n_uname");

        break;

    case P9_RAUTH:

        fprintf(llogfile, "RAUTH: (");

        pprint_qid(pdu, 1, &offset, "qid");

        break;

    case P9_TATTACH:

        fprintf(llogfile, "TATTACH: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_int32(pdu, 0, &offset, ", afid");

        pprint_str(pdu, 0, &offset, ", uname");

        pprint_str(pdu, 0, &offset, ", aname");

        pprint_int32(pdu, 0, &offset, ", n_uname");

        break;

    case P9_RATTACH:

        fprintf(llogfile, "RATTACH: (");

        pprint_qid(pdu, 1, &offset, "qid");

        break;

    case P9_TERROR:

        fprintf(llogfile, "TERROR: (");

        break;

    case P9_RERROR:

        fprintf(llogfile, "RERROR: (");

        pprint_str(pdu, 1, &offset, "ename");

        pprint_int32(pdu, 1, &offset, ", ecode");

        break;

    case P9_TFLUSH:

        fprintf(llogfile, "TFLUSH: (");

        pprint_int16(pdu, 0, &offset, "oldtag");

        break;

    case P9_RFLUSH:

        fprintf(llogfile, "RFLUSH: (");

        break;

    case P9_TWALK:

        fprintf(llogfile, "TWALK: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_int32(pdu, 0, &offset, ", newfid");

        pprint_strs(pdu, 0, &offset, ", wnames");

        break;

    case P9_RWALK:

        fprintf(llogfile, "RWALK: (");

        pprint_qids(pdu, 1, &offset, "wqids");

        break;

    case P9_TOPEN:

        fprintf(llogfile, "TOPEN: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_int8(pdu, 0, &offset, ", mode");

        break;

    case P9_ROPEN:

        fprintf(llogfile, "ROPEN: (");

        pprint_qid(pdu, 1, &offset, "qid");

        pprint_int32(pdu, 1, &offset, ", iounit");

        break;

    case P9_TCREATE:

        fprintf(llogfile, "TCREATE: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_str(pdu, 0, &offset, ", name");

        pprint_int32(pdu, 0, &offset, ", perm");

        pprint_int8(pdu, 0, &offset, ", mode");

        pprint_str(pdu, 0, &offset, ", extension");

        break;

    case P9_RCREATE:

        fprintf(llogfile, "RCREATE: (");

        pprint_qid(pdu, 1, &offset, "qid");

        pprint_int32(pdu, 1, &offset, ", iounit");

        break;

    case P9_TSYMLINK:

        fprintf(llogfile, "TSYMLINK: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_str(pdu, 0, &offset, ", name");

        pprint_str(pdu, 0, &offset, ", symname");

        pprint_int32(pdu, 0, &offset, ", gid");

        break;

    case P9_RSYMLINK:

        fprintf(llogfile, "RSYMLINK: (");

        pprint_qid(pdu, 1, &offset, "qid");

        break;

    case P9_TLCREATE:

        fprintf(llogfile, "TLCREATE: (");

        pprint_int32(pdu, 0, &offset, "dfid");

        pprint_str(pdu, 0, &offset, ", name");

        pprint_int32(pdu, 0, &offset, ", flags");

        pprint_int32(pdu, 0, &offset, ", mode");

        pprint_int32(pdu, 0, &offset, ", gid");

        break;

    case P9_RLCREATE:

        fprintf(llogfile, "RLCREATE: (");

        pprint_qid(pdu, 1, &offset, "qid");

        pprint_int32(pdu, 1, &offset, ", iounit");

        break;

    case P9_TMKNOD:

	fprintf(llogfile, "TMKNOD: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_str(pdu, 0, &offset, "name");

        pprint_int32(pdu, 0, &offset, "mode");

        pprint_int32(pdu, 0, &offset, "major");

        pprint_int32(pdu, 0, &offset, "minor");

        pprint_int32(pdu, 0, &offset, "gid");

        break;

    case P9_RMKNOD:

        fprintf(llogfile, "RMKNOD: )");

        pprint_qid(pdu, 0, &offset, "qid");

        break;

    case P9_TREADLINK:

	fprintf(llogfile, "TREADLINK: (");

        pprint_int32(pdu, 0, &offset, "fid");

        break;

    case P9_RREADLINK:

	fprintf(llogfile, "RREADLINK: (");

        pprint_str(pdu, 0, &offset, "target");

        break;

    case P9_TREAD:

        fprintf(llogfile, "TREAD: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_int64(pdu, 0, &offset, ", offset");

        pprint_int32(pdu, 0, &offset, ", count");

        pprint_sg(pdu, 0, &offset, ", sg");

        break;

    case P9_RREAD:

        fprintf(llogfile, "RREAD: (");

        pprint_int32(pdu, 1, &offset, "count");

        pprint_sg(pdu, 1, &offset, ", sg");

        offset = 7;

#ifdef DEBUG_DATA

        pprint_data(pdu, 1, &offset, ", data");

#endif

        break;

    case P9_TWRITE:

        fprintf(llogfile, "TWRITE: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_int64(pdu, 0, &offset, ", offset");

        pprint_int32(pdu, 0, &offset, ", count");

        break;

    case P9_RWRITE:

        fprintf(llogfile, "RWRITE: (");

        pprint_int32(pdu, 1, &offset, "count");

        break;

    case P9_TCLUNK:

        fprintf(llogfile, "TCLUNK: (");

        pprint_int32(pdu, 0, &offset, "fid");

        break;

    case P9_RCLUNK:

        fprintf(llogfile, "RCLUNK: (");

        break;

    case P9_TFSYNC:

        fprintf(llogfile, "TFSYNC: (");

        pprint_int32(pdu, 0, &offset, "fid");

        break;

    case P9_RFSYNC:

        fprintf(llogfile, "RFSYNC: (");

        break;

    case P9_TLINK:

        fprintf(llogfile, "TLINK: (");

        pprint_int32(pdu, 0, &offset, "dfid");

        pprint_int32(pdu, 0, &offset, ", fid");

        pprint_str(pdu, 0, &offset, ", newpath");

        break;

    case P9_RLINK:

        fprintf(llogfile, "RLINK: (");

        break;

    case P9_TREMOVE:

        fprintf(llogfile, "TREMOVE: (");

        pprint_int32(pdu, 0, &offset, "fid");

        break;

    case P9_RREMOVE:

        fprintf(llogfile, "RREMOVE: (");

        break;

    case P9_TSTAT:

        fprintf(llogfile, "TSTAT: (");

        pprint_int32(pdu, 0, &offset, "fid");

        break;

    case P9_RSTAT:

        fprintf(llogfile, "RSTAT: (");

        offset += 2; /* ignored */

        pprint_stat(pdu, 1, &offset, "stat");

        break;

    case P9_TWSTAT:

        fprintf(llogfile, "TWSTAT: (");

        pprint_int32(pdu, 0, &offset, "fid");

        offset += 2; /* ignored */

        pprint_stat(pdu, 0, &offset, ", stat");

        break;

    case P9_RWSTAT:

        fprintf(llogfile, "RWSTAT: (");

        break;

    case P9_TXATTRWALK:

        fprintf(llogfile, "TXATTRWALK: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_int32(pdu, 0, &offset, ", newfid");

        pprint_str(pdu, 0, &offset, ", xattr name");

        break;

    case P9_RXATTRWALK:

        fprintf(llogfile, "RXATTRWALK: (");

        pprint_int64(pdu, 1, &offset, "xattrsize");

    case P9_TXATTRCREATE:

        fprintf(llogfile, "TXATTRCREATE: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_str(pdu, 0, &offset, ", name");

        pprint_int64(pdu, 0, &offset, ", xattrsize");

        pprint_int32(pdu, 0, &offset, ", flags");

        break;

    case P9_RXATTRCREATE:

        fprintf(llogfile, "RXATTRCREATE: (");

        break;

    case P9_TLOCK:

        fprintf(llogfile, "TLOCK: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_int8(pdu, 0, &offset, ", type");

        pprint_int32(pdu, 0, &offset, ", flags");

        pprint_int64(pdu, 0, &offset, ", start");

        pprint_int64(pdu, 0, &offset, ", length");

        pprint_int32(pdu, 0, &offset, ", proc_id");

        pprint_str(pdu, 0, &offset, ", client_id");

        break;

    case P9_RLOCK:

        fprintf(llogfile, "RLOCK: (");

        pprint_int8(pdu, 0, &offset, "status");

        break;

    case P9_TGETLOCK:

        fprintf(llogfile, "TGETLOCK: (");

        pprint_int32(pdu, 0, &offset, "fid");

        pprint_int8(pdu, 0, &offset, ", type");

        pprint_int64(pdu, 0, &offset, ", start");

        pprint_int64(pdu, 0, &offset, ", length");

        pprint_int32(pdu, 0, &offset, ", proc_id");

        pprint_str(pdu, 0, &offset, ", client_id");

        break;

    case P9_RGETLOCK:

        fprintf(llogfile, "RGETLOCK: (");

        pprint_int8(pdu, 0, &offset, "type");

        pprint_int64(pdu, 0, &offset, ", start");

        pprint_int64(pdu, 0, &offset, ", length");

        pprint_int32(pdu, 0, &offset, ", proc_id");

        pprint_str(pdu, 0, &offset, ", client_id");

        break;

    default:

        fprintf(llogfile, "unknown(%d): (", pdu->id);

        break;

    }

    fprintf(llogfile, ")\n");

    /* Flush the log message out */

    fflush(llogfile);

}

#ifndef _QEMU_VIRTIO_9P_DEBUG_H

#define _QEMU_VIRTIO_9P_DEBUG_H

void pprint_pdu(V9fsPDU *pdu);

#endif

/*

 * Virtio 9p Posix callback

 *

 * Copyright IBM, Corp. 2010

 *

 * Authors:

 *  Anthony Liguori   <aliguori@us.ibm.com>

 *

 * This work is licensed under the terms of the GNU GPL, version 2.  See

 * the COPYING file in the top-level directory.

 *

 */

#include "virtio.h"

#include "virtio-9p.h"

#include "virtio-9p-xattr.h"

#include <arpa/inet.h>

#include <pwd.h>

#include <grp.h>

#include <sys/socket.h>

#include <sys/un.h>

#include <attr/xattr.h>

static int local_lstat(FsContext *fs_ctx, const char *path, struct stat *stbuf)

{

    int err;

    err =  lstat(rpath(fs_ctx, path), stbuf);

    if (err) {

        return err;

    }

    if (fs_ctx->fs_sm == SM_MAPPED) {

        /* Actual credentials are part of extended attrs */

        uid_t tmp_uid;

        gid_t tmp_gid;

        mode_t tmp_mode;

        dev_t tmp_dev;

        if (getxattr(rpath(fs_ctx, path), "user.virtfs.uid", &tmp_uid,

                    sizeof(uid_t)) > 0) {

            stbuf->st_uid = tmp_uid;

        }

        if (getxattr(rpath(fs_ctx, path), "user.virtfs.gid", &tmp_gid,

                    sizeof(gid_t)) > 0) {

            stbuf->st_gid = tmp_gid;

        }

        if (getxattr(rpath(fs_ctx, path), "user.virtfs.mode", &tmp_mode,

                    sizeof(mode_t)) > 0) {

            stbuf->st_mode = tmp_mode;

        }

        if (getxattr(rpath(fs_ctx, path), "user.virtfs.rdev", &tmp_dev,

                        sizeof(dev_t)) > 0) {

                stbuf->st_rdev = tmp_dev;

        }

    }

    return err;

}

static int local_set_xattr(const char *path, FsCred *credp)

{

    int err;

    if (credp->fc_uid != -1) {

        err = setxattr(path, "user.virtfs.uid", &credp->fc_uid, sizeof(uid_t),

                0);

        if (err) {

            return err;

        }

    }

    if (credp->fc_gid != -1) {

        err = setxattr(path, "user.virtfs.gid", &credp->fc_gid, sizeof(gid_t),

                0);

        if (err) {

            return err;

        }

    }

    if (credp->fc_mode != -1) {

        err = setxattr(path, "user.virtfs.mode", &credp->fc_mode,

                sizeof(mode_t), 0);

        if (err) {

            return err;

        }

    }

    if (credp->fc_rdev != -1) {

        err = setxattr(path, "user.virtfs.rdev", &credp->fc_rdev,

                sizeof(dev_t), 0);

        if (err) {

            return err;

        }

    }

    return 0;

}

static int local_post_create_passthrough(FsContext *fs_ctx, const char *path,

        FsCred *credp)

{

    if (chmod(rpath(fs_ctx, path), credp->fc_mode & 07777) < 0) {

        return -1;

    }

    if (lchown(rpath(fs_ctx, path), credp->fc_uid, credp->fc_gid) < 0) {

        /*

         * If we fail to change ownership and if we are

         * using security model none. Ignore the error

         */

        if (fs_ctx->fs_sm != SM_NONE) {

            return -1;

        }

    }

    return 0;

}

static ssize_t local_readlink(FsContext *fs_ctx, const char *path,

        char *buf, size_t bufsz)

{

    ssize_t tsize = -1;

    if (fs_ctx->fs_sm == SM_MAPPED) {

        int fd;

        fd = open(rpath(fs_ctx, path), O_RDONLY);

        if (fd == -1) {

            return -1;

        }

        do {

            tsize = read(fd, (void *)buf, bufsz);

        } while (tsize == -1 && errno == EINTR);

        close(fd);

        return tsize;

    } else if ((fs_ctx->fs_sm == SM_PASSTHROUGH) ||

               (fs_ctx->fs_sm == SM_NONE)) {

        tsize = readlink(rpath(fs_ctx, path), buf, bufsz);

    }

    return tsize;

}

static int local_close(FsContext *ctx, int fd)

{

    return close(fd);

}

static int local_closedir(FsContext *ctx, DIR *dir)

{

    return closedir(dir);

}

static int local_open(FsContext *ctx, const char *path, int flags)

{

    return open(rpath(ctx, path), flags);

}

static DIR *local_opendir(FsContext *ctx, const char *path)

{

    return opendir(rpath(ctx, path));

}

static void local_rewinddir(FsContext *ctx, DIR *dir)

{

    return rewinddir(dir);

}

static off_t local_telldir(FsContext *ctx, DIR *dir)

{

    return telldir(dir);

}

static struct dirent *local_readdir(FsContext *ctx, DIR *dir)

{

    return readdir(dir);

}

static void local_seekdir(FsContext *ctx, DIR *dir, off_t off)

{

    return seekdir(dir, off);

}

static ssize_t local_preadv(FsContext *ctx, int fd, const struct iovec *iov,

                            int iovcnt, off_t offset)

{

#ifdef CONFIG_PREADV

    return preadv(fd, iov, iovcnt, offset);

#else

    int err = lseek(fd, offset, SEEK_SET);

    if (err == -1) {

        return err;

    } else {

        return readv(fd, iov, iovcnt);

    }

#endif

}

static ssize_t local_pwritev(FsContext *ctx, int fd, const struct iovec *iov,

                            int iovcnt, off_t offset)

{

#ifdef CONFIG_PREADV

    return pwritev(fd, iov, iovcnt, offset);

#else

    int err = lseek(fd, offset, SEEK_SET);

    if (err == -1) {

        return err;

    } else {

        return writev(fd, iov, iovcnt);

    }

#endif

}

static int local_chmod(FsContext *fs_ctx, const char *path, FsCred *credp)

{

    if (fs_ctx->fs_sm == SM_MAPPED) {

        return local_set_xattr(rpath(fs_ctx, path), credp);

    } else if ((fs_ctx->fs_sm == SM_PASSTHROUGH) ||

               (fs_ctx->fs_sm == SM_NONE)) {

        return chmod(rpath(fs_ctx, path), credp->fc_mode);

    }

    return -1;

}

static int local_mknod(FsContext *fs_ctx, const char *path, FsCred *credp)

{

    int err = -1;

    int serrno = 0;

    /* Determine the security model */

    if (fs_ctx->fs_sm == SM_MAPPED) {

        err = mknod(rpath(fs_ctx, path), SM_LOCAL_MODE_BITS|S_IFREG, 0);

        if (err == -1) {

            return err;

        }

        local_set_xattr(rpath(fs_ctx, path), credp);

        if (err == -1) {

            serrno = errno;

            goto err_end;

        }

    } else if ((fs_ctx->fs_sm == SM_PASSTHROUGH) ||

               (fs_ctx->fs_sm == SM_NONE)) {

        err = mknod(rpath(fs_ctx, path), credp->fc_mode, credp->fc_rdev);

        if (err == -1) {

            return err;

        }

        err = local_post_create_passthrough(fs_ctx, path, credp);

        if (err == -1) {

            serrno = errno;

            goto err_end;

        }

    }

    return err;

err_end:

    remove(rpath(fs_ctx, path));

    errno = serrno;

    return err;

}

static int local_mkdir(FsContext *fs_ctx, const char *path, FsCred *credp)

{

    int err = -1;

    int serrno = 0;

    /* Determine the security model */

    if (fs_ctx->fs_sm == SM_MAPPED) {

        err = mkdir(rpath(fs_ctx, path), SM_LOCAL_DIR_MODE_BITS);

        if (err == -1) {

            return err;

        }

        credp->fc_mode = credp->fc_mode|S_IFDIR;

        err = local_set_xattr(rpath(fs_ctx, path), credp);

        if (err == -1) {

            serrno = errno;

            goto err_end;

        }

    } else if ((fs_ctx->fs_sm == SM_PASSTHROUGH) ||

               (fs_ctx->fs_sm == SM_NONE)) {

        err = mkdir(rpath(fs_ctx, path), credp->fc_mode);

        if (err == -1) {

            return err;

        }

        err = local_post_create_passthrough(fs_ctx, path, credp);

        if (err == -1) {

            serrno = errno;

            goto err_end;

        }

    }

    return err;

err_end:

    remove(rpath(fs_ctx, path));

    errno = serrno;

    return err;

}

static int local_fstat(FsContext *fs_ctx, int fd, struct stat *stbuf)

{

    int err;

    err = fstat(fd, stbuf);

    if (err) {

        return err;

    }

    if (fs_ctx->fs_sm == SM_MAPPED) {

        /* Actual credentials are part of extended attrs */

        uid_t tmp_uid;

        gid_t tmp_gid;

        mode_t tmp_mode;

        dev_t tmp_dev;

        if (fgetxattr(fd, "user.virtfs.uid", &tmp_uid, sizeof(uid_t)) > 0) {

            stbuf->st_uid = tmp_uid;

        }

        if (fgetxattr(fd, "user.virtfs.gid", &tmp_gid, sizeof(gid_t)) > 0) {

            stbuf->st_gid = tmp_gid;

        }

        if (fgetxattr(fd, "user.virtfs.mode", &tmp_mode, sizeof(mode_t)) > 0) {

            stbuf->st_mode = tmp_mode;

        }

        if (fgetxattr(fd, "user.virtfs.rdev", &tmp_dev, sizeof(dev_t)) > 0) {

                stbuf->st_rdev = tmp_dev;

        }

    }

    return err;

}

static int local_open2(FsContext *fs_ctx, const char *path, int flags,

        FsCred *credp)

{

    int fd = -1;

    int err = -1;

    int serrno = 0;

    /* Determine the security model */

    if (fs_ctx->fs_sm == SM_MAPPED) {

        fd = open(rpath(fs_ctx, path), flags, SM_LOCAL_MODE_BITS);

        if (fd == -1) {

            return fd;

        }

        credp->fc_mode = credp->fc_mode|S_IFREG;

        /* Set cleint credentials in xattr */

        err = local_set_xattr(rpath(fs_ctx, path), credp);

        if (err == -1) {

            serrno = errno;

            goto err_end;

        }

    } else if ((fs_ctx->fs_sm == SM_PASSTHROUGH) ||

               (fs_ctx->fs_sm == SM_NONE)) {

        fd = open(rpath(fs_ctx, path), flags, credp->fc_mode);

        if (fd == -1) {

            return fd;

        }

        err = local_post_create_passthrough(fs_ctx, path, credp);

        if (err == -1) {

            serrno = errno;

            goto err_end;

        }

    }

    return fd;

err_end:

    close(fd);

    remove(rpath(fs_ctx, path));

    errno = serrno;

    return err;

}

static int local_symlink(FsContext *fs_ctx, const char *oldpath,

        const char *newpath, FsCred *credp)

{

    int err = -1;

    int serrno = 0;

    /* Determine the security model */

    if (fs_ctx->fs_sm == SM_MAPPED) {

        int fd;

        ssize_t oldpath_size, write_size;

        fd = open(rpath(fs_ctx, newpath), O_CREAT|O_EXCL|O_RDWR,

                SM_LOCAL_MODE_BITS);

        if (fd == -1) {

            return fd;

        }

        /* Write the oldpath (target) to the file. */

        oldpath_size = strlen(oldpath) + 1;

        do {

            write_size = write(fd, (void *)oldpath, oldpath_size);

        } while (write_size == -1 && errno == EINTR);

        if (write_size != oldpath_size) {

            serrno = errno;

            close(fd);

            err = -1;

            goto err_end;

        }

        close(fd);

        /* Set cleint credentials in symlink's xattr */

        credp->fc_mode = credp->fc_mode|S_IFLNK;

        err = local_set_xattr(rpath(fs_ctx, newpath), credp);

        if (err == -1) {

            serrno = errno;

            goto err_end;

        }

    } else if ((fs_ctx->fs_sm == SM_PASSTHROUGH) ||

               (fs_ctx->fs_sm == SM_NONE)) {

        err = symlink(oldpath, rpath(fs_ctx, newpath));

        if (err) {

            return err;

        }

        err = lchown(rpath(fs_ctx, newpath), credp->fc_uid, credp->fc_gid);

        if (err == -1) {

            /*

             * If we fail to change ownership and if we are

             * using security model none. Ignore the error

             */

            if (fs_ctx->fs_sm != SM_NONE) {

                serrno = errno;

                goto err_end;

            } else

                err = 0;

        }

    }

    return err;

err_end:

    remove(rpath(fs_ctx, newpath));

    errno = serrno;

    return err;

}

static int local_link(FsContext *ctx, const char *oldpath, const char *newpath)

{

    char *tmp = qemu_strdup(rpath(ctx, oldpath));

    int err, serrno = 0;

    if (tmp == NULL) {

        return -ENOMEM;

    }

    err = link(tmp, rpath(ctx, newpath));

    if (err == -1) {

        serrno = errno;

    }

    qemu_free(tmp);

    if (err == -1) {

        errno = serrno;

    }

    return err;

}

static int local_truncate(FsContext *ctx, const char *path, off_t size)

{

    return truncate(rpath(ctx, path), size);

}

static int local_rename(FsContext *ctx, const char *oldpath,

                        const char *newpath)

{

    char *tmp;

    int err;

    tmp = qemu_strdup(rpath(ctx, oldpath));

    err = rename(tmp, rpath(ctx, newpath));

    if (err == -1) {

        int serrno = errno;

        qemu_free(tmp);

        errno = serrno;

    } else {

        qemu_free(tmp);

    }

    return err;

}

static int local_chown(FsContext *fs_ctx, const char *path, FsCred *credp)

{

    if ((credp->fc_uid == -1 && credp->fc_gid == -1) ||

            (fs_ctx->fs_sm == SM_PASSTHROUGH)) {

        return lchown(rpath(fs_ctx, path), credp->fc_uid, credp->fc_gid);

    } else if (fs_ctx->fs_sm == SM_MAPPED) {

        return local_set_xattr(rpath(fs_ctx, path), credp);

    } else if ((fs_ctx->fs_sm == SM_PASSTHROUGH) ||

               (fs_ctx->fs_sm == SM_NONE)) {

        return lchown(rpath(fs_ctx, path), credp->fc_uid, credp->fc_gid);

    }

    return -1;

}

static int local_utimensat(FsContext *s, const char *path,

                           const struct timespec *buf)

{

    return qemu_utimensat(AT_FDCWD, rpath(s, path), buf, AT_SYMLINK_NOFOLLOW);

}

static int local_remove(FsContext *ctx, const char *path)

{

    return remove(rpath(ctx, path));

}

static int local_fsync(FsContext *ctx, int fd, int datasync)

{

    if (datasync) {

        return qemu_fdatasync(fd);

    } else {

        return fsync(fd);

    }

}

static int local_statfs(FsContext *s, const char *path, struct statfs *stbuf)

{

   return statfs(rpath(s, path), stbuf);

}

static ssize_t local_lgetxattr(FsContext *ctx, const char *path,

                               const char *name, void *value, size_t size)

{

    return v9fs_get_xattr(ctx, path, name, value, size);

}

static ssize_t local_llistxattr(FsContext *ctx, const char *path,

                                void *value, size_t size)

{

    return v9fs_list_xattr(ctx, path, value, size);

}

static int local_lsetxattr(FsContext *ctx, const char *path, const char *name,

                           void *value, size_t size, int flags)

{

    return v9fs_set_xattr(ctx, path, name, value, size, flags);

}

static int local_lremovexattr(FsContext *ctx,

                              const char *path, const char *name)

{

    return v9fs_remove_xattr(ctx, path, name);

}

FileOperations local_ops = {

    .lstat = local_lstat,

    .readlink = local_readlink,

    .close = local_close,

    .closedir = local_closedir,

    .open = local_open,

    .opendir = local_opendir,

    .rewinddir = local_rewinddir,

    .telldir = local_telldir,

    .readdir = local_readdir,

    .seekdir = local_seekdir,

    .preadv = local_preadv,

    .pwritev = local_pwritev,

    .chmod = local_chmod,

    .mknod = local_mknod,

    .mkdir = local_mkdir,

    .fstat = local_fstat,

    .open2 = local_open2,

    .symlink = local_symlink,

    .link = local_link,

    .truncate = local_truncate,

    .rename = local_rename,

    .chown = local_chown,

    .utimensat = local_utimensat,

    .remove = local_remove,

    .fsync = local_fsync,

    .statfs = local_statfs,

    .lgetxattr = local_lgetxattr,

    .llistxattr = local_llistxattr,

    .lsetxattr = local_lsetxattr,

    .lremovexattr = local_lremovexattr,

};

/*

 * Virtio 9p system.posix* xattr callback

 *

 * Copyright IBM, Corp. 2010

 *

 * Authors:

 * Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>

 *

 * This work is licensed under the terms of the GNU GPL, version 2.  See

 * the COPYING file in the top-level directory.

 *

 */

#include <sys/types.h>

#include <attr/xattr.h>

#include "virtio.h"

#include "virtio-9p.h"

#include "fsdev/file-op-9p.h"

#include "virtio-9p-xattr.h"

#define MAP_ACL_ACCESS "user.virtfs.system.posix_acl_access"

#define MAP_ACL_DEFAULT "user.virtfs.system.posix_acl_default"

#define ACL_ACCESS "system.posix_acl_access"

#define ACL_DEFAULT "system.posix_acl_default"

static ssize_t mp_pacl_getxattr(FsContext *ctx, const char *path,

                                const char *name, void *value, size_t size)

{

    return lgetxattr(rpath(ctx, path), MAP_ACL_ACCESS, value, size);

}

static ssize_t mp_pacl_listxattr(FsContext *ctx, const char *path,

                                 char *name, void *value, size_t osize)

{

    ssize_t len = sizeof(ACL_ACCESS);

    if (!value) {

        return len;

    }

    if (osize < len) {

        errno = ERANGE;

        return -1;

    }

    strncpy(value, ACL_ACCESS, len);

    return 0;

}

static int mp_pacl_setxattr(FsContext *ctx, const char *path, const char *name,

                            void *value, size_t size, int flags)

{

    return lsetxattr(rpath(ctx, path), MAP_ACL_ACCESS, value, size, flags);

}

static int mp_pacl_removexattr(FsContext *ctx,

                               const char *path, const char *name)

{