![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to wmount.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Research Unix] / researchv10dc / cmd / oworm / scsi|
Return to wmount.c CVS log | Up to [Research Unix] / researchv10dc / cmd / oworm / scsi |
1.1 root 1: #include "scsi.h"
2: #include <getflags.h>
3: #include <string.h>
4: #include <errno.h>
5: #include <fio.h>
6:
7: #define JDIR "/usr/worm/jukedir"
8: #define JMODE 03666
9: #define NSHELF 50
10:
11: int NDRIVES; /* how many to use */
12:
13: char *shelf[NSHELF];
14: int wr = 0;
15:
16: main(argc, argv)
17: char **argv;
18: {
19: long t;
20:
21: (void)time(&t);
22: srand((int)t);
23: if((argc = getflags(argc, argv, "clmprsuUe:1[volid]w:1[secs]", 0)) < 0)
24: usage("[ vol_id ]");
25: if((argc <= 1) && !flag['u'] && !flag['r'] && !flag['e'] && !flag['l'] && !flag['w'] && !flag['p'])
26: flag['m'] = flagset;
27: if(flag['r'] || flag['e'] || flag['l'] || flag['p'] || flag['m'] || flag['u']){
28: if(scsiinit(1))
29: exit(1);
30: } else { /* mounting */
31: if(scsiinit(0)){
32: Fprint(1, "0\n");
33: exit(0);
34: }
35: }
36: scsiid(2);
37: NDRIVES = s_ndrives();
38: if(NDRIVES < 1){
39: fprint(2, "cannot determine the number of drives\n");
40: exit(1);
41: }
42: /*print("using %d drives\n", NDRIVES);/**/
43: jread();
44: if(flag['u'])
45: unload(0);
46: if(flag['U'])
47: unload(1);
48: if(flag['r'])
49: if(jreload()){
50: fprint(2, "reload failed\n");
51: exit(1);
52: }
53: if(flag['e'])
54: jeject(flag['e'][0]);
55: if(flag['l'])
56: jload();
57: if(flag['m'])
58: jmpr();
59: if(flag['p'])
60: jpr();
61: if(wr)
62: jwrite();
63: if(argc > 1)
64: jmount(argv[1]);
65: else {
66: if(flag['w']){
67: fprint(2, "worm mount: -w given with no vol_id\n");
68: exit(1);
69: }
70: }
71: exit(0);
72: }
73:
74: jpr()
75: {
76: int i;
77:
78: for(i = 0; i < NSHELF; i++)
79: if(shelf[i]) Fprint(1, "%2d: %s\n", i, shelf[i]);
80: Fflush(1);
81: }
82:
83: jmpr()
84: {
85: int i;
86: register unsigned char *d;
87: struct scsi_o o;
88:
89: if(s_istatus(0, &o) == 0){
90: for(i = 0, d = &o.data[18]; i < NDRIVES; i++, d += 4)
91: if(*d&0x80)
92: Fprint(1, "drive %d: %s%c, %sline\n", i,
93: shelf[(*d&0x7F)/2], (*d&1)? 'b':'a',
94: (d[-2]&1)?"on":"off");
95: }
96: Fflush(1);
97: }
98:
99: jeject(s)
100: char *s;
101: {
102: int i, me, drive;
103: register unsigned char *d;
104: struct scsi_o o;
105:
106: if(s_istatus(0, &o) == 0){
107: for(i = 0, d = &o.data[18]; i < NDRIVES; i++, d += 4)
108: if((*d&0x80) && (strcmp(s, shelf[me = (*d&0x7F)/2]) == 0)){
109: if(s_diskeject(i))
110: fprint(2, "worm mount: couldn't eject drive %d\n", i);
111: shelf[me] = 0;
112: wr = 1;
113: return;
114: }
115: }
116: drive = getdrive();
117: for(i = 0; i < NSHELF; i++)
118: if(strcmp(shelf[i], s) == 0){
119: if(s_diskset(i, A, drive, 1)){
120: fprint(2, "worm mount: couldn't load %s into drive 1\n", s);
121: return;
122: }
123: if(s_diskeject(1)){
124: fprint(2, "worm mount: couldn't eject %s from drive 1\n", s);
125: s_diskrelease(-1, A, drive, 1);
126: return;
127: }
128: shelf[i] = 0;
129: wr = 1;
130: return;
131: }
132: fprint(2, "worm mount: can't find %s\n", s);
133: exit(1);
134: }
135:
136: jload()
137: {
138: int i;
139: int drive, flip;
140: char s[256], *side;
141: struct scsi_o output;
142: int ndone = 0;
143:
144: drive = getdrive();
145: Fprint(1, "loading new disks\n");
146: loop:
147: if(s_diskset(127, A, drive, 0)){
148: Fprint(1, "%d new disk%s loaded\n", ndone, ndone==1? "":"s");
149: return;
150: }
151: Fprint(1, "loading... "); Fflush(1);
152: if(s_start(drive)){
153: fprint(2, "worm mount: drive %d won't start\n", drive);
154: return;
155: }
156: s_readid(drive, s);
157: side = &s[strlen(s)-1];
158: if((*s == 0) || ((*side != 'a')&&(*side != 'b'))){
159: fprint(2, "worm mount: bad name '%s' in drive %d\n", s, drive);
160: return;
161: }
162: flip = (*side =='a')? A:B;
163: *side = 0;
164: if(strcmp(s, UNLABELLED))
165: for(i = 0; i < NSHELF; i++)
166: if(strcmp(shelf[i], s) == 0){
167: fprint(2, "worm mount: %s was listed shelf %d\n", s, i);
168: shelf[i] = 0;
169: break;
170: }
171: for(i = 0; i < NSHELF; i++)
172: if(shelf[i] == 0){
173: if(s_diskrelease(i, flip, drive, 1)){
174: fprint(2, "worm mount: %s to shelf %d failed\n", s, i);
175: return;
176: }
177: shelf[i] = strdup(s);
178: print("%s loaded to shelf %d\n", s, i);
179: wr = 1;
180: ndone++;
181: goto loop;
182: }
183: fprint(2, "worm mount: no space left for %s\n", s);
184: }
185:
186: jreload()
187: {
188: int i, dest, flip, try;
189: int drive = 1;
190: char s[256], *side;
191: struct scsi_o output;
192: int todo[NSHELF];
193:
194: flag['l'] = flagset;
195: for(i = 0; i < NSHELF; i++)
196: shelf[i] = 0, todo[i] = 0;
197: drive = getdrive();
198: if(s_istatus(drive, &output))
199: return(1);
200: for(i = 0; i < NSHELF; i++)
201: if((output.data[48+i]&0x80) && (output.data[48+i]&0x60)){
202: shelf[i] = "";
203: todo[i] = 1;
204: }
205: for(i = 0, try = 0; i < NSHELF; i++, try++){
206: if(!todo[i]) continue;
207: if(s_diskset(i, A, drive, 0))
208: continue;
209: Fprint(1, "doing shelf %d: ", i); Fflush(1);
210: if(s_start(drive)){
211: fprint(2, "worm mount: drive %d won't start\n", drive);
212: exit(1);
213: }
214: s_readid(drive, s);
215: if(strcmp(s, UNLABELLED) == 0)
216: strcat(s, "a");
217: side = &s[strlen(s)-1];
218: if((*s == 0) || ((*side != 'a')&&(*side != 'b'))){
219: fprint(2, "worm mount: bad volid '%s', %s\n", s, try?"ignoring":"retrying");
220: if(try == 0){
221: s_diskrelease(i, B, drive, 1);
222: i--;
223: }
224: continue;
225: }
226: sleep(1);
227: if(flag['c']){
228: for(dest = 0; dest < i; dest++)
229: if(shelf[dest] == 0) break;
230: } else if(flag['s']){
231: while(shelf[dest = nrand(NSHELF)] && (i != dest))
232: ;
233: } else
234: dest = i;
235: flip = (*side == 'a')? A:B;
236: if(s_diskrelease(dest, flip, drive, 1)){
237: fprint(2, "worm mount: %s to shelf %d failed\n", s, dest); exit(1);
238: }
239: *side = 0;
240: Fprint(1, "%s", s);
241: if(dest != i)
242: Fprint(1, " -> shelf %d", dest);
243: Fprint(1, "\n"); Fflush(1);
244: sleep(1);
245: shelf[i] = 0;
246: shelf[dest] = strdup(s);
247: wr = 1;
248: try = -1;
249: }
250: return(0);
251: }
252:
253: #define STEP 5
254:
255: jmount(vol)
256: char *vol;
257: {
258: int limit, i, sh, flip;
259: unsigned char *d;
260: char *ss;
261: struct scsi_o o;
262:
263: ss = &vol[strlen(vol)-1];
264: if((*ss != 'a') && (*ss != 'b')){
265: fprint(2, "worm mount: mount name (%s) must end in [ab]\n", vol);
266: exit(1);
267: }
268: flip = (*ss == 'a')? A:B;
269: *ss = 0;
270: for(sh = 0; sh < NSHELF; sh++)
271: if(shelf[sh] && (strcmp(vol, shelf[sh]) == 0))
272: break;
273: if(sh == NSHELF){
274: fprint(2, "worm mount: no disk with vol_id '%s'\n", vol);
275: exit(1);
276: }
277: limit = flag['w']? atoi(flag['w'][0]) : 9999999;
278: for(; limit > -STEP; limit -= STEP, sleep(STEP)){
279: if(s_istatus(0, &o))
280: continue;
281: for(i = 0, d = &o.data[18]; i < NDRIVES; i++, d += 4)
282: if((*d&0x80) && (strcmp(shelf[(*d&0x7F)/2], vol) == 0)){
283: if(((*d&1) == flip) && (d[-1] != 0x80)){
284: Fprint(1, "%d\n", i);
285: return;
286: }
287: s_diskrelease(-1, A, i, 0);
288: }
289: for(i = 0, d = &o.data[18]; i < NDRIVES; i++, d += 4)
290: if((d[-2]&0x40) == 0){
291: if(s_diskset(sh, flip, i, 1))
292: exit(1);
293: /*----->*/ prompt(i);
294: Fprint(1, "%d\n", i);
295: return;
296: }
297: for(i = 0, d = &o.data[18]; i < NDRIVES; i++, d += 4)
298: if((d[-2]&1) == 0){
299: s_diskrelease(-1, A, i, 0);
300: }
301: }
302: }
303:
304: jread()
305: {
306: int fd, errs = 0;
307: int ntries;
308: register char *s, *ss;
309:
310: for(ntries = 0; ntries < 10; ntries++){
311: if((fd = open(JDIR, 0)) >= 0)
312: break;
313: if(errno != ECONC)
314: break;
315: sleep(1);
316: }
317: if(fd < 0){
318: perror(JDIR);
319: exit(1);
320: }
321: Finit(fd, (char *)0);
322: while(s = Frdline(fd)){
323: if(ss = strchr(s, ' ')){
324: *ss++ = 0;
325: shelf[atoi(s)] = strdup(ss);
326: } else {
327: Fprint(2, "bad line: '%s'\n", s);
328: errs++;
329: }
330: }
331: if(errs){
332: fprint(2, "%d errors\n", errs);
333: exit(1);
334: }
335: close(fd);
336: }
337:
338: jwrite()
339: {
340: int ntries, fd, i;
341:
342: for(ntries = 0; ntries < 10; ntries++){
343: if((fd = creat(JDIR, JMODE)) >= 0)
344: break;
345: if(errno != ECONC)
346: break;
347: sleep(1);
348: }
349: if(fd < 0){
350: perror(JDIR);
351: exit(1);
352: }
353: Finit(fd, (char *)0);
354: for(i = 0; i < NSHELF; i++)
355: if(shelf[i])
356: Fprint(fd, "%d %s\n", i, shelf[i]);
357: Fflush(fd);
358: close(fd);
359: }
360:
361: unload(force)
362: {
363: int i, ret = -1;
364: unsigned char *d;
365: struct scsi_o output;
366:
367: if(s_istatus(0, &output))
368: return(1);
369: for(i = 0; i < NDRIVES; i++){
370: d = &output.data[16+4*i];
371: if((*d&0x40) || force){
372: if(((*d&1) == 0) || force)
373: s_diskrelease(-1, A, i, 0);
374: } else
375: ret = i;
376: }
377: return(ret);
378: }
379:
380: getdrive()
381: {
382: int i;
383:
384: if((i = unload(0)) < 0)
385: i = NDRIVES;
386: return(i);
387: }
388:
389: #include <sys/types.h>
390: #include <sys/udaioc.h>
391:
392: prompt(i)
393: {
394: char buf[1024];
395: int fd;
396:
397: sprint(buf, "/dev/worm%d", i);
398: fd = open(buf, 0);
399: read(fd, buf, sizeof buf);
400: ioctl(fd, UIOSPDW);
401: close(fd);
402: sleep(1);
403: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.