1 76193d7c 2003-09-30 devnull #include "sam.h"
  2 76193d7c 2003-09-30 devnull 
  3 76193d7c 2003-09-30 devnull Header	h;
  4 76193d7c 2003-09-30 devnull uchar	indata[DATASIZE];
  5 76193d7c 2003-09-30 devnull uchar	outdata[2*DATASIZE+3];	/* room for overflow message */
  6 76193d7c 2003-09-30 devnull uchar	*inp;
  7 76193d7c 2003-09-30 devnull uchar	*outp;
  8 76193d7c 2003-09-30 devnull uchar	*outmsg = outdata;
  9 76193d7c 2003-09-30 devnull Posn	cmdpt;
 10 76193d7c 2003-09-30 devnull Posn	cmdptadv;
 11 76193d7c 2003-09-30 devnull Buffer	snarfbuf;
 12 76193d7c 2003-09-30 devnull int	waitack;
 13 76193d7c 2003-09-30 devnull int	noflush;
 14 76193d7c 2003-09-30 devnull int	tversion;
 15 76193d7c 2003-09-30 devnull 
 16 76193d7c 2003-09-30 devnull long	inlong(void);
 17 76193d7c 2003-09-30 devnull long	invlong(void);
 18 76193d7c 2003-09-30 devnull int	inshort(void);
 19 76193d7c 2003-09-30 devnull int	inmesg(Tmesg);
 20 76193d7c 2003-09-30 devnull void	setgenstr(File*, Posn, Posn);
 21 76193d7c 2003-09-30 devnull 
 22 76193d7c 2003-09-30 devnull #ifdef DEBUG
 23 76193d7c 2003-09-30 devnull char *hname[] = {
 24 76193d7c 2003-09-30 devnull 	[Hversion]	"Hversion",
 25 76193d7c 2003-09-30 devnull 	[Hbindname]	"Hbindname",
 26 76193d7c 2003-09-30 devnull 	[Hcurrent]	"Hcurrent",
 27 76193d7c 2003-09-30 devnull 	[Hnewname]	"Hnewname",
 28 76193d7c 2003-09-30 devnull 	[Hmovname]	"Hmovname",
 29 76193d7c 2003-09-30 devnull 	[Hgrow]		"Hgrow",
 30 76193d7c 2003-09-30 devnull 	[Hcheck0]	"Hcheck0",
 31 76193d7c 2003-09-30 devnull 	[Hcheck]	"Hcheck",
 32 76193d7c 2003-09-30 devnull 	[Hunlock]	"Hunlock",
 33 76193d7c 2003-09-30 devnull 	[Hdata]		"Hdata",
 34 76193d7c 2003-09-30 devnull 	[Horigin]	"Horigin",
 35 76193d7c 2003-09-30 devnull 	[Hunlockfile]	"Hunlockfile",
 36 76193d7c 2003-09-30 devnull 	[Hsetdot]	"Hsetdot",
 37 76193d7c 2003-09-30 devnull 	[Hgrowdata]	"Hgrowdata",
 38 76193d7c 2003-09-30 devnull 	[Hmoveto]	"Hmoveto",
 39 76193d7c 2003-09-30 devnull 	[Hclean]	"Hclean",
 40 76193d7c 2003-09-30 devnull 	[Hdirty]	"Hdirty",
 41 76193d7c 2003-09-30 devnull 	[Hcut]		"Hcut",
 42 76193d7c 2003-09-30 devnull 	[Hsetpat]	"Hsetpat",
 43 76193d7c 2003-09-30 devnull 	[Hdelname]	"Hdelname",
 44 76193d7c 2003-09-30 devnull 	[Hclose]	"Hclose",
 45 76193d7c 2003-09-30 devnull 	[Hsetsnarf]	"Hsetsnarf",
 46 76193d7c 2003-09-30 devnull 	[Hsnarflen]	"Hsnarflen",
 47 76193d7c 2003-09-30 devnull 	[Hack]		"Hack",
 48 76193d7c 2003-09-30 devnull 	[Hexit]		"Hexit",
 49 76193d7c 2003-09-30 devnull 	[Hplumb]		"Hplumb",
 50 76193d7c 2003-09-30 devnull };
 51 76193d7c 2003-09-30 devnull 
 52 76193d7c 2003-09-30 devnull char *tname[] = {
 53 76193d7c 2003-09-30 devnull 	[Tversion]	"Tversion",
 54 76193d7c 2003-09-30 devnull 	[Tstartcmdfile]	"Tstartcmdfile",
 55 76193d7c 2003-09-30 devnull 	[Tcheck]	"Tcheck",
 56 76193d7c 2003-09-30 devnull 	[Trequest]	"Trequest",
 57 76193d7c 2003-09-30 devnull 	[Torigin]	"Torigin",
 58 76193d7c 2003-09-30 devnull 	[Tstartfile]	"Tstartfile",
 59 76193d7c 2003-09-30 devnull 	[Tworkfile]	"Tworkfile",
 60 76193d7c 2003-09-30 devnull 	[Ttype]		"Ttype",
 61 76193d7c 2003-09-30 devnull 	[Tcut]		"Tcut",
 62 76193d7c 2003-09-30 devnull 	[Tpaste]	"Tpaste",
 63 76193d7c 2003-09-30 devnull 	[Tsnarf]	"Tsnarf",
 64 76193d7c 2003-09-30 devnull 	[Tstartnewfile]	"Tstartnewfile",
 65 76193d7c 2003-09-30 devnull 	[Twrite]	"Twrite",
 66 76193d7c 2003-09-30 devnull 	[Tclose]	"Tclose",
 67 76193d7c 2003-09-30 devnull 	[Tlook]		"Tlook",
 68 76193d7c 2003-09-30 devnull 	[Tsearch]	"Tsearch",
 69 76193d7c 2003-09-30 devnull 	[Tsend]		"Tsend",
 70 76193d7c 2003-09-30 devnull 	[Tdclick]	"Tdclick",
 71 76193d7c 2003-09-30 devnull 	[Tstartsnarf]	"Tstartsnarf",
 72 76193d7c 2003-09-30 devnull 	[Tsetsnarf]	"Tsetsnarf",
 73 76193d7c 2003-09-30 devnull 	[Tack]		"Tack",
 74 76193d7c 2003-09-30 devnull 	[Texit]		"Texit",
 75 76193d7c 2003-09-30 devnull 	[Tplumb]		"Tplumb",
 76 76193d7c 2003-09-30 devnull };
 77 76193d7c 2003-09-30 devnull 
 78 76193d7c 2003-09-30 devnull void
 79 76193d7c 2003-09-30 devnull journal(int out, char *s)
 80 76193d7c 2003-09-30 devnull {
 81 76193d7c 2003-09-30 devnull 	static int fd = 0;
 82 76193d7c 2003-09-30 devnull 
 83 76193d7c 2003-09-30 devnull 	if(fd <= 0)
 84 76193d7c 2003-09-30 devnull 		fd = create("/tmp/sam.out", 1, 0666L);
 85 76193d7c 2003-09-30 devnull 	fprint(fd, "%s%s\n", out? "out: " : "in:  ", s);
 86 76193d7c 2003-09-30 devnull }
 87 76193d7c 2003-09-30 devnull 
 88 76193d7c 2003-09-30 devnull void
 89 76193d7c 2003-09-30 devnull journaln(int out, long n)
 90 76193d7c 2003-09-30 devnull {
 91 76193d7c 2003-09-30 devnull 	char buf[32];
 92 76193d7c 2003-09-30 devnull 
 93 76193d7c 2003-09-30 devnull 	sprint(buf, "%ld", n);
 94 76193d7c 2003-09-30 devnull 	journal(out, buf);
 95 76193d7c 2003-09-30 devnull }
 96 76193d7c 2003-09-30 devnull #else
 97 76193d7c 2003-09-30 devnull #define	journal(a, b)
 98 76193d7c 2003-09-30 devnull #define journaln(a, b)
 99 76193d7c 2003-09-30 devnull #endif
100 76193d7c 2003-09-30 devnull 
101 76193d7c 2003-09-30 devnull int
102 76193d7c 2003-09-30 devnull rcvchar(void){
103 76193d7c 2003-09-30 devnull 	static uchar buf[64];
104 522b0689 2003-09-30 devnull 	static int i, nleft = 0;
105 76193d7c 2003-09-30 devnull 
106 76193d7c 2003-09-30 devnull 	if(nleft <= 0){
107 76193d7c 2003-09-30 devnull 		nleft = read(0, (char *)buf, sizeof buf);
108 76193d7c 2003-09-30 devnull 		if(nleft <= 0)
109 76193d7c 2003-09-30 devnull 			return -1;
110 76193d7c 2003-09-30 devnull 		i = 0;
111 76193d7c 2003-09-30 devnull 	}
112 76193d7c 2003-09-30 devnull 	--nleft;
113 76193d7c 2003-09-30 devnull 	return buf[i++];
114 76193d7c 2003-09-30 devnull }
115 76193d7c 2003-09-30 devnull 
116 76193d7c 2003-09-30 devnull int
117 76193d7c 2003-09-30 devnull rcv(void){
118 76193d7c 2003-09-30 devnull 	int c;
119 522b0689 2003-09-30 devnull 	static int state = 0;
120 522b0689 2003-09-30 devnull 	static int count = 0;
121 522b0689 2003-09-30 devnull 	static int i = 0;
122 76193d7c 2003-09-30 devnull 
123 76193d7c 2003-09-30 devnull 	while((c=rcvchar()) != -1)
124 76193d7c 2003-09-30 devnull 		switch(state){
125 76193d7c 2003-09-30 devnull 		case 0:
126 76193d7c 2003-09-30 devnull 			h.type = c;
127 76193d7c 2003-09-30 devnull 			state++;
128 76193d7c 2003-09-30 devnull 			break;
129 76193d7c 2003-09-30 devnull 
130 76193d7c 2003-09-30 devnull 		case 1:
131 76193d7c 2003-09-30 devnull 			h.count0 = c;
132 76193d7c 2003-09-30 devnull 			state++;
133 76193d7c 2003-09-30 devnull 			break;
134 76193d7c 2003-09-30 devnull 
135 76193d7c 2003-09-30 devnull 		case 2:
136 76193d7c 2003-09-30 devnull 			h.count1 = c;
137 76193d7c 2003-09-30 devnull 			count = h.count0|(h.count1<<8);
138 76193d7c 2003-09-30 devnull 			i = 0;
139 76193d7c 2003-09-30 devnull 			if(count > DATASIZE)
140 76193d7c 2003-09-30 devnull 				panic("count>DATASIZE");
141 76193d7c 2003-09-30 devnull 			if(count == 0)
142 76193d7c 2003-09-30 devnull 				goto zerocount;
143 76193d7c 2003-09-30 devnull 			state++;
144 76193d7c 2003-09-30 devnull 			break;
145 76193d7c 2003-09-30 devnull 
146 76193d7c 2003-09-30 devnull 		case 3:
147 76193d7c 2003-09-30 devnull 			indata[i++] = c;
148 76193d7c 2003-09-30 devnull 			if(i == count){
149 76193d7c 2003-09-30 devnull 		zerocount:
150 76193d7c 2003-09-30 devnull 				indata[i] = 0;
151 76193d7c 2003-09-30 devnull 				state = count = 0;
152 76193d7c 2003-09-30 devnull 				return inmesg(h.type);
153 76193d7c 2003-09-30 devnull 			}
154 76193d7c 2003-09-30 devnull 			break;
155 76193d7c 2003-09-30 devnull 		}
156 76193d7c 2003-09-30 devnull 	return 0;
157 76193d7c 2003-09-30 devnull }
158 76193d7c 2003-09-30 devnull 
159 76193d7c 2003-09-30 devnull File *
160 76193d7c 2003-09-30 devnull whichfile(int tag)
161 76193d7c 2003-09-30 devnull {
162 76193d7c 2003-09-30 devnull 	int i;
163 76193d7c 2003-09-30 devnull 
164 76193d7c 2003-09-30 devnull 	for(i = 0; i<file.nused; i++)
165 76193d7c 2003-09-30 devnull 		if(file.filepptr[i]->tag==tag)
166 76193d7c 2003-09-30 devnull 			return file.filepptr[i];
167 76193d7c 2003-09-30 devnull 	hiccough((char *)0);
168 76193d7c 2003-09-30 devnull 	return 0;
169 76193d7c 2003-09-30 devnull }
170 76193d7c 2003-09-30 devnull 
171 76193d7c 2003-09-30 devnull int
172 76193d7c 2003-09-30 devnull inmesg(Tmesg type)
173 76193d7c 2003-09-30 devnull {
174 76193d7c 2003-09-30 devnull 	Rune buf[1025];
175 76193d7c 2003-09-30 devnull 	char cbuf[64];
176 76193d7c 2003-09-30 devnull 	int i, m;
177 76193d7c 2003-09-30 devnull 	short s;
178 76193d7c 2003-09-30 devnull 	long l, l1;
179 76193d7c 2003-09-30 devnull 	File *f;
180 76193d7c 2003-09-30 devnull 	Posn p0, p1, p;
181 76193d7c 2003-09-30 devnull 	Range r;
182 76193d7c 2003-09-30 devnull 	String *str;
183 76193d7c 2003-09-30 devnull 	char *c, *wdir;
184 76193d7c 2003-09-30 devnull 	Rune *rp;
185 76193d7c 2003-09-30 devnull 	Plumbmsg *pm;
186 76193d7c 2003-09-30 devnull 
187 76193d7c 2003-09-30 devnull 	if(type > TMAX)
188 76193d7c 2003-09-30 devnull 		panic("inmesg");
189 76193d7c 2003-09-30 devnull 
190 76193d7c 2003-09-30 devnull 	journal(0, tname[type]);
191 76193d7c 2003-09-30 devnull 
192 76193d7c 2003-09-30 devnull 	inp = indata;
193 76193d7c 2003-09-30 devnull 	switch(type){
194 76193d7c 2003-09-30 devnull 	case -1:
195 76193d7c 2003-09-30 devnull 		panic("rcv error");
196 76193d7c 2003-09-30 devnull 
197 76193d7c 2003-09-30 devnull 	default:
198 76193d7c 2003-09-30 devnull 		fprint(2, "unknown type %d\n", type);
199 76193d7c 2003-09-30 devnull 		panic("rcv unknown");
200 76193d7c 2003-09-30 devnull 
201 76193d7c 2003-09-30 devnull 	case Tversion:
202 76193d7c 2003-09-30 devnull 		tversion = inshort();
203 76193d7c 2003-09-30 devnull 		journaln(0, tversion);
204 76193d7c 2003-09-30 devnull 		break;
205 76193d7c 2003-09-30 devnull 
206 76193d7c 2003-09-30 devnull 	case Tstartcmdfile:
207 76193d7c 2003-09-30 devnull 		l = invlong();		/* for 64-bit pointers */
208 76193d7c 2003-09-30 devnull 		journaln(0, l);
209 76193d7c 2003-09-30 devnull 		Strdupl(&genstr, samname);
210 76193d7c 2003-09-30 devnull 		cmd = newfile();
211 76193d7c 2003-09-30 devnull 		cmd->unread = 0;
212 76193d7c 2003-09-30 devnull 		outTsv(Hbindname, cmd->tag, l);
213 76193d7c 2003-09-30 devnull 		outTs(Hcurrent, cmd->tag);
214 76193d7c 2003-09-30 devnull 		logsetname(cmd, &genstr);
215 76193d7c 2003-09-30 devnull 		cmd->rasp = emalloc(sizeof(List));
216 76193d7c 2003-09-30 devnull 		cmd->mod = 0;
217 76193d7c 2003-09-30 devnull 		if(cmdstr.n){
218 76193d7c 2003-09-30 devnull 			loginsert(cmd, 0L, cmdstr.s, cmdstr.n);
219 76193d7c 2003-09-30 devnull 			Strdelete(&cmdstr, 0L, (Posn)cmdstr.n);
220 76193d7c 2003-09-30 devnull 		}
221 76193d7c 2003-09-30 devnull 		fileupdate(cmd, FALSE, TRUE);
222 76193d7c 2003-09-30 devnull 		outT0(Hunlock);
223 76193d7c 2003-09-30 devnull 		break;
224 76193d7c 2003-09-30 devnull 
225 76193d7c 2003-09-30 devnull 	case Tcheck:
226 76193d7c 2003-09-30 devnull 		/* go through whichfile to check the tag */
227 76193d7c 2003-09-30 devnull 		outTs(Hcheck, whichfile(inshort())->tag);
228 76193d7c 2003-09-30 devnull 		break;
229 76193d7c 2003-09-30 devnull 
230 76193d7c 2003-09-30 devnull 	case Trequest:
231 76193d7c 2003-09-30 devnull 		f = whichfile(inshort());
232 76193d7c 2003-09-30 devnull 		p0 = inlong();
233 76193d7c 2003-09-30 devnull 		p1 = p0+inshort();
234 76193d7c 2003-09-30 devnull 		journaln(0, p0);
235 76193d7c 2003-09-30 devnull 		journaln(0, p1-p0);
236 76193d7c 2003-09-30 devnull 		if(f->unread)
237 76193d7c 2003-09-30 devnull 			panic("Trequest: unread");
238 522b0689 2003-09-30 devnull 		if(p1>f->b.nc)
239 522b0689 2003-09-30 devnull 			p1 = f->b.nc;
240 522b0689 2003-09-30 devnull 		if(p0>f->b.nc) /* can happen e.g. scrolling during command */
241 522b0689 2003-09-30 devnull 			p0 = f->b.nc;
242 76193d7c 2003-09-30 devnull 		if(p0 == p1){
243 76193d7c 2003-09-30 devnull 			i = 0;
244 76193d7c 2003-09-30 devnull 			r.p1 = r.p2 = p0;
245 76193d7c 2003-09-30 devnull 		}else{
246 76193d7c 2003-09-30 devnull 			r = rdata(f->rasp, p0, p1-p0);
247 76193d7c 2003-09-30 devnull 			i = r.p2-r.p1;
248 522b0689 2003-09-30 devnull 			bufread(&f->b, r.p1, buf, i);
249 76193d7c 2003-09-30 devnull 		}
250 76193d7c 2003-09-30 devnull 		buf[i]=0;
251 76193d7c 2003-09-30 devnull 		outTslS(Hdata, f->tag, r.p1, tmprstr(buf, i+1));
252 76193d7c 2003-09-30 devnull 		break;
253 76193d7c 2003-09-30 devnull 
254 76193d7c 2003-09-30 devnull 	case Torigin:
255 76193d7c 2003-09-30 devnull 		s = inshort();
256 76193d7c 2003-09-30 devnull 		l = inlong();
257 76193d7c 2003-09-30 devnull 		l1 = inlong();
258 76193d7c 2003-09-30 devnull 		journaln(0, l1);
259 76193d7c 2003-09-30 devnull 		lookorigin(whichfile(s), l, l1);
260 76193d7c 2003-09-30 devnull 		break;
261 76193d7c 2003-09-30 devnull 
262 76193d7c 2003-09-30 devnull 	case Tstartfile:
263 76193d7c 2003-09-30 devnull 		termlocked++;
264 76193d7c 2003-09-30 devnull 		f = whichfile(inshort());
265 76193d7c 2003-09-30 devnull 		if(!f->rasp)	/* this might be a duplicate message */
266 76193d7c 2003-09-30 devnull 			f->rasp = emalloc(sizeof(List));
267 76193d7c 2003-09-30 devnull 		current(f);
268 76193d7c 2003-09-30 devnull 		outTsv(Hbindname, f->tag, invlong());	/* for 64-bit pointers */
269 76193d7c 2003-09-30 devnull 		outTs(Hcurrent, f->tag);
270 76193d7c 2003-09-30 devnull 		journaln(0, f->tag);
271 76193d7c 2003-09-30 devnull 		if(f->unread)
272 76193d7c 2003-09-30 devnull 			load(f);
273 76193d7c 2003-09-30 devnull 		else{
274 522b0689 2003-09-30 devnull 			if(f->b.nc>0){
275 522b0689 2003-09-30 devnull 				rgrow(f->rasp, 0L, f->b.nc);
276 522b0689 2003-09-30 devnull 				outTsll(Hgrow, f->tag, 0L, f->b.nc);
277 76193d7c 2003-09-30 devnull 			}
278 76193d7c 2003-09-30 devnull 			outTs(Hcheck0, f->tag);
279 76193d7c 2003-09-30 devnull 			moveto(f, f->dot.r);
280 76193d7c 2003-09-30 devnull 		}
281 76193d7c 2003-09-30 devnull 		break;
282 76193d7c 2003-09-30 devnull 
283 76193d7c 2003-09-30 devnull 	case Tworkfile:
284 76193d7c 2003-09-30 devnull 		i = inshort();
285 76193d7c 2003-09-30 devnull 		f = whichfile(i);
286 76193d7c 2003-09-30 devnull 		current(f);
287 76193d7c 2003-09-30 devnull 		f->dot.r.p1 = inlong();
288 76193d7c 2003-09-30 devnull 		f->dot.r.p2 = inlong();
289 76193d7c 2003-09-30 devnull 		f->tdot = f->dot.r;
290 76193d7c 2003-09-30 devnull 		journaln(0, i);
291 76193d7c 2003-09-30 devnull 		journaln(0, f->dot.r.p1);
292 76193d7c 2003-09-30 devnull 		journaln(0, f->dot.r.p2);
293 76193d7c 2003-09-30 devnull 		break;
294 76193d7c 2003-09-30 devnull 
295 76193d7c 2003-09-30 devnull 	case Ttype:
296 76193d7c 2003-09-30 devnull 		f = whichfile(inshort());
297 76193d7c 2003-09-30 devnull 		p0 = inlong();
298 76193d7c 2003-09-30 devnull 		journaln(0, p0);
299 76193d7c 2003-09-30 devnull 		journal(0, (char*)inp);
300 76193d7c 2003-09-30 devnull 		str = tmpcstr((char*)inp);
301 76193d7c 2003-09-30 devnull 		i = str->n;
302 76193d7c 2003-09-30 devnull 		loginsert(f, p0, str->s, str->n);
303 76193d7c 2003-09-30 devnull 		if(fileupdate(f, FALSE, FALSE))
304 76193d7c 2003-09-30 devnull 			seq++;
305 522b0689 2003-09-30 devnull 		if(f==cmd && p0==f->b.nc-i && i>0 && str->s[i-1]=='\n'){
306 76193d7c 2003-09-30 devnull 			freetmpstr(str);
307 76193d7c 2003-09-30 devnull 			termlocked++;
308 76193d7c 2003-09-30 devnull 			termcommand();
309 76193d7c 2003-09-30 devnull 		}else
310 76193d7c 2003-09-30 devnull 			freetmpstr(str);
311 76193d7c 2003-09-30 devnull 		f->dot.r.p1 = f->dot.r.p2 = p0+i; /* terminal knows this already */
312 76193d7c 2003-09-30 devnull 		f->tdot = f->dot.r;
313 76193d7c 2003-09-30 devnull 		break;
314 76193d7c 2003-09-30 devnull 
315 76193d7c 2003-09-30 devnull 	case Tcut:
316 76193d7c 2003-09-30 devnull 		f = whichfile(inshort());
317 76193d7c 2003-09-30 devnull 		p0 = inlong();
318 76193d7c 2003-09-30 devnull 		p1 = inlong();
319 76193d7c 2003-09-30 devnull 		journaln(0, p0);
320 76193d7c 2003-09-30 devnull 		journaln(0, p1);
321 76193d7c 2003-09-30 devnull 		logdelete(f, p0, p1);
322 76193d7c 2003-09-30 devnull 		if(fileupdate(f, FALSE, FALSE))
323 76193d7c 2003-09-30 devnull 			seq++;
324 76193d7c 2003-09-30 devnull 		f->dot.r.p1 = f->dot.r.p2 = p0;
325 76193d7c 2003-09-30 devnull 		f->tdot = f->dot.r;   /* terminal knows the value of dot already */
326 76193d7c 2003-09-30 devnull 		break;
327 76193d7c 2003-09-30 devnull 
328 76193d7c 2003-09-30 devnull 	case Tpaste:
329 76193d7c 2003-09-30 devnull 		f = whichfile(inshort());
330 76193d7c 2003-09-30 devnull 		p0 = inlong();
331 76193d7c 2003-09-30 devnull 		journaln(0, p0);
332 76193d7c 2003-09-30 devnull 		for(l=0; l<snarfbuf.nc; l+=m){
333 76193d7c 2003-09-30 devnull 			m = snarfbuf.nc-l;
334 76193d7c 2003-09-30 devnull 			if(m>BLOCKSIZE)
335 76193d7c 2003-09-30 devnull 				m = BLOCKSIZE;
336 76193d7c 2003-09-30 devnull 			bufread(&snarfbuf, l, genbuf, m);
337 76193d7c 2003-09-30 devnull 			loginsert(f, p0, tmprstr(genbuf, m)->s, m);
338 76193d7c 2003-09-30 devnull 		}
339 76193d7c 2003-09-30 devnull 		if(fileupdate(f, FALSE, TRUE))
340 76193d7c 2003-09-30 devnull 			seq++;
341 76193d7c 2003-09-30 devnull 		f->dot.r.p1 = p0;
342 76193d7c 2003-09-30 devnull 		f->dot.r.p2 = p0+snarfbuf.nc;
343 76193d7c 2003-09-30 devnull 		f->tdot.p1 = -1; /* force telldot to tell (arguably a BUG) */
344 76193d7c 2003-09-30 devnull 		telldot(f);
345 76193d7c 2003-09-30 devnull 		outTs(Hunlockfile, f->tag);
346 76193d7c 2003-09-30 devnull 		break;
347 76193d7c 2003-09-30 devnull 
348 76193d7c 2003-09-30 devnull 	case Tsnarf:
349 76193d7c 2003-09-30 devnull 		i = inshort();
350 76193d7c 2003-09-30 devnull 		p0 = inlong();
351 76193d7c 2003-09-30 devnull 		p1 = inlong();
352 76193d7c 2003-09-30 devnull 		snarf(whichfile(i), p0, p1, &snarfbuf, 0);
353 76193d7c 2003-09-30 devnull 		break;
354 76193d7c 2003-09-30 devnull 
355 76193d7c 2003-09-30 devnull 	case Tstartnewfile:
356 76193d7c 2003-09-30 devnull 		l = invlong();
357 76193d7c 2003-09-30 devnull 		Strdupl(&genstr, empty);
358 76193d7c 2003-09-30 devnull 		f = newfile();
359 76193d7c 2003-09-30 devnull 		f->rasp = emalloc(sizeof(List));
360 76193d7c 2003-09-30 devnull 		outTsv(Hbindname, f->tag, l);
361 76193d7c 2003-09-30 devnull 		logsetname(f, &genstr);
362 76193d7c 2003-09-30 devnull 		outTs(Hcurrent, f->tag);
363 76193d7c 2003-09-30 devnull 		current(f);
364 76193d7c 2003-09-30 devnull 		load(f);
365 76193d7c 2003-09-30 devnull 		break;
366 76193d7c 2003-09-30 devnull 
367 76193d7c 2003-09-30 devnull 	case Twrite:
368 76193d7c 2003-09-30 devnull 		termlocked++;
369 76193d7c 2003-09-30 devnull 		i = inshort();
370 76193d7c 2003-09-30 devnull 		journaln(0, i);
371 76193d7c 2003-09-30 devnull 		f = whichfile(i);
372 76193d7c 2003-09-30 devnull 		addr.r.p1 = 0;
373 522b0689 2003-09-30 devnull 		addr.r.p2 = f->b.nc;
374 76193d7c 2003-09-30 devnull 		if(f->name.s[0] == 0)
375 76193d7c 2003-09-30 devnull 			error(Enoname);
376 76193d7c 2003-09-30 devnull 		Strduplstr(&genstr, &f->name);
377 76193d7c 2003-09-30 devnull 		writef(f);
378 76193d7c 2003-09-30 devnull 		break;
379 76193d7c 2003-09-30 devnull 
380 76193d7c 2003-09-30 devnull 	case Tclose:
381 76193d7c 2003-09-30 devnull 		termlocked++;
382 76193d7c 2003-09-30 devnull 		i = inshort();
383 76193d7c 2003-09-30 devnull 		journaln(0, i);
384 76193d7c 2003-09-30 devnull 		f = whichfile(i);
385 76193d7c 2003-09-30 devnull 		current(f);
386 76193d7c 2003-09-30 devnull 		trytoclose(f);
387 76193d7c 2003-09-30 devnull 		/* if trytoclose fails, will error out */
388 76193d7c 2003-09-30 devnull 		delete(f);
389 76193d7c 2003-09-30 devnull 		break;
390 76193d7c 2003-09-30 devnull 
391 76193d7c 2003-09-30 devnull 	case Tlook:
392 76193d7c 2003-09-30 devnull 		f = whichfile(inshort());
393 76193d7c 2003-09-30 devnull 		termlocked++;
394 76193d7c 2003-09-30 devnull 		p0 = inlong();
395 76193d7c 2003-09-30 devnull 		p1 = inlong();
396 76193d7c 2003-09-30 devnull 		journaln(0, p0);
397 76193d7c 2003-09-30 devnull 		journaln(0, p1);
398 76193d7c 2003-09-30 devnull 		setgenstr(f, p0, p1);
399 76193d7c 2003-09-30 devnull 		for(l = 0; l<genstr.n; l++){
400 76193d7c 2003-09-30 devnull 			i = genstr.s[l];
401 611d815b 2005-03-18 devnull 			if(utfrune(".*+?(|)\\[]^$", i)){
402 611d815b 2005-03-18 devnull 				str = tmpcstr("\\");
403 611d815b 2005-03-18 devnull 				Strinsert(&genstr, str, l++);
404 611d815b 2005-03-18 devnull 				freetmpstr(str);
405 611d815b 2005-03-18 devnull 			}
406 76193d7c 2003-09-30 devnull 		}
407 76193d7c 2003-09-30 devnull 		Straddc(&genstr, '\0');
408 76193d7c 2003-09-30 devnull 		nextmatch(f, &genstr, p1, 1);
409 76193d7c 2003-09-30 devnull 		moveto(f, sel.p[0]);
410 76193d7c 2003-09-30 devnull 		break;
411 76193d7c 2003-09-30 devnull 
412 76193d7c 2003-09-30 devnull 	case Tsearch:
413 76193d7c 2003-09-30 devnull 		termlocked++;
414 76193d7c 2003-09-30 devnull 		if(curfile == 0)
415 76193d7c 2003-09-30 devnull 			error(Enofile);
416 76193d7c 2003-09-30 devnull 		if(lastpat.s[0] == 0)
417 76193d7c 2003-09-30 devnull 			panic("Tsearch");
418 76193d7c 2003-09-30 devnull 		nextmatch(curfile, &lastpat, curfile->dot.r.p2, 1);
419 76193d7c 2003-09-30 devnull 		moveto(curfile, sel.p[0]);
420 76193d7c 2003-09-30 devnull 		break;
421 76193d7c 2003-09-30 devnull 
422 76193d7c 2003-09-30 devnull 	case Tsend:
423 76193d7c 2003-09-30 devnull 		termlocked++;
424 76193d7c 2003-09-30 devnull 		inshort();	/* ignored */
425 76193d7c 2003-09-30 devnull 		p0 = inlong();
426 76193d7c 2003-09-30 devnull 		p1 = inlong();
427 76193d7c 2003-09-30 devnull 		setgenstr(cmd, p0, p1);
428 76193d7c 2003-09-30 devnull 		bufreset(&snarfbuf);
429 76193d7c 2003-09-30 devnull 		bufinsert(&snarfbuf, (Posn)0, genstr.s, genstr.n);
430 76193d7c 2003-09-30 devnull 		outTl(Hsnarflen, genstr.n);
431 76193d7c 2003-09-30 devnull 		if(genstr.s[genstr.n-1] != '\n')
432 76193d7c 2003-09-30 devnull 			Straddc(&genstr, '\n');
433 522b0689 2003-09-30 devnull 		loginsert(cmd, cmd->b.nc, genstr.s, genstr.n);
434 76193d7c 2003-09-30 devnull 		fileupdate(cmd, FALSE, TRUE);
435 522b0689 2003-09-30 devnull 		cmd->dot.r.p1 = cmd->dot.r.p2 = cmd->b.nc;
436 76193d7c 2003-09-30 devnull 		telldot(cmd);
437 76193d7c 2003-09-30 devnull 		termcommand();
438 76193d7c 2003-09-30 devnull 		break;
439 76193d7c 2003-09-30 devnull 
440 76193d7c 2003-09-30 devnull 	case Tdclick:
441 76193d7c 2003-09-30 devnull 		f = whichfile(inshort());
442 76193d7c 2003-09-30 devnull 		p1 = inlong();
443 76193d7c 2003-09-30 devnull 		doubleclick(f, p1);
444 76193d7c 2003-09-30 devnull 		f->tdot.p1 = f->tdot.p2 = p1;
445 76193d7c 2003-09-30 devnull 		telldot(f);
446 76193d7c 2003-09-30 devnull 		outTs(Hunlockfile, f->tag);
447 76193d7c 2003-09-30 devnull 		break;
448 76193d7c 2003-09-30 devnull 
449 76193d7c 2003-09-30 devnull 	case Tstartsnarf:
450 76193d7c 2003-09-30 devnull 		if (snarfbuf.nc <= 0) {	/* nothing to export */
451 76193d7c 2003-09-30 devnull 			outTs(Hsetsnarf, 0);
452 76193d7c 2003-09-30 devnull 			break;
453 76193d7c 2003-09-30 devnull 		}
454 76193d7c 2003-09-30 devnull 		c = 0;
455 76193d7c 2003-09-30 devnull 		i = 0;
456 76193d7c 2003-09-30 devnull 		m = snarfbuf.nc;
457 76193d7c 2003-09-30 devnull 		if(m > SNARFSIZE) {
458 76193d7c 2003-09-30 devnull 			m = SNARFSIZE;
459 76193d7c 2003-09-30 devnull 			dprint("?warning: snarf buffer truncated\n");
460 76193d7c 2003-09-30 devnull 		}
461 76193d7c 2003-09-30 devnull 		rp = malloc(m*sizeof(Rune));
462 76193d7c 2003-09-30 devnull 		if(rp){
463 76193d7c 2003-09-30 devnull 			bufread(&snarfbuf, 0, rp, m);
464 76193d7c 2003-09-30 devnull 			c = Strtoc(tmprstr(rp, m));
465 76193d7c 2003-09-30 devnull 			free(rp);
466 76193d7c 2003-09-30 devnull 			i = strlen(c);
467 76193d7c 2003-09-30 devnull 		}
468 76193d7c 2003-09-30 devnull 		outTs(Hsetsnarf, i);
469 76193d7c 2003-09-30 devnull 		if(c){
470 76193d7c 2003-09-30 devnull 			Write(1, c, i);
471 76193d7c 2003-09-30 devnull 			free(c);
472 76193d7c 2003-09-30 devnull 		} else
473 76193d7c 2003-09-30 devnull 			dprint("snarf buffer too long\n");
474 76193d7c 2003-09-30 devnull 		break;
475 76193d7c 2003-09-30 devnull 
476 76193d7c 2003-09-30 devnull 	case Tsetsnarf:
477 76193d7c 2003-09-30 devnull 		m = inshort();
478 76193d7c 2003-09-30 devnull 		if(m > SNARFSIZE)
479 76193d7c 2003-09-30 devnull 			error(Etoolong);
480 76193d7c 2003-09-30 devnull 		c = malloc(m+1);
481 76193d7c 2003-09-30 devnull 		if(c){
482 76193d7c 2003-09-30 devnull 			for(i=0; i<m; i++)
483 76193d7c 2003-09-30 devnull 				c[i] = rcvchar();
484 76193d7c 2003-09-30 devnull 			c[m] = 0;
485 76193d7c 2003-09-30 devnull 			str = tmpcstr(c);
486 76193d7c 2003-09-30 devnull 			free(c);
487 76193d7c 2003-09-30 devnull 			bufreset(&snarfbuf);
488 76193d7c 2003-09-30 devnull 			bufinsert(&snarfbuf, (Posn)0, str->s, str->n);
489 76193d7c 2003-09-30 devnull 			freetmpstr(str);
490 76193d7c 2003-09-30 devnull 			outT0(Hunlock);
491 76193d7c 2003-09-30 devnull 		}
492 76193d7c 2003-09-30 devnull 		break;
493 76193d7c 2003-09-30 devnull 
494 76193d7c 2003-09-30 devnull 	case Tack:
495 76193d7c 2003-09-30 devnull 		waitack = 0;
496 76193d7c 2003-09-30 devnull 		break;
497 76193d7c 2003-09-30 devnull 
498 76193d7c 2003-09-30 devnull 	case Tplumb:
499 76193d7c 2003-09-30 devnull 		f = whichfile(inshort());
500 76193d7c 2003-09-30 devnull 		p0 = inlong();
501 76193d7c 2003-09-30 devnull 		p1 = inlong();
502 76193d7c 2003-09-30 devnull 		pm = emalloc(sizeof(Plumbmsg));
503 76193d7c 2003-09-30 devnull 		pm->src = strdup("sam");
504 76193d7c 2003-09-30 devnull 		pm->dst = 0;
505 76193d7c 2003-09-30 devnull 		/* construct current directory */
506 76193d7c 2003-09-30 devnull 		c = Strtoc(&f->name);
507 76193d7c 2003-09-30 devnull 		if(c[0] == '/')
508 76193d7c 2003-09-30 devnull 			pm->wdir = c;
509 76193d7c 2003-09-30 devnull 		else{
510 76193d7c 2003-09-30 devnull 			wdir = emalloc(1024);
511 76193d7c 2003-09-30 devnull 			getwd(wdir, 1024);
512 76193d7c 2003-09-30 devnull 			pm->wdir = emalloc(1024);
513 76193d7c 2003-09-30 devnull 			snprint(pm->wdir, 1024, "%s/%s", wdir, c);
514 76193d7c 2003-09-30 devnull 			cleanname(pm->wdir);
515 76193d7c 2003-09-30 devnull 			free(wdir);
516 76193d7c 2003-09-30 devnull 			free(c);
517 76193d7c 2003-09-30 devnull 		}
518 76193d7c 2003-09-30 devnull 		c = strrchr(pm->wdir, '/');
519 76193d7c 2003-09-30 devnull 		if(c)
520 76193d7c 2003-09-30 devnull 			*c = '\0';
521 76193d7c 2003-09-30 devnull 		pm->type = strdup("text");
522 76193d7c 2003-09-30 devnull 		if(p1 > p0)
523 76193d7c 2003-09-30 devnull 			pm->attr = nil;
524 76193d7c 2003-09-30 devnull 		else{
525 76193d7c 2003-09-30 devnull 			p = p0;
526 76193d7c 2003-09-30 devnull 			while(p0>0 && (i=filereadc(f, p0 - 1))!=' ' && i!='\t' && i!='\n')
527 76193d7c 2003-09-30 devnull 				p0--;
528 522b0689 2003-09-30 devnull 			while(p1<f->b.nc && (i=filereadc(f, p1))!=' ' && i!='\t' && i!='\n')
529 76193d7c 2003-09-30 devnull 				p1++;
530 76193d7c 2003-09-30 devnull 			sprint(cbuf, "click=%ld", p-p0);
531 76193d7c 2003-09-30 devnull 			pm->attr = plumbunpackattr(cbuf);
532 76193d7c 2003-09-30 devnull 		}
533 76193d7c 2003-09-30 devnull 		if(p0==p1 || p1-p0>=BLOCKSIZE){
534 76193d7c 2003-09-30 devnull 			plumbfree(pm);
535 76193d7c 2003-09-30 devnull 			break;
536 76193d7c 2003-09-30 devnull 		}
537 76193d7c 2003-09-30 devnull 		setgenstr(f, p0, p1);
538 76193d7c 2003-09-30 devnull 		pm->data = Strtoc(&genstr);
539 76193d7c 2003-09-30 devnull 		pm->ndata = strlen(pm->data);
540 76193d7c 2003-09-30 devnull 		c = plumbpack(pm, &i);
541 76193d7c 2003-09-30 devnull 		if(c != 0){
542 76193d7c 2003-09-30 devnull 			outTs(Hplumb, i);
543 76193d7c 2003-09-30 devnull 			Write(1, c, i);
544 76193d7c 2003-09-30 devnull 			free(c);
545 76193d7c 2003-09-30 devnull 		}
546 76193d7c 2003-09-30 devnull 		plumbfree(pm);
547 76193d7c 2003-09-30 devnull 		break;
548 76193d7c 2003-09-30 devnull 
549 76193d7c 2003-09-30 devnull 	case Texit:
550 76193d7c 2003-09-30 devnull 		exits(0);
551 76193d7c 2003-09-30 devnull 	}
552 76193d7c 2003-09-30 devnull 	return TRUE;
553 76193d7c 2003-09-30 devnull }
554 76193d7c 2003-09-30 devnull 
555 76193d7c 2003-09-30 devnull void
556 76193d7c 2003-09-30 devnull snarf(File *f, Posn p1, Posn p2, Buffer *buf, int emptyok)
557 76193d7c 2003-09-30 devnull {
558 76193d7c 2003-09-30 devnull 	Posn l;
559 76193d7c 2003-09-30 devnull 	int i;
560 76193d7c 2003-09-30 devnull 
561 76193d7c 2003-09-30 devnull 	if(!emptyok && p1==p2)
562 76193d7c 2003-09-30 devnull 		return;
563 76193d7c 2003-09-30 devnull 	bufreset(buf);
564 76193d7c 2003-09-30 devnull 	/* Stage through genbuf to avoid compaction problems (vestigial) */
565 522b0689 2003-09-30 devnull 	if(p2 > f->b.nc){
566 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 */
567 522b0689 2003-09-30 devnull 		p2 = f->b.nc;
568 76193d7c 2003-09-30 devnull 	}
569 76193d7c 2003-09-30 devnull 	for(l=p1; l<p2; l+=i){
570 76193d7c 2003-09-30 devnull 		i = p2-l>BLOCKSIZE? BLOCKSIZE : p2-l;
571 522b0689 2003-09-30 devnull 		bufread(&f->b, l, genbuf, i);
572 76193d7c 2003-09-30 devnull 		bufinsert(buf, buf->nc, tmprstr(genbuf, i)->s, i);
573 76193d7c 2003-09-30 devnull 	}
574 76193d7c 2003-09-30 devnull }
575 76193d7c 2003-09-30 devnull 
576 76193d7c 2003-09-30 devnull int
577 76193d7c 2003-09-30 devnull inshort(void)
578 76193d7c 2003-09-30 devnull {
579 76193d7c 2003-09-30 devnull 	ushort n;
580 76193d7c 2003-09-30 devnull 
581 76193d7c 2003-09-30 devnull 	n = inp[0] | (inp[1]<<8);
582 76193d7c 2003-09-30 devnull 	inp += 2;
583 76193d7c 2003-09-30 devnull 	return n;
584 76193d7c 2003-09-30 devnull }
585 76193d7c 2003-09-30 devnull 
586 76193d7c 2003-09-30 devnull long
587 76193d7c 2003-09-30 devnull inlong(void)
588 76193d7c 2003-09-30 devnull {
589 76193d7c 2003-09-30 devnull 	ulong n;
590 76193d7c 2003-09-30 devnull 
591 76193d7c 2003-09-30 devnull 	n = inp[0] | (inp[1]<<8) | (inp[2]<<16) | (inp[3]<<24);
592 76193d7c 2003-09-30 devnull 	inp += 4;
593 76193d7c 2003-09-30 devnull 	return n;
594 76193d7c 2003-09-30 devnull }
595 76193d7c 2003-09-30 devnull 
596 76193d7c 2003-09-30 devnull long
597 76193d7c 2003-09-30 devnull invlong(void)
598 76193d7c 2003-09-30 devnull {
599 76193d7c 2003-09-30 devnull 	ulong n;
600 76193d7c 2003-09-30 devnull 	
601 76193d7c 2003-09-30 devnull 	n = (inp[7]<<24) | (inp[6]<<16) | (inp[5]<<8) | inp[4];
602 76193d7c 2003-09-30 devnull 	n = (n<<16) | (inp[3]<<8) | inp[2];
603 76193d7c 2003-09-30 devnull 	n = (n<<16) | (inp[1]<<8) | inp[0];
604 76193d7c 2003-09-30 devnull 	inp += 8;
605 76193d7c 2003-09-30 devnull 	return n;
606 76193d7c 2003-09-30 devnull }
607 76193d7c 2003-09-30 devnull 
608 76193d7c 2003-09-30 devnull void
609 76193d7c 2003-09-30 devnull setgenstr(File *f, Posn p0, Posn p1)
610 76193d7c 2003-09-30 devnull {
611 76193d7c 2003-09-30 devnull 	if(p0 != p1){
612 76193d7c 2003-09-30 devnull 		if(p1-p0 >= TBLOCKSIZE)
613 76193d7c 2003-09-30 devnull 			error(Etoolong);
614 76193d7c 2003-09-30 devnull 		Strinsure(&genstr, p1-p0);
615 522b0689 2003-09-30 devnull 		bufread(&f->b, p0, genbuf, p1-p0);
616 76193d7c 2003-09-30 devnull 		memmove(genstr.s, genbuf, RUNESIZE*(p1-p0));
617 76193d7c 2003-09-30 devnull 		genstr.n = p1-p0;
618 76193d7c 2003-09-30 devnull 	}else{
619 76193d7c 2003-09-30 devnull 		if(snarfbuf.nc == 0)
620 76193d7c 2003-09-30 devnull 			error(Eempty);
621 76193d7c 2003-09-30 devnull 		if(snarfbuf.nc > TBLOCKSIZE)
622 76193d7c 2003-09-30 devnull 			error(Etoolong);
623 76193d7c 2003-09-30 devnull 		bufread(&snarfbuf, (Posn)0, genbuf, snarfbuf.nc);
624 76193d7c 2003-09-30 devnull 		Strinsure(&genstr, snarfbuf.nc);
625 76193d7c 2003-09-30 devnull 		memmove(genstr.s, genbuf, RUNESIZE*snarfbuf.nc);
626 76193d7c 2003-09-30 devnull 		genstr.n = snarfbuf.nc;
627 76193d7c 2003-09-30 devnull 	}
628 76193d7c 2003-09-30 devnull }
629 76193d7c 2003-09-30 devnull 
630 76193d7c 2003-09-30 devnull void
631 76193d7c 2003-09-30 devnull outT0(Hmesg type)
632 76193d7c 2003-09-30 devnull {
633 76193d7c 2003-09-30 devnull 	outstart(type);
634 76193d7c 2003-09-30 devnull 	outsend();
635 76193d7c 2003-09-30 devnull }
636 76193d7c 2003-09-30 devnull 
637 76193d7c 2003-09-30 devnull void
638 76193d7c 2003-09-30 devnull outTl(Hmesg type, long l)
639 76193d7c 2003-09-30 devnull {
640 76193d7c 2003-09-30 devnull 	outstart(type);
641 76193d7c 2003-09-30 devnull 	outlong(l);
642 76193d7c 2003-09-30 devnull 	outsend();
643 76193d7c 2003-09-30 devnull }
644 76193d7c 2003-09-30 devnull 
645 76193d7c 2003-09-30 devnull void
646 76193d7c 2003-09-30 devnull outTs(Hmesg type, int s)
647 76193d7c 2003-09-30 devnull {
648 76193d7c 2003-09-30 devnull 	outstart(type);
649 76193d7c 2003-09-30 devnull 	journaln(1, s);
650 76193d7c 2003-09-30 devnull 	outshort(s);
651 76193d7c 2003-09-30 devnull 	outsend();
652 76193d7c 2003-09-30 devnull }
653 76193d7c 2003-09-30 devnull 
654 76193d7c 2003-09-30 devnull void
655 76193d7c 2003-09-30 devnull outS(String *s)
656 76193d7c 2003-09-30 devnull {
657 76193d7c 2003-09-30 devnull 	char *c;
658 76193d7c 2003-09-30 devnull 	int i;
659 76193d7c 2003-09-30 devnull 
660 76193d7c 2003-09-30 devnull 	c = Strtoc(s);
661 76193d7c 2003-09-30 devnull 	i = strlen(c);
662 76193d7c 2003-09-30 devnull 	outcopy(i, c);
663 76193d7c 2003-09-30 devnull 	if(i > 99)
664 76193d7c 2003-09-30 devnull 		c[99] = 0;
665 76193d7c 2003-09-30 devnull 	journaln(1, i);
666 76193d7c 2003-09-30 devnull 	journal(1, c);
667 76193d7c 2003-09-30 devnull 	free(c);
668 76193d7c 2003-09-30 devnull }
669 76193d7c 2003-09-30 devnull 
670 76193d7c 2003-09-30 devnull void
671 76193d7c 2003-09-30 devnull outTsS(Hmesg type, int s1, String *s)
672 76193d7c 2003-09-30 devnull {
673 76193d7c 2003-09-30 devnull 	outstart(type);
674 76193d7c 2003-09-30 devnull 	outshort(s1);
675 76193d7c 2003-09-30 devnull 	outS(s);
676 76193d7c 2003-09-30 devnull 	outsend();
677 76193d7c 2003-09-30 devnull }
678 76193d7c 2003-09-30 devnull 
679 76193d7c 2003-09-30 devnull void
680 76193d7c 2003-09-30 devnull outTslS(Hmesg type, int s1, Posn l1, String *s)
681 76193d7c 2003-09-30 devnull {
682 76193d7c 2003-09-30 devnull 	outstart(type);
683 76193d7c 2003-09-30 devnull 	outshort(s1);
684 76193d7c 2003-09-30 devnull 	journaln(1, s1);
685 76193d7c 2003-09-30 devnull 	outlong(l1);
686 76193d7c 2003-09-30 devnull 	journaln(1, l1);
687 76193d7c 2003-09-30 devnull 	outS(s);
688 76193d7c 2003-09-30 devnull 	outsend();
689 76193d7c 2003-09-30 devnull }
690 76193d7c 2003-09-30 devnull 
691 76193d7c 2003-09-30 devnull void
692 76193d7c 2003-09-30 devnull outTS(Hmesg type, String *s)
693 76193d7c 2003-09-30 devnull {
694 76193d7c 2003-09-30 devnull 	outstart(type);
695 76193d7c 2003-09-30 devnull 	outS(s);
696 76193d7c 2003-09-30 devnull 	outsend();
697 76193d7c 2003-09-30 devnull }
698 76193d7c 2003-09-30 devnull 
699 76193d7c 2003-09-30 devnull void
700 76193d7c 2003-09-30 devnull outTsllS(Hmesg type, int s1, Posn l1, Posn l2, String *s)
701 76193d7c 2003-09-30 devnull {
702 76193d7c 2003-09-30 devnull 	outstart(type);
703 76193d7c 2003-09-30 devnull 	outshort(s1);
704 76193d7c 2003-09-30 devnull 	outlong(l1);
705 76193d7c 2003-09-30 devnull 	outlong(l2);
706 76193d7c 2003-09-30 devnull 	journaln(1, l1);
707 76193d7c 2003-09-30 devnull 	journaln(1, l2);
708 76193d7c 2003-09-30 devnull 	outS(s);
709 76193d7c 2003-09-30 devnull 	outsend();
710 76193d7c 2003-09-30 devnull }
711 76193d7c 2003-09-30 devnull 
712 76193d7c 2003-09-30 devnull void
713 76193d7c 2003-09-30 devnull outTsll(Hmesg type, int s, Posn l1, Posn l2)
714 76193d7c 2003-09-30 devnull {
715 76193d7c 2003-09-30 devnull 	outstart(type);
716 76193d7c 2003-09-30 devnull 	outshort(s);
717 76193d7c 2003-09-30 devnull 	outlong(l1);
718 76193d7c 2003-09-30 devnull 	outlong(l2);
719 76193d7c 2003-09-30 devnull 	journaln(1, l1);
720 76193d7c 2003-09-30 devnull 	journaln(1, l2);
721 76193d7c 2003-09-30 devnull 	outsend();
722 76193d7c 2003-09-30 devnull }
723 76193d7c 2003-09-30 devnull 
724 76193d7c 2003-09-30 devnull void
725 76193d7c 2003-09-30 devnull outTsl(Hmesg type, int s, Posn l)
726 76193d7c 2003-09-30 devnull {
727 76193d7c 2003-09-30 devnull 	outstart(type);
728 76193d7c 2003-09-30 devnull 	outshort(s);
729 76193d7c 2003-09-30 devnull 	outlong(l);
730 76193d7c 2003-09-30 devnull 	journaln(1, l);
731 76193d7c 2003-09-30 devnull 	outsend();
732 76193d7c 2003-09-30 devnull }
733 76193d7c 2003-09-30 devnull 
734 76193d7c 2003-09-30 devnull void
735 76193d7c 2003-09-30 devnull outTsv(Hmesg type, int s, Posn l)
736 76193d7c 2003-09-30 devnull {
737 76193d7c 2003-09-30 devnull 	outstart(type);
738 76193d7c 2003-09-30 devnull 	outshort(s);
739 76193d7c 2003-09-30 devnull 	outvlong((void*)l);
740 76193d7c 2003-09-30 devnull 	journaln(1, l);
741 76193d7c 2003-09-30 devnull 	outsend();
742 76193d7c 2003-09-30 devnull }
743 76193d7c 2003-09-30 devnull 
744 76193d7c 2003-09-30 devnull void
745 76193d7c 2003-09-30 devnull outstart(Hmesg type)
746 76193d7c 2003-09-30 devnull {
747 76193d7c 2003-09-30 devnull 	journal(1, hname[type]);
748 76193d7c 2003-09-30 devnull 	outmsg[0] = type;
749 76193d7c 2003-09-30 devnull 	outp = outmsg+3;
750 76193d7c 2003-09-30 devnull }
751 76193d7c 2003-09-30 devnull 
752 76193d7c 2003-09-30 devnull void
753 76193d7c 2003-09-30 devnull outcopy(int count, void *data)
754 76193d7c 2003-09-30 devnull {
755 76193d7c 2003-09-30 devnull 	memmove(outp, data, count);
756 76193d7c 2003-09-30 devnull 	outp += count;
757 76193d7c 2003-09-30 devnull }
758 76193d7c 2003-09-30 devnull 
759 76193d7c 2003-09-30 devnull void
760 76193d7c 2003-09-30 devnull outshort(int s)
761 76193d7c 2003-09-30 devnull {
762 76193d7c 2003-09-30 devnull 	*outp++ = s;
763 76193d7c 2003-09-30 devnull 	*outp++ = s>>8; 
764 76193d7c 2003-09-30 devnull }
765 76193d7c 2003-09-30 devnull 
766 76193d7c 2003-09-30 devnull void
767 76193d7c 2003-09-30 devnull outlong(long l)
768 76193d7c 2003-09-30 devnull {
769 76193d7c 2003-09-30 devnull 	*outp++ = l;
770 76193d7c 2003-09-30 devnull 	*outp++ = l>>8;
771 76193d7c 2003-09-30 devnull 	*outp++ = l>>16;
772 76193d7c 2003-09-30 devnull 	*outp++ = l>>24;
773 76193d7c 2003-09-30 devnull }
774 76193d7c 2003-09-30 devnull 
775 76193d7c 2003-09-30 devnull void
776 76193d7c 2003-09-30 devnull outvlong(void *v)
777 76193d7c 2003-09-30 devnull {
778 76193d7c 2003-09-30 devnull 	int i;
779 76193d7c 2003-09-30 devnull 	ulong l;
780 76193d7c 2003-09-30 devnull 
781 76193d7c 2003-09-30 devnull 	l = (ulong) v;
782 76193d7c 2003-09-30 devnull 	for(i = 0; i < 8; i++, l >>= 8)
783 76193d7c 2003-09-30 devnull 		*outp++ = l;
784 76193d7c 2003-09-30 devnull }
785 76193d7c 2003-09-30 devnull 
786 76193d7c 2003-09-30 devnull void
787 76193d7c 2003-09-30 devnull outsend(void)
788 76193d7c 2003-09-30 devnull {
789 76193d7c 2003-09-30 devnull 	int outcount;
790 76193d7c 2003-09-30 devnull 
791 76193d7c 2003-09-30 devnull 	outcount = outp-outmsg;
792 76193d7c 2003-09-30 devnull 	outcount -= 3;
793 76193d7c 2003-09-30 devnull 	outmsg[1] = outcount;
794 76193d7c 2003-09-30 devnull 	outmsg[2] = outcount>>8;
795 76193d7c 2003-09-30 devnull 	outmsg = outp;
796 76193d7c 2003-09-30 devnull 	if(!noflush){
797 76193d7c 2003-09-30 devnull 		outcount = outmsg-outdata;
798 76193d7c 2003-09-30 devnull 		if (write(1, (char*) outdata, outcount) != outcount)
799 76193d7c 2003-09-30 devnull 			rescue();
800 76193d7c 2003-09-30 devnull 		outmsg = outdata;
801 76193d7c 2003-09-30 devnull 		return;
802 76193d7c 2003-09-30 devnull 	}
803 76193d7c 2003-09-30 devnull 	if(outmsg < outdata+DATASIZE)
804 76193d7c 2003-09-30 devnull 		return;
805 76193d7c 2003-09-30 devnull 	outflush();
806 76193d7c 2003-09-30 devnull }
807 76193d7c 2003-09-30 devnull 
808 76193d7c 2003-09-30 devnull void
809 76193d7c 2003-09-30 devnull outflush(void)
810 76193d7c 2003-09-30 devnull {
811 76193d7c 2003-09-30 devnull 	if(outmsg == outdata)
812 76193d7c 2003-09-30 devnull 		return;
813 76193d7c 2003-09-30 devnull 	noflush = 0;
814 76193d7c 2003-09-30 devnull 	outT0(Hack);
815 76193d7c 2003-09-30 devnull 	waitack = 1;
816 76193d7c 2003-09-30 devnull 	do
817 76193d7c 2003-09-30 devnull 		if(rcv() == 0){
818 76193d7c 2003-09-30 devnull 			rescue();
819 76193d7c 2003-09-30 devnull 			exits("eof");
820 76193d7c 2003-09-30 devnull 		}
821 76193d7c 2003-09-30 devnull 	while(waitack);
822 76193d7c 2003-09-30 devnull 	outmsg = outdata;
823 76193d7c 2003-09-30 devnull 	noflush = 1;
824 76193d7c 2003-09-30 devnull }