1 76193d7c 2003-09-30 devnull #include "sam.h"
  2 76193d7c 2003-09-30 devnull Header	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;
 14 76193d7c 2003-09-30 devnull 
 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);
 19 2c0f3733 2006-04-20 devnull 
 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);
 26 2c0f3733 2006-04-20 devnull 
 27 76193d7c 2003-09-30 devnull void	setgenstr(File*, Posn, Posn);
 28 76193d7c 2003-09-30 devnull 
 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"
 57 76193d7c 2003-09-30 devnull };
 58 76193d7c 2003-09-30 devnull 
 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"
 83 76193d7c 2003-09-30 devnull };
 84 76193d7c 2003-09-30 devnull 
 85 76193d7c 2003-09-30 devnull void
 86 76193d7c 2003-09-30 devnull journal(int out, char *s)
 87 76193d7c 2003-09-30 devnull {
 88 76193d7c 2003-09-30 devnull 	static int fd = 0;
 89 76193d7c 2003-09-30 devnull 
 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);
 93 76193d7c 2003-09-30 devnull }
 94 76193d7c 2003-09-30 devnull 
 95 76193d7c 2003-09-30 devnull void
 96 76193d7c 2003-09-30 devnull journaln(int out, long n)
 97 76193d7c 2003-09-30 devnull {
 98 76193d7c 2003-09-30 devnull 	char buf[32];
 99 76193d7c 2003-09-30 devnull 
100 2c0f3733 2006-04-20 devnull 	snprint(buf, sizeof buf, "%ld", n);
101 76193d7c 2003-09-30 devnull 	journal(out, buf);
102 76193d7c 2003-09-30 devnull }
103 2c0f3733 2006-04-20 devnull 
104 2c0f3733 2006-04-20 devnull void
105 2c0f3733 2006-04-20 devnull journalv(int out, vlong v)
106 2c0f3733 2006-04-20 devnull {
107 2c0f3733 2006-04-20 devnull 	char buf[32];
108 2c0f3733 2006-04-20 devnull 
109 2c0f3733 2006-04-20 devnull 	snprint(buf, sizeof buf, "%lld", v);
110 2c0f3733 2006-04-20 devnull 	journal(out, buf);
111 2c0f3733 2006-04-20 devnull }
112 2c0f3733 2006-04-20 devnull 
113 76193d7c 2003-09-30 devnull #else
114 76193d7c 2003-09-30 devnull #define	journal(a, b)
115 76193d7c 2003-09-30 devnull #define journaln(a, b)
116 76193d7c 2003-09-30 devnull #endif
117 76193d7c 2003-09-30 devnull 
118 76193d7c 2003-09-30 devnull int
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;
122 76193d7c 2003-09-30 devnull 
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;
127 76193d7c 2003-09-30 devnull 		i = 0;
128 76193d7c 2003-09-30 devnull 	}
129 76193d7c 2003-09-30 devnull 	--nleft;
130 76193d7c 2003-09-30 devnull 	return buf[i++];
131 76193d7c 2003-09-30 devnull }
132 76193d7c 2003-09-30 devnull 
133 76193d7c 2003-09-30 devnull int
134 76193d7c 2003-09-30 devnull rcv(void){
135 76193d7c 2003-09-30 devnull 	int c;
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;
139 76193d7c 2003-09-30 devnull 
140 76193d7c 2003-09-30 devnull 	while((c=rcvchar()) != -1)
141 76193d7c 2003-09-30 devnull 		switch(state){
142 76193d7c 2003-09-30 devnull 		case 0:
143 76193d7c 2003-09-30 devnull 			h.type = c;
144 76193d7c 2003-09-30 devnull 			state++;
145 76193d7c 2003-09-30 devnull 			break;
146 76193d7c 2003-09-30 devnull 
147 76193d7c 2003-09-30 devnull 		case 1:
148 76193d7c 2003-09-30 devnull 			h.count0 = c;
149 76193d7c 2003-09-30 devnull 			state++;
150 76193d7c 2003-09-30 devnull 			break;
151 76193d7c 2003-09-30 devnull 
152 76193d7c 2003-09-30 devnull 		case 2:
153 76193d7c 2003-09-30 devnull 			h.count1 = c;
154 76193d7c 2003-09-30 devnull 			count = h.count0|(h.count1<<8);
155 76193d7c 2003-09-30 devnull 			i = 0;
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++;
161 76193d7c 2003-09-30 devnull 			break;
162 76193d7c 2003-09-30 devnull 
163 76193d7c 2003-09-30 devnull 		case 3:
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);
170 76193d7c 2003-09-30 devnull 			}
171 76193d7c 2003-09-30 devnull 			break;
172 76193d7c 2003-09-30 devnull 		}
173 76193d7c 2003-09-30 devnull 	return 0;
174 76193d7c 2003-09-30 devnull }
175 76193d7c 2003-09-30 devnull 
176 76193d7c 2003-09-30 devnull File *
177 76193d7c 2003-09-30 devnull whichfile(int tag)
178 76193d7c 2003-09-30 devnull {
179 76193d7c 2003-09-30 devnull 	int i;
180 76193d7c 2003-09-30 devnull 
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;
186 76193d7c 2003-09-30 devnull }
187 76193d7c 2003-09-30 devnull 
188 76193d7c 2003-09-30 devnull int
189 76193d7c 2003-09-30 devnull inmesg(Tmesg type)
190 76193d7c 2003-09-30 devnull {
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;
204 76193d7c 2003-09-30 devnull 
205 76193d7c 2003-09-30 devnull 	if(type > TMAX)
206 76193d7c 2003-09-30 devnull 		panic("inmesg");
207 76193d7c 2003-09-30 devnull 
208 76193d7c 2003-09-30 devnull 	journal(0, tname[type]);
209 76193d7c 2003-09-30 devnull 
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");
214 76193d7c 2003-09-30 devnull 
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");
218 76193d7c 2003-09-30 devnull 
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);
222 76193d7c 2003-09-30 devnull 		break;
223 76193d7c 2003-09-30 devnull 
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);
238 76193d7c 2003-09-30 devnull 		}
239 76193d7c 2003-09-30 devnull 		fileupdate(cmd, FALSE, TRUE);
240 76193d7c 2003-09-30 devnull 		outT0(Hunlock);
241 76193d7c 2003-09-30 devnull 		break;
242 76193d7c 2003-09-30 devnull 
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);
246 76193d7c 2003-09-30 devnull 		break;
247 76193d7c 2003-09-30 devnull 
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){
261 76193d7c 2003-09-30 devnull 			i = 0;
262 76193d7c 2003-09-30 devnull 			r.p1 = r.p2 = p0;
263 76193d7c 2003-09-30 devnull 		}else{
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);
267 76193d7c 2003-09-30 devnull 		}
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));
270 76193d7c 2003-09-30 devnull 		break;
271 76193d7c 2003-09-30 devnull 
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);
278 76193d7c 2003-09-30 devnull 		break;
279 76193d7c 2003-09-30 devnull 
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);
291 76193d7c 2003-09-30 devnull 		else{
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);
295 76193d7c 2003-09-30 devnull 			}
296 76193d7c 2003-09-30 devnull 			outTs(Hcheck0, f->tag);
297 76193d7c 2003-09-30 devnull 			moveto(f, f->dot.r);
298 76193d7c 2003-09-30 devnull 		}
299 76193d7c 2003-09-30 devnull 		break;
300 76193d7c 2003-09-30 devnull 
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);
311 76193d7c 2003-09-30 devnull 		break;
312 76193d7c 2003-09-30 devnull 
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))
322 76193d7c 2003-09-30 devnull 			seq++;
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();
327 76193d7c 2003-09-30 devnull 		}else
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;
331 76193d7c 2003-09-30 devnull 		break;
332 76193d7c 2003-09-30 devnull 
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))
341 76193d7c 2003-09-30 devnull 			seq++;
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 */
344 76193d7c 2003-09-30 devnull 		break;
345 76193d7c 2003-09-30 devnull 
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);
356 76193d7c 2003-09-30 devnull 		}
357 76193d7c 2003-09-30 devnull 		if(fileupdate(f, FALSE, TRUE))
358 76193d7c 2003-09-30 devnull 			seq++;
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);
364 76193d7c 2003-09-30 devnull 		break;
365 76193d7c 2003-09-30 devnull 
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);
371 76193d7c 2003-09-30 devnull 		break;
372 76193d7c 2003-09-30 devnull 
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);
383 76193d7c 2003-09-30 devnull 		break;
384 76193d7c 2003-09-30 devnull 
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);
396 76193d7c 2003-09-30 devnull 		break;
397 76193d7c 2003-09-30 devnull 
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);
407 76193d7c 2003-09-30 devnull 		break;
408 76193d7c 2003-09-30 devnull 
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);
423 611d815b 2005-03-18 devnull 			}
424 76193d7c 2003-09-30 devnull 		}
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]);
428 76193d7c 2003-09-30 devnull 		break;
429 76193d7c 2003-09-30 devnull 
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]);
438 76193d7c 2003-09-30 devnull 		break;
439 76193d7c 2003-09-30 devnull 
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();
456 76193d7c 2003-09-30 devnull 		break;
457 76193d7c 2003-09-30 devnull 
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);
465 76193d7c 2003-09-30 devnull 		break;
466 76193d7c 2003-09-30 devnull 
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);
470 76193d7c 2003-09-30 devnull 			break;
471 76193d7c 2003-09-30 devnull 		}
472 76193d7c 2003-09-30 devnull 		c = 0;
473 76193d7c 2003-09-30 devnull 		i = 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");
478 76193d7c 2003-09-30 devnull 		}
479 76193d7c 2003-09-30 devnull 		rp = malloc(m*sizeof(Rune));
480 76193d7c 2003-09-30 devnull 		if(rp){
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);
485 76193d7c 2003-09-30 devnull 		}
486 76193d7c 2003-09-30 devnull 		outTs(Hsetsnarf, i);
487 76193d7c 2003-09-30 devnull 		if(c){
488 76193d7c 2003-09-30 devnull 			Write(1, c, i);
489 76193d7c 2003-09-30 devnull 			free(c);
490 76193d7c 2003-09-30 devnull 		} else
491 76193d7c 2003-09-30 devnull 			dprint("snarf buffer too long\n");
492 76193d7c 2003-09-30 devnull 		break;
493 76193d7c 2003-09-30 devnull 
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);
499 76193d7c 2003-09-30 devnull 		if(c){
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);
509 76193d7c 2003-09-30 devnull 		}
510 76193d7c 2003-09-30 devnull 		break;
511 76193d7c 2003-09-30 devnull 
512 76193d7c 2003-09-30 devnull 	case Tack:
513 76193d7c 2003-09-30 devnull 		waitack = 0;
514 76193d7c 2003-09-30 devnull 		break;
515 76193d7c 2003-09-30 devnull 
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;
527 76193d7c 2003-09-30 devnull 		else{
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);
535 76193d7c 2003-09-30 devnull 		}
536 76193d7c 2003-09-30 devnull 		c = strrchr(pm->wdir, '/');
537 76193d7c 2003-09-30 devnull 		if(c)
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;
542 76193d7c 2003-09-30 devnull 		else{
543 76193d7c 2003-09-30 devnull 			p = p0;
544 76193d7c 2003-09-30 devnull 			while(p0>0 && (i=filereadc(f, p0 - 1))!=' ' && i!='\t' && i!='\n')
545 76193d7c 2003-09-30 devnull 				p0--;
546 522b0689 2003-09-30 devnull 			while(p1<f->b.nc && (i=filereadc(f, p1))!=' ' && i!='\t' && i!='\n')
547 76193d7c 2003-09-30 devnull 				p1++;
548 76193d7c 2003-09-30 devnull 			sprint(cbuf, "click=%ld", p-p0);
549 76193d7c 2003-09-30 devnull 			pm->attr = plumbunpackattr(cbuf);
550 76193d7c 2003-09-30 devnull 		}
551 76193d7c 2003-09-30 devnull 		if(p0==p1 || p1-p0>=BLOCKSIZE){
552 76193d7c 2003-09-30 devnull 			plumbfree(pm);
553 76193d7c 2003-09-30 devnull 			break;
554 76193d7c 2003-09-30 devnull 		}
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);
563 76193d7c 2003-09-30 devnull 		}
564 76193d7c 2003-09-30 devnull 		plumbfree(pm);
565 76193d7c 2003-09-30 devnull 		break;
566 76193d7c 2003-09-30 devnull 
567 76193d7c 2003-09-30 devnull 	case Texit:
568 76193d7c 2003-09-30 devnull 		exits(0);
569 76193d7c 2003-09-30 devnull 	}
570 76193d7c 2003-09-30 devnull 	return TRUE;
571 76193d7c 2003-09-30 devnull }
572 76193d7c 2003-09-30 devnull 
573 76193d7c 2003-09-30 devnull void
574 76193d7c 2003-09-30 devnull snarf(File *f, Posn p1, Posn p2, Buffer *buf, int emptyok)
575 76193d7c 2003-09-30 devnull {
576 76193d7c 2003-09-30 devnull 	Posn l;
577 76193d7c 2003-09-30 devnull 	int i;
578 76193d7c 2003-09-30 devnull 
579 76193d7c 2003-09-30 devnull 	if(!emptyok && p1==p2)
580 76193d7c 2003-09-30 devnull 		return;
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;
586 76193d7c 2003-09-30 devnull 	}
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);
591 76193d7c 2003-09-30 devnull 	}
592 76193d7c 2003-09-30 devnull }
593 76193d7c 2003-09-30 devnull 
594 76193d7c 2003-09-30 devnull int
595 76193d7c 2003-09-30 devnull inshort(void)
596 76193d7c 2003-09-30 devnull {
597 76193d7c 2003-09-30 devnull 	ushort n;
598 76193d7c 2003-09-30 devnull 
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;
602 76193d7c 2003-09-30 devnull }
603 76193d7c 2003-09-30 devnull 
604 76193d7c 2003-09-30 devnull long
605 76193d7c 2003-09-30 devnull inlong(void)
606 76193d7c 2003-09-30 devnull {
607 76193d7c 2003-09-30 devnull 	ulong n;
608 76193d7c 2003-09-30 devnull 
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;
612 76193d7c 2003-09-30 devnull }
613 76193d7c 2003-09-30 devnull 
614 2c0f3733 2006-04-20 devnull vlong
615 76193d7c 2003-09-30 devnull invlong(void)
616 76193d7c 2003-09-30 devnull {
617 2c0f3733 2006-04-20 devnull 	vlong v;
618 2c0f3733 2006-04-20 devnull 	
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;
624 76193d7c 2003-09-30 devnull }
625 76193d7c 2003-09-30 devnull 
626 76193d7c 2003-09-30 devnull void
627 76193d7c 2003-09-30 devnull setgenstr(File *f, Posn p0, Posn p1)
628 76193d7c 2003-09-30 devnull {
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;
636 76193d7c 2003-09-30 devnull 	}else{
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;
645 76193d7c 2003-09-30 devnull 	}
646 76193d7c 2003-09-30 devnull }
647 76193d7c 2003-09-30 devnull 
648 76193d7c 2003-09-30 devnull void
649 76193d7c 2003-09-30 devnull outT0(Hmesg type)
650 76193d7c 2003-09-30 devnull {
651 76193d7c 2003-09-30 devnull 	outstart(type);
652 76193d7c 2003-09-30 devnull 	outsend();
653 76193d7c 2003-09-30 devnull }
654 76193d7c 2003-09-30 devnull 
655 76193d7c 2003-09-30 devnull void
656 76193d7c 2003-09-30 devnull outTl(Hmesg type, long l)
657 76193d7c 2003-09-30 devnull {
658 76193d7c 2003-09-30 devnull 	outstart(type);
659 76193d7c 2003-09-30 devnull 	outlong(l);
660 76193d7c 2003-09-30 devnull 	outsend();
661 76193d7c 2003-09-30 devnull }
662 76193d7c 2003-09-30 devnull 
663 76193d7c 2003-09-30 devnull void
664 76193d7c 2003-09-30 devnull outTs(Hmesg type, int s)
665 76193d7c 2003-09-30 devnull {
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();
670 76193d7c 2003-09-30 devnull }
671 76193d7c 2003-09-30 devnull 
672 76193d7c 2003-09-30 devnull void
673 76193d7c 2003-09-30 devnull outS(String *s)
674 76193d7c 2003-09-30 devnull {
675 76193d7c 2003-09-30 devnull 	char *c;
676 76193d7c 2003-09-30 devnull 	int i;
677 76193d7c 2003-09-30 devnull 
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);
686 76193d7c 2003-09-30 devnull }
687 76193d7c 2003-09-30 devnull 
688 76193d7c 2003-09-30 devnull void
689 76193d7c 2003-09-30 devnull outTsS(Hmesg type, int s1, String *s)
690 76193d7c 2003-09-30 devnull {
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();
695 76193d7c 2003-09-30 devnull }
696 76193d7c 2003-09-30 devnull 
697 76193d7c 2003-09-30 devnull void
698 76193d7c 2003-09-30 devnull outTslS(Hmesg type, int s1, Posn l1, String *s)
699 76193d7c 2003-09-30 devnull {
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();
707 76193d7c 2003-09-30 devnull }
708 76193d7c 2003-09-30 devnull 
709 76193d7c 2003-09-30 devnull void
710 76193d7c 2003-09-30 devnull outTS(Hmesg type, String *s)
711 76193d7c 2003-09-30 devnull {
712 76193d7c 2003-09-30 devnull 	outstart(type);
713 76193d7c 2003-09-30 devnull 	outS(s);
714 76193d7c 2003-09-30 devnull 	outsend();
715 76193d7c 2003-09-30 devnull }
716 76193d7c 2003-09-30 devnull 
717 76193d7c 2003-09-30 devnull void
718 76193d7c 2003-09-30 devnull outTsllS(Hmesg type, int s1, Posn l1, Posn l2, String *s)
719 76193d7c 2003-09-30 devnull {
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();
728 76193d7c 2003-09-30 devnull }
729 76193d7c 2003-09-30 devnull 
730 76193d7c 2003-09-30 devnull void
731 76193d7c 2003-09-30 devnull outTsll(Hmesg type, int s, Posn l1, Posn l2)
732 76193d7c 2003-09-30 devnull {
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();
740 76193d7c 2003-09-30 devnull }
741 76193d7c 2003-09-30 devnull 
742 76193d7c 2003-09-30 devnull void
743 76193d7c 2003-09-30 devnull outTsl(Hmesg type, int s, Posn l)
744 76193d7c 2003-09-30 devnull {
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();
750 76193d7c 2003-09-30 devnull }
751 76193d7c 2003-09-30 devnull 
752 76193d7c 2003-09-30 devnull void
753 2c0f3733 2006-04-20 devnull outTsv(Hmesg type, int s, vlong v)
754 76193d7c 2003-09-30 devnull {
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();
760 76193d7c 2003-09-30 devnull }
761 76193d7c 2003-09-30 devnull 
762 76193d7c 2003-09-30 devnull void
763 76193d7c 2003-09-30 devnull outstart(Hmesg type)
764 76193d7c 2003-09-30 devnull {
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;
768 76193d7c 2003-09-30 devnull }
769 76193d7c 2003-09-30 devnull 
770 76193d7c 2003-09-30 devnull void
771 76193d7c 2003-09-30 devnull outcopy(int count, void *data)
772 76193d7c 2003-09-30 devnull {
773 76193d7c 2003-09-30 devnull 	memmove(outp, data, count);
774 76193d7c 2003-09-30 devnull 	outp += count;
775 76193d7c 2003-09-30 devnull }
776 76193d7c 2003-09-30 devnull 
777 76193d7c 2003-09-30 devnull void
778 76193d7c 2003-09-30 devnull outshort(int s)
779 76193d7c 2003-09-30 devnull {
780 76193d7c 2003-09-30 devnull 	*outp++ = s;
781 76193d7c 2003-09-30 devnull 	*outp++ = s>>8; 
782 76193d7c 2003-09-30 devnull }
783 76193d7c 2003-09-30 devnull 
784 76193d7c 2003-09-30 devnull void
785 76193d7c 2003-09-30 devnull outlong(long l)
786 76193d7c 2003-09-30 devnull {
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;
791 76193d7c 2003-09-30 devnull }
792 76193d7c 2003-09-30 devnull 
793 76193d7c 2003-09-30 devnull void
794 2c0f3733 2006-04-20 devnull outvlong(vlong v)
795 76193d7c 2003-09-30 devnull {
796 76193d7c 2003-09-30 devnull 	int i;
797 76193d7c 2003-09-30 devnull 
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;
801 2c0f3733 2006-04-20 devnull 	}
802 76193d7c 2003-09-30 devnull }
803 76193d7c 2003-09-30 devnull 
804 76193d7c 2003-09-30 devnull void
805 76193d7c 2003-09-30 devnull outsend(void)
806 76193d7c 2003-09-30 devnull {
807 76193d7c 2003-09-30 devnull 	int outcount;
808 76193d7c 2003-09-30 devnull 
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;
821 76193d7c 2003-09-30 devnull 		return;
822 76193d7c 2003-09-30 devnull 	}
823 76193d7c 2003-09-30 devnull }
824 76193d7c 2003-09-30 devnull 
825 78439d25 2007-01-12 devnull int
826 78439d25 2007-01-12 devnull needoutflush(void)
827 78439d25 2007-01-12 devnull {
828 7103ceb0 2007-01-12 devnull 	return outmsg >= outdata+DATASIZE;
829 78439d25 2007-01-12 devnull }
830 78439d25 2007-01-12 devnull 
831 76193d7c 2003-09-30 devnull void
832 76193d7c 2003-09-30 devnull outflush(void)
833 76193d7c 2003-09-30 devnull {
834 76193d7c 2003-09-30 devnull 	if(outmsg == outdata)
835 76193d7c 2003-09-30 devnull 		return;
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;
840 76193d7c 2003-09-30 devnull 	do
841 76193d7c 2003-09-30 devnull 		if(rcv() == 0){
842 76193d7c 2003-09-30 devnull 			rescue();
843 76193d7c 2003-09-30 devnull 			exits("eof");
844 76193d7c 2003-09-30 devnull 		}
845 76193d7c 2003-09-30 devnull 	while(waitack);
846 76193d7c 2003-09-30 devnull 	outmsg = outdata;
847 78439d25 2007-01-12 devnull 	outbuffered = 1;
848 76193d7c 2003-09-30 devnull }