commit - 34049f27b8f8974dd2ff368c959914afffaaa162
commit + 7ce2007ce514e427bfd0b37bc79013d3425f4033
blob - cde9e986476a0556574cc0e3d3bb86a242ec3b72
blob + 8d1e7a0248cff4d9e99e4cc639bc6a7eccba9df1
--- src/cmd/upas/common/config.c
+++ src/cmd/upas/common/config.c
char *_UPASLOG = "#9/sys/log";
char *_UPASLIB = "#9/mail/lib";
char *_UPASBIN= "#9/bin/upas";
-char *_UPASTMP = "#9/mail/tmp";
+char *_UPASTMP = "/var/tmp";
char *_SHELL = "#9/bin/rc";
char *_POST = "#9/sys/lib/post/dispatch";
blob - 2df5a98731fc02620edb8bde4ab0b096e644f65f
blob + d4685000e985feaf1d988247a300dd524d96c5da
--- src/cmd/upas/marshal/marshal.c
+++ src/cmd/upas/marshal/marshal.c
#include "common.h"
+#include <thread.h>
+#include <9pclient.h>
#include <ctype.h>
+enum
+{
+ STACK = 32768
+};
+
#define inline _inline
typedef struct Attach Attach;
struct Attach {
Attach *next;
char *path;
+ int fd;
char *type;
int inline;
Ctype *ctype;
void freealias(Alias*);
void freealiases(Alias*);
int doublequote(Fmt*);
+int mountmail(void);
+int nprocexec;
int rflag, lbflag, xflag, holding, nflag, Fflag, eightflag, dflag;
int pgpflag = 0;
char lastchar;
char *replymsg;
+CFsys *mailfs;
+
enum
{
Ok = 0,
{
fprint(2, "usage: %s [-Fr#xn] [-s subject] [-c ccrecipient] [-t type] [-aA attachment] [-p[es]] [-R replymsg] -8 | recipient-list\n",
argv0);
- exits("usage");
+ threadexitsall("usage");
}
void
va_end(arg);
fprint(2, "%s: %s\n", argv0, buf);
holdoff(holding);
- exits(buf);
+ threadexitsall(buf);
}
void
-main(int argc, char **argv)
+threadmain(int argc, char **argv)
{
Attach *first, **l, *a;
char *subject, *type, *boundary;
quotefmtinstall();
fmtinstall('Z', doublequote);
+ threadwaitchan();
ARGBEGIN{
case 't':
- type = ARGF();
- if(type == nil)
- usage();
+ type = EARGF(usage());
break;
case 'a':
flags = 0;
case 'A':
flags = 1;
aflag:
- a = mkattach(ARGF(), type, flags);
+ a = mkattach(EARGF(usage()), type, flags);
if(a == nil)
- exits("bad args");
+ threadexitsall("bad args");
type = nil;
*l = a;
l = &a->next;
ccargc++;
break;
case 'R':
- replymsg = ARGF();
+ replymsg = EARGF(usage());
break;
case 's':
- subject = ARGF();
+ subject = EARGF(usage());
break;
case 'F':
Fflag = 1; // file message
eightflag = 1;
break;
case 'p': // pgp flag: encrypt, sign, or both
- if(pgpopts(ARGF()) < 0)
+ if(pgpopts(EARGF(usage())) < 0)
sysfatal("bad pgp options");
break;
default:
case Nomessage: // no message, just exit mimicking old behavior
noinput = 1;
if(first == nil)
- exits(0);
+ threadexitsall(0);
break;
}
}
fd = sendmail(to, cc, &pid, Fflag ? argv[0] : nil);
if(fd < 0)
sysfatal("execing sendmail: %r\n:");
+fprint(2, "sendmail fd %d\n", fd);
if(xflag || lbflag || dflag){
close(fd);
- exits(waitforsubprocs());
+ threadexitsall(waitforsubprocs());
}
if(Binit(&out, fd, OWRITE) < 0)
if(printsubject(&out, subject) < 0)
fatal("writing");
if(replymsg != nil)
- if(printinreplyto(&out, replymsg) < 0)
- fatal("writing");
+ printinreplyto(&out, replymsg); /* ignore errors */
Bprint(&out, "MIME-Version: 1.0\n");
if(pgpflag){ // interpose pgp process between us and sendmail to handle body
Bterm(&out);
close(fd);
- exits(waitforsubprocs());
+ threadexitsall(waitforsubprocs());
}
// evaluate pgp option string
Biobuf *f;
char *p;
+ f = emalloc(sizeof *f);
+ Binit(f, a->fd, OREAD);
// if it's already mime encoded, just copy
if(strcmp(a->type, "mime") == 0){
- f = Bopen(a->path, OREAD);
- if(f == nil){
- /* hack: give marshal time to stdin, before we kill it (for dead.letter) */
- sleep(500);
- postnote(PNPROC, pid, "interrupt");
- sysfatal("opening %s: %r", a->path);
- }
copy(f, out);
Bterm(f);
+ free(f);
+ return;
}
// if it's not already mime encoded ...
Bprint(out, "Content-Disposition: attachment; filename=%Z\n", p);
}
- f = Bopen(a->path, OREAD);
- if(f == nil){
- /* hack: give marshal time to stdin, before we kill it (for dead.letter) */
- sleep(500);
- postnote(PNPROC, pid, "interrupt");
- sysfatal("opening %s: %r", a->path);
- }
-
/* dump our local 'From ' line when passing along mail messages */
if(strcmp(a->type, "message/rfc822") == 0){
p = Brdline(f, '\n');
body64(f, out);
}
Bterm(f);
+ free(f);
}
char *ascwday[] =
int
printinreplyto(Biobuf *out, char *dir)
{
- String *s = s_copy(dir);
+ String *s;
char buf[256];
int fd;
int n;
+ if(mountmail() < 0)
+ return -1;
+ if(strncmp(dir, "Mail/", 5) != 0)
+ return -1;
+ s = s_copy(dir+5);
s_append(s, "/messageid");
- fd = open(s_to_c(s), OREAD);
+ fd = fsopenfd(mailfs, s_to_c(s), OREAD);
s_free(s);
if(fd < 0)
- return 0;
- n = read(fd, buf, sizeof(buf)-1);
+ return -1;
+ n = readn(fd, buf, sizeof(buf)-1);
close(fd);
if(n <= 0)
- return 0;
+ return -1;
buf[n] = 0;
return Bprint(out, "In-Reply-To: %s\n", buf);
}
Attach *a;
char ftype[64];
char *p;
- int n, pfd[2];
+ int fd, n, pfd[2], xfd[3];
if(file == nil)
return nil;
- if(access(file, 4) == -1){
+ if((fd = open(file, OREAD)) < 0)
+ if(strncmp(file, "Mail/", 5) != 0 || mountmail() < 0 || (fd = fsopenfd(mailfs, file+5, OREAD)) < 0){
fprint(2, "%s: %s can't read file\n", argv0, file);
return nil;
}
a = emalloc(sizeof(*a));
+ a->fd = fd;
a->path = file;
a->next = nil;
a->type = type;
a->type = "application/octet-stream"; // safest default
if(pipe(pfd) < 0)
return a;
- switch(fork()){
- case -1:
- break;
- case 0:
- close(pfd[1]);
- close(0);
- dup(pfd[0], 0);
- close(1);
- dup(pfd[0], 1);
- execl(unsharp("#9/bin/file"), "file", "-m", file, nil);
- exits(0);
- default:
- close(pfd[0]);
- n = read(pfd[1], ftype, sizeof(ftype));
- if(n > 0){
- ftype[n-1] = 0;
- a->type = estrdup(ftype);
- }
- close(pfd[1]);
- waitpid();
- break;
+
+ xfd[0] = pfd[0];
+ xfd[1] = pfd[0];
+ xfd[2] = dup(2, -1);
+ if((pid=threadspawnl(xfd, unsharp("#9/bin/file"), "file", "-m", file, nil)) < 0){
+ close(xfd[0]);
+ close(xfd[2]);
+ return a;
}
+ /* threadspawnl closed pfd[0] */
+ n = readn(pfd[1], ftype, sizeof(ftype));
+ if(n > 0){
+ ftype[n-1] = 0;
+ a->type = estrdup(ftype);
+ }
+ close(pfd[1]);
+ procwait(pid);
+
for(c = ctype; ; c++)
if(strncmp(a->type, c->type, strlen(c->type)) == 0){
a->ctype = c;
if(write(out2, buf, n) < 0)
break;
}
+}
+
+static void
+teeproc(void *v)
+{
+ int *a;
+
+ a = v;
+ tee(a[0], a[1], a[2]);
+ write(a[2], "\n", 1);
}
// print the unix from line
sendmail(Addr *to, Addr *cc, int *pid, char *rcvr)
{
char **av, **v;
- int ac, fd;
- int pfd[2];
+ int ac, fd, *targ;
+ int pfd[2], sfd, xfd[3];
String *cmd;
+ char *x;
Addr *a;
fd = -1;
v[ac] = 0;
if(pipe(pfd) < 0)
- fatal("%r");
- switch(*pid = fork()){
- case -1:
- fatal("%r");
- break;
- case 0:
- if(holding)
- close(holding);
- close(pfd[1]);
- dup(pfd[0], 0);
- close(pfd[0]);
+ fatal("pipe: %r");
+
+ xfd[0] = pfd[0];
+ xfd[1] = dup(1, -1);
+ xfd[2] = dup(2, -1);
- if(rcvr != nil){
- if(pipe(pfd) < 0)
- fatal("%r");
- switch(fork()){
- case -1:
- fatal("%r");
- break;
- case 0:
- close(pfd[0]);
- seek(fd, 0, 2);
- printunixfrom(fd);
- tee(0, pfd[1], fd);
- write(fd, "\n", 1);
- exits(0);
- default:
- close(fd);
- close(pfd[1]);
- dup(pfd[0], 0);
- break;
- }
- }
+ if(replymsg != nil)
+ putenv("replymsg", replymsg);
+ cmd = mboxpath("pipefrom", login, s_new(), 0);
- if(replymsg != nil)
- putenv("replymsg", replymsg);
-
- cmd = mboxpath("pipefrom", login, s_new(), 0);
- exec(s_to_c(cmd), av);
- exec("myupassend", av);
- exec(unsharp("#9/bin/upas/send"), av);
+ if((*pid = threadspawn(xfd, x=s_to_c(cmd), av)) < 0
+ && (*pid = threadspawn(xfd, x="myupassend", av)) < 0
+ && (*pid = threadspawn(xfd, x=unsharp("#9/bin/upas/send"), av)) < 0)
fatal("exec: %r");
- break;
- default:
- if(rcvr != nil)
- close(fd);
- close(pfd[0]);
- break;
+ /* threadspawn closed pfd[0] (== xfd[0]) */
+ sfd = pfd[1];
+
+fprint(2, "exec'ed %s\n", x);
+
+ if(rcvr != nil){
+fprint(2, "rcvr\n");
+ if(pipe(pfd) < 0)
+ fatal("pipe: %r");
+ seek(fd, 0, 2);
+ printunixfrom(fd);
+ targ = emalloc(3*sizeof targ[0]);
+ targ[0] = sfd;
+ targ[1] = pfd[0];
+ targ[2] = fd;
+ proccreate(teeproc, targ, STACK);
+ sfd = pfd[1];
}
- return pfd[1];
+
+ return sfd;
}
// start up pgp process and return an fd to talk to it with.
char *err;
err = nil;
- while((w = wait()) != nil){
- if(w->pid == pid || w->pid == pgppid){
- if(w->msg[0] != 0)
- err = estrdup(w->msg);
- }
- free(w);
- }
- if(err)
- exits(err);
+ if(pgppid >= 0 && (w=procwait(pgppid)) && w->msg[0])
+ err = w->msg;
+ if(pid >= 0 && (w=procwait(pid)) && w->msg[0])
+ err = w->msg;
return nil;
}
fmtrune(f, r);
}
return fmtrune(f, '"');
+}
+
+int
+mountmail(void)
+{
+ if(mailfs != nil)
+ return 0;
+ if((mailfs = nsmount("mail", nil)) == nil)
+ return -1;
+ return 0;
}
blob - afd93e3bee92debb91fbafa1a85da9b4727c1cea
blob + 34393a96a8f19f56d6d51603818e48f7e457db26
--- src/cmd/upas/send/message.c
+++ src/cmd/upas/send/message.c
mp->size += n;
if(n == VMLIMIT){
if(m_read_to_file(fp, mp) < 0){
- perror("m_read");
+ perror("m_read_to_file");
exit(1);
}
}
-
}
/*
blob - 9d9081500b03b694d8fdef69efb5b88930726b27
blob + bc8a7960fec47f60dcde5cb71feb6bac109bca97
--- src/cmd/upas/vf/vf.c
+++ src/cmd/upas/vf/vf.c
Mtype *m;
Mtype **l;
- b = Bopen(unsharp("#9/sys/lib/mimetype"), OREAD);
+ b = Bopen(unsharp("#9/lib/mimetype"), OREAD);
if(b == nil)
return;
