1 b8c14089 2003-11-23 devnull #include <u.h>
2 b8c14089 2003-11-23 devnull #include <libc.h>
3 b8c14089 2003-11-23 devnull #include <regexp.h>
4 b8c14089 2003-11-23 devnull #include <thread.h>
5 b8c14089 2003-11-23 devnull #include <plumb.h>
6 b8c14089 2003-11-23 devnull #include <fcall.h>
7 b8c14089 2003-11-23 devnull #include "plumber.h"
9 32f69c36 2003-12-11 devnull int debug;
10 b8c14089 2003-11-23 devnull char *plumbfile;
11 b8c14089 2003-11-23 devnull char *user;
12 b8c14089 2003-11-23 devnull char *home;
13 b8c14089 2003-11-23 devnull char *progname;
14 b8c14089 2003-11-23 devnull Ruleset **rules;
15 b8c14089 2003-11-23 devnull int printerrors=1;
16 b8c14089 2003-11-23 devnull jmp_buf parsejmp;
17 b8c14089 2003-11-23 devnull char *lasterror;
20 b8c14089 2003-11-23 devnull makeports(Ruleset *rules[])
24 b8c14089 2003-11-23 devnull for(i=0; rules[i]; i++)
25 b8c14089 2003-11-23 devnull addport(rules[i]->port);
29 b8c14089 2003-11-23 devnull threadmain(int argc, char *argv[])
31 b8c14089 2003-11-23 devnull char buf[512];
34 b8c14089 2003-11-23 devnull progname = "plumber";
36 b8c14089 2003-11-23 devnull ARGBEGIN{
37 32f69c36 2003-12-11 devnull case 'd':
38 32f69c36 2003-12-11 devnull debug = 1;
40 b8c14089 2003-11-23 devnull case 'p':
41 b8c14089 2003-11-23 devnull plumbfile = ARGF();
45 32f69c36 2003-12-11 devnull user = getuser();
46 c8b6342d 2005-01-13 devnull home = getenv("HOME");
47 b8c14089 2003-11-23 devnull if(user==nil || home==nil)
48 b8c14089 2003-11-23 devnull error("can't initialize $user or $home: %r");
49 b8c14089 2003-11-23 devnull if(plumbfile == nil){
50 b8c14089 2003-11-23 devnull sprint(buf, "%s/lib/plumbing", home);
51 8ad51794 2004-03-25 devnull if(access(buf, 0) >= 0)
52 8ad51794 2004-03-25 devnull plumbfile = estrdup(buf);
54 8ad51794 2004-03-25 devnull plumbfile = unsharp("#9/plumb/initial.plumbing");
57 b8c14089 2003-11-23 devnull fd = open(plumbfile, OREAD);
58 b8c14089 2003-11-23 devnull if(fd < 0)
59 b8c14089 2003-11-23 devnull error("can't open rules file %s: %r", plumbfile);
60 b8c14089 2003-11-23 devnull if(setjmp(parsejmp))
61 b8c14089 2003-11-23 devnull error("parse error");
63 b8c14089 2003-11-23 devnull rules = readrules(plumbfile, fd);
64 b8c14089 2003-11-23 devnull close(fd);
67 df49b303 2004-12-28 devnull * Start all processes and threads from other proc
68 df49b303 2004-12-28 devnull * so we (main pid) can return to user.
70 f4b26b64 2005-01-04 devnull printerrors = 0;
71 f4b26b64 2005-01-04 devnull makeports(rules);
72 f4b26b64 2005-01-04 devnull startfsys();
73 df49b303 2004-12-28 devnull threadexits(nil);
77 b8c14089 2003-11-23 devnull error(char *fmt, ...)
79 b8c14089 2003-11-23 devnull char buf[512];
80 b8c14089 2003-11-23 devnull va_list args;
82 b8c14089 2003-11-23 devnull va_start(args, fmt);
83 b8c14089 2003-11-23 devnull vseprint(buf, buf+sizeof buf, fmt, args);
84 b8c14089 2003-11-23 devnull va_end(args);
86 b8c14089 2003-11-23 devnull fprint(2, "%s: %s\n", progname, buf);
87 b8c14089 2003-11-23 devnull threadexitsall("error");
91 b8c14089 2003-11-23 devnull parseerror(char *fmt, ...)
93 b8c14089 2003-11-23 devnull char buf[512];
94 b8c14089 2003-11-23 devnull va_list args;
96 b8c14089 2003-11-23 devnull va_start(args, fmt);
97 b8c14089 2003-11-23 devnull vseprint(buf, buf+sizeof buf, fmt, args);
98 b8c14089 2003-11-23 devnull va_end(args);
100 b8c14089 2003-11-23 devnull if(printerrors){
101 b8c14089 2003-11-23 devnull printinputstack();
102 b8c14089 2003-11-23 devnull fprint(2, "%s\n", buf);
104 b8c14089 2003-11-23 devnull do; while(popinput());
105 b8c14089 2003-11-23 devnull lasterror = estrdup(buf);
106 b8c14089 2003-11-23 devnull longjmp(parsejmp, 1);
110 b8c14089 2003-11-23 devnull emalloc(long n)
112 b8c14089 2003-11-23 devnull void *p;
114 b8c14089 2003-11-23 devnull p = malloc(n);
115 b8c14089 2003-11-23 devnull if(p == nil)
116 b8c14089 2003-11-23 devnull error("malloc failed: %r");
117 b8c14089 2003-11-23 devnull memset(p, 0, n);
118 b8c14089 2003-11-23 devnull return p;
122 b8c14089 2003-11-23 devnull erealloc(void *p, long n)
124 b8c14089 2003-11-23 devnull p = realloc(p, n);
125 b8c14089 2003-11-23 devnull if(p == nil)
126 b8c14089 2003-11-23 devnull error("realloc failed: %r");
127 b8c14089 2003-11-23 devnull return p;
131 b8c14089 2003-11-23 devnull estrdup(char *s)
133 b8c14089 2003-11-23 devnull char *t;
135 b8c14089 2003-11-23 devnull t = strdup(s);
136 b8c14089 2003-11-23 devnull if(t == nil)
137 b8c14089 2003-11-23 devnull error("estrdup failed: %r");
138 b8c14089 2003-11-23 devnull return t;