1 76193d7c 2003-09-30 devnull #include "sam.h"
3 76193d7c 2003-09-30 devnull #define NSYSFILE 3
4 76193d7c 2003-09-30 devnull #define NOFILE 128
7 76193d7c 2003-09-30 devnull checkqid(File *f)
12 76193d7c 2003-09-30 devnull w = whichmenu(f);
13 76193d7c 2003-09-30 devnull for(i=1; i<file.nused; i++){
14 76193d7c 2003-09-30 devnull g = file.filepptr[i];
15 76193d7c 2003-09-30 devnull if(w == i)
16 76193d7c 2003-09-30 devnull continue;
17 76193d7c 2003-09-30 devnull if(f->dev==g->dev && f->qidpath==g->qidpath)
18 76193d7c 2003-09-30 devnull warn_SS(Wdupfile, &f->name, &g->name);
23 76193d7c 2003-09-30 devnull writef(File *f)
26 76193d7c 2003-09-30 devnull char *name;
27 76193d7c 2003-09-30 devnull int i, samename, newfile;
28 76193d7c 2003-09-30 devnull ulong dev;
29 76193d7c 2003-09-30 devnull uvlong qid;
30 76193d7c 2003-09-30 devnull long mtime, appendonly, length;
32 76193d7c 2003-09-30 devnull newfile = 0;
33 76193d7c 2003-09-30 devnull samename = Strcmp(&genstr, &f->name) == 0;
34 76193d7c 2003-09-30 devnull name = Strtoc(&f->name);
35 76193d7c 2003-09-30 devnull i = statfile(name, &dev, &qid, &mtime, 0, 0);
36 76193d7c 2003-09-30 devnull if(i == -1)
37 76193d7c 2003-09-30 devnull newfile++;
38 76193d7c 2003-09-30 devnull else if(samename &&
39 76193d7c 2003-09-30 devnull (f->dev!=dev || f->qidpath!=qid || f->mtime<mtime)){
40 76193d7c 2003-09-30 devnull f->dev = dev;
41 76193d7c 2003-09-30 devnull f->qidpath = qid;
42 76193d7c 2003-09-30 devnull f->mtime = mtime;
43 76193d7c 2003-09-30 devnull warn_S(Wdate, &genstr);
47 76193d7c 2003-09-30 devnull free(genc);
48 76193d7c 2003-09-30 devnull genc = Strtoc(&genstr);
49 76193d7c 2003-09-30 devnull if((io=create(genc, 1, 0666L)) < 0)
50 76193d7c 2003-09-30 devnull error_r(Ecreate, genc);
51 76193d7c 2003-09-30 devnull dprint("%s: ", genc);
52 76193d7c 2003-09-30 devnull if(statfd(io, 0, 0, 0, &length, &appendonly) > 0 && appendonly && length>0)
53 76193d7c 2003-09-30 devnull error(Eappend);
54 76193d7c 2003-09-30 devnull n = writeio(f);
55 76193d7c 2003-09-30 devnull if(f->name.s[0]==0 || samename){
56 522b0689 2003-09-30 devnull if(addr.r.p1==0 && addr.r.p2==f->b.nc)
57 76193d7c 2003-09-30 devnull f->cleanseq = f->seq;
58 76193d7c 2003-09-30 devnull state(f, f->cleanseq==f->seq? Clean : Dirty);
60 76193d7c 2003-09-30 devnull if(newfile)
61 76193d7c 2003-09-30 devnull dprint("(new file) ");
62 76193d7c 2003-09-30 devnull if(addr.r.p2>0 && filereadc(f, addr.r.p2-1)!='\n')
63 76193d7c 2003-09-30 devnull warn(Wnotnewline);
64 76193d7c 2003-09-30 devnull closeio(n);
65 76193d7c 2003-09-30 devnull if(f->name.s[0]==0 || samename){
66 76193d7c 2003-09-30 devnull if(statfile(name, &dev, &qid, &mtime, 0, 0) > 0){
67 76193d7c 2003-09-30 devnull f->dev = dev;
68 76193d7c 2003-09-30 devnull f->qidpath = qid;
69 76193d7c 2003-09-30 devnull f->mtime = mtime;
70 76193d7c 2003-09-30 devnull checkqid(f);
76 76193d7c 2003-09-30 devnull readio(File *f, int *nulls, int setdate, int toterm)
78 76193d7c 2003-09-30 devnull int n, b, w;
81 76193d7c 2003-09-30 devnull Posn p = addr.r.p2;
82 76193d7c 2003-09-30 devnull ulong dev;
83 76193d7c 2003-09-30 devnull uvlong qid;
84 76193d7c 2003-09-30 devnull long mtime;
85 76193d7c 2003-09-30 devnull char buf[BLOCKSIZE+1], *s;
87 76193d7c 2003-09-30 devnull *nulls = FALSE;
89 76193d7c 2003-09-30 devnull if(f->unread){
90 522b0689 2003-09-30 devnull nt = bufload(&f->b, 0, io, nulls);
91 76193d7c 2003-09-30 devnull if(toterm)
92 76193d7c 2003-09-30 devnull raspload(f);
94 76193d7c 2003-09-30 devnull for(nt = 0; (n = read(io, buf+b, BLOCKSIZE-b))>0; nt+=(r-genbuf)){
97 76193d7c 2003-09-30 devnull r = genbuf;
99 76193d7c 2003-09-30 devnull while(n > 0){
100 76193d7c 2003-09-30 devnull if((*r = *(uchar*)s) < Runeself){
104 76193d7c 2003-09-30 devnull *nulls = TRUE;
107 76193d7c 2003-09-30 devnull continue;
109 76193d7c 2003-09-30 devnull if(fullrune(s, n)){
110 76193d7c 2003-09-30 devnull w = chartorune(r, s);
114 76193d7c 2003-09-30 devnull *nulls = TRUE;
117 76193d7c 2003-09-30 devnull continue;
120 76193d7c 2003-09-30 devnull memmove(buf, s, b);
123 76193d7c 2003-09-30 devnull loginsert(f, p, genbuf, r-genbuf);
126 76193d7c 2003-09-30 devnull *nulls = TRUE;
127 76193d7c 2003-09-30 devnull if(*nulls)
128 76193d7c 2003-09-30 devnull warn(Wnulls);
129 76193d7c 2003-09-30 devnull if(setdate){
130 76193d7c 2003-09-30 devnull if(statfd(io, &dev, &qid, &mtime, 0, 0) > 0){
131 76193d7c 2003-09-30 devnull f->dev = dev;
132 76193d7c 2003-09-30 devnull f->qidpath = qid;
133 76193d7c 2003-09-30 devnull f->mtime = mtime;
134 76193d7c 2003-09-30 devnull checkqid(f);
137 76193d7c 2003-09-30 devnull return nt;
141 76193d7c 2003-09-30 devnull writeio(File *f)
143 76193d7c 2003-09-30 devnull int m, n;
144 76193d7c 2003-09-30 devnull Posn p = addr.r.p1;
145 76193d7c 2003-09-30 devnull char *c;
147 76193d7c 2003-09-30 devnull while(p < addr.r.p2){
148 76193d7c 2003-09-30 devnull if(addr.r.p2-p>BLOCKSIZE)
149 76193d7c 2003-09-30 devnull n = BLOCKSIZE;
151 76193d7c 2003-09-30 devnull n = addr.r.p2-p;
152 522b0689 2003-09-30 devnull bufread(&f->b, p, genbuf, n);
153 76193d7c 2003-09-30 devnull c = Strtoc(tmprstr(genbuf, n));
154 76193d7c 2003-09-30 devnull m = strlen(c);
155 76193d7c 2003-09-30 devnull if(Write(io, c, m) != m){
156 76193d7c 2003-09-30 devnull free(c);
157 76193d7c 2003-09-30 devnull if(p > 0)
161 76193d7c 2003-09-30 devnull free(c);
164 76193d7c 2003-09-30 devnull return p-addr.r.p1;
167 76193d7c 2003-09-30 devnull closeio(Posn p)
169 76193d7c 2003-09-30 devnull close(io);
171 76193d7c 2003-09-30 devnull if(p >= 0)
172 76193d7c 2003-09-30 devnull dprint("#%lud\n", p);
175 76193d7c 2003-09-30 devnull int remotefd0 = 0;
176 76193d7c 2003-09-30 devnull int remotefd1 = 1;
179 76193d7c 2003-09-30 devnull bootterm(char *machine, char **argv, char **end)
181 76193d7c 2003-09-30 devnull int ph2t[2], pt2h[2];
183 76193d7c 2003-09-30 devnull if(machine){
184 76193d7c 2003-09-30 devnull dup(remotefd0, 0);
185 76193d7c 2003-09-30 devnull dup(remotefd1, 1);
186 76193d7c 2003-09-30 devnull close(remotefd0);
187 76193d7c 2003-09-30 devnull close(remotefd1);
188 76193d7c 2003-09-30 devnull argv[0] = "samterm";
189 76193d7c 2003-09-30 devnull *end = 0;
190 e6c4346b 2003-11-23 devnull execvp(samterm, argv);
191 522b0689 2003-09-30 devnull fprint(2, "can't exec %s: %r\n", samterm);
192 76193d7c 2003-09-30 devnull _exits("damn");
194 76193d7c 2003-09-30 devnull if(pipe(ph2t)==-1 || pipe(pt2h)==-1)
195 76193d7c 2003-09-30 devnull panic("pipe");
196 76193d7c 2003-09-30 devnull switch(fork()){
198 76193d7c 2003-09-30 devnull dup(ph2t[0], 0);
199 76193d7c 2003-09-30 devnull dup(pt2h[1], 1);
200 76193d7c 2003-09-30 devnull close(ph2t[0]);
201 76193d7c 2003-09-30 devnull close(ph2t[1]);
202 76193d7c 2003-09-30 devnull close(pt2h[0]);
203 76193d7c 2003-09-30 devnull close(pt2h[1]);
204 76193d7c 2003-09-30 devnull argv[0] = "samterm";
205 76193d7c 2003-09-30 devnull *end = 0;
206 e6c4346b 2003-11-23 devnull execvp(samterm, argv);
207 76193d7c 2003-09-30 devnull fprint(2, "can't exec: ");
208 76193d7c 2003-09-30 devnull perror(samterm);
209 76193d7c 2003-09-30 devnull _exits("damn");
210 76193d7c 2003-09-30 devnull case -1:
211 76193d7c 2003-09-30 devnull panic("can't fork samterm");
213 76193d7c 2003-09-30 devnull dup(pt2h[0], 0);
214 76193d7c 2003-09-30 devnull dup(ph2t[1], 1);
215 76193d7c 2003-09-30 devnull close(ph2t[0]);
216 76193d7c 2003-09-30 devnull close(ph2t[1]);
217 76193d7c 2003-09-30 devnull close(pt2h[0]);
218 76193d7c 2003-09-30 devnull close(pt2h[1]);
222 8538a660 2004-05-14 devnull connectto(char *machine, char **argv)
224 76193d7c 2003-09-30 devnull int p1[2], p2[2];
225 8538a660 2004-05-14 devnull char **av;
228 8538a660 2004-05-14 devnull // count args
229 8538a660 2004-05-14 devnull for(av = argv; *av; av++)
231 8538a660 2004-05-14 devnull av = malloc(sizeof(char*)*((av-argv) + 5));
232 8538a660 2004-05-14 devnull if(av == nil){
233 8538a660 2004-05-14 devnull dprint("out of memory\n");
234 8538a660 2004-05-14 devnull exits("fork/exec");
237 8538a660 2004-05-14 devnull av[ac++] = RX;
238 8538a660 2004-05-14 devnull av[ac++] = machine;
239 8538a660 2004-05-14 devnull av[ac++] = rsamname;
240 8538a660 2004-05-14 devnull av[ac++] = "-R";
241 8538a660 2004-05-14 devnull while(*argv)
242 8538a660 2004-05-14 devnull av[ac++] = *argv++;
243 8538a660 2004-05-14 devnull av[ac] = 0;
244 76193d7c 2003-09-30 devnull if(pipe(p1)<0 || pipe(p2)<0){
245 76193d7c 2003-09-30 devnull dprint("can't pipe\n");
246 76193d7c 2003-09-30 devnull exits("pipe");
248 76193d7c 2003-09-30 devnull remotefd0 = p1[0];
249 76193d7c 2003-09-30 devnull remotefd1 = p2[1];
250 76193d7c 2003-09-30 devnull switch(fork()){
252 76193d7c 2003-09-30 devnull dup(p2[0], 0);
253 76193d7c 2003-09-30 devnull dup(p1[1], 1);
254 76193d7c 2003-09-30 devnull close(p1[0]);
255 76193d7c 2003-09-30 devnull close(p1[1]);
256 76193d7c 2003-09-30 devnull close(p2[0]);
257 76193d7c 2003-09-30 devnull close(p2[1]);
258 8538a660 2004-05-14 devnull execvp(RXPATH, av);
259 76193d7c 2003-09-30 devnull dprint("can't exec %s\n", RXPATH);
260 76193d7c 2003-09-30 devnull exits("exec");
262 76193d7c 2003-09-30 devnull case -1:
263 76193d7c 2003-09-30 devnull dprint("can't fork\n");
264 76193d7c 2003-09-30 devnull exits("fork");
266 8538a660 2004-05-14 devnull free(av);
267 76193d7c 2003-09-30 devnull close(p1[1]);
268 76193d7c 2003-09-30 devnull close(p2[0]);
272 8538a660 2004-05-14 devnull startup(char *machine, int Rflag, char **argv, char **end, char **files)
274 76193d7c 2003-09-30 devnull if(machine)
275 8538a660 2004-05-14 devnull connectto(machine, files);
276 76193d7c 2003-09-30 devnull if(!Rflag)
277 76193d7c 2003-09-30 devnull bootterm(machine, argv, end);
278 76193d7c 2003-09-30 devnull downloaded = 1;
279 76193d7c 2003-09-30 devnull outTs(Hversion, VERSION);