Module Name:    src
Committed By:   pooka
Date:           Sun Oct 11 17:54:22 UTC 2009

Modified Files:
        src/sys/rump/librump/rumpvfs: rumpfs.c

Log Message:
Support creating file system sockets (non-sockets not supported in
VOP_CREATE since I don't want to have to write read/write support
for non-etfs files).


To generate a diff of this commit:
cvs rdiff -u -r1.25 -r1.26 src/sys/rump/librump/rumpvfs/rumpfs.c

Please note that diffs are not public domain; they are subject to the
copyright notices on the relevant files.

Modified files:

Index: src/sys/rump/librump/rumpvfs/rumpfs.c
diff -u src/sys/rump/librump/rumpvfs/rumpfs.c:1.25 src/sys/rump/librump/rumpvfs/rumpfs.c:1.26
--- src/sys/rump/librump/rumpvfs/rumpfs.c:1.25	Wed Oct  7 09:17:54 2009
+++ src/sys/rump/librump/rumpvfs/rumpfs.c	Sun Oct 11 17:54:22 2009
@@ -1,4 +1,4 @@
-/*	$NetBSD: rumpfs.c,v 1.25 2009/10/07 09:17:54 pooka Exp $	*/
+/*	$NetBSD: rumpfs.c,v 1.26 2009/10/11 17:54:22 pooka Exp $	*/
 
 /*
  * Copyright (c) 2007 Antti Kantee.  All Rights Reserved.
@@ -28,7 +28,7 @@
  */
 
 #include <sys/cdefs.h>
-__KERNEL_RCSID(0, "$NetBSD: rumpfs.c,v 1.25 2009/10/07 09:17:54 pooka Exp $");
+__KERNEL_RCSID(0, "$NetBSD: rumpfs.c,v 1.26 2009/10/11 17:54:22 pooka Exp $");
 
 #include <sys/param.h>
 #include <sys/atomic.h>
@@ -59,6 +59,7 @@
 static int rump_vop_getattr(void *);
 static int rump_vop_mkdir(void *);
 static int rump_vop_mknod(void *);
+static int rump_vop_create(void *);
 static int rump_vop_inactive(void *);
 static int rump_vop_reclaim(void *);
 static int rump_vop_success(void *);
@@ -82,6 +83,7 @@
 	{ &vop_getattr_desc, rump_vop_getattr },
 	{ &vop_mkdir_desc, rump_vop_mkdir },
 	{ &vop_mknod_desc, rump_vop_mknod },
+	{ &vop_create_desc, rump_vop_create },
 	{ &vop_access_desc, rump_vop_success },
 	{ &vop_read_desc, rump_vop_read },
 	{ &vop_write_desc, rump_vop_write },
@@ -371,7 +373,8 @@
 		vpops = rump_vnodeop_p;
 	}
 	if (vpops != rump_specop_p && va->va_type != VDIR
-	    && !(va->va_type == VREG && rn->rn_hostpath != NULL))
+	    && !(va->va_type == VREG && rn->rn_hostpath != NULL)
+	    && va->va_type != VSOCK)
 		return EOPNOTSUPP;
 
 	rv = getnewvnode(VT_RUMP, &rump_mnt, vpops, &vp);
@@ -563,6 +566,47 @@
 }
 
 static int
+rump_vop_create(void *v)
+{
+	struct vop_create_args /* {
+		struct vnode *a_dvp;
+		struct vnode **a_vpp;
+		struct componentname *a_cnp;
+		struct vattr *a_vap;
+	}; */ *ap = v;
+	struct vnode *dvp = ap->a_dvp;
+	struct vnode **vpp = ap->a_vpp;
+	struct componentname *cnp = ap->a_cnp;
+	struct vattr *va = ap->a_vap;
+	struct rumpfs_node *rnd = dvp->v_data, *rn;
+	struct rumpfs_dent *rdent;
+	int rv;
+
+	if (va->va_type != VSOCK) {
+		rv = EOPNOTSUPP;
+		goto out;
+	}
+	rn = makeprivate(VSOCK, NODEV, DEV_BSIZE, NULL);
+	mutex_enter(&reclock);
+	rv = makevnode(rn, vpp);
+	mutex_exit(&reclock);
+	if (rv)
+		goto out;
+
+	rdent = kmem_alloc(sizeof(*rdent), KM_SLEEP);
+	rdent->rd_name = kmem_alloc(cnp->cn_namelen+1, KM_SLEEP);
+	rdent->rd_node = (*vpp)->v_data;
+	rdent->rd_node->rn_va.va_rdev = NODEV;
+	strlcpy(rdent->rd_name, cnp->cn_nameptr, cnp->cn_namelen+1);
+
+	LIST_INSERT_HEAD(&rnd->rn_dir, rdent, rd_entries);
+
+ out:
+	vput(dvp);
+	return rv;
+}
+
+static int
 rump_vop_open(void *v)
 {
 	struct vop_open_args /* {

Reply via email to