ref: bdd385803dcbccdf2750f7259a1784744541dec4
dir: /sys/src/cmd/upas/Mail/mbox.c/
#include <u.h>
#include <libc.h>
#include <bio.h>
#include <thread.h>
#include <plumb.h>
#include <ctype.h>
#include <regexp.h>
#include "mail.h"
typedef struct Fn Fn;
struct Fn {
char *name;
void (*fn)(char **, int);
};
enum {
Cevent,
Cseemail,
Cshowmail,
Csendmail,
Nchan,
};
char *maildir = "/mail/fs";
char *mailbox = "mbox";
char *savebox = "outgoing";
char *listfmt = "%>48s\t<%f>";
Mesg dead = {.messageid="", .hash=42};
Reprog *mesgpat;
int threadsort = 1;
int sender;
int plumbsendfd;
int plumbseemailfd;
int plumbshowmailfd;
int plumbsendmailfd;
Channel *cwait;
Mbox mbox;
static void showmesg(Biobuf*, Mesg*, int, int);
static void
plumbloop(Channel *ch, int fd)
{
Plumbmsg *m;
while(1){
if((m = plumbrecv(fd)) == nil)
threadexitsall("plumber gone");
sendp(ch, m);
}
}
static void
plumbshowmail(void*)
{
threadsetname("plumbshow %s", mbox.path);
plumbloop(mbox.show, plumbshowmailfd);
}
static void
plumbseemail(void*)
{
threadsetname("plumbsee %s", mbox.path);
plumbloop(mbox.see, plumbseemailfd);
}
static void
plumbsendmail(void*)
{
threadsetname("plumbsend %s", mbox.path);
plumbloop(mbox.send, plumbsendmailfd);
}
static void
eventread(void*)
{
Event *ev;
threadsetname("mbevent %s", mbox.path);
while(1){
ev = emalloc(sizeof(Event));
if(winevent(&mbox, ev) == -1)
break;
sendp(mbox.event, ev);
}
sendp(mbox.event, nil);
threadexits(nil);
}
static int
ideq(char *a, char *b)
{
if(a == nil || b == nil)
return 0;
return strcmp(a, b) == 0;
}
static int
cmpmesg(void *pa, void *pb)
{
Mesg *a, *b;
a = *(Mesg**)pa;
b = *(Mesg**)pb;
return b->time - a->time;
}
static int
rcmpmesg(void *pa, void *pb)
{
Mesg *a, *b;
a = *(Mesg**)pa;
b = *(Mesg**)pb;
return a->time - b->time;
}
static int
mesglineno(Mesg *msg, int *depth)
{
Mesg *p, *m;
int i, o, n, d;
o = 0;
d = 0;
n = 1;
/* Walk up to root, counting depth in the thread */
p = msg;
while(p->parent != nil){
m = p;
p = p->parent;
for(i = 0; i < p->nchild; i++){
if(p->child[i] == m)
break;
o += p->child[i]->nsub + 1;
}
if(!(p->state & (Sdummy|Szap))){
o++;
d++;
}
}
/* Find the thread in the thread list */
for(i = 0; i < mbox.nmesg; i++){
m = mbox.mesg[i];
if(m == p)
break;
if(m->state & Stoplev){
n += mbox.mesg[i]->nsub;
if(!(m->state & (Sdummy|Szap)))
n++;
}
}
if(depth != nil)
*depth = d;
assert(n + o <= mbox.nmesg);
return n + o;
}
static int
addchild(Mesg *p, Mesg *m, int d)
{
Mesg *q;
assert(m->parent == nil);
for(q = p; q != nil; q = q->parent){
/* some messages refer to themselves */
if(ideq(m->messageid, q->messageid))
return 0;
if(m->time > q->time)
q->time = m->time;
}
for(q = p; q != nil; q = q->parent)
q->nsub += d;
p->child = erealloc(p->child, ++p->nchild*sizeof(Mesg*));
p->child[p->nchild - 1] = m;
qsort(p->child, p->nchild, sizeof(Mesg*), rcmpmesg);
m->parent = p;
return 1;
}
static int
slotfor(Mesg *m)
{
int i;
for(i = 0; i < mbox.nmesg; i++)
if(cmpmesg(&mbox.mesg[i], &m) >= 0)
break;
return i;
}
static void
removeid(Mesg *m)
{
Mesg *e;
int i;
/* Dummies don't go in the table */
if(m->state & Sdummy)
return;
i = m->hash % mbox.hashsz;
while(1){
e = mbox.hash[i];
if(e == nil)
return;
if(e != &dead && e->hash == m->hash && strcmp(e->messageid, m->messageid) == 0){
mbox.hash[i] = &dead;
mbox.ndead++;
}
i = (i + 1) % mbox.hashsz;
}
}
Mesg*
lookupid(char *msgid)
{
u32int h, i;
Mesg *e;
if(msgid == nil || strlen(msgid) == 0)
return nil;
h = strhash(msgid);
i = h % mbox.hashsz;
while(1){
e = mbox.hash[i];
if(e == nil)
return nil;
if(e != &dead && e->hash == h && strcmp(e->messageid, msgid) == 0)
return e;
i = (i + 1) % mbox.hashsz;
}
}
static void
addmesg(Mesg *m, int ins)
{
Mesg *o, *e, **oldh;
int i, oldsz, idx;
/*
* on initial load, it's faster to append everything then sort,
* but on subsequent messages it's better to just put it in the
* right place; we don't want to shuffle the already-sorted
* messages.
*/
if(mbox.nmesg == mbox.mesgsz){
mbox.mesgsz *= 2;
mbox.mesg = erealloc(mbox.mesg, mbox.mesgsz*sizeof(Mesg*));
}
if(ins)
idx = slotfor(m);
else
idx = mbox.nmesg;
memmove(&mbox.mesg[idx + 1], &mbox.mesg[idx], (mbox.nmesg - idx)*sizeof(Mesg*));
mbox.mesg[idx] = m;
mbox.nmesg++;
if(m->messageid == nil)
return;
/* grow hash table, or squeeze out deadwood */
if(mbox.hashsz <= 2*(mbox.nmesg + mbox.ndead)){
oldsz = mbox.hashsz;
oldh = mbox.hash;
if(mbox.hashsz <= 2*mbox.nmesg)
mbox.hashsz *= 2;
mbox.ndead = 0;
mbox.hash = emalloc(mbox.hashsz*sizeof(Mesg*));
for(i = 0; i < oldsz; i++){
if((o = oldh[i]) == nil)
continue;
mbox.hash[o->hash % mbox.hashsz] = o;
}
free(oldh);
}
i = m->hash % mbox.hashsz;
while(1){
e = mbox.hash[i % mbox.hashsz];
if(e == nil || e == &dead)
break;
i = (i + 1) % mbox.hashsz;
}
mbox.hash[i] = m;
}
static Mesg *
placeholder(char *msgid, vlong time, int ins)
{
Mesg *m;
m = emalloc(sizeof(Mesg));
m->state |= Sdummy|Stoplev;
m->messageid = estrdup(msgid);
m->hash = strhash(msgid);
m->time = time;
addmesg(m, ins);
return m;
}
static Mesg*
change(char *name, char *digest)
{
Mesg *m;
char *f;
if((m = mesglookup(name, digest)) == nil)
return nil;
if((f = rslurp(m, "flags", nil)) == nil)
return nil;
free(m->mflags);
m->mflags = f;
m->flags &= ~(Fdel|Fseen|Fresp);
if(strchr(m->mflags, 'd')) m->flags |= Fdel;
if(strchr(m->mflags, 's')) m->flags |= Fseen;
if(strchr(m->mflags, 'a')) m->flags |= Fresp;
return m;
}
static Mesg*
delete(char *name, char *digest)
{
Mesg *m;
if((m = mesglookup(name, digest)) == nil)
return nil;
m->flags |= Fdel;
return m;
}
static Mesg*
load(char *name, char *digest, int ins)
{
Mesg *m, *p;
int d;
if(strncmp(name, mbox.path, strlen(mbox.path)) == 0)
name += strlen(mbox.path);
if((m = mesgload(name)) == nil)
goto error;
if(digest != nil && strcmp(digest, m->digest) != 0)
goto error;
/* if we already have a dummy, populate it */
d = 1;
p = lookupid(m->messageid);
if(p != nil && (p->state & Sdummy)){
d = p->nsub + 1;
m->child = p->child;
m->nchild = p->nchild;
m->nsub = p->nsub;
mesgclear(p);
memcpy(p, m, sizeof(*p));
free(m);
m = p;
}else{
/*
* if we raced a notify and a mailbox load, we
* can get duplicate load requests for the same
* name in the mailbox.
*/
if(p != nil && strcmp(p->name, m->name) == 0)
goto error;
addmesg(m, ins);
}
if(!threadsort || m->inreplyto == nil || ideq(m->messageid, m->inreplyto)){
m->state |= Stoplev;
return m;
}
p = lookupid(m->inreplyto);
if(p == nil)
p = placeholder(m->inreplyto, m->time, ins);
if(!addchild(p, m, d))
m->state |= Stoplev;
return m;
error:
mesgfree(m);
return nil;
}
void
mbredraw(Mesg *m, int add, int rec)
{
Biobuf *bfd;
int ln, depth;
ln = mesglineno(m, &depth);
fprint(mbox.addr, "%d%s", ln, add?"-#0":"");
bfd = bwindata(&mbox, OWRITE);
showmesg(bfd, m, depth, rec);
Bterm(bfd);
/* highlight the redrawn message */
fprint(mbox.addr, "%d%s", ln, add ? "-#0" : "");
fprint(mbox.ctl, "dot=addr\n");
}
static void
mbload(void)
{
int i, n, fd;
Dir *d;
mbox.mesgsz = 128;
mbox.hashsz = 128;
mbox.mesg = emalloc(mbox.mesgsz*sizeof(Mesg*));
mbox.hash = emalloc(mbox.hashsz*sizeof(Mesg*));
mbox.path = esmprint("%s/%s/", maildir, mailbox);
cleanname(mbox.path);
n = strlen(mbox.path);
if(mbox.path[n - 1] != '/')
mbox.path[n] = '/';
if((fd = open(mbox.path, OREAD)) == -1)
sysfatal("%s: open: %r", mbox.path);
while(1){
n = dirread(fd, &d);
if(n == -1)
sysfatal("%s read: %r", mbox.path);
if(n == 0)
break;
for(i = 0; i < n; i++)
if(strcmp(d[i].name, "ctl") != 0)
load(d[i].name, nil, 0);
free(d);
}
qsort(mbox.mesg, mbox.nmesg, sizeof(Mesg*), cmpmesg);
}
static char*
getflag(Mesg *m)
{
char* flag;
flag = "★";
if(m->flags & Fseen) flag = " ";
if(m->flags & Fresp) flag = "←";
if(m->flags & Fdel) flag = "∉";
if(m->flags & Ftodel) flag = "∉";
return flag;
}
static void
printw(Biobuf *bp, char *s, int width)
{
char *dots;
if(width <= 0)
Bprint(bp, "%s", s);
else{
dots = "";
if(utflen(s) > width){
width -= 1;
dots = "…";
}
Bprint(bp, "%*.*s%s", -width, width, s, dots);
}
}
/*
* Message format string:
* ======================
* %s: subject
* %f: from address
* %F: name + from address
* %t: to address
* %c: CC address
* %r: replyto address
* %[...]: string to display for child messages
* %{...}: date format string
*/
static void
fmtmesg(Biobuf *bp, char *fmt, Mesg *m, int depth)
{
char *p, *e, buf[64];
int width, i, indent;
Tm tm;
Bprint(bp, "%-6s\t%s ", m->name, getflag(m));
for(p = fmt; *p; p++){
if(*p != '%'){
Bputc(bp, *p);
continue;
}
p++;
width = 0;
indent = 0;
while(*p == '>'){
p++;
indent++;
}
while('0'<=*p && *p<='9')
width = width * 10 + *p++ - '0';
for(i = 0; indent && i < depth; i++){
Bputc(bp, '\t');
width -= 4;
if(indent == 1)
break;
}
switch(*p){
case '%':
Bprint(bp, "%%");
break;
case 'i':
if(depth > 0)
depth = 1;
case 'I':
for(i = 0; i < depth; i++){
if(width>0)
Bprint(bp, "%*s", width, "");
else
Bprint(bp, "\t");
}
break;
case 's':
printw(bp, m->subject, width);
break;
case 'f':
printw(bp, m->from, width);
break;
case 'F':
printw(bp, m->fromcolon, width);
break;
case 't':
printw(bp, m->to, width);
break;
case 'c':
printw(bp, m->cc, width);
break;
case 'r':
printw(bp, m->replyto, width);
break;
case '[':
p++;
if((e = strchr(p, ']')) == nil)
sysfatal("missing closing '}' in %%{");
if(e - p >= sizeof(buf) - 1)
sysfatal("%%{} contents too long");
snprint(buf, sizeof(buf), "%.*s", (int)(e - p), p);
if(depth > 0)
Bprint(bp, "%s", buf);
p = e;
break;
case '{':
p++;
if((e = strchr(p, '}')) == nil)
sysfatal("missing closing '}' in %%{");
if(e - p >= sizeof(buf) - 1)
sysfatal("%%{} contents too long");
snprint(buf, sizeof(buf), "%.*s", (int)(e - p), p);
tmtime(&tm, m->time, nil);
Bprint(bp, "%τ", tmfmt(&tm, buf));
p = e;
break;
default:
sysfatal("invalid directive '%%%c' in format string", *p);
break;
}
}
Bputc(bp, '\n');
}
static void
showmesg(Biobuf *bfd, Mesg *m, int depth, int recurse)
{
int i;
if(!(m->state & Sdummy)){
fmtmesg(bfd, listfmt, m, depth);
depth++;
}
if(recurse && mbox.view != Vflat)
for(i = 0; i < m->nchild; i++)
showmesg(bfd, m->child[i], depth, recurse);
}
static void
mark(char **f, int nf, char *fstr, int flags, int add)
{
char *sel, *p, *q, *e, *path;
int i, q0, q1, fd;
Mesg *m;
if(flags == 0)
return;
wingetsel(&mbox, &q0, &q1);
if(nf == 0){
sel = winreadsel(&mbox);
for(p = sel; p != nil; p = e){
if((e = strchr(p, '\n')) != nil)
*e++ = 0;
if(!matchmesg(&mbox, p))
continue;
if((q = strchr(p, '/')) != nil)
q[1] = 0;
if((m = mesglookup(p, nil)) != nil){
if(add)
m->flags |= flags;
else
m->flags &= ~flags;
if(fstr != nil && strlen(fstr) != 0){
path = estrjoin(mbox.path, "/", m->name, "/flags", nil);
if((fd = open(path, OWRITE)) != -1){
fprint(fd, fstr);
close(fd);
}
free(path);
}
mbredraw(m, 0, 0);
}
}
free(sel);
}else for(i = 0; i < nf; i++){
if((m = mesglookup(f[i], nil)) != nil){
m->flags |= flags;
mbredraw(m, 0, 0);
}
}
winsetsel(&mbox, q0, q1);
}
static void
mbmark(char **f, int nf)
{
int add, flg;
if(nf == 0){
fprint(2, "missing fstr");
return;
}
if((flg = mesgflagparse(f[0], &add)) == -1){
fprint(2, "Mark: invalid flags %s\n", f[0]);
return;
}
mark(f+1, nf-1, f[0], flg, add);
}
static void
relinkmsg(Mesg *p, Mesg *m)
{
Mesg *c, *pp;
int i, j;
/* remove child, preserving order */
j = 0;
for(i = 0; p && i < p->nchild; i++){
if(p->child[i] != m)
p->child[j++] = p->child[i];
}
p->nchild = j;
for(pp = p; pp != nil; pp = pp->parent)
pp->nsub -= m->nsub + 1;
/* reparent children */
for(i = 0; i < m->nchild; i++){
c = m->child[i];
c->parent = nil;
addchild(p, c, c->nsub + 1);
}
}
static void
mbflush(char **, int)
{
int i, j, ln, fd;
char *path;
Mesg *m, *p;
path = estrjoin(maildir, "/ctl", nil);
fd = open(path, OWRITE);
free(path);
if(fd == -1)
sysfatal("open mbox: %r");
for(i = 0; i < mbox.nmesg; i++){
m = mbox.mesg[i];
p = m->parent;
if(m->state & (Sopen|Szap) || (m->flags & (Fdel|Ftodel)) == 0)
continue;
ln = mesglineno(m, nil);
fprint(mbox.addr, "%d,%d", ln, ln+m->nsub);
write(mbox.data, "", 0);
if(m->flags & Ftodel)
fprint(fd, "delete %s %d", mailbox, atoi(m->name));
removeid(m);
m->state |= Szap;
if(p == nil && m->nsub != 0){
p = placeholder(m->messageid, m->time, 1);
p->nsub = m->nsub + 1;
}
if(p != nil)
relinkmsg(p, m);
for(j = 0; j < m->nchild; j++)
mbredraw(m->child[j], 1, 1);
}
for(i = 0, j = 0; i < mbox.nmesg; i++){
m = mbox.mesg[i];
if((m->state & Szap) != 0)
mesgfree(m);
else
mbox.mesg[j++] = m;
}
mbox.nmesg = j;
close(fd);
fprint(mbox.ctl, "clean\n");
}
static void
mbcompose(char **, int)
{
compose("", nil, 0);
}
static void
delmesg(char **f, int nf)
{
mark(f, nf, nil, Ftodel, 1);
}
static void
undelmesg(char **f, int nf)
{
mark(f, nf, nil, Ftodel, 0);
}
static void
showlist(void)
{
Biobuf *bfd;
Mesg *m;
int i;
bfd = bwindata(&mbox, OWRITE);
for(i = 0; i < mbox.nmesg; i++){
m = mbox.mesg[i];
if(mbox.view == Vflat || m->state & (Sdummy|Stoplev))
showmesg(bfd, m, 0, 1);
}
Bterm(bfd);
fprint(mbox.addr, "0");
fprint(mbox.ctl, "dot=addr\n");
fprint(mbox.ctl, "show\n");
}
static void
quitall(char **, int)
{
Mesg *m;
Comp *c;
if(mbox.nopen > 0 && !mbox.canquit){
fprint(2, "Del: %d open messages\n", mbox.nopen);
mbox.canquit = 1;
return;
}
for(m = mbox.openmesg; m != nil; m = m->qnext)
fprint(m->ctl, "del\n");
for(c = mbox.opencomp; c != nil; c = c->qnext)
fprint(c->ctl, "del\n");
fprint(mbox.ctl, "del\n");
threadexitsall(nil);
}
/*
* shuffle a message to the right location
* in the list without doing a full sort.
*/
static void
reinsert(Mesg *m)
{
int i, idx;
idx = slotfor(m);
for(i = idx; i < mbox.nmesg; i++)
if(mbox.mesg[i] == m)
break;
memmove(&mbox.mesg[idx + 1], &mbox.mesg[idx], (i - idx)*sizeof(Mesg*));
mbox.mesg[idx] = m;
}
static void
changemesg(Plumbmsg *pm)
{
char *digest, *action;
Mesg *m, *r;
int ln, nr;
digest = plumblookup(pm->attr, "digest");
action = plumblookup(pm->attr, "mailtype");
if(digest == nil || action == nil)
return;
if(strcmp(action, "new") == 0){
if((m = load(pm->data, digest, 1)) == nil)
return;
for(r = m; r->parent != nil; r = r->parent)
/* nothing */;
/* Bump whole thread up in list */
if(r->nsub > 0){
ln = mesglineno(r, nil);
nr = r->nsub-1;
if(!(r->state & Sdummy))
nr++;
/*
* We can end up with an empty container
* in an edge case.
*
* Imagine we have a dummy message with
* a child, and that child gets deleted,
* then a new message comes in replying
* to that dummy.
*
* In this case, r->nsub == 1 due to the
* newly added message, so nr=0.
* in that case, skip the redraw, and
* reinsert the dummy in the right place.
*/
if(nr > 0){
fprint(mbox.addr, "%d,%d", ln, ln+nr-1);
write(mbox.data, "", 0);
}
reinsert(r);
}
mbredraw(r, 1, 1);
}else if(strcmp(action, "delete") == 0){
if((m = delete(pm->data, digest)) != nil)
mbredraw(m, 0, 0);
}else if(strcmp(action, "modify") == 0){
if((m = change(pm->data, digest)) != nil)
mbredraw(m, 0, 0);
}
}
static void
viewmesg(Plumbmsg *pm)
{
Mesg *m;
m = mesgopen(pm->data, plumblookup(pm->attr, "digest"));
if(m != nil){
fprint(mbox.addr, "%d", mesglineno(m, nil));
fprint(mbox.ctl, "dot=addr\n");
fprint(mbox.ctl, "show\n");
}
}
static void
redraw(char **, int)
{
fprint(mbox.addr, ",");
showlist();
}
static void
nextunread(char **, int)
{
fprint(mbox.ctl, "addr=dot\n");
fprint(mbox.addr, "/^[0-9]+\\/ *\t★.*");
fprint(mbox.ctl, "dot=addr\n");
fprint(mbox.ctl, "show\n");
}
Fn mboxfn[] = {
{"Put", mbflush},
{"Mail", mbcompose},
{"Delmesg", delmesg},
{"Undelmesg", undelmesg},
{"Del", quitall},
{"Redraw", redraw},
{"Next", nextunread},
{"Mark", mbmark},
#ifdef NOTYET
{"Filter", filter},
{"Get", mbrefresh},
#endif
{nil}
};
static void
doevent(Event *ev)
{
char *f[32];
int nf;
Fn *p;
if(ev->action != 'M')
return;
switch(ev->type){
case 'l':
case 'L':
if(matchmesg(&mbox, ev->text))
if(mesgopen(ev->text, nil) != nil)
break;
winreturn(&mbox, ev);
break;
case 'x':
case 'X':
if((nf = tokenize(ev->text, f, nelem(f))) == 0)
return;
for(p = mboxfn; p->fn != nil; p++)
if(strcmp(p->name, f[0]) == 0 && p->fn != nil){
p->fn(&f[1], nf - 1);
break;
}
if(p->fn == nil)
winreturn(&mbox, ev);
else if(p->fn != quitall)
mbox.canquit = 0;
break;
}
}
static void
execlog(void*)
{
Waitmsg *w;
while(1){
w = recvp(cwait);
if(w->msg[0] != 0)
fprint(2, "%d: %s\n", w->pid, w->msg);
free(w);
}
}
static void
mbmain(void *cmd)
{
Event *ev;
Plumbmsg *psee, *pshow, *psend;
Alt a[] = {
[Cevent] = {mbox.event, &ev, CHANRCV},
[Cseemail] = {mbox.see, &psee, CHANRCV},
[Cshowmail] = {mbox.show, &pshow, CHANRCV},
[Csendmail] = {mbox.send, &psend, CHANRCV},
[Nchan] = {nil, nil, CHANEND},
};
threadsetname("mbox %s", mbox.path);
wininit(&mbox, mbox.path);
wintagwrite(&mbox, "Put Mail Delmesg Undelmesg Next Mark +s");
showlist();
fprint(mbox.ctl, "dump %s\n", cmd);
fprint(mbox.ctl, "clean\n");
proccreate(eventread, nil, Stack);
while(1){
switch(alt(a)){
case Cevent:
doevent(ev);
free(ev);
break;
case Cseemail:
changemesg(psee);
plumbfree(psee);
break;
case Cshowmail:
viewmesg(pshow);
plumbfree(pshow);
break;
case Csendmail:
compose(psend->data, nil, 0);
plumbfree(psend);
break;
}
}
}
static void
usage(void)
{
fprint(2, "usage: %s [-T] [-m mailfs] [-s] [-f format] [mbox]\n", argv0);
exits("usage");
}
void
threadmain(int argc, char **argv)
{
Fmt fmt;
char *cmd;
int i;
mbox.view = Vgroup;
doquote = needsrcquote;
quotefmtinstall();
tmfmtinstall();
fmtstrinit(&fmt);
for(i = 0; i < argc; i++)
fmtprint(&fmt, "%q ", argv[i]);
cmd = fmtstrflush(&fmt);
if(cmd == nil)
sysfatal("out of memory");
ARGBEGIN{
case 'm':
maildir = EARGF(usage());
break;
case 'T':
mbox.view = Vflat;
break;
case 's':
sender++;
break;
case 'f':
listfmt = EARGF(usage());
break;
case 'O':
savebox = nil;
break;
case 'o':
savebox = EARGF(usage());
break;
default:
usage();
break;
}ARGEND;
if(argc > 1)
usage();
if(argc == 1)
mailbox = argv[0];
mesgpat = regcomp("([0-9]+)(/.*)?");
cwait = threadwaitchan();
/* open these early so we won't miss messages while loading */
mbox.event = chancreate(sizeof(Event*), 0);
mbox.see = chancreate(sizeof(Plumbmsg*), 0);
mbox.show = chancreate(sizeof(Plumbmsg*), 0);
mbox.send = chancreate(sizeof(Plumbmsg*), 0);
plumbsendfd = plumbopen("send", OWRITE|OCEXEC);
plumbseemailfd = plumbopen("seemail", OREAD|OCEXEC);
plumbshowmailfd = plumbopen("showmail", OREAD|OCEXEC);
mbload();
proccreate(plumbseemail, nil, Stack);
proccreate(plumbshowmail, nil, Stack);
/* avoid duplicate sends when multiple mailboxes are open */
if(sender || strcmp(mailbox, "mbox") == 0){
plumbsendmailfd = plumbopen("sendmail", OREAD|OCEXEC);
proccreate(plumbsendmail, nil, Stack);
}
threadcreate(execlog, nil, Stack);
threadcreate(mbmain, cmd, Stack);
threadexits(nil);
}