From 336df1ddf15d36dfa658adab290056c912edfbbd Mon Sep 17 00:00:00 2001
From: David du Colombier <0intro@gmail.com>
Date: Sun, 21 Mar 1993 00:00:00 +0000
Subject: [PATCH] Plan 9 from Bell Labs 1993-03-21

---
 port/dev.c    | 11 ++++++-----
 port/devmnt.c | 51 ++++++++++++++++++++++++++++++++++-----------------
 2 files changed, 40 insertions(+), 22 deletions(-)

diff --git a/port/dev.c b/port/dev.c
index f181c02fd5e270fe71c9b82fa53ef3c7fdbc16b7..b97ec88f98fb08e698aba0709785fedfc4883a68 100644
--- a/port/dev.c
+++ b/port/dev.c
@@ -124,8 +124,10 @@ devstat(Chan *c, char *db, Dirtab *tab, int ntab, Devgen *gen)
 	int i;
 	Dir dir;
 
-	for(i=0;; i++)
+	for(i=0;; i++) {
 		switch((*gen)(c, tab, ntab, i, &dir)){
+		case 0:
+			break;
 		case -1:
 			/*
 			 *  given a channel, we cannot derive the directory name
@@ -138,17 +140,16 @@ devstat(Chan *c, char *db, Dirtab *tab, int ntab, Devgen *gen)
 				return;
 			}
 			print("%s %s: devstat %C %lux\n", u->p->text, u->p->user,
-							devchar[c->type], c->qid.path);
+						devchar[c->type], c->qid.path);
 			error(Enonexist);
-		case 0:
-			break;
 		case 1:
-			if(eqqid(c->qid, dir.qid)){
+			if(eqqid(c->qid, dir.qid)) {
 				convD2M(&dir, db);
 				return;
 			}
 			break;
 		}
+	}
 }
 
 long
diff --git a/port/devmnt.c b/port/devmnt.c
index 761b4a24f04d8b11c1a70fc048cf3860878c7e4f..5909d2328d1dddc988a5793b5c68a7b15ca1ea91 100644
--- a/port/devmnt.c
+++ b/port/devmnt.c
@@ -29,7 +29,7 @@ struct Mnt
 	Mntrpc	*queue;		/* Queue of pending requests on this channel */
 	int	id;		/* Multiplexor id for channel check */
 	Mnt	*list;		/* Free list */
-	char	mux;		/* Set if the device aleady does the multiplexing */
+	char	mux;		/* Set if the device does the multiplexing */
 	int	blocksize;	/* read/write block size */
 	ushort	flushtag;	/* Tag to send flush on */
 	ushort	flushbase;	/* Base tag of flush window for this buffer */
@@ -65,6 +65,7 @@ void	mountio(Mnt*, Mntrpc*);
 void	mountmux(Mnt*, Mntrpc*);
 void	mountrpc(Mnt*, Mntrpc*);
 int	rpcattn(Mntrpc*);
+void	mclose(Mnt*);
 
 enum
 {
@@ -91,7 +92,7 @@ Chan*
 mntattach(char *muxattach)
 {
 	Mnt *m;
-	Chan *c;
+	Chan *c, *mc;
 	struct bogus{
 		Chan	*chan;
 		char	*spec;
@@ -114,6 +115,7 @@ mntattach(char *muxattach)
 			unlock(m);	
 		}
 	}
+
 	m = mntalloc.mntfree;
 	if(m != 0)
 		mntalloc.mntfree = m->list;	
@@ -151,13 +153,21 @@ mntattach(char *muxattach)
 	unlock(m);
 
 	if(waserror()) {
-		close(m->c);
-		if(decref(m) == 0)
-			mntpntfree(m);
+		mclose(m);
 		nexterror();
 	}
 
 	c = mattach(m, bogus.spec, bogus.serv);
+
+	mc = m->c;
+	if(mc->type == devno('M', 0)) {
+		c->mntptr = mc->mntptr;
+		c->mchan = c->mntptr->c;
+		c->mqid = c->qid;
+		incref(c->mntptr);
+		mclose(m);
+	}
+
 	poperror();
 	return c;
 }
@@ -391,21 +401,28 @@ mntclunk(Chan *c, int t)
 }
 
 void
-mntdoclunk(Mnt *m, Mntrpc *r)
+mclose(Mnt *m)
 {
-	Mntrpc *q;
+	Mntrpc *q, *r;
 
-	mntfree(r);
-	if(decref(m) == 0) {
-		for(q = m->queue; q; q = r) {
-			r = q->list;
-			q->flushed = 0;
-			mntfree(q);
-		}
-		m->id = 0;
-		close(m->c);
-		mntpntfree(m);
+	if(decref(m) != 0)
+		return;
+
+	for(q = m->queue; q; q = r) {
+		r = q->list;
+		q->flushed = 0;
+		mntfree(q);
 	}
+	m->id = 0;
+	close(m->c);
+	mntpntfree(m);
+}
+
+void
+mntdoclunk(Mnt *m, Mntrpc *r)
+{
+	mntfree(r);
+	mclose(m);
 }
 
 void