Blame


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 <bio.h>
4 b8c14089 2003-11-23 devnull #include <regexp.h>
5 b8c14089 2003-11-23 devnull #include <thread.h>
6 b8c14089 2003-11-23 devnull #include <plumb.h>
7 b8c14089 2003-11-23 devnull #include "plumber.h"
8 b8c14089 2003-11-23 devnull
9 32f69c36 2003-12-11 devnull /*
10 b8c14089 2003-11-23 devnull static char*
11 b8c14089 2003-11-23 devnull nonnil(char *s)
12 b8c14089 2003-11-23 devnull {
13 b8c14089 2003-11-23 devnull if(s == nil)
14 b8c14089 2003-11-23 devnull return "";
15 b8c14089 2003-11-23 devnull return s;
16 b8c14089 2003-11-23 devnull }
17 32f69c36 2003-12-11 devnull */
18 b8c14089 2003-11-23 devnull
19 b8c14089 2003-11-23 devnull int
20 b8c14089 2003-11-23 devnull verbis(int obj, Plumbmsg *m, Rule *r)
21 b8c14089 2003-11-23 devnull {
22 b8c14089 2003-11-23 devnull switch(obj){
23 b8c14089 2003-11-23 devnull default:
24 b8c14089 2003-11-23 devnull fprint(2, "unimplemented 'is' object %d\n", obj);
25 b8c14089 2003-11-23 devnull break;
26 b8c14089 2003-11-23 devnull case OData:
27 b8c14089 2003-11-23 devnull return strcmp(m->data, r->qarg) == 0;
28 b8c14089 2003-11-23 devnull case ODst:
29 b8c14089 2003-11-23 devnull return strcmp(m->dst, r->qarg) == 0;
30 b8c14089 2003-11-23 devnull case OType:
31 b8c14089 2003-11-23 devnull return strcmp(m->type, r->qarg) == 0;
32 b8c14089 2003-11-23 devnull case OWdir:
33 b8c14089 2003-11-23 devnull return strcmp(m->wdir, r->qarg) == 0;
34 b8c14089 2003-11-23 devnull case OSrc:
35 b8c14089 2003-11-23 devnull return strcmp(m->src, r->qarg) == 0;
36 b8c14089 2003-11-23 devnull }
37 b8c14089 2003-11-23 devnull return 0;
38 b8c14089 2003-11-23 devnull }
39 b8c14089 2003-11-23 devnull
40 b8c14089 2003-11-23 devnull static void
41 b8c14089 2003-11-23 devnull setvar(Resub rs[10], char *match[10])
42 b8c14089 2003-11-23 devnull {
43 b8c14089 2003-11-23 devnull int i, n;
44 b8c14089 2003-11-23 devnull
45 b8c14089 2003-11-23 devnull for(i=0; i<10; i++){
46 b8c14089 2003-11-23 devnull free(match[i]);
47 b8c14089 2003-11-23 devnull match[i] = nil;
48 b8c14089 2003-11-23 devnull }
49 32f69c36 2003-12-11 devnull for(i=0; i<10 && rs[i].s.sp!=nil; i++){
50 32f69c36 2003-12-11 devnull n = rs[i].e.ep-rs[i].s.sp;
51 b8c14089 2003-11-23 devnull match[i] = emalloc(n+1);
52 32f69c36 2003-12-11 devnull memmove(match[i], rs[i].s.sp, n);
53 b8c14089 2003-11-23 devnull match[i][n] = '\0';
54 b8c14089 2003-11-23 devnull }
55 b8c14089 2003-11-23 devnull }
56 b8c14089 2003-11-23 devnull
57 b8c14089 2003-11-23 devnull int
58 b8c14089 2003-11-23 devnull clickmatch(Reprog *re, char *text, Resub rs[10], int click)
59 b8c14089 2003-11-23 devnull {
60 b8c14089 2003-11-23 devnull char *clickp;
61 b8c14089 2003-11-23 devnull int i, w;
62 b8c14089 2003-11-23 devnull Rune r;
63 b8c14089 2003-11-23 devnull
64 b8c14089 2003-11-23 devnull /* click is in characters, not bytes */
65 b8c14089 2003-11-23 devnull for(i=0; i<click && text[i]!='\0'; i+=w)
66 b8c14089 2003-11-23 devnull w = chartorune(&r, text+i);
67 b8c14089 2003-11-23 devnull clickp = text+i;
68 b8c14089 2003-11-23 devnull for(i=0; i<=click; i++){
69 b8c14089 2003-11-23 devnull memset(rs, 0, 10*sizeof(Resub));
70 b8c14089 2003-11-23 devnull if(regexec(re, text+i, rs, 10))
71 32f69c36 2003-12-11 devnull if(rs[0].s.sp<=clickp && clickp<=rs[0].e.ep)
72 b8c14089 2003-11-23 devnull return 1;
73 b8c14089 2003-11-23 devnull }
74 b8c14089 2003-11-23 devnull return 0;
75 b8c14089 2003-11-23 devnull }
76 b8c14089 2003-11-23 devnull
77 b8c14089 2003-11-23 devnull int
78 b8c14089 2003-11-23 devnull verbmatches(int obj, Plumbmsg *m, Rule *r, Exec *e)
79 b8c14089 2003-11-23 devnull {
80 b8c14089 2003-11-23 devnull Resub rs[10];
81 b8c14089 2003-11-23 devnull char *clickval, *alltext;
82 b8c14089 2003-11-23 devnull int p0, p1, ntext;
83 b8c14089 2003-11-23 devnull
84 b8c14089 2003-11-23 devnull memset(rs, 0, sizeof rs);
85 b8c14089 2003-11-23 devnull ntext = -1;
86 b8c14089 2003-11-23 devnull switch(obj){
87 b8c14089 2003-11-23 devnull default:
88 b8c14089 2003-11-23 devnull fprint(2, "unimplemented 'matches' object %d\n", obj);
89 b8c14089 2003-11-23 devnull break;
90 b8c14089 2003-11-23 devnull case OData:
91 b8c14089 2003-11-23 devnull clickval = plumblookup(m->attr, "click");
92 b8c14089 2003-11-23 devnull if(clickval == nil){
93 b8c14089 2003-11-23 devnull alltext = m->data;
94 b8c14089 2003-11-23 devnull ntext = m->ndata;
95 b8c14089 2003-11-23 devnull goto caseAlltext;
96 b8c14089 2003-11-23 devnull }
97 b8c14089 2003-11-23 devnull if(!clickmatch(r->regex, m->data, rs, atoi(clickval)))
98 b8c14089 2003-11-23 devnull break;
99 32f69c36 2003-12-11 devnull p0 = rs[0].s.sp - m->data;
100 32f69c36 2003-12-11 devnull p1 = rs[0].e.ep - m->data;
101 b8c14089 2003-11-23 devnull if(e->p0 >=0 && !(p0==e->p0 && p1==e->p1))
102 b8c14089 2003-11-23 devnull break;
103 b8c14089 2003-11-23 devnull e->clearclick = 1;
104 b8c14089 2003-11-23 devnull e->setdata = 1;
105 b8c14089 2003-11-23 devnull e->p0 = p0;
106 b8c14089 2003-11-23 devnull e->p1 = p1;
107 b8c14089 2003-11-23 devnull setvar(rs, e->match);
108 b8c14089 2003-11-23 devnull return 1;
109 b8c14089 2003-11-23 devnull case ODst:
110 b8c14089 2003-11-23 devnull alltext = m->dst;
111 b8c14089 2003-11-23 devnull goto caseAlltext;
112 b8c14089 2003-11-23 devnull case OType:
113 b8c14089 2003-11-23 devnull alltext = m->type;
114 b8c14089 2003-11-23 devnull goto caseAlltext;
115 b8c14089 2003-11-23 devnull case OWdir:
116 b8c14089 2003-11-23 devnull alltext = m->wdir;
117 b8c14089 2003-11-23 devnull goto caseAlltext;
118 b8c14089 2003-11-23 devnull case OSrc:
119 b8c14089 2003-11-23 devnull alltext = m->src;
120 b8c14089 2003-11-23 devnull /* fall through */
121 b8c14089 2003-11-23 devnull caseAlltext:
122 b8c14089 2003-11-23 devnull /* must match full text */
123 b8c14089 2003-11-23 devnull if(ntext < 0)
124 b8c14089 2003-11-23 devnull ntext = strlen(alltext);
125 32f69c36 2003-12-11 devnull if(!regexec(r->regex, alltext, rs, 10) || rs[0].s.sp!=alltext || rs[0].e.ep!=alltext+ntext)
126 b8c14089 2003-11-23 devnull break;
127 b8c14089 2003-11-23 devnull setvar(rs, e->match);
128 b8c14089 2003-11-23 devnull return 1;
129 b8c14089 2003-11-23 devnull }
130 b8c14089 2003-11-23 devnull return 0;
131 b8c14089 2003-11-23 devnull }
132 b8c14089 2003-11-23 devnull
133 b8c14089 2003-11-23 devnull int
134 b8c14089 2003-11-23 devnull isfile(char *file, ulong maskon, ulong maskoff)
135 b8c14089 2003-11-23 devnull {
136 b8c14089 2003-11-23 devnull Dir *d;
137 b8c14089 2003-11-23 devnull int mode;
138 b8c14089 2003-11-23 devnull
139 b8c14089 2003-11-23 devnull d = dirstat(file);
140 b8c14089 2003-11-23 devnull if(d == nil)
141 b8c14089 2003-11-23 devnull return 0;
142 b8c14089 2003-11-23 devnull mode = d->mode;
143 b8c14089 2003-11-23 devnull free(d);
144 b8c14089 2003-11-23 devnull if((mode & maskon) == 0)
145 b8c14089 2003-11-23 devnull return 0;
146 b8c14089 2003-11-23 devnull if(mode & maskoff)
147 b8c14089 2003-11-23 devnull return 0;
148 b8c14089 2003-11-23 devnull return 1;
149 b8c14089 2003-11-23 devnull }
150 b8c14089 2003-11-23 devnull
151 b8c14089 2003-11-23 devnull char*
152 b8c14089 2003-11-23 devnull absolute(char *dir, char *file)
153 b8c14089 2003-11-23 devnull {
154 b8c14089 2003-11-23 devnull char *p;
155 b8c14089 2003-11-23 devnull
156 b8c14089 2003-11-23 devnull if(file[0] == '/')
157 b8c14089 2003-11-23 devnull return estrdup(file);
158 b8c14089 2003-11-23 devnull p = emalloc(strlen(dir)+1+strlen(file)+1);
159 b8c14089 2003-11-23 devnull sprint(p, "%s/%s", dir, file);
160 b8c14089 2003-11-23 devnull return cleanname(p);
161 b8c14089 2003-11-23 devnull }
162 b8c14089 2003-11-23 devnull
163 b8c14089 2003-11-23 devnull int
164 b8c14089 2003-11-23 devnull verbisfile(int obj, Plumbmsg *m, Rule *r, Exec *e, ulong maskon, ulong maskoff, char **var)
165 b8c14089 2003-11-23 devnull {
166 b8c14089 2003-11-23 devnull char *file;
167 b8c14089 2003-11-23 devnull
168 b8c14089 2003-11-23 devnull switch(obj){
169 b8c14089 2003-11-23 devnull default:
170 b8c14089 2003-11-23 devnull fprint(2, "unimplemented 'isfile' object %d\n", obj);
171 b8c14089 2003-11-23 devnull break;
172 b8c14089 2003-11-23 devnull case OArg:
173 b8c14089 2003-11-23 devnull file = absolute(m->wdir, expand(e, r->arg, nil));
174 b8c14089 2003-11-23 devnull if(isfile(file, maskon, maskoff)){
175 b8c14089 2003-11-23 devnull *var = file;
176 b8c14089 2003-11-23 devnull return 1;
177 b8c14089 2003-11-23 devnull }
178 b8c14089 2003-11-23 devnull free(file);
179 b8c14089 2003-11-23 devnull break;
180 b8c14089 2003-11-23 devnull case OData:
181 b8c14089 2003-11-23 devnull case OWdir:
182 b8c14089 2003-11-23 devnull file = absolute(m->wdir, obj==OData? m->data : m->wdir);
183 b8c14089 2003-11-23 devnull if(isfile(file, maskon, maskoff)){
184 b8c14089 2003-11-23 devnull *var = file;
185 b8c14089 2003-11-23 devnull return 1;
186 b8c14089 2003-11-23 devnull }
187 b8c14089 2003-11-23 devnull free(file);
188 b8c14089 2003-11-23 devnull break;
189 b8c14089 2003-11-23 devnull }
190 b8c14089 2003-11-23 devnull return 0;
191 b8c14089 2003-11-23 devnull }
192 b8c14089 2003-11-23 devnull
193 b8c14089 2003-11-23 devnull int
194 b8c14089 2003-11-23 devnull verbset(int obj, Plumbmsg *m, Rule *r, Exec *e)
195 b8c14089 2003-11-23 devnull {
196 b8c14089 2003-11-23 devnull char *new;
197 b8c14089 2003-11-23 devnull
198 b8c14089 2003-11-23 devnull switch(obj){
199 b8c14089 2003-11-23 devnull default:
200 b8c14089 2003-11-23 devnull fprint(2, "unimplemented 'is' object %d\n", obj);
201 b8c14089 2003-11-23 devnull break;
202 b8c14089 2003-11-23 devnull case OData:
203 b8c14089 2003-11-23 devnull new = estrdup(expand(e, r->arg, nil));
204 b8c14089 2003-11-23 devnull m->ndata = strlen(new);
205 b8c14089 2003-11-23 devnull free(m->data);
206 b8c14089 2003-11-23 devnull m->data = new;
207 b8c14089 2003-11-23 devnull e->p0 = -1;
208 b8c14089 2003-11-23 devnull e->p1 = -1;
209 b8c14089 2003-11-23 devnull e->setdata = 0;
210 b8c14089 2003-11-23 devnull return 1;
211 b8c14089 2003-11-23 devnull case ODst:
212 b8c14089 2003-11-23 devnull new = estrdup(expand(e, r->arg, nil));
213 b8c14089 2003-11-23 devnull free(m->dst);
214 b8c14089 2003-11-23 devnull m->dst = new;
215 b8c14089 2003-11-23 devnull return 1;
216 b8c14089 2003-11-23 devnull case OType:
217 b8c14089 2003-11-23 devnull new = estrdup(expand(e, r->arg, nil));
218 b8c14089 2003-11-23 devnull free(m->type);
219 b8c14089 2003-11-23 devnull m->type = new;
220 b8c14089 2003-11-23 devnull return 1;
221 b8c14089 2003-11-23 devnull case OWdir:
222 b8c14089 2003-11-23 devnull new = estrdup(expand(e, r->arg, nil));
223 b8c14089 2003-11-23 devnull free(m->wdir);
224 b8c14089 2003-11-23 devnull m->wdir = new;
225 b8c14089 2003-11-23 devnull return 1;
226 b8c14089 2003-11-23 devnull case OSrc:
227 b8c14089 2003-11-23 devnull new = estrdup(expand(e, r->arg, nil));
228 b8c14089 2003-11-23 devnull free(m->src);
229 b8c14089 2003-11-23 devnull m->src = new;
230 b8c14089 2003-11-23 devnull return 1;
231 b8c14089 2003-11-23 devnull }
232 b8c14089 2003-11-23 devnull return 0;
233 b8c14089 2003-11-23 devnull }
234 b8c14089 2003-11-23 devnull
235 b8c14089 2003-11-23 devnull int
236 b8c14089 2003-11-23 devnull verbadd(int obj, Plumbmsg *m, Rule *r, Exec *e)
237 b8c14089 2003-11-23 devnull {
238 b8c14089 2003-11-23 devnull switch(obj){
239 b8c14089 2003-11-23 devnull default:
240 b8c14089 2003-11-23 devnull fprint(2, "unimplemented 'add' object %d\n", obj);
241 b8c14089 2003-11-23 devnull break;
242 b8c14089 2003-11-23 devnull case OAttr:
243 b8c14089 2003-11-23 devnull m->attr = plumbaddattr(m->attr, plumbunpackattr(expand(e, r->arg, nil)));
244 b8c14089 2003-11-23 devnull return 1;
245 b8c14089 2003-11-23 devnull }
246 b8c14089 2003-11-23 devnull return 0;
247 b8c14089 2003-11-23 devnull }
248 b8c14089 2003-11-23 devnull
249 b8c14089 2003-11-23 devnull int
250 b8c14089 2003-11-23 devnull verbdelete(int obj, Plumbmsg *m, Rule *r, Exec *e)
251 b8c14089 2003-11-23 devnull {
252 b8c14089 2003-11-23 devnull char *a;
253 b8c14089 2003-11-23 devnull
254 b8c14089 2003-11-23 devnull switch(obj){
255 b8c14089 2003-11-23 devnull default:
256 b8c14089 2003-11-23 devnull fprint(2, "unimplemented 'delete' object %d\n", obj);
257 b8c14089 2003-11-23 devnull break;
258 b8c14089 2003-11-23 devnull case OAttr:
259 b8c14089 2003-11-23 devnull a = expand(e, r->arg, nil);
260 b8c14089 2003-11-23 devnull if(plumblookup(m->attr, a) == nil)
261 b8c14089 2003-11-23 devnull break;
262 b8c14089 2003-11-23 devnull m->attr = plumbdelattr(m->attr, a);
263 b8c14089 2003-11-23 devnull return 1;
264 b8c14089 2003-11-23 devnull }
265 b8c14089 2003-11-23 devnull return 0;
266 b8c14089 2003-11-23 devnull }
267 b8c14089 2003-11-23 devnull
268 b8c14089 2003-11-23 devnull int
269 b8c14089 2003-11-23 devnull matchpat(Plumbmsg *m, Exec *e, Rule *r)
270 b8c14089 2003-11-23 devnull {
271 b8c14089 2003-11-23 devnull switch(r->verb){
272 b8c14089 2003-11-23 devnull default:
273 b8c14089 2003-11-23 devnull fprint(2, "unimplemented verb %d\n", r->verb);
274 b8c14089 2003-11-23 devnull break;
275 b8c14089 2003-11-23 devnull case VAdd:
276 b8c14089 2003-11-23 devnull return verbadd(r->obj, m, r, e);
277 b8c14089 2003-11-23 devnull case VDelete:
278 b8c14089 2003-11-23 devnull return verbdelete(r->obj, m, r, e);
279 b8c14089 2003-11-23 devnull case VIs:
280 b8c14089 2003-11-23 devnull return verbis(r->obj, m, r);
281 b8c14089 2003-11-23 devnull case VIsdir:
282 b8c14089 2003-11-23 devnull return verbisfile(r->obj, m, r, e, DMDIR, 0, &e->dir);
283 b8c14089 2003-11-23 devnull case VIsfile:
284 b8c14089 2003-11-23 devnull return verbisfile(r->obj, m, r, e, ~DMDIR, DMDIR, &e->file);
285 b8c14089 2003-11-23 devnull case VMatches:
286 b8c14089 2003-11-23 devnull return verbmatches(r->obj, m, r, e);
287 b8c14089 2003-11-23 devnull case VSet:
288 b8c14089 2003-11-23 devnull verbset(r->obj, m, r, e);
289 b8c14089 2003-11-23 devnull return 1;
290 b8c14089 2003-11-23 devnull }
291 b8c14089 2003-11-23 devnull return 0;
292 b8c14089 2003-11-23 devnull }
293 b8c14089 2003-11-23 devnull
294 b8c14089 2003-11-23 devnull void
295 b8c14089 2003-11-23 devnull freeexec(Exec *exec)
296 b8c14089 2003-11-23 devnull {
297 b8c14089 2003-11-23 devnull int i;
298 b8c14089 2003-11-23 devnull
299 b8c14089 2003-11-23 devnull if(exec == nil)
300 b8c14089 2003-11-23 devnull return;
301 b8c14089 2003-11-23 devnull free(exec->dir);
302 b8c14089 2003-11-23 devnull free(exec->file);
303 b8c14089 2003-11-23 devnull for(i=0; i<10; i++)
304 b8c14089 2003-11-23 devnull free(exec->match[i]);
305 b8c14089 2003-11-23 devnull free(exec);
306 b8c14089 2003-11-23 devnull }
307 b8c14089 2003-11-23 devnull
308 b8c14089 2003-11-23 devnull Exec*
309 b8c14089 2003-11-23 devnull newexec(Plumbmsg *m)
310 b8c14089 2003-11-23 devnull {
311 b8c14089 2003-11-23 devnull Exec *exec;
312 fa325e9b 2020-01-10 cross
313 b8c14089 2003-11-23 devnull exec = emalloc(sizeof(Exec));
314 b8c14089 2003-11-23 devnull exec->msg = m;
315 b8c14089 2003-11-23 devnull exec->p0 = -1;
316 b8c14089 2003-11-23 devnull exec->p1 = -1;
317 b8c14089 2003-11-23 devnull return exec;
318 b8c14089 2003-11-23 devnull }
319 b8c14089 2003-11-23 devnull
320 b8c14089 2003-11-23 devnull void
321 b8c14089 2003-11-23 devnull rewrite(Plumbmsg *m, Exec *e)
322 b8c14089 2003-11-23 devnull {
323 b8c14089 2003-11-23 devnull Plumbattr *a, *prev;
324 b8c14089 2003-11-23 devnull
325 b8c14089 2003-11-23 devnull if(e->clearclick){
326 b8c14089 2003-11-23 devnull prev = nil;
327 b8c14089 2003-11-23 devnull for(a=m->attr; a!=nil; a=a->next){
328 b8c14089 2003-11-23 devnull if(strcmp(a->name, "click") == 0){
329 b8c14089 2003-11-23 devnull if(prev == nil)
330 b8c14089 2003-11-23 devnull m->attr = a->next;
331 b8c14089 2003-11-23 devnull else
332 b8c14089 2003-11-23 devnull prev->next = a->next;
333 b8c14089 2003-11-23 devnull free(a->name);
334 fa325e9b 2020-01-10 cross free(a->value);
335 b8c14089 2003-11-23 devnull free(a);
336 b8c14089 2003-11-23 devnull break;
337 b8c14089 2003-11-23 devnull }
338 b8c14089 2003-11-23 devnull prev = a;
339 b8c14089 2003-11-23 devnull }
340 b8c14089 2003-11-23 devnull if(e->setdata){
341 b8c14089 2003-11-23 devnull free(m->data);
342 b8c14089 2003-11-23 devnull m->data = estrdup(expand(e, "$0", nil));
343 b8c14089 2003-11-23 devnull m->ndata = strlen(m->data);
344 b8c14089 2003-11-23 devnull }
345 b8c14089 2003-11-23 devnull }
346 b8c14089 2003-11-23 devnull }
347 b8c14089 2003-11-23 devnull
348 b8c14089 2003-11-23 devnull char**
349 b8c14089 2003-11-23 devnull buildargv(char *s, Exec *e)
350 b8c14089 2003-11-23 devnull {
351 b8c14089 2003-11-23 devnull char **av;
352 b8c14089 2003-11-23 devnull int ac;
353 b8c14089 2003-11-23 devnull
354 b8c14089 2003-11-23 devnull ac = 0;
355 b8c14089 2003-11-23 devnull av = nil;
356 b8c14089 2003-11-23 devnull for(;;){
357 b8c14089 2003-11-23 devnull av = erealloc(av, (ac+1) * sizeof(char*));
358 b8c14089 2003-11-23 devnull av[ac] = nil;
359 b8c14089 2003-11-23 devnull while(*s==' ' || *s=='\t')
360 b8c14089 2003-11-23 devnull s++;
361 b8c14089 2003-11-23 devnull if(*s == '\0')
362 b8c14089 2003-11-23 devnull break;
363 b8c14089 2003-11-23 devnull av[ac++] = estrdup(expand(e, s, &s));
364 b8c14089 2003-11-23 devnull }
365 b8c14089 2003-11-23 devnull return av;
366 b8c14089 2003-11-23 devnull }
367 b8c14089 2003-11-23 devnull
368 b8c14089 2003-11-23 devnull Exec*
369 b8c14089 2003-11-23 devnull matchruleset(Plumbmsg *m, Ruleset *rs)
370 b8c14089 2003-11-23 devnull {
371 b8c14089 2003-11-23 devnull int i;
372 b8c14089 2003-11-23 devnull Exec *exec;
373 b8c14089 2003-11-23 devnull
374 b8c14089 2003-11-23 devnull if(m->dst!=nil && m->dst[0]!='\0' && rs->port!=nil && strcmp(m->dst, rs->port)!=0)
375 b8c14089 2003-11-23 devnull return nil;
376 b8c14089 2003-11-23 devnull exec = newexec(m);
377 b8c14089 2003-11-23 devnull for(i=0; i<rs->npat; i++)
378 b8c14089 2003-11-23 devnull if(!matchpat(m, exec, rs->pat[i])){
379 b8c14089 2003-11-23 devnull freeexec(exec);
380 b8c14089 2003-11-23 devnull return nil;
381 b8c14089 2003-11-23 devnull }
382 b8c14089 2003-11-23 devnull if(rs->port!=nil && (m->dst==nil || m->dst[0]=='\0')){
383 b8c14089 2003-11-23 devnull free(m->dst);
384 b8c14089 2003-11-23 devnull m->dst = estrdup(rs->port);
385 b8c14089 2003-11-23 devnull }
386 b8c14089 2003-11-23 devnull rewrite(m, exec);
387 b8c14089 2003-11-23 devnull return exec;
388 b8c14089 2003-11-23 devnull }
389 b8c14089 2003-11-23 devnull
390 b8c14089 2003-11-23 devnull enum
391 b8c14089 2003-11-23 devnull {
392 b8c14089 2003-11-23 devnull NARGS = 100,
393 b8c14089 2003-11-23 devnull NARGCHAR = 8*1024,
394 32f69c36 2003-12-11 devnull EXECSTACK = 32*1024+(NARGS+1)*sizeof(char*)+NARGCHAR
395 b8c14089 2003-11-23 devnull };
396 b8c14089 2003-11-23 devnull
397 b8c14089 2003-11-23 devnull /* copy argv to stack and free the incoming strings, so we don't leak argument vectors */
398 b8c14089 2003-11-23 devnull void
399 b8c14089 2003-11-23 devnull stackargv(char **inargv, char *argv[NARGS+1], char args[NARGCHAR])
400 b8c14089 2003-11-23 devnull {
401 b8c14089 2003-11-23 devnull int i, n;
402 b8c14089 2003-11-23 devnull char *s, *a;
403 b8c14089 2003-11-23 devnull
404 b8c14089 2003-11-23 devnull s = args;
405 b8c14089 2003-11-23 devnull for(i=0; i<NARGS; i++){
406 b8c14089 2003-11-23 devnull a = inargv[i];
407 b8c14089 2003-11-23 devnull if(a == nil)
408 b8c14089 2003-11-23 devnull break;
409 b8c14089 2003-11-23 devnull n = strlen(a)+1;
410 b8c14089 2003-11-23 devnull if((s-args)+n >= NARGCHAR) /* too many characters */
411 b8c14089 2003-11-23 devnull break;
412 b8c14089 2003-11-23 devnull argv[i] = s;
413 b8c14089 2003-11-23 devnull memmove(s, a, n);
414 b8c14089 2003-11-23 devnull s += n;
415 b8c14089 2003-11-23 devnull free(a);
416 b8c14089 2003-11-23 devnull }
417 b8c14089 2003-11-23 devnull argv[i] = nil;
418 b8c14089 2003-11-23 devnull }
419 b8c14089 2003-11-23 devnull
420 b8c14089 2003-11-23 devnull
421 b8c14089 2003-11-23 devnull void
422 b8c14089 2003-11-23 devnull execproc(void *v)
423 b8c14089 2003-11-23 devnull {
424 32f69c36 2003-12-11 devnull int fd[3];
425 b8c14089 2003-11-23 devnull char **av;
426 32f69c36 2003-12-11 devnull char *args[NARGS+1], argc[NARGCHAR];
427 b8c14089 2003-11-23 devnull
428 32f69c36 2003-12-11 devnull fd[0] = open("/dev/null", OREAD);
429 32f69c36 2003-12-11 devnull fd[1] = dup(1, -1);
430 32f69c36 2003-12-11 devnull fd[2] = dup(2, -1);
431 b8c14089 2003-11-23 devnull av = v;
432 b8c14089 2003-11-23 devnull stackargv(av, args, argc);
433 b8c14089 2003-11-23 devnull free(av);
434 f063dad9 2004-02-29 devnull threadexec(nil, fd, args[0], args);
435 b8c14089 2003-11-23 devnull threadexits("can't exec");
436 b8c14089 2003-11-23 devnull }
437 b8c14089 2003-11-23 devnull
438 b8c14089 2003-11-23 devnull char*
439 b8c14089 2003-11-23 devnull startup(Ruleset *rs, Exec *e)
440 b8c14089 2003-11-23 devnull {
441 b8c14089 2003-11-23 devnull char **argv;
442 b8c14089 2003-11-23 devnull int i;
443 b8c14089 2003-11-23 devnull
444 b8c14089 2003-11-23 devnull if(rs != nil)
445 b8c14089 2003-11-23 devnull for(i=0; i<rs->nact; i++){
446 b8c14089 2003-11-23 devnull if(rs->act[i]->verb == VStart)
447 b8c14089 2003-11-23 devnull goto Found;
448 b8c14089 2003-11-23 devnull if(rs->act[i]->verb == VClient){
449 b8c14089 2003-11-23 devnull if(e->msg->dst==nil || e->msg->dst[0]=='\0')
450 b8c14089 2003-11-23 devnull return "no port for \"client\" rule";
451 b8c14089 2003-11-23 devnull e->holdforclient = 1;
452 b8c14089 2003-11-23 devnull goto Found;
453 b8c14089 2003-11-23 devnull }
454 b8c14089 2003-11-23 devnull }
455 b8c14089 2003-11-23 devnull return "no start action for plumb message";
456 b8c14089 2003-11-23 devnull
457 b8c14089 2003-11-23 devnull Found:
458 b8c14089 2003-11-23 devnull argv = buildargv(rs->act[i]->arg, e);
459 b8c14089 2003-11-23 devnull if(argv[0] == nil)
460 b8c14089 2003-11-23 devnull return "empty argument list";
461 f063dad9 2004-02-29 devnull threadcreate(execproc, argv, EXECSTACK);
462 b8c14089 2003-11-23 devnull return nil;
463 b8c14089 2003-11-23 devnull }