/*  * This file is part of the UCB release of Plan 9. It is subject to the license * terms in the LICENSE file found in the top-level directory of this * distribution and at http://akaros.cs.berkeley.edu/files/Plan9License. No * part of the UCB release of Plan 9, including this file, may be copied, * modified, propagated, or distributed except according to the terms contained * in the LICENSE file. */ #include	<u.h>#include	<libc.h>#include	<bio.h>#include	"sky.h" #define JUKEFS "tcp!jukefs"	/* dial string for jukebox; was il!jukefs */ struct{	char	name[9];	char	offset;} Hproto[] ={	"ppo1",		Pppo1,	"ppo2",		Pppo2,	"ppo3",		Pppo3,	"ppo4",		Pppo4,	"ppo5",		Pppo5,	"ppo6",		Pppo6, 	"amdx1",	Pamdx1,	"amdx2",	Pamdx2,	"amdx3",	Pamdx3,	"amdx4",	Pamdx4,	"amdx5",	Pamdx5,	"amdx6",	Pamdx6,	"amdx7",	Pamdx7,	"amdx8",	Pamdx8,	"amdx9",	Pamdx9,	"amdx10",	Pamdx10,	"amdx11",	Pamdx11,	"amdx12",	Pamdx12,	"amdx13",	Pamdx13,	"amdx14",	Pamdx14,	"amdx15",	Pamdx15,	"amdx16",	Pamdx16,	"amdx17",	Pamdx17,	"amdx18",	Pamdx18,	"amdx19",	Pamdx19,	"amdx20",	Pamdx20, 	"amdy1",	Pamdy1,	"amdy2",	Pamdy2,	"amdy3",	Pamdy3,	"amdy4",	Pamdy4,	"amdy5",	Pamdy5,	"amdy6",	Pamdy6,	"amdy7",	Pamdy7,	"amdy8",	Pamdy8,	"amdy9",	Pamdy9,	"amdy10",	Pamdy10,	"amdy11",	Pamdy11,	"amdy12",	Pamdy12,	"amdy13",	Pamdy13,	"amdy14",	Pamdy14,	"amdy15",	Pamdy15,	"amdy16",	Pamdy16,	"amdy17",	Pamdy17,	"amdy18",	Pamdy18,	"amdy19",	Pamdy19,	"amdy20",	Pamdy20, 	"pltscale",	Ppltscale,	"xpixelsz",	Pxpixelsz,	"ypixelsz",	Pypixelsz, 	"pltrah",	Ppltrah,	"pltram",	Ppltram,	"pltras",	Ppltras,	"pltdecd",	Ppltdecd,	"pltdecm",	Ppltdecm,	"pltdecs",	Ppltdecs, }; Header*getheader(char *rgn){	char rec[81], name[81], value[81];	char *p;	Biobuf *bin;	Header hd, *h;	int i, j, decsn, dss; 	dss = 0;	sprint(rec, "/lib/sky/dssheaders/%s.hhh", rgn);	bin = Bopen(rec, OREAD);	if(bin == 0) {		dss = 102;		sprint(rec, "/n/juke/dss/dss.102/headers/%s.hhh", rgn);		bin = Bopen(rec, OREAD);	}	if(bin == 0) {		dss = 61;		sprint(rec, "/n/juke/dss/dss.061/headers/%s.hhh", rgn);		bin = Bopen(rec, OREAD);	}	if(bin == 0) {		fprint(2, "cannot open %s\n", rgn);		exits("file");	}	if(debug)		Bprint(&bout, "reading %s\n", rec);	if(dss)		Bprint(&bout, "warning: reading %s from jukebox\n", rec); 	memset(&hd, 0, sizeof(hd));	j = 0;	decsn = 0;	for(;;) {		if(dss) {			if(Bread(bin, rec, 80) != 80)				break;			rec[80] = 0;		} else {			p = Brdline(bin, '\n');			if(p == 0)				break;			p[Blinelen(bin)-1] = 0;			strcpy(rec, p);		} 		p = strchr(rec, '/');		if(p)			*p = 0;		p = strchr(rec, '=');		if(p == 0)			continue;		*p++ = 0;		if(getword(name, rec) == 0)			continue;		if(getword(value, p) == 0)			continue;		if(strcmp(name, "pltdecsn") == 0) {			if(strchr(value, '-'))				decsn = 1;			continue;		}		for(i=0; i<nelem(Hproto); i++) {			j++;			if(j >= nelem(Hproto))				j = 0;			if(strcmp(name, Hproto[j].name) == 0) {				hd.param[Hproto[j].offset] = atof(value);				break;			}		}	}	Bterm(bin); 	hd.param[Ppltra] = RAD(hd.param[Ppltrah]*15 +		hd.param[Ppltram]/4 + hd.param[Ppltras]/240);	hd.param[Ppltdec] = RAD(hd.param[Ppltdecd] +		hd.param[Ppltdecm]/60 + hd.param[Ppltdecs]/3600);	if(decsn)		hd.param[Ppltdec] = -hd.param[Ppltdec];	hd.amdflag = 0;	for(i=Pamdx1; i<=Pamdx20; i++)		if(hd.param[i] != 0) {			hd.amdflag = 1;			break;		}	h = malloc(sizeof(*h));	*h = hd;	return h;} voidgetplates(void){	char rec[81], *q;	Plate *p;	Biobuf *bin;	int c, i, dss; 	dss = 0;	sprint(rec, "/lib/sky/dssheaders/lo_comp.lis");	bin = Bopen(rec, OREAD);	if(bin == 0) {		dss = 102;		sprint(rec, "%s/headers/lo_comp.lis", dssmount(dss));		bin = Bopen(rec, OREAD);	}	if(bin == 0) {		dss = 61;		sprint(rec, "%s/headers/lo_comp.lis", dssmount(dss));		bin = Bopen(rec, OREAD);	}	if(bin == 0) {		fprint(2, "can't open lo_comp.lis; try 9fs juke\n");		exits("open");	}	if(debug)		Bprint(&bout, "reading %s\n", rec);	if(dss)		Bprint(&bout, "warning: reading %s from jukebox\n", rec);	for(nplate=0;;) {		if(dss) {			if(Bread(bin, rec, 80) != 80)				break;			rec[80] = 0;		} else {			q = Brdline(bin, '\n');			if(q == 0)				break;			q[Blinelen(bin)-1] = 0;			strcpy(rec, q);		}		if(rec[0] == '#')			continue;		if(nplate < nelem(plate)) {			p = &plate[nplate];			memmove(p->rgn, rec+0, 5);			if(p->rgn[4] == ' ')				p->rgn[4] = 0;			for(i=0; c=p->rgn[i]; i++)				if(c >= 'A' && c <= 'Z')					p->rgn[i] += 'a'-'A';			p->ra = RAD(atof(rec+12)*15 +				atof(rec+15)/4 +				atof(rec+18)/240);			p->dec = RAD(atof(rec+26) +				atof(rec+29)/60 +				atof(rec+32)/3600);			if(rec[25] == '-')				p->dec = -p->dec;			p->disk = atoi(rec+53);			if(p->disk == 0)				continue;		}		nplate++;	}	Bterm(bin); 	if(nplate >= nelem(plate))		fprint(2, "nplate too small %d %d\n", nelem(plate), nplate);	if(debug)		Bprint(&bout, "%d plates\n", nplate);} char*dssmount(int dskno){	char dssname[100];	int s1, s2, count;	static int sdiskno = -1; 	if(sdiskno == dskno)		goto out;	count = 0; loop:	unmount(nil, "/n/njuke");	unmount(nil, "/n/dss");	sprint(dssname, "/n/njuke/juke/dss/dss.%.3d", dskno); 	/*	 * start nfs jukebox server	 */	s1 = open("/srv/" JUKEFS, ORDWR);	if(s1 < 0) {		if(fork() == 0) {			execl("/bin/srv", "srv", "-q", JUKEFS, nil);			exits(0);		}		waitpid();		s1 = open("/srv/" JUKEFS, ORDWR);		if(s1 < 0) {			Bprint(&bout, "can't open /srv/%s: %r\n", JUKEFS);			goto out;		}	} 	/*	 * mount nfs jukebox server	 */	if(mount(s1, -1, "/n/njuke", 0, "") < 0) {		close(s1);		Bprint(&bout, "\"mount /srv/%s /n/juke\" failed: %r\n", JUKEFS);		goto out;	} 	/*	 * run 9660 server	 */	s2 = open("/srv/9660", ORDWR);	if(s2 < 0) {		if(fork() == 0) {			execl("/bin/9660srv", "9660srv", nil);			exits(0);		}		waitpid();		s2 = open("/srv/9660", ORDWR);		if(s2 < 0) {			Bprint(&bout, "can't open /srv/9660: %r\n");			goto out;		}	} 	/*	 * mount 9660 server	 */	if(mount(s2, -1, "/n/dss", 0, dssname) < 0) {		close(s2);		if(count == 0) {			// do it again so /n/njuke is in 9660's namespace			remove("/srv/9660");			remove("/srv/" JUKEFS);			count = 1;			goto loop;		}		Bprint(&bout, "\"mount /srv/9660 /n/dss %s\" failed %r\n", dssname);		goto out;	} //	print("mount %s\n", dssname);	sdiskno = dskno; out:	return "/n/dss";}