Source-Changes-HG archive
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index][Old Index]
[src/trunk]: src/tests/fs/common Run puffs/dtfs as part of the vfs tests.
details: https://anonhg.NetBSD.org/src/rev/c4101d35a8e2
branches: trunk
changeset: 756345:c4101d35a8e2
user: pooka <pooka%NetBSD.org@localhost>
date: Tue Jul 13 16:48:15 2010 +0000
description:
Run puffs/dtfs as part of the vfs tests.
diffstat:
tests/fs/common/h_fsmacros.h | 5 +-
tests/fs/common/puffs.c | 363 +++++++++++++++++++++++++++++++++++++++++++
2 files changed, 367 insertions(+), 1 deletions(-)
diffs (truncated from 400 to 300 lines):
diff -r bf5fbfc245c6 -r c4101d35a8e2 tests/fs/common/h_fsmacros.h
--- a/tests/fs/common/h_fsmacros.h Tue Jul 13 15:50:31 2010 +0000
+++ b/tests/fs/common/h_fsmacros.h Tue Jul 13 16:48:15 2010 +0000
@@ -1,4 +1,4 @@
-/* $NetBSD: h_fsmacros.h,v 1.9 2010/07/13 15:50:31 njoly Exp $ */
+/* $NetBSD: h_fsmacros.h,v 1.10 2010/07/13 16:48:15 pooka Exp $ */
/*-
* Copyright (c) 2010 The NetBSD Foundation, Inc.
@@ -41,6 +41,7 @@
#include "ffs.c"
#include "lfs.c"
#include "msdosfs.c"
+#include "puffs.c"
#include "sysvbfs.c"
#include "tmpfs.c"
@@ -79,6 +80,7 @@
ATF_TC_FSADD(ffs,MOUNT_FFS,func,desc) \
ATF_TC_FSADD(lfs,MOUNT_LFS,func,desc) \
ATF_TC_FSADD(msdosfs,MOUNT_MSDOS,func,desc) \
+ ATF_TC_FSADD(puffs,MOUNT_PUFFS,func,desc) \
ATF_TC_FSADD(sysvbfs,MOUNT_SYSVBFS,func,desc) \
ATF_TC_FSADD(tmpfs,MOUNT_TMPFS,func,desc)
@@ -87,6 +89,7 @@
ATF_TP_FSADD(ffs,func); \
ATF_TP_FSADD(lfs,func); \
ATF_TP_FSADD(msdosfs,func); \
+ ATF_TP_FSADD(puffs,func); \
ATF_TP_FSADD(sysvbfs,func); \
ATF_TP_FSADD(tmpfs,func);
diff -r bf5fbfc245c6 -r c4101d35a8e2 tests/fs/common/puffs.c
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/tests/fs/common/puffs.c Tue Jul 13 16:48:15 2010 +0000
@@ -0,0 +1,363 @@
+/* $NetBSD: puffs.c,v 1.1 2010/07/13 16:48:15 pooka Exp $ */
+
+/*
+ * Copyright (c) 2010 The NetBSD Foundation, Inc.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
+ * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ */
+
+#include <sys/types.h>
+#include <sys/mount.h>
+#include <sys/socket.h>
+#include <sys/statvfs.h>
+#include <sys/wait.h>
+
+#include <assert.h>
+#include <atf-c.h>
+#include <err.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <pthread.h>
+#include <puffs.h>
+#include <puffsdump.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <string.h>
+#include <stdlib.h>
+
+#include <rump/rump.h>
+#include <rump/rump_syscalls.h>
+
+struct puffstestargs {
+ uint8_t *pta_pargs;
+ size_t pta_pargslen;
+
+ int pta_pflags;
+ int pta_servfd;
+ pid_t pta_childpid;
+
+ char pta_dev[MAXPATHLEN];
+ char pta_dir[MAXPATHLEN];
+
+ int pta_mntflags;
+};
+
+#define BUFSIZE (128*1024)
+#define DTFS_DUMP "-o","dump"
+
+struct thefds {
+ int rumpfd;
+ int servfd;
+};
+
+int vfs_toserv_ops[PUFFS_VFS_MAX];
+int vn_toserv_ops[PUFFS_VN_MAX];
+
+#ifdef PUFFSDUMP
+static void __unused
+dumpopcount(void)
+{
+ size_t i;
+
+ printf("VFS OPS:\n");
+ for (i = 0; i < MIN(puffsdump_vfsop_count, PUFFS_VFS_MAX); i++) {
+ printf("\t%s: %d\n",
+ puffsdump_vfsop_revmap[i], vfs_toserv_ops[i]);
+ }
+
+ printf("VN OPS:\n");
+ for (i = 0; i < MIN(puffsdump_vnop_count, PUFFS_VN_MAX); i++) {
+ printf("\t%s: %d\n",
+ puffsdump_vnop_revmap[i], vn_toserv_ops[i]);
+ }
+}
+#endif
+
+/*
+ * Threads which shovel data between comfd and /dev/puffs.
+ * (cannot use polling since fd's are in different namespaces)
+ */
+static void *
+readshovel(void *arg)
+{
+ struct putter_hdr *phdr;
+ struct puffs_req *preq;
+ struct thefds *fds = arg;
+ char buf[BUFSIZE];
+ int comfd, puffsfd;
+
+ comfd = fds->servfd;
+ puffsfd = fds->rumpfd;
+
+ phdr = (void *)buf;
+ preq = (void *)buf;
+
+ /* use static thread id */
+ rump_pub_lwp_alloc_and_switch(0, 10);
+
+ for (;;) {
+ ssize_t n;
+
+ n = rump_sys_read(puffsfd, buf, sizeof(*phdr));
+ if (n <= 0)
+ break;
+
+ assert(phdr->pth_framelen < BUFSIZE);
+ n = rump_sys_read(puffsfd, buf+sizeof(*phdr),
+ phdr->pth_framelen - sizeof(*phdr));
+ if (n <= 0)
+ break;
+
+ /* Analyze request */
+ if (PUFFSOP_OPCLASS(preq->preq_opclass) == PUFFSOP_VFS) {
+ assert(preq->preq_optype < PUFFS_VFS_MAX);
+ vfs_toserv_ops[preq->preq_optype]++;
+ } else if (PUFFSOP_OPCLASS(preq->preq_opclass) == PUFFSOP_VN) {
+ assert(preq->preq_optype < PUFFS_VN_MAX);
+ vn_toserv_ops[preq->preq_optype]++;
+ }
+
+ n = phdr->pth_framelen;
+ if (write(comfd, buf, n) != n)
+ break;
+ }
+
+ return NULL;
+}
+
+static void *
+writeshovel(void *arg)
+{
+ struct thefds *fds = arg;
+ struct putter_hdr *phdr;
+ char buf[BUFSIZE];
+ size_t toread;
+ int comfd, puffsfd;
+
+ /* use static thread id */
+ rump_pub_lwp_alloc_and_switch(0, 11);
+
+ comfd = fds->servfd;
+ puffsfd = fds->rumpfd;
+
+ phdr = (struct putter_hdr *)buf;
+
+ for (;;) {
+ off_t off;
+ ssize_t n;
+
+ /*
+ * Need to write everything to the "kernel" in one chunk,
+ * so make sure we have it here.
+ */
+ off = 0;
+ toread = sizeof(struct putter_hdr);
+ assert(toread < BUFSIZE);
+ do {
+ n = read(comfd, buf+off, toread);
+ if (n <= 0) {
+ break;
+ }
+ off += n;
+ if (off >= sizeof(struct putter_hdr))
+ toread = phdr->pth_framelen - off;
+ else
+ toread = off - sizeof(struct putter_hdr);
+ } while (toread);
+
+ n = rump_sys_write(puffsfd, buf, phdr->pth_framelen);
+ if ((size_t)n != phdr->pth_framelen)
+ break;
+ }
+
+ return NULL;
+}
+
+static void
+rumpshovels(int rumpfd, int servfd)
+{
+ struct thefds *fds;
+ pthread_t pt;
+ int rv;
+
+ if ((rv = rump_init()) == -1)
+ err(1, "rump_init");
+
+ fds = malloc(sizeof(*fds));
+ fds->rumpfd = rumpfd;
+ fds->servfd = servfd;
+ if (pthread_create(&pt, NULL, readshovel, fds) == -1)
+ err(1, "read shovel");
+ pthread_detach(pt);
+ if (pthread_create(&pt, NULL, writeshovel, fds) == -1)
+ err(1, "write shovel");
+ pthread_detach(pt);
+}
+
+/* XXX: we don't support size */
+static int
+puffs_fstest_newfs(const atf_tc_t *tc, void **argp,
+ const char *image, off_t size)
+{
+ struct puffstestargs *args;
+ char dtfs_path[MAXPATHLEN];
+ char *dtfsargv[5];
+ pid_t childpid;
+ int *pflags;
+ char comfd[16];
+ int sv[2];
+ int mntflags;
+ size_t len;
+ ssize_t n;
+
+ *argp = NULL;
+
+ args = malloc(sizeof(*args));
+ if (args == NULL)
+ return errno;
+
+ pflags = &args->pta_pflags;
+
+ /* build dtfs exec path from atf test dir */
+ sprintf(dtfs_path, "%s/../puffs/h_dtfs/h_dtfs",
+ atf_tc_get_config_var(tc, "srcdir"));
+ dtfsargv[0] = dtfs_path;
+ dtfsargv[1] = __UNCONST("-i");
+ dtfsargv[2] = __UNCONST("dtfs");
+ dtfsargv[3] = __UNCONST("fictional");
+ dtfsargv[4] = NULL;
+
+ /* Create sucketpair for communication with the real file server */
+ if (socketpair(PF_LOCAL, SOCK_STREAM, 0, sv) == -1)
+ return errno;
+
+ switch ((childpid = fork())) {
+ case 0:
+ close(sv[1]);
+ snprintf(comfd, sizeof(sv[0]), "%d", sv[0]);
+ if (setenv("PUFFS_COMFD", comfd, 1) == -1)
+ return errno;
+
+ if (execvp(dtfsargv[0], dtfsargv) == -1)
+ return errno;
+ case -1:
+ return errno;
Home |
Main Index |
Thread Index |
Old Index