1 76193d7c 2003-09-30 devnull #include "sam.h"
3 76193d7c 2003-09-30 devnull uchar indata[DATASIZE];
4 76193d7c 2003-09-30 devnull uchar outdata[2*DATASIZE+3]; /* room for overflow message */
5 76193d7c 2003-09-30 devnull uchar *inp;
6 76193d7c 2003-09-30 devnull uchar *outp;
7 76193d7c 2003-09-30 devnull uchar *outmsg = outdata;
8 76193d7c 2003-09-30 devnull Posn cmdpt;
9 76193d7c 2003-09-30 devnull Posn cmdptadv;
10 76193d7c 2003-09-30 devnull Buffer snarfbuf;
11 76193d7c 2003-09-30 devnull int waitack;
12 78439d25 2007-01-12 devnull int outbuffered;
13 76193d7c 2003-09-30 devnull int tversion;
15 76193d7c 2003-09-30 devnull int inshort(void);
16 2c0f3733 2006-04-20 devnull long inlong(void);
17 2c0f3733 2006-04-20 devnull vlong invlong(void);
18 76193d7c 2003-09-30 devnull int inmesg(Tmesg);
20 2c0f3733 2006-04-20 devnull void outshort(int);
21 2c0f3733 2006-04-20 devnull void outlong(long);
22 2c0f3733 2006-04-20 devnull void outvlong(vlong);
23 2c0f3733 2006-04-20 devnull void outcopy(int, void*);
24 2c0f3733 2006-04-20 devnull void outsend(void);
25 2c0f3733 2006-04-20 devnull void outstart(Hmesg);
27 76193d7c 2003-09-30 devnull void setgenstr(File*, Posn, Posn);
29 76193d7c 2003-09-30 devnull #ifdef DEBUG
30 76193d7c 2003-09-30 devnull char *hname[] = {
31 76193d7c 2003-09-30 devnull [Hversion] "Hversion",
32 76193d7c 2003-09-30 devnull [Hbindname] "Hbindname",
33 76193d7c 2003-09-30 devnull [Hcurrent] "Hcurrent",
34 76193d7c 2003-09-30 devnull [Hnewname] "Hnewname",
35 76193d7c 2003-09-30 devnull [Hmovname] "Hmovname",
36 76193d7c 2003-09-30 devnull [Hgrow] "Hgrow",
37 76193d7c 2003-09-30 devnull [Hcheck0] "Hcheck0",
38 76193d7c 2003-09-30 devnull [Hcheck] "Hcheck",
39 76193d7c 2003-09-30 devnull [Hunlock] "Hunlock",
40 76193d7c 2003-09-30 devnull [Hdata] "Hdata",
41 76193d7c 2003-09-30 devnull [Horigin] "Horigin",
42 76193d7c 2003-09-30 devnull [Hunlockfile] "Hunlockfile",
43 76193d7c 2003-09-30 devnull [Hsetdot] "Hsetdot",
44 76193d7c 2003-09-30 devnull [Hgrowdata] "Hgrowdata",
45 76193d7c 2003-09-30 devnull [Hmoveto] "Hmoveto",
46 76193d7c 2003-09-30 devnull [Hclean] "Hclean",
47 76193d7c 2003-09-30 devnull [Hdirty] "Hdirty",
48 76193d7c 2003-09-30 devnull [Hcut] "Hcut",
49 76193d7c 2003-09-30 devnull [Hsetpat] "Hsetpat",
50 76193d7c 2003-09-30 devnull [Hdelname] "Hdelname",
51 76193d7c 2003-09-30 devnull [Hclose] "Hclose",
52 76193d7c 2003-09-30 devnull [Hsetsnarf] "Hsetsnarf",
53 76193d7c 2003-09-30 devnull [Hsnarflen] "Hsnarflen",
54 76193d7c 2003-09-30 devnull [Hack] "Hack",
55 76193d7c 2003-09-30 devnull [Hexit] "Hexit",
56 cbeb0b26 2006-04-01 devnull [Hplumb] "Hplumb"
59 76193d7c 2003-09-30 devnull char *tname[] = {
60 76193d7c 2003-09-30 devnull [Tversion] "Tversion",
61 76193d7c 2003-09-30 devnull [Tstartcmdfile] "Tstartcmdfile",
62 76193d7c 2003-09-30 devnull [Tcheck] "Tcheck",
63 76193d7c 2003-09-30 devnull [Trequest] "Trequest",
64 76193d7c 2003-09-30 devnull [Torigin] "Torigin",
65 76193d7c 2003-09-30 devnull [Tstartfile] "Tstartfile",
66 76193d7c 2003-09-30 devnull [Tworkfile] "Tworkfile",
67 76193d7c 2003-09-30 devnull [Ttype] "Ttype",
68 76193d7c 2003-09-30 devnull [Tcut] "Tcut",
69 76193d7c 2003-09-30 devnull [Tpaste] "Tpaste",
70 76193d7c 2003-09-30 devnull [Tsnarf] "Tsnarf",
71 76193d7c 2003-09-30 devnull [Tstartnewfile] "Tstartnewfile",
72 76193d7c 2003-09-30 devnull [Twrite] "Twrite",
73 76193d7c 2003-09-30 devnull [Tclose] "Tclose",
74 76193d7c 2003-09-30 devnull [Tlook] "Tlook",
75 76193d7c 2003-09-30 devnull [Tsearch] "Tsearch",
76 76193d7c 2003-09-30 devnull [Tsend] "Tsend",
77 76193d7c 2003-09-30 devnull [Tdclick] "Tdclick",
78 76193d7c 2003-09-30 devnull [Tstartsnarf] "Tstartsnarf",
79 76193d7c 2003-09-30 devnull [Tsetsnarf] "Tsetsnarf",
80 76193d7c 2003-09-30 devnull [Tack] "Tack",
81 76193d7c 2003-09-30 devnull [Texit] "Texit",
82 cbeb0b26 2006-04-01 devnull [Tplumb] "Tplumb"
86 76193d7c 2003-09-30 devnull journal(int out, char *s)
88 76193d7c 2003-09-30 devnull static int fd = 0;
90 76193d7c 2003-09-30 devnull if(fd <= 0)
91 76193d7c 2003-09-30 devnull fd = create("/tmp/sam.out", 1, 0666L);
92 76193d7c 2003-09-30 devnull fprint(fd, "%s%s\n", out? "out: " : "in: ", s);
96 76193d7c 2003-09-30 devnull journaln(int out, long n)
98 76193d7c 2003-09-30 devnull char buf[32];
100 2c0f3733 2006-04-20 devnull snprint(buf, sizeof buf, "%ld", n);
101 76193d7c 2003-09-30 devnull journal(out, buf);
105 2c0f3733 2006-04-20 devnull journalv(int out, vlong v)
107 2c0f3733 2006-04-20 devnull char buf[32];
109 2c0f3733 2006-04-20 devnull snprint(buf, sizeof buf, "%lld", v);
110 2c0f3733 2006-04-20 devnull journal(out, buf);
114 76193d7c 2003-09-30 devnull #define journal(a, b)
115 76193d7c 2003-09-30 devnull #define journaln(a, b)
119 76193d7c 2003-09-30 devnull rcvchar(void){
120 76193d7c 2003-09-30 devnull static uchar buf[64];
121 522b0689 2003-09-30 devnull static int i, nleft = 0;
123 76193d7c 2003-09-30 devnull if(nleft <= 0){
124 76193d7c 2003-09-30 devnull nleft = read(0, (char *)buf, sizeof buf);
125 76193d7c 2003-09-30 devnull if(nleft <= 0)
126 76193d7c 2003-09-30 devnull return -1;
129 76193d7c 2003-09-30 devnull --nleft;
130 76193d7c 2003-09-30 devnull return buf[i++];
134 76193d7c 2003-09-30 devnull rcv(void){
136 522b0689 2003-09-30 devnull static int state = 0;
137 522b0689 2003-09-30 devnull static int count = 0;
138 522b0689 2003-09-30 devnull static int i = 0;
140 76193d7c 2003-09-30 devnull while((c=rcvchar()) != -1)
141 76193d7c 2003-09-30 devnull switch(state){
143 76193d7c 2003-09-30 devnull h.type = c;
144 76193d7c 2003-09-30 devnull state++;
148 76193d7c 2003-09-30 devnull h.count0 = c;
149 76193d7c 2003-09-30 devnull state++;
153 76193d7c 2003-09-30 devnull h.count1 = c;
154 76193d7c 2003-09-30 devnull count = h.count0|(h.count1<<8);
156 76193d7c 2003-09-30 devnull if(count > DATASIZE)
157 76193d7c 2003-09-30 devnull panic("count>DATASIZE");
158 76193d7c 2003-09-30 devnull if(count == 0)
159 76193d7c 2003-09-30 devnull goto zerocount;
160 76193d7c 2003-09-30 devnull state++;
164 76193d7c 2003-09-30 devnull indata[i++] = c;
165 76193d7c 2003-09-30 devnull if(i == count){
166 76193d7c 2003-09-30 devnull zerocount:
167 76193d7c 2003-09-30 devnull indata[i] = 0;
168 76193d7c 2003-09-30 devnull state = count = 0;
169 76193d7c 2003-09-30 devnull return inmesg(h.type);
173 76193d7c 2003-09-30 devnull return 0;
177 76193d7c 2003-09-30 devnull whichfile(int tag)
181 76193d7c 2003-09-30 devnull for(i = 0; i<file.nused; i++)
182 76193d7c 2003-09-30 devnull if(file.filepptr[i]->tag==tag)
183 76193d7c 2003-09-30 devnull return file.filepptr[i];
184 76193d7c 2003-09-30 devnull hiccough((char *)0);
185 76193d7c 2003-09-30 devnull return 0;
189 76193d7c 2003-09-30 devnull inmesg(Tmesg type)
191 76193d7c 2003-09-30 devnull Rune buf[1025];
192 76193d7c 2003-09-30 devnull char cbuf[64];
193 76193d7c 2003-09-30 devnull int i, m;
194 76193d7c 2003-09-30 devnull short s;
195 76193d7c 2003-09-30 devnull long l, l1;
196 2c0f3733 2006-04-20 devnull vlong v;
197 76193d7c 2003-09-30 devnull File *f;
198 76193d7c 2003-09-30 devnull Posn p0, p1, p;
199 76193d7c 2003-09-30 devnull Range r;
200 76193d7c 2003-09-30 devnull String *str;
201 76193d7c 2003-09-30 devnull char *c, *wdir;
202 76193d7c 2003-09-30 devnull Rune *rp;
203 76193d7c 2003-09-30 devnull Plumbmsg *pm;
205 76193d7c 2003-09-30 devnull if(type > TMAX)
206 76193d7c 2003-09-30 devnull panic("inmesg");
208 76193d7c 2003-09-30 devnull journal(0, tname[type]);
210 76193d7c 2003-09-30 devnull inp = indata;
211 76193d7c 2003-09-30 devnull switch(type){
212 76193d7c 2003-09-30 devnull case -1:
213 76193d7c 2003-09-30 devnull panic("rcv error");
215 76193d7c 2003-09-30 devnull default:
216 76193d7c 2003-09-30 devnull fprint(2, "unknown type %d\n", type);
217 76193d7c 2003-09-30 devnull panic("rcv unknown");
219 76193d7c 2003-09-30 devnull case Tversion:
220 76193d7c 2003-09-30 devnull tversion = inshort();
221 76193d7c 2003-09-30 devnull journaln(0, tversion);
224 76193d7c 2003-09-30 devnull case Tstartcmdfile:
225 2c0f3733 2006-04-20 devnull v = invlong(); /* for 64-bit pointers */
226 2c0f3733 2006-04-20 devnull journaln(0, v);
227 76193d7c 2003-09-30 devnull Strdupl(&genstr, samname);
228 76193d7c 2003-09-30 devnull cmd = newfile();
229 76193d7c 2003-09-30 devnull cmd->unread = 0;
230 2c0f3733 2006-04-20 devnull outTsv(Hbindname, cmd->tag, v);
231 76193d7c 2003-09-30 devnull outTs(Hcurrent, cmd->tag);
232 76193d7c 2003-09-30 devnull logsetname(cmd, &genstr);
233 2c0f3733 2006-04-20 devnull cmd->rasp = listalloc('P');
234 76193d7c 2003-09-30 devnull cmd->mod = 0;
235 76193d7c 2003-09-30 devnull if(cmdstr.n){
236 76193d7c 2003-09-30 devnull loginsert(cmd, 0L, cmdstr.s, cmdstr.n);
237 76193d7c 2003-09-30 devnull Strdelete(&cmdstr, 0L, (Posn)cmdstr.n);
239 76193d7c 2003-09-30 devnull fileupdate(cmd, FALSE, TRUE);
240 76193d7c 2003-09-30 devnull outT0(Hunlock);
243 76193d7c 2003-09-30 devnull case Tcheck:
244 76193d7c 2003-09-30 devnull /* go through whichfile to check the tag */
245 76193d7c 2003-09-30 devnull outTs(Hcheck, whichfile(inshort())->tag);
248 76193d7c 2003-09-30 devnull case Trequest:
249 76193d7c 2003-09-30 devnull f = whichfile(inshort());
250 76193d7c 2003-09-30 devnull p0 = inlong();
251 76193d7c 2003-09-30 devnull p1 = p0+inshort();
252 76193d7c 2003-09-30 devnull journaln(0, p0);
253 76193d7c 2003-09-30 devnull journaln(0, p1-p0);
254 76193d7c 2003-09-30 devnull if(f->unread)
255 76193d7c 2003-09-30 devnull panic("Trequest: unread");
256 522b0689 2003-09-30 devnull if(p1>f->b.nc)
257 522b0689 2003-09-30 devnull p1 = f->b.nc;
258 522b0689 2003-09-30 devnull if(p0>f->b.nc) /* can happen e.g. scrolling during command */
259 522b0689 2003-09-30 devnull p0 = f->b.nc;
260 76193d7c 2003-09-30 devnull if(p0 == p1){
262 76193d7c 2003-09-30 devnull r.p1 = r.p2 = p0;
264 76193d7c 2003-09-30 devnull r = rdata(f->rasp, p0, p1-p0);
265 76193d7c 2003-09-30 devnull i = r.p2-r.p1;
266 522b0689 2003-09-30 devnull bufread(&f->b, r.p1, buf, i);
268 76193d7c 2003-09-30 devnull buf[i]=0;
269 76193d7c 2003-09-30 devnull outTslS(Hdata, f->tag, r.p1, tmprstr(buf, i+1));
272 76193d7c 2003-09-30 devnull case Torigin:
273 76193d7c 2003-09-30 devnull s = inshort();
274 76193d7c 2003-09-30 devnull l = inlong();
275 76193d7c 2003-09-30 devnull l1 = inlong();
276 76193d7c 2003-09-30 devnull journaln(0, l1);
277 76193d7c 2003-09-30 devnull lookorigin(whichfile(s), l, l1);
280 76193d7c 2003-09-30 devnull case Tstartfile:
281 76193d7c 2003-09-30 devnull termlocked++;
282 76193d7c 2003-09-30 devnull f = whichfile(inshort());
283 76193d7c 2003-09-30 devnull if(!f->rasp) /* this might be a duplicate message */
284 2c0f3733 2006-04-20 devnull f->rasp = listalloc('P');
285 76193d7c 2003-09-30 devnull current(f);
286 76193d7c 2003-09-30 devnull outTsv(Hbindname, f->tag, invlong()); /* for 64-bit pointers */
287 76193d7c 2003-09-30 devnull outTs(Hcurrent, f->tag);
288 76193d7c 2003-09-30 devnull journaln(0, f->tag);
289 76193d7c 2003-09-30 devnull if(f->unread)
290 76193d7c 2003-09-30 devnull load(f);
292 522b0689 2003-09-30 devnull if(f->b.nc>0){
293 522b0689 2003-09-30 devnull rgrow(f->rasp, 0L, f->b.nc);
294 522b0689 2003-09-30 devnull outTsll(Hgrow, f->tag, 0L, f->b.nc);
296 76193d7c 2003-09-30 devnull outTs(Hcheck0, f->tag);
297 76193d7c 2003-09-30 devnull moveto(f, f->dot.r);
301 76193d7c 2003-09-30 devnull case Tworkfile:
302 76193d7c 2003-09-30 devnull i = inshort();
303 76193d7c 2003-09-30 devnull f = whichfile(i);
304 76193d7c 2003-09-30 devnull current(f);
305 76193d7c 2003-09-30 devnull f->dot.r.p1 = inlong();
306 76193d7c 2003-09-30 devnull f->dot.r.p2 = inlong();
307 76193d7c 2003-09-30 devnull f->tdot = f->dot.r;
308 76193d7c 2003-09-30 devnull journaln(0, i);
309 76193d7c 2003-09-30 devnull journaln(0, f->dot.r.p1);
310 76193d7c 2003-09-30 devnull journaln(0, f->dot.r.p2);
313 76193d7c 2003-09-30 devnull case Ttype:
314 76193d7c 2003-09-30 devnull f = whichfile(inshort());
315 76193d7c 2003-09-30 devnull p0 = inlong();
316 76193d7c 2003-09-30 devnull journaln(0, p0);
317 76193d7c 2003-09-30 devnull journal(0, (char*)inp);
318 76193d7c 2003-09-30 devnull str = tmpcstr((char*)inp);
319 76193d7c 2003-09-30 devnull i = str->n;
320 76193d7c 2003-09-30 devnull loginsert(f, p0, str->s, str->n);
321 76193d7c 2003-09-30 devnull if(fileupdate(f, FALSE, FALSE))
323 522b0689 2003-09-30 devnull if(f==cmd && p0==f->b.nc-i && i>0 && str->s[i-1]=='\n'){
324 76193d7c 2003-09-30 devnull freetmpstr(str);
325 76193d7c 2003-09-30 devnull termlocked++;
326 76193d7c 2003-09-30 devnull termcommand();
328 76193d7c 2003-09-30 devnull freetmpstr(str);
329 76193d7c 2003-09-30 devnull f->dot.r.p1 = f->dot.r.p2 = p0+i; /* terminal knows this already */
330 76193d7c 2003-09-30 devnull f->tdot = f->dot.r;
333 76193d7c 2003-09-30 devnull case Tcut:
334 76193d7c 2003-09-30 devnull f = whichfile(inshort());
335 76193d7c 2003-09-30 devnull p0 = inlong();
336 76193d7c 2003-09-30 devnull p1 = inlong();
337 76193d7c 2003-09-30 devnull journaln(0, p0);
338 76193d7c 2003-09-30 devnull journaln(0, p1);
339 76193d7c 2003-09-30 devnull logdelete(f, p0, p1);
340 76193d7c 2003-09-30 devnull if(fileupdate(f, FALSE, FALSE))
342 76193d7c 2003-09-30 devnull f->dot.r.p1 = f->dot.r.p2 = p0;
343 76193d7c 2003-09-30 devnull f->tdot = f->dot.r; /* terminal knows the value of dot already */
346 76193d7c 2003-09-30 devnull case Tpaste:
347 76193d7c 2003-09-30 devnull f = whichfile(inshort());
348 76193d7c 2003-09-30 devnull p0 = inlong();
349 76193d7c 2003-09-30 devnull journaln(0, p0);
350 76193d7c 2003-09-30 devnull for(l=0; l<snarfbuf.nc; l+=m){
351 76193d7c 2003-09-30 devnull m = snarfbuf.nc-l;
352 76193d7c 2003-09-30 devnull if(m>BLOCKSIZE)
353 76193d7c 2003-09-30 devnull m = BLOCKSIZE;
354 76193d7c 2003-09-30 devnull bufread(&snarfbuf, l, genbuf, m);
355 76193d7c 2003-09-30 devnull loginsert(f, p0, tmprstr(genbuf, m)->s, m);
357 76193d7c 2003-09-30 devnull if(fileupdate(f, FALSE, TRUE))
359 76193d7c 2003-09-30 devnull f->dot.r.p1 = p0;
360 76193d7c 2003-09-30 devnull f->dot.r.p2 = p0+snarfbuf.nc;
361 76193d7c 2003-09-30 devnull f->tdot.p1 = -1; /* force telldot to tell (arguably a BUG) */
362 76193d7c 2003-09-30 devnull telldot(f);
363 76193d7c 2003-09-30 devnull outTs(Hunlockfile, f->tag);
366 76193d7c 2003-09-30 devnull case Tsnarf:
367 76193d7c 2003-09-30 devnull i = inshort();
368 76193d7c 2003-09-30 devnull p0 = inlong();
369 76193d7c 2003-09-30 devnull p1 = inlong();
370 76193d7c 2003-09-30 devnull snarf(whichfile(i), p0, p1, &snarfbuf, 0);
373 76193d7c 2003-09-30 devnull case Tstartnewfile:
374 2c0f3733 2006-04-20 devnull v = invlong();
375 76193d7c 2003-09-30 devnull Strdupl(&genstr, empty);
376 76193d7c 2003-09-30 devnull f = newfile();
377 2c0f3733 2006-04-20 devnull f->rasp = listalloc('P');
378 2c0f3733 2006-04-20 devnull outTsv(Hbindname, f->tag, v);
379 76193d7c 2003-09-30 devnull logsetname(f, &genstr);
380 76193d7c 2003-09-30 devnull outTs(Hcurrent, f->tag);
381 76193d7c 2003-09-30 devnull current(f);
382 76193d7c 2003-09-30 devnull load(f);
385 76193d7c 2003-09-30 devnull case Twrite:
386 76193d7c 2003-09-30 devnull termlocked++;
387 76193d7c 2003-09-30 devnull i = inshort();
388 76193d7c 2003-09-30 devnull journaln(0, i);
389 76193d7c 2003-09-30 devnull f = whichfile(i);
390 76193d7c 2003-09-30 devnull addr.r.p1 = 0;
391 522b0689 2003-09-30 devnull addr.r.p2 = f->b.nc;
392 76193d7c 2003-09-30 devnull if(f->name.s[0] == 0)
393 76193d7c 2003-09-30 devnull error(Enoname);
394 76193d7c 2003-09-30 devnull Strduplstr(&genstr, &f->name);
395 76193d7c 2003-09-30 devnull writef(f);
398 76193d7c 2003-09-30 devnull case Tclose:
399 76193d7c 2003-09-30 devnull termlocked++;
400 76193d7c 2003-09-30 devnull i = inshort();
401 76193d7c 2003-09-30 devnull journaln(0, i);
402 76193d7c 2003-09-30 devnull f = whichfile(i);
403 76193d7c 2003-09-30 devnull current(f);
404 76193d7c 2003-09-30 devnull trytoclose(f);
405 76193d7c 2003-09-30 devnull /* if trytoclose fails, will error out */
406 76193d7c 2003-09-30 devnull delete(f);
409 76193d7c 2003-09-30 devnull case Tlook:
410 76193d7c 2003-09-30 devnull f = whichfile(inshort());
411 76193d7c 2003-09-30 devnull termlocked++;
412 76193d7c 2003-09-30 devnull p0 = inlong();
413 76193d7c 2003-09-30 devnull p1 = inlong();
414 76193d7c 2003-09-30 devnull journaln(0, p0);
415 76193d7c 2003-09-30 devnull journaln(0, p1);
416 76193d7c 2003-09-30 devnull setgenstr(f, p0, p1);
417 76193d7c 2003-09-30 devnull for(l = 0; l<genstr.n; l++){
418 76193d7c 2003-09-30 devnull i = genstr.s[l];
419 611d815b 2005-03-18 devnull if(utfrune(".*+?(|)\\[]^$", i)){
420 611d815b 2005-03-18 devnull str = tmpcstr("\\");
421 611d815b 2005-03-18 devnull Strinsert(&genstr, str, l++);
422 611d815b 2005-03-18 devnull freetmpstr(str);
425 76193d7c 2003-09-30 devnull Straddc(&genstr, '\0');
426 76193d7c 2003-09-30 devnull nextmatch(f, &genstr, p1, 1);
427 76193d7c 2003-09-30 devnull moveto(f, sel.p[0]);
430 76193d7c 2003-09-30 devnull case Tsearch:
431 76193d7c 2003-09-30 devnull termlocked++;
432 76193d7c 2003-09-30 devnull if(curfile == 0)
433 76193d7c 2003-09-30 devnull error(Enofile);
434 76193d7c 2003-09-30 devnull if(lastpat.s[0] == 0)
435 76193d7c 2003-09-30 devnull panic("Tsearch");
436 76193d7c 2003-09-30 devnull nextmatch(curfile, &lastpat, curfile->dot.r.p2, 1);
437 76193d7c 2003-09-30 devnull moveto(curfile, sel.p[0]);
440 76193d7c 2003-09-30 devnull case Tsend:
441 76193d7c 2003-09-30 devnull termlocked++;
442 76193d7c 2003-09-30 devnull inshort(); /* ignored */
443 76193d7c 2003-09-30 devnull p0 = inlong();
444 76193d7c 2003-09-30 devnull p1 = inlong();
445 76193d7c 2003-09-30 devnull setgenstr(cmd, p0, p1);
446 76193d7c 2003-09-30 devnull bufreset(&snarfbuf);
447 76193d7c 2003-09-30 devnull bufinsert(&snarfbuf, (Posn)0, genstr.s, genstr.n);
448 76193d7c 2003-09-30 devnull outTl(Hsnarflen, genstr.n);
449 76193d7c 2003-09-30 devnull if(genstr.s[genstr.n-1] != '\n')
450 76193d7c 2003-09-30 devnull Straddc(&genstr, '\n');
451 522b0689 2003-09-30 devnull loginsert(cmd, cmd->b.nc, genstr.s, genstr.n);
452 76193d7c 2003-09-30 devnull fileupdate(cmd, FALSE, TRUE);
453 522b0689 2003-09-30 devnull cmd->dot.r.p1 = cmd->dot.r.p2 = cmd->b.nc;
454 76193d7c 2003-09-30 devnull telldot(cmd);
455 76193d7c 2003-09-30 devnull termcommand();
458 76193d7c 2003-09-30 devnull case Tdclick:
459 76193d7c 2003-09-30 devnull f = whichfile(inshort());
460 76193d7c 2003-09-30 devnull p1 = inlong();
461 76193d7c 2003-09-30 devnull doubleclick(f, p1);
462 76193d7c 2003-09-30 devnull f->tdot.p1 = f->tdot.p2 = p1;
463 76193d7c 2003-09-30 devnull telldot(f);
464 76193d7c 2003-09-30 devnull outTs(Hunlockfile, f->tag);
467 76193d7c 2003-09-30 devnull case Tstartsnarf:
468 76193d7c 2003-09-30 devnull if (snarfbuf.nc <= 0) { /* nothing to export */
469 76193d7c 2003-09-30 devnull outTs(Hsetsnarf, 0);
474 76193d7c 2003-09-30 devnull m = snarfbuf.nc;
475 76193d7c 2003-09-30 devnull if(m > SNARFSIZE) {
476 76193d7c 2003-09-30 devnull m = SNARFSIZE;
477 76193d7c 2003-09-30 devnull dprint("?warning: snarf buffer truncated\n");
479 76193d7c 2003-09-30 devnull rp = malloc(m*sizeof(Rune));
481 76193d7c 2003-09-30 devnull bufread(&snarfbuf, 0, rp, m);
482 76193d7c 2003-09-30 devnull c = Strtoc(tmprstr(rp, m));
483 76193d7c 2003-09-30 devnull free(rp);
484 76193d7c 2003-09-30 devnull i = strlen(c);
486 76193d7c 2003-09-30 devnull outTs(Hsetsnarf, i);
488 76193d7c 2003-09-30 devnull Write(1, c, i);
489 76193d7c 2003-09-30 devnull free(c);
491 76193d7c 2003-09-30 devnull dprint("snarf buffer too long\n");
494 76193d7c 2003-09-30 devnull case Tsetsnarf:
495 76193d7c 2003-09-30 devnull m = inshort();
496 76193d7c 2003-09-30 devnull if(m > SNARFSIZE)
497 76193d7c 2003-09-30 devnull error(Etoolong);
498 76193d7c 2003-09-30 devnull c = malloc(m+1);
500 76193d7c 2003-09-30 devnull for(i=0; i<m; i++)
501 76193d7c 2003-09-30 devnull c[i] = rcvchar();
502 76193d7c 2003-09-30 devnull c[m] = 0;
503 76193d7c 2003-09-30 devnull str = tmpcstr(c);
504 76193d7c 2003-09-30 devnull free(c);
505 76193d7c 2003-09-30 devnull bufreset(&snarfbuf);
506 76193d7c 2003-09-30 devnull bufinsert(&snarfbuf, (Posn)0, str->s, str->n);
507 76193d7c 2003-09-30 devnull freetmpstr(str);
508 76193d7c 2003-09-30 devnull outT0(Hunlock);
512 76193d7c 2003-09-30 devnull case Tack:
513 76193d7c 2003-09-30 devnull waitack = 0;
516 76193d7c 2003-09-30 devnull case Tplumb:
517 76193d7c 2003-09-30 devnull f = whichfile(inshort());
518 76193d7c 2003-09-30 devnull p0 = inlong();
519 76193d7c 2003-09-30 devnull p1 = inlong();
520 76193d7c 2003-09-30 devnull pm = emalloc(sizeof(Plumbmsg));
521 76193d7c 2003-09-30 devnull pm->src = strdup("sam");
522 76193d7c 2003-09-30 devnull pm->dst = 0;
523 76193d7c 2003-09-30 devnull /* construct current directory */
524 76193d7c 2003-09-30 devnull c = Strtoc(&f->name);
525 76193d7c 2003-09-30 devnull if(c[0] == '/')
526 76193d7c 2003-09-30 devnull pm->wdir = c;
528 76193d7c 2003-09-30 devnull wdir = emalloc(1024);
529 76193d7c 2003-09-30 devnull getwd(wdir, 1024);
530 76193d7c 2003-09-30 devnull pm->wdir = emalloc(1024);
531 76193d7c 2003-09-30 devnull snprint(pm->wdir, 1024, "%s/%s", wdir, c);
532 76193d7c 2003-09-30 devnull cleanname(pm->wdir);
533 76193d7c 2003-09-30 devnull free(wdir);
534 76193d7c 2003-09-30 devnull free(c);
536 76193d7c 2003-09-30 devnull c = strrchr(pm->wdir, '/');
538 76193d7c 2003-09-30 devnull *c = '\0';
539 76193d7c 2003-09-30 devnull pm->type = strdup("text");
540 76193d7c 2003-09-30 devnull if(p1 > p0)
541 76193d7c 2003-09-30 devnull pm->attr = nil;
544 76193d7c 2003-09-30 devnull while(p0>0 && (i=filereadc(f, p0 - 1))!=' ' && i!='\t' && i!='\n')
546 522b0689 2003-09-30 devnull while(p1<f->b.nc && (i=filereadc(f, p1))!=' ' && i!='\t' && i!='\n')
548 76193d7c 2003-09-30 devnull sprint(cbuf, "click=%ld", p-p0);
549 76193d7c 2003-09-30 devnull pm->attr = plumbunpackattr(cbuf);
551 76193d7c 2003-09-30 devnull if(p0==p1 || p1-p0>=BLOCKSIZE){
552 76193d7c 2003-09-30 devnull plumbfree(pm);
555 76193d7c 2003-09-30 devnull setgenstr(f, p0, p1);
556 76193d7c 2003-09-30 devnull pm->data = Strtoc(&genstr);
557 76193d7c 2003-09-30 devnull pm->ndata = strlen(pm->data);
558 76193d7c 2003-09-30 devnull c = plumbpack(pm, &i);
559 76193d7c 2003-09-30 devnull if(c != 0){
560 76193d7c 2003-09-30 devnull outTs(Hplumb, i);
561 76193d7c 2003-09-30 devnull Write(1, c, i);
562 76193d7c 2003-09-30 devnull free(c);
564 76193d7c 2003-09-30 devnull plumbfree(pm);
567 76193d7c 2003-09-30 devnull case Texit:
568 76193d7c 2003-09-30 devnull exits(0);
570 76193d7c 2003-09-30 devnull return TRUE;
574 76193d7c 2003-09-30 devnull snarf(File *f, Posn p1, Posn p2, Buffer *buf, int emptyok)
579 76193d7c 2003-09-30 devnull if(!emptyok && p1==p2)
581 76193d7c 2003-09-30 devnull bufreset(buf);
582 76193d7c 2003-09-30 devnull /* Stage through genbuf to avoid compaction problems (vestigial) */
583 522b0689 2003-09-30 devnull if(p2 > f->b.nc){
584 522b0689 2003-09-30 devnull fprint(2, "bad snarf addr p1=%ld p2=%ld f->b.nc=%d\n", p1, p2, f->b.nc); /*ZZZ should never happen, can remove */
585 522b0689 2003-09-30 devnull p2 = f->b.nc;
587 76193d7c 2003-09-30 devnull for(l=p1; l<p2; l+=i){
588 76193d7c 2003-09-30 devnull i = p2-l>BLOCKSIZE? BLOCKSIZE : p2-l;
589 522b0689 2003-09-30 devnull bufread(&f->b, l, genbuf, i);
590 76193d7c 2003-09-30 devnull bufinsert(buf, buf->nc, tmprstr(genbuf, i)->s, i);
595 76193d7c 2003-09-30 devnull inshort(void)
597 76193d7c 2003-09-30 devnull ushort n;
599 76193d7c 2003-09-30 devnull n = inp[0] | (inp[1]<<8);
600 76193d7c 2003-09-30 devnull inp += 2;
601 76193d7c 2003-09-30 devnull return n;
605 76193d7c 2003-09-30 devnull inlong(void)
607 76193d7c 2003-09-30 devnull ulong n;
609 76193d7c 2003-09-30 devnull n = inp[0] | (inp[1]<<8) | (inp[2]<<16) | (inp[3]<<24);
610 76193d7c 2003-09-30 devnull inp += 4;
611 76193d7c 2003-09-30 devnull return n;
615 76193d7c 2003-09-30 devnull invlong(void)
617 2c0f3733 2006-04-20 devnull vlong v;
619 2c0f3733 2006-04-20 devnull v = (inp[7]<<24) | (inp[6]<<16) | (inp[5]<<8) | inp[4];
620 2c0f3733 2006-04-20 devnull v = (v<<16) | (inp[3]<<8) | inp[2];
621 2c0f3733 2006-04-20 devnull v = (v<<16) | (inp[1]<<8) | inp[0];
622 76193d7c 2003-09-30 devnull inp += 8;
623 2c0f3733 2006-04-20 devnull return v;
627 76193d7c 2003-09-30 devnull setgenstr(File *f, Posn p0, Posn p1)
629 76193d7c 2003-09-30 devnull if(p0 != p1){
630 76193d7c 2003-09-30 devnull if(p1-p0 >= TBLOCKSIZE)
631 76193d7c 2003-09-30 devnull error(Etoolong);
632 76193d7c 2003-09-30 devnull Strinsure(&genstr, p1-p0);
633 522b0689 2003-09-30 devnull bufread(&f->b, p0, genbuf, p1-p0);
634 76193d7c 2003-09-30 devnull memmove(genstr.s, genbuf, RUNESIZE*(p1-p0));
635 76193d7c 2003-09-30 devnull genstr.n = p1-p0;
637 76193d7c 2003-09-30 devnull if(snarfbuf.nc == 0)
638 76193d7c 2003-09-30 devnull error(Eempty);
639 76193d7c 2003-09-30 devnull if(snarfbuf.nc > TBLOCKSIZE)
640 76193d7c 2003-09-30 devnull error(Etoolong);
641 76193d7c 2003-09-30 devnull bufread(&snarfbuf, (Posn)0, genbuf, snarfbuf.nc);
642 76193d7c 2003-09-30 devnull Strinsure(&genstr, snarfbuf.nc);
643 76193d7c 2003-09-30 devnull memmove(genstr.s, genbuf, RUNESIZE*snarfbuf.nc);
644 76193d7c 2003-09-30 devnull genstr.n = snarfbuf.nc;
649 76193d7c 2003-09-30 devnull outT0(Hmesg type)
651 76193d7c 2003-09-30 devnull outstart(type);
652 76193d7c 2003-09-30 devnull outsend();
656 76193d7c 2003-09-30 devnull outTl(Hmesg type, long l)
658 76193d7c 2003-09-30 devnull outstart(type);
659 76193d7c 2003-09-30 devnull outlong(l);
660 76193d7c 2003-09-30 devnull outsend();
664 76193d7c 2003-09-30 devnull outTs(Hmesg type, int s)
666 76193d7c 2003-09-30 devnull outstart(type);
667 76193d7c 2003-09-30 devnull journaln(1, s);
668 76193d7c 2003-09-30 devnull outshort(s);
669 76193d7c 2003-09-30 devnull outsend();
673 76193d7c 2003-09-30 devnull outS(String *s)
675 76193d7c 2003-09-30 devnull char *c;
678 76193d7c 2003-09-30 devnull c = Strtoc(s);
679 76193d7c 2003-09-30 devnull i = strlen(c);
680 76193d7c 2003-09-30 devnull outcopy(i, c);
681 76193d7c 2003-09-30 devnull if(i > 99)
682 76193d7c 2003-09-30 devnull c[99] = 0;
683 76193d7c 2003-09-30 devnull journaln(1, i);
684 76193d7c 2003-09-30 devnull journal(1, c);
685 76193d7c 2003-09-30 devnull free(c);
689 76193d7c 2003-09-30 devnull outTsS(Hmesg type, int s1, String *s)
691 76193d7c 2003-09-30 devnull outstart(type);
692 76193d7c 2003-09-30 devnull outshort(s1);
693 76193d7c 2003-09-30 devnull outS(s);
694 76193d7c 2003-09-30 devnull outsend();
698 76193d7c 2003-09-30 devnull outTslS(Hmesg type, int s1, Posn l1, String *s)
700 76193d7c 2003-09-30 devnull outstart(type);
701 76193d7c 2003-09-30 devnull outshort(s1);
702 76193d7c 2003-09-30 devnull journaln(1, s1);
703 76193d7c 2003-09-30 devnull outlong(l1);
704 76193d7c 2003-09-30 devnull journaln(1, l1);
705 76193d7c 2003-09-30 devnull outS(s);
706 76193d7c 2003-09-30 devnull outsend();
710 76193d7c 2003-09-30 devnull outTS(Hmesg type, String *s)
712 76193d7c 2003-09-30 devnull outstart(type);
713 76193d7c 2003-09-30 devnull outS(s);
714 76193d7c 2003-09-30 devnull outsend();
718 76193d7c 2003-09-30 devnull outTsllS(Hmesg type, int s1, Posn l1, Posn l2, String *s)
720 76193d7c 2003-09-30 devnull outstart(type);
721 76193d7c 2003-09-30 devnull outshort(s1);
722 76193d7c 2003-09-30 devnull outlong(l1);
723 76193d7c 2003-09-30 devnull outlong(l2);
724 76193d7c 2003-09-30 devnull journaln(1, l1);
725 76193d7c 2003-09-30 devnull journaln(1, l2);
726 76193d7c 2003-09-30 devnull outS(s);
727 76193d7c 2003-09-30 devnull outsend();
731 76193d7c 2003-09-30 devnull outTsll(Hmesg type, int s, Posn l1, Posn l2)
733 76193d7c 2003-09-30 devnull outstart(type);
734 76193d7c 2003-09-30 devnull outshort(s);
735 76193d7c 2003-09-30 devnull outlong(l1);
736 76193d7c 2003-09-30 devnull outlong(l2);
737 76193d7c 2003-09-30 devnull journaln(1, l1);
738 76193d7c 2003-09-30 devnull journaln(1, l2);
739 76193d7c 2003-09-30 devnull outsend();
743 76193d7c 2003-09-30 devnull outTsl(Hmesg type, int s, Posn l)
745 76193d7c 2003-09-30 devnull outstart(type);
746 76193d7c 2003-09-30 devnull outshort(s);
747 76193d7c 2003-09-30 devnull outlong(l);
748 76193d7c 2003-09-30 devnull journaln(1, l);
749 76193d7c 2003-09-30 devnull outsend();
753 2c0f3733 2006-04-20 devnull outTsv(Hmesg type, int s, vlong v)
755 76193d7c 2003-09-30 devnull outstart(type);
756 76193d7c 2003-09-30 devnull outshort(s);
757 2c0f3733 2006-04-20 devnull outvlong(v);
758 2c0f3733 2006-04-20 devnull journaln(1, v);
759 76193d7c 2003-09-30 devnull outsend();
763 76193d7c 2003-09-30 devnull outstart(Hmesg type)
765 76193d7c 2003-09-30 devnull journal(1, hname[type]);
766 76193d7c 2003-09-30 devnull outmsg[0] = type;
767 76193d7c 2003-09-30 devnull outp = outmsg+3;
771 76193d7c 2003-09-30 devnull outcopy(int count, void *data)
773 76193d7c 2003-09-30 devnull memmove(outp, data, count);
774 76193d7c 2003-09-30 devnull outp += count;
778 76193d7c 2003-09-30 devnull outshort(int s)
780 76193d7c 2003-09-30 devnull *outp++ = s;
781 76193d7c 2003-09-30 devnull *outp++ = s>>8;
785 76193d7c 2003-09-30 devnull outlong(long l)
787 76193d7c 2003-09-30 devnull *outp++ = l;
788 76193d7c 2003-09-30 devnull *outp++ = l>>8;
789 76193d7c 2003-09-30 devnull *outp++ = l>>16;
790 76193d7c 2003-09-30 devnull *outp++ = l>>24;
794 2c0f3733 2006-04-20 devnull outvlong(vlong v)
798 2c0f3733 2006-04-20 devnull for(i = 0; i < 8; i++){
799 2c0f3733 2006-04-20 devnull *outp++ = v;
800 2c0f3733 2006-04-20 devnull v >>= 8;
805 76193d7c 2003-09-30 devnull outsend(void)
807 76193d7c 2003-09-30 devnull int outcount;
809 78439d25 2007-01-12 devnull if(outp >= outdata+nelem(outdata))
810 78439d25 2007-01-12 devnull panic("outsend");
811 76193d7c 2003-09-30 devnull outcount = outp-outmsg;
812 76193d7c 2003-09-30 devnull outcount -= 3;
813 76193d7c 2003-09-30 devnull outmsg[1] = outcount;
814 76193d7c 2003-09-30 devnull outmsg[2] = outcount>>8;
815 76193d7c 2003-09-30 devnull outmsg = outp;
816 78439d25 2007-01-12 devnull if(!outbuffered){
817 76193d7c 2003-09-30 devnull outcount = outmsg-outdata;
818 76193d7c 2003-09-30 devnull if (write(1, (char*) outdata, outcount) != outcount)
819 76193d7c 2003-09-30 devnull rescue();
820 76193d7c 2003-09-30 devnull outmsg = outdata;
826 78439d25 2007-01-12 devnull needoutflush(void)
828 7103ceb0 2007-01-12 devnull return outmsg >= outdata+DATASIZE;
832 76193d7c 2003-09-30 devnull outflush(void)
834 76193d7c 2003-09-30 devnull if(outmsg == outdata)
836 78439d25 2007-01-12 devnull outbuffered = 0;
837 7103ceb0 2007-01-12 devnull /* flow control */
838 76193d7c 2003-09-30 devnull outT0(Hack);
839 76193d7c 2003-09-30 devnull waitack = 1;
841 76193d7c 2003-09-30 devnull if(rcv() == 0){
842 76193d7c 2003-09-30 devnull rescue();
843 76193d7c 2003-09-30 devnull exits("eof");
845 76193d7c 2003-09-30 devnull while(waitack);
846 76193d7c 2003-09-30 devnull outmsg = outdata;
847 78439d25 2007-01-12 devnull outbuffered = 1;