Index: unk/Ohana/src/getstar/src/old/ForkToServer.c =================================================================== --- /trunk/Ohana/src/getstar/src/old/ForkToServer.c (revision 3646) +++ (revision ) @@ -1,77 +1,0 @@ -# include - -int ForkToServer (int argc, char **argv, char *database, char *server) { - - int i, fd, N, pid, status; - char **arglist, *p; - char hostname[1025]; - struct timeval now, then; - double dtime; - - /* get local hostname */ - if (gethostname (hostname, 1024)) { - fprintf (stderr, "ERROR: can't get hostname\n"); - exit (1); - } - - /* lock database file */ - fd = setlockfile (database, 60.0, TRUE); - if (fd == -1) { - fprintf (stderr, "ERROR: can't set lock on %s\n", database); - exit (1); - } - - if ((p = strchr (server, '.')) != (char *) NULL) *p = 0; - if ((p = strchr (hostname, '.')) != (char *) NULL) *p = 0; - - if (!strcasecmp (hostname, server)) return (fd); - - if (!strlen (server)) { - fprintf (stderr, "ERROR: no Database Server defined\n"); - clearlockfile (database, fd, TRUE); - exit (1); - } - - /* get start of fork time */ - gettimeofday (&then, (void *) NULL); - pid = fork (); - if (!pid) { - /* must be child process, fork to remote machine */ - - /* create argument list */ - N = argc + 4; - ALLOCATE (arglist, char *, N); - - arglist[0] = strcreate ("rsh"); - arglist[1] = strcreate (server); - arglist[2] = strcreate (argv[0]); - arglist[3] = strcreate ("-remote"); - for (i = 4; i < N; i++) { - arglist[i] = strcreate (argv[i-3]); - } - fprintf (stderr, "starting remote process on %s\n", server); - status = execvp ("rsh", arglist); - fprintf (stderr, "ERROR: can't start remote shell process\n"); - exit (1); - } - /* it would be good to put rsh in the config file */ - - /* block until child exits */ - wait (0); - - /***** - inetd has a maximum connection rate of 40 / 60 seconds it will - block for 10 min if this rate is exceeded. this is here because - we have to hold the lock long enough that the connection rate does - not get exceeded. We actually use 3.0 seconds to avoid stealing - too many rsh slots. - *****/ - - gettimeofday (&now, (void *) NULL); - dtime = 1e6*(3.0 - DTIME(now,then)); - if (dtime > 0) usleep (dtime); - - clearlockfile (database, fd, TRUE); - exit (0); - -} Index: unk/Ohana/src/getstar/src/old/add_unfound.c =================================================================== --- /trunk/Ohana/src/getstar/src/old/add_unfound.c (revision 3646) +++ (revision ) @@ -1,35 +1,0 @@ - /* incorporate unmatched image stars -- after all catalogs searched... */ - for (i = 0; i < Nstars; i++) { - if (!found[i]) { - catalog[0].average[Nave].R = stars[N1[i]].R; - catalog[0].average[Nave].D = stars[N1[i]].D; - catalog[0].average[Nave].M = 1000.0*stars[N1[i]].M; - catalog[0].average[Nave].Nm = 1; - catalog[0].average[Nave].Xp = catalog[0].average[Nave].Xm = 0.0; - catalog[0].average[Nave].offset = Nmeas; - catalog[0].measure[Nmeas].dR = 0.0; - catalog[0].measure[Nmeas].dD = 0.0; - catalog[0].measure[Nmeas].M = 1000.0*stars[N1[i]].M; - catalog[0].measure[Nmeas].dM = stars[N1[i]].dM; - catalog[0].measure[Nmeas].t = 3600.0 + stars[N1[i]].Y*0.1; - catalog[0].measure[Nmeas].average = (0x00ffffff & Nave); - /* time of star = time of image + offset + Y*rate */ - Nave ++; - if (Nave == 0x1000000) { - fprintf (stderr, "too many stars in catalog\n"); - clear_lockfile (); - exit (0); - } - if (Nave == NAVE) { - NAVE = Nave + 1000; - REALLOCATE (next, int, NAVE); - REALLOCATE (catalog[0].average, Average, NAVE); - } - Nmeas ++; - if (Nmeas == NMEAS) { - NMEAS = Nmeas + 1000; - REALLOCATE (next, int, NMEAS); - REALLOCATE (catalog[0].measure, Measure, NMEAS); - } - } - } Index: unk/Ohana/src/getstar/src/old/check_lockfile.c =================================================================== --- /trunk/Ohana/src/getstar/src/old/check_lockfile.c (revision 3646) +++ (revision ) @@ -1,46 +1,0 @@ -# include "addstar.h" - -check_lockfile () -{ - - FILE *f; - char filename[128]; - struct stat filestat; - - sprintf (filename, "%s/lock\0", CATDIR); - if (stat (filename, &filestat) != -1) { - fprintf (stderr, "ERROR: catalog %s is locked, try again later\n", CATDIR); - sprintf (filename, "%s/kill\0", CATDIR); - f = fopen (filename, "w"); - if (f == (FILE *) NULL) { - fprintf (stderr, "ERROR: can't set kill file %s\n", filename); - exit (0); - } - fclose (f); - exit (0); - } - - f = fopen (filename, "w"); - if (f == (FILE *) NULL) { - fprintf (stderr, "ERROR: can't set lock file %s\n", filename); - exit (0); - } - fclose (f); - -} - -clear_lockfile () -{ - - char filename[128], line[256]; - struct stat filestat; - - sprintf (filename, "%s/lock\0", CATDIR); - if (stat (filename, &filestat) != -1) { - sprintf (line, "rm %s\0", filename); - system (line); - } else { - fprintf (stderr, "can't remove lockfile, why not?\n"); - } - -} Index: unk/Ohana/src/getstar/src/old/config.c =================================================================== --- /trunk/Ohana/src/getstar/src/old/config.c (revision 3646) +++ (revision ) @@ -1,110 +1,0 @@ -# include -# define D_NBYTES 4096 - -char *LoadConfigFile (filename) -char *filename; -{ - - FILE *f; - int i, done, Nbytes, NBYTES, size; - char *config; - - f = fopen (filename, "r"); - if (f == NULL) { - fprintf (stderr, "couldn't find %s\n", filename); - return ((char *) NULL); - } - - NBYTES = D_NBYTES; - ALLOCATE (config, char, NBYTES); - - size = 0; - done = FALSE; - for (i = 0; !done; i++) { - Nbytes = Fread (&config[i*D_NBYTES], sizeof(char), D_NBYTES, f, "char"); - size += Nbytes; - if (Nbytes < D_NBYTES) - done = TRUE; - else { - NBYTES += D_NBYTES; - REALLOCATE (config, char, NBYTES); - } - } - - config[size] = '\n'; - config[size+1] = 0; - REALLOCATE (config, char, size + 2); - - fclose (f); - - return (config); -} - -int ScanConfig /* we expect one more field: the pointer to the value requested */ -# ifndef ANSI -(config, field, mode, va_alist) - char *config; char *field, *mode; va_dcl -# else -(char config[], - char field[], - char mode[],...) -# endif -{ - - int i, j; - char *p, *p2, tmp[256]; - va_list argp; - double value; - -# ifndef ANSI - va_start (argp); -# else - va_start (argp, N); -# endif - - /* find the correct line with field */ - p2 = config; - for (i = 0; ; i++) { - if (!strncmp (field, p2, strlen(field))) { - p = p2 + strlen (field); - break; - } - else { - p2 = strchr (p2, '\n'); - if (p2 == (char *) NULL) { - fprintf (stderr, "entry %s not found in config file\n", field); - return (FALSE); - } - else p2++; - } - } - if (!strcmp (mode, "%s")) { - p2 = strchr (p, '\n'); - if (p2 == (char *) NULL) - p2 = config + strlen(config); - bcopy (p, tmp, (p2-p)); - tmp[(p2-p)] = 0; - stripwhite (tmp); - p2 = va_arg (argp, char *); - strcpy (p2, tmp); - } - else { - - /* try to get a numerical value from the field */ - value = strtod (p, &p2); - if ((*p2 == 'd') || (*p2 == 'D')) - value *= pow (10.0, atof (p2 + 1)); - - if (!strcmp (mode, "%d")) *va_arg (argp, int *) = value; - if (!strcmp (mode, "%u")) *va_arg (argp, unsigned *) = value; - if (!strcmp (mode, "%ld")) *va_arg (argp, long *) = value; - if (!strcmp (mode, "%hd")) *va_arg (argp, short *) = value; - if (!strcmp (mode, "%f")) *va_arg (argp, float *) = value; - if (!strcmp (mode, "%lf")) *va_arg (argp, double *) = value; - - } - - va_end (argp); - return (TRUE); - -} Index: unk/Ohana/src/getstar/src/old/dumpcat.c =================================================================== --- /trunk/Ohana/src/getstar/src/old/dumpcat.c (revision 3646) +++ (revision ) @@ -1,61 +1,0 @@ -# include "addstar.h" - -main (argc, argv) -int argc; -char **argv; -{ - - int i, j, Nstars, Nimage, Nregions; - Average *average; - Measure *measure; - Missing *missing; - Catalog catalog; - GSCRegion region; - FILE *f; - - if (argc < 4) { - fprintf (stderr, "USAGE: dumpcat catalog output mode(0,1,2,3)\n"); - clear_lockfile (); - exit (0); - } - - strcpy (region.filename, argv[1]); - - gcatalog (®ion, &catalog); - - f = fopen (argv[2], "w"); - if (f == (FILE *) NULL) { - fprintf (stderr, "failed to open file %s for write\n", argv[2]); - clear_lockfile (); - exit (0); - } - - average = catalog.average; - for (i = 0; i < catalog.Naverage; i++) { - fprintf (f, "%10.6f %10.6f %7.3f %3d %3d %8d %d\n", average[i].R, average[i].D, - 0.001*average[i].M, average[i].Nm, average[i].Nn, average[i].offset, catalog.measure[average[i].offset].t); - if ((atof(argv[3]) == 1) || (atof(argv[3]) == 3)) { - measure = &catalog.measure[average[i].offset]; - for (j = 0; j < average[i].Nm; j++) { - fprintf (f, " %d %d %f %f %d\n", measure[j].dR, measure[j].dD, 0.001*measure[j].M, - measure[j].t, measure[j].average); - } - } - if ((atof(argv[3]) == 2) || (atof(argv[3]) == 3)) { - if (average[i].Nn > 0) { - missing = &catalog.missing[average[i].missing]; - for (j = 0; j < average[i].Nn; j++) { - fprintf (f, " %f\n", missing[j].t); - } - } else { - fprintf (f, "no missing obs\n"); - } - } - } - - - - fclose (f); - - -} Index: unk/Ohana/src/getstar/src/old/gstars1.c =================================================================== --- /trunk/Ohana/src/getstar/src/old/gstars1.c (revision 3646) +++ (revision ) @@ -1,273 +1,0 @@ -# include "addstar.h" -# define D_NSTARS 1000 -# define BYTES_STAR 31 -# define BLOCK 1000 -#include -#include - -Stars *gstars (file, NSTARS, image) -char file[]; -int *NSTARS; -Image *image; -{ - - FILE *f; - Header header; - int j, N, Ninstar; - int nbytes, Nbytes; - Stars *stars; - char *buffer; - double tmp; - int done, doneread, Nskip, Nextra, itmp; - char *c, *c2; - unsigned short int Nc; - - if (!fits_read_header (file, &header)) { - fprintf (stderr, "ERROR: can't read header for %s\n", file); - clearlockfile (ImageCat, -1); - exit(0); - } - - /* open file */ - f = fopen (file, "r"); - if (f == NULL) { - fprintf (stderr, "ERROR: can't read data from %s\n", file); - clearlockfile (ImageCat, -1); - exit(0); - } - fseek (f, header.size, SEEK_SET); - - /* find image rootname */ - c = strrchr (file, 0x2f); - if (c == (char *) NULL) { - strcpy (image[0].name, file); - } else { - strcpy (image[0].name, (c+1)); - } - - /* get astrometry information */ - if (!GetCoords (&image[0].coords, &header)) { - fprintf (stderr, "ERROR: no astrometric solution in header\n"); - clearlockfile (ImageCat, -1); - exit (0); - } - while (image[0].coords.crval1 < 0) image[0].coords.crval1 += 360.0; - while (image[0].coords.crval1 > 360.0) image[0].coords.crval1 -= 360.0; - itmp = 0; - fits_scan (&header, "NASTRO", "%d", 1, &itmp); - if (itmp == 0) { - fprintf (stderr, "ERROR: bad astrometric solution in header\n"); - clearlockfile (ImageCat, -1); - exit (0); - } - - /* CERROR in data file is in arcsec */ - fits_scan (&header, "CERROR", "%lf", 1, &tmp); - image[0].cerror = tmp * 50.0; - fits_scan (&header, "NAXIS1", "%hd", 1, &image[0].NX); - fits_scan (&header, "NAXIS2", "%hd", 1, &image[0].NY); - fits_scan (&header, "PHOTCODE", "%hd", 1, &image[0].source); - if (NEWPHOTCODE) { - image[0].source = PHOTCODE; - } - if ((image[0].source < 0) || (image[0].source > 0xffff)) { - fprintf (stderr, "error: invalid photcode\n"); - exit (0); - } - Nc = photcodes.hashcode[image[0].source]; - if (Nc < 0) { - fprintf (stderr, "ERROR: image has invalid photcode value\n"); - exit (0); - } - thiscode = &photcodes.code[Nc]; - - image[0].NX -= XOVERSCAN; - image[0].NY -= YOVERSCAN; - fits_scan (&header, "EXPTIME", "%lf", 1, &tmp); - image[0].exptime = tmp; - - tmp = 0; - fits_scan (&header, "APMIFIT", "%lf", 1, &tmp); - image[0].apmifit = tmp * 1000.0; - - tmp = 0; - fits_scan (&header, "dAPMIFIT", "%lf", 1, &tmp); - image[0].dapmifit = tmp * 1000.0; - - tmp = 0; - fits_scan (&header, "FLIMIT", "%lf", 1, &tmp); - image[0].detection_limit = tmp * 10.0; - - tmp = 0; - fits_scan (&header, "FSATUR", "%lf", 1, &tmp); - image[0].saturation_limit = tmp * 10.0; - - tmp = 0; - fits_scan (&header, "FWHM_X", "%lf", 1, &tmp); - image[0].fwhm_x = tmp * 25.0 * image[0].coords.cdelt1 * 3600.0; - - tmp = 0; - fits_scan (&header, "FWHM_Y", "%lf", 1, &tmp); - image[0].fwhm_y = tmp * 25.0 * image[0].coords.cdelt1 * 3600.0; - - if (!fits_scan (&header, "TZERO", "%d", 1, &image[0].tzero)) { - image[0].tzero = parse_time (&header); - } - - tmp = 0; - fits_scan (&header, "TRATE", "%lf", 1, &tmp); - image[0].trate = 10000 * tmp; - - tmp = 0; - fits_scan (&header, "AIRMASS", "%lf", 1, &tmp); - image[0].secz = 1000*tmp; - - if (!fits_scan (&header, "IMAGEID", "%d", 1, &itmp)) { - image[0].ccdnum = 0xff; - } else { - image[0].ccdnum = itmp; - } - - fits_scan (&header, "ZERO_PT", "%lf", 1, &ZeroPt); - - /* secz is in units milli-airmass */ - image[0].Mcal = ALPHA*(image[0].secz - 1000); - image[0].Xm = 30.0; - image[0].code = 0; - bzero (image[0].dummy, sizeof(image[0].dummy)); - - /* find expected number of stars */ - fits_scan (&header, "NSTARS", "%d", 1, &image[0].nstar); - if (image[0].nstar == 0) { - fprintf (stderr, "ERROR: can't get NSTARS from header\n"); - clearlockfile (ImageCat, -1); - exit (0); - } - ALLOCATE (stars, Stars, image[0].nstar); - - /* load in stars by blocks of 1000 */ - N = 0; - ALLOCATE (buffer, char, (BLOCK*BYTES_STAR) + 1); - buffer[BLOCK*BYTES_STAR] = 0; - Nextra = 0; - doneread = FALSE; - while (!doneread) { - Nbytes = BYTES_STAR * BLOCK - Nextra; - nbytes = Fread (&buffer[Nextra], 1, Nbytes, f, "char"); - if (nbytes == 0) { - doneread = TRUE; - continue; - } - nbytes += Nextra; - /* check line-by-line integrity */ - c = buffer; - done = FALSE; - while ((c < buffer + nbytes) && (!done)) { - for (c2 = c; *c2 == '\n'; c2++); - if (c2 > c) { /* extra return chars */ - memmove (c, c2, (int)(buffer + nbytes - c2)); - Nskip = c2 - c; - nbytes -= Nskip; - bzero (buffer + nbytes, Nskip); - if (VERBOSE) fprintf (stderr, "deleted %d extra return chars\n", Nskip); - } - c2 = strchr (c, '\n'); - if (c2 == (char *) NULL) { - done = TRUE; - continue; - } - c2++; - if ((c2 - c) != BYTES_STAR) { /* bad line, delete it */ - memmove (c, c2, (int)(buffer + nbytes - c2)); - Nskip = c2 - c; - nbytes -= Nskip; - bzero (buffer + nbytes, Nskip); - if (VERBOSE) fprintf (stderr, "deleted line, %d extra chars\n", Nskip); - } else { - c = c2; - } - } - Ninstar = nbytes / BYTES_STAR; - Nextra = nbytes % BYTES_STAR; - for (j = 0; j < Ninstar; j++, N++) { - dparse (&stars[N].X, 1, &buffer[j*BYTES_STAR]); - dparse (&stars[N].Y, 2, &buffer[j*BYTES_STAR]); - dparse (&stars[N].M, 3, &buffer[j*BYTES_STAR]); - dparse (&stars[N].dM, 4, &buffer[j*BYTES_STAR]); - XY_to_RD (&stars[N].R, &stars[N].D, stars[N].X, stars[N].Y, &image[0].coords); - while (stars[N].R < 0.0) stars[N].R += 360.0; - while (stars[N].R >= 360.0) stars[N].R -= 360.0; - dparse (&tmp, 5, &buffer[j*BYTES_STAR]); - stars[N].dophot = tmp; - stars[N].found = -1; - } - } - - image[0].nstar = N; - REALLOCATE (stars, Stars, image[0].nstar); - if (VERBOSE) fprintf (stderr, "read %d stars from target file\n", image[0].nstar); - *NSTARS = image[0].nstar; - - return (stars); -} - - - - -# if (0) - /* left over fraction of a block */ - nbytes = Fread (buffer, 1, (Nbytes % (BLOCK*BYTES_STAR)), f, "char"); - if (nbytes != (Nbytes % (BLOCK*BYTES_STAR))) { - fprintf (stderr, "ERROR: failed to read in stars (2)\n"); - clearlockfile (ImageCat, -1); - exit (0); - } - /* check line-by-line integrity */ - Nnew = 0; - c = buffer; - done = FALSE; - while ((c < buffer + nbytes) && (!done)) { - for (c2 = c; *c2 == '\n'; c2++); - if (c2 > c) { /* extra return chars */ - memmove (c, c2, (int)(buffer + nbytes - c2)); - Nnew += c2 - c; - fprintf (stderr, "deleting %d extra return chars\n", (int)(c2-c)); - } - c2 = strchr (c, '\n'); - if (c2 == (char *) NULL) { - if (Nnew > 0) { - nnew = Fread (&buffer[nbytes-Nnew], 1, Nnew, f, "char"); - if (nnew != Nnew) { - fprintf (stderr, "ERROR: failed to read in stars (1)\n"); - exit (0); - } - } else { - done = TRUE; - } - continue; - } - c2++; - if ((c2 - c) != BYTES_STAR) { - /* this is a bad line, delete it, adjust data in buffer, - and be ready to read the rest of the last line */ - memmove (c, c2, (int)(buffer + nbytes - c2)); - Nnew += c2 - c; - fprintf (stderr, "deleting bad line with %d chars\n", (int)(c2-c)); - } else { - c = c2; - } - } - for (j = 0; j < nbytes / BYTES_STAR; j++, nstar++, N++) { - dparse (&stars[N].X, 1, &buffer[j*BYTES_STAR]); - dparse (&stars[N].Y, 2, &buffer[j*BYTES_STAR]); - dparse (&stars[N].M, 3, &buffer[j*BYTES_STAR]); - dparse (&stars[N].dM, 4, &buffer[j*BYTES_STAR]); - XY_to_RD (&stars[N].R, &stars[N].D, stars[N].X, stars[N].Y, &image[0].coords); - while (stars[N].R < 0.0) stars[N].R += 360.0; - while (stars[N].R >= 360.0) stars[N].R -= 360.0; - dparse (&tmp, 5, &buffer[j*BYTES_STAR]); - stars[N].dophot = tmp; - stars[N].found = -1; - } - -# endif Index: unk/Ohana/src/getstar/src/old/sort_stars.c =================================================================== --- /trunk/Ohana/src/getstar/src/old/sort_stars.c (revision 3646) +++ (revision ) @@ -1,61 +1,0 @@ -# include "relphot.h" - -void sort_stars (radec, stars, Nstars) -int **radec; -Star *stars; -int Nstars; -{ - - int i; - double *RAs; - - ALLOCATE (radec[0], int, Nstars); - ALLOCATE (RAs, double, Nstars); - for (i = 0; i < Nstars; i++) { - radec[0][i] = i; - RAs[i] = stars[i].RA; - } - - sort_seq (radec[0], RAs, Nstars); - free (RAs); - -} - - -void sort_seq (seq, value, N) -int *seq; -double *value; -int N; -{ - int l,j,ir,i; - int temp; - - l = N >> 1; - ir = N - 1; - for (;;) { - if (l > 0) { - temp = seq[--l]; - } - else { - temp = seq[ir]; - seq[ir] = seq[0]; - if (--ir == 0) { - seq[0] = temp; - return; - } - } - i = l; - j = (l << 1) + 1; - while (j <= ir) { - if (j < ir && value[seq[j]] < value[seq[j+1]]) ++j; - if (value[temp] < value[seq[j]]) { - seq[i]=seq[j]; - j += (i=j) + 1; - } - else j = ir + 1; - } - seq[i] = temp; - } -} - - Index: unk/Ohana/src/getstar/src/old/string.c =================================================================== --- /trunk/Ohana/src/getstar/src/old/string.c (revision 3646) +++ (revision ) @@ -1,64 +1,0 @@ -# include -# include -# define TRUE 1 -# define FALSE 0 - -int scan_line (f, line) -FILE *f; -char line[]; -{ - - int i, status; - char c; - - status = EOF + 1; - - for (i = 0, c = 0; (c != '\n') && (status != EOF); i++) { - status = fscanf (f, "%c", &c); - line[i] = c; - } - line[i - 1] = 0; /* this could make things crash! */ - - if (i > 1) { - status = EOF + 1; - } - - return (status); - -} - -char *_parse_nextword(string) -char *string; -{ - if (string == (char *) NULL) return ((char *) NULL); - - for (; isspace (*string); string++); - for (; (*string != 0) && !isspace (*string); string++); - for (; isspace (*string); string++); - return (string); -} - -int dparse (X, NX, line) -double *X; -int NX; -char *line; -{ - - int i; - char *word; - char *ptr; - - word = line; - for (i = 0; i < NX - 1; i++) - word = _parse_nextword (word); - - *X = strtod (word, &ptr); - if (ptr == word) - return (FALSE); - else { - if (word[0] == '-') - return (-1); - else - return (1); - } -} Index: unk/Ohana/src/misc/src/dbrshtest.c =================================================================== --- /trunk/Ohana/src/misc/src/dbrshtest.c (revision 3646) +++ (revision ) @@ -1,150 +1,0 @@ -# include -# define DTIME(A,B) ((A.tv_sec - B.tv_sec) + 1e-6*(A.tv_usec - B.tv_usec)) - -static char dbhost[] = "kiawe.cfht.hawaii.edu"; -static char dbfile[] = "/h/eugene/d4/flattest/test.db"; - -void main (int argc, char **argv) { - - char buffer[10000], hostname[1025]; - int vbuffer[10000]; - FILE *f; - int i, j, Nrun, status, fd, pid, Remote; - struct timeval now, then; - double dtime; - - /* check cmd line args */ - Remote = FALSE; - if (argc > 1) { - if (!strcmp (argv[1], "-check")) { - f = fopen (dbfile, "r"); - if (f == (FILE *) NULL) { - fprintf (stderr, "ERROR: can't open file\n"); - exit (0); - } - status = fread (buffer, 1, 5000, f); - if (status != 5000) { - fprintf (stderr, "ERROR: can't read header\n"); - exit (0); - } - sscanf (&buffer[500], "%*s %*s %*s %d", &Nrun); - for (j = 0 ; j < Nrun; j++) { - status = fread (vbuffer, 4, 1000, f); - if (status != 1000) { - fprintf (stderr, "ERROR: can't read data\n"); - exit (0); - } - for (i = 0; i < 1000; i++) { - if (vbuffer[i] != j) { - fprintf (stderr, "ERROR: invalid data %d/%d, %d - %d\n", j, Nrun, i, vbuffer[i]); - exit (0); - } - } - } - fprintf (stderr, "Data is good\n"); - exit (0); - } - if (!strcmp (argv[1], "-remote")) { - Remote = TRUE; - } - } - - /* if lockfile exists, program will complain and quit */ - if (!Remote && ((fd = setlockfile (dbfile, 60.0)) == -1)) { - fprintf (stderr, "ERROR: can't set lock on %s\n", dbfile); - exit (1); - } - - /* check if we are on correct machine, or fork to it */ - if (gethostname (hostname, 1024)) { - fprintf (stderr, "ERROR: can't get hostname\n"); - exit (1); - } - if (strcmp (hostname, dbhost)) { - - gettimeofday (&then, (void *) NULL); - pid = fork (); - if (!pid) { /* must be child process */ - status = execlp ("rsh", "rsh", dbhost, "dbtest", "-remote", 0); - fprintf (stderr, "error starting remote shell process\n"); - exit (1); - } - wait (0); - - /** - inetd has a maximum connection rate of 40 / 60 seconds it will - block for 10 min if this rate is exceeded. this is here because - we have to hold the lock long enough that the connection rate does - not get exceeded. We actually use 3.0 seconds to avoid stealing - too many rsh slots. - **/ - - gettimeofday (&now, (void *) NULL); - dtime = 1e6*(3.0 - DTIME(now,then)); - fprintf (stderr, "dtime %f\n", dtime); - if (dtime > 0) usleep (dtime); - - clearlockfile (dbfile, fd); - exit (0); - - } - - /* read the header block, change one line, write the header block */ - /* write a block to EOF */ - - f = fopen (dbfile, "r"); - if (f == (FILE *) NULL) { - /* make a header block */ - for (i = 0; i < 50; i++) { - memset (&buffer[100*i], 65+i, 99); - buffer[100*i + 99] = '\n'; - } - sprintf (&buffer[500], "THIS IS TEST 0 \n"); - Nrun = 0; - } else { - status = fread (buffer, 1, 5000, f); - if (status != 5000) { - fprintf (stderr, "ERROR: can't read data\n"); - exit (0); - } - - sscanf (&buffer[500], "%*s %*s %*s %d", &Nrun); - Nrun ++; - sprintf (&buffer[500], "THIS IS TEST %d \n", Nrun); - } - - f = fopen (dbfile, "r+"); - if (f == NULL) { - f = fopen (dbfile, "w"); - if (f == NULL) { - fprintf (stderr, "ERROR: can't create/open file %s\n", dbfile); - exit (0); - } - } - - /* position to begining of file to write header */ - fseek (f, 0, SEEK_SET); - status = fwrite (buffer, 1, 5000, f); - if (status != 5000) { - fprintf (stderr, "ERROR: failed writing data to header\n"); - exit (0); - } - - for (i = 0; i < 1000; i++) vbuffer[i] = Nrun; - - fseek (f, 0, SEEK_END); - status = fwrite (vbuffer, 4, 1000, f); - if (status != 1000) { - fprintf (stderr, "ERROR: failed writing data to file\n"); - exit (0); - } - - fclose (f); - - if (!gnfsflush (dbfile)) { - fprintf (stderr, "ERROR: failed to flush image catalog\n"); - exit (0); - } - - -}