Changeset 27588
- Timestamp:
- Apr 3, 2010, 8:35:01 AM (16 years ago)
- Location:
- trunk/Ohana/src
- Files:
-
- 17 edited
-
addstar/test (modified) (1 prop)
-
elixir/src/ConfigPID.c (modified) (1 diff)
-
elixir/src/DumpStatus.c (modified) (1 diff)
-
elixir/src/MachineOps.c (modified) (3 diffs)
-
elixir/src/StartMachine.c (modified) (1 diff)
-
elixir/src/rconnect.c (modified) (1 diff)
-
libautocode/def/autocode.c (modified) (2 diffs)
-
libdvo/src/dvo_catalog_mef.c (modified) (1 diff)
-
libdvo/src/dvo_catalog_raw.c (modified) (1 diff)
-
libkapa/src/IOfuncs.c (modified) (5 diffs)
-
libkapa/src/KapaOpen.c (modified) (2 diffs)
-
libkapa/src/KapaWindow.c (modified) (2 diffs)
-
libkapa/src/KiiOpen.c (modified) (1 diff)
-
libkapa/src/KiiOverlay.c (modified) (2 diffs)
-
libkapa/src/KiiPicture.c (modified) (6 diffs)
-
relastro/src/UpdateObjects.c (modified) (1 diff)
-
relastro/src/plotstuff.c (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Ohana/src/addstar/test
- Property svn:ignore
-
old new 4 4 catdir.test 5 5 .dvo 6 relphot.airmass.png 7 relphot.chisq.png 8 relphot.dMcalhist.png 9 relphot.dMhist.png 10 relphot.dvo 11 relphot.iMag.png 12 relphot.Mag.png 13 relphot.Mcal.dMcal.png
-
- Property svn:ignore
-
trunk/Ohana/src/elixir/src/ConfigPID.c
r10336 r27588 40 40 41 41 ALLOCATE (username, char, 256); 42 fscanf (f, "%*s %d", &pid);43 fscanf (f, "%*s %s", username);44 fscanf (f, "%*s %s", machine);42 if (fscanf (f, "%*s %d", &pid) != 1) fprintf (stderr, "error reading pid\n"); 43 if (fscanf (f, "%*s %s", username) != 1) fprintf (stderr, "error reading pid\n"); 44 if (fscanf (f, "%*s %s", machine) != 1) fprintf (stderr, "error reading pid\n"); 45 45 fclose (f); 46 46 -
trunk/Ohana/src/elixir/src/DumpStatus.c
r27435 r27588 12 12 13 13 if (filename == (char *) NULL) { 14 system ("tput clear"); 14 if (system ("tput clear") == -1) { 15 fprintf (stderr, "\n\n\n"); 16 } 15 17 f = stderr; 16 18 } else { -
trunk/Ohana/src/elixir/src/MachineOps.c
r27435 r27588 209 209 /* we can set up the shell here */ 210 210 sprintf (line, "setenv PTOLEMY %s\n", ConfigFilename); 211 write (wsock, line, strlen (line)); 211 if (write (wsock, line, strlen (line)) != strlen(line)) { 212 return FALSE; 213 } 212 214 sprintf (line, "umask 002\n"); 213 write (wsock, line, strlen (line)); 215 if (write (wsock, line, strlen (line)) != strlen(line)) { 216 return FALSE; 217 } 214 218 return (TRUE); 215 219 } else { … … 325 329 326 330 sprintf (buffer, "exit\n"); 327 write (machine[0].wsock, buffer, strlen(buffer)); 331 if (write (machine[0].wsock, buffer, strlen(buffer)) != strlen(buffer)) { 332 fprintf (stderr, "can't shutdown %s\n", machine[0].hostname); 333 } 328 334 close (machine[0].wsock); 329 335 close (machine[0].rsock); … … 448 454 449 455 if (filename == (char *) NULL) { 450 system ("tput clear"); 456 if (system ("tput clear") == -1) { 457 fprintf (stderr, "--------\n"); 458 } 451 459 f = stderr; 452 460 } else { -
trunk/Ohana/src/elixir/src/StartMachine.c
r10336 r27588 23 23 24 24 Nout = sprintf (&command[Nbyte], "\n echo PROCESS DONE\n"); 25 write (machine[0].wsock, command, strlen(command));25 if (write (machine[0].wsock, command, strlen(command)) != strlen(command)) return (FALSE); 26 26 27 27 gettimeofday (&machine[0].object[0].start, (void *) NULL); -
trunk/Ohana/src/elixir/src/rconnect.c
r12332 r27588 87 87 without setting onintr */ 88 88 sprintf (buffer, "onintr\n"); 89 write (*wsock, buffer, strlen(buffer));89 status = write (*wsock, buffer, strlen(buffer)); 90 90 if ((status == -1) && (errno == EPIPE)) { 91 91 fprintf (stderr, "socket closed unexpectedly\n"); -
trunk/Ohana/src/libautocode/def/autocode.c
r27435 r27588 113 113 int Send_$STRUCT (int device, $STRUCT *data, int Ndata, int copy) { 114 114 115 int N bytes;115 int Nwrite, Nbytes; 116 116 $STRUCT *tmpdata; 117 117 … … 129 129 SendCommand (device, 16, "NVALUE: %6d", Ndata); 130 130 SendCommand (device, 16, "NBYTES: %6d", Nbytes); 131 write (device, tmpdata, Nbytes); 131 Nwrite = write (device, tmpdata, Nbytes); 132 if (Nwrite != Nbytes) { 133 return (FALSE); 134 } 132 135 133 136 /* perform handshaking? */ -
trunk/Ohana/src/libdvo/src/dvo_catalog_mef.c
r27435 r27588 248 248 /* rewind file pointers and truncate */ 249 249 fseeko (f, 0LL, SEEK_SET); 250 ftruncate (fileno (catalog[0].f), 0); 250 if (ftruncate (fileno (catalog[0].f), 0)) { 251 if (VERBOSE) fprintf (stderr, "failed to truncate file\n"); 252 goto failure; 253 } 251 254 ftable.header = &header; 252 255 -
trunk/Ohana/src/libdvo/src/dvo_catalog_raw.c
r27580 r27588 285 285 f = catalog[0].f; 286 286 fseeko (f, 0, SEEK_SET); 287 ftruncate (fileno (catalog[0].f), 0); 287 if (ftruncate (fileno (catalog[0].f), 0)) { 288 if (VERBOSE) fprintf (stderr, "failed to truncate file\n"); 289 goto failure; 290 } 288 291 289 292 /* write header data (use gfits_write_header?) */ -
trunk/Ohana/src/libkapa/src/IOfuncs.c
r18277 r27588 9 9 int KiiSendData (int device, char *data, int Nbytes) { 10 10 11 int Nwrite; 12 11 13 KiiSendCommand (device, 16, "LEN: %11d", Nbytes); 12 write (device, data, Nbytes); 14 Nwrite = write (device, data, Nbytes); 15 if (Nwrite != Nbytes) return (FALSE); 13 16 return (TRUE); 14 17 } … … 21 24 /* read 16 bytes: LEN (length) */ 22 25 status = read (device, buffer, 16); 26 if (status != 16) return NULL; 23 27 buffer[16] = 0; 24 28 … … 26 30 sscanf (buffer, "%*s %d", &Nbytes); 27 31 ALLOCATE (data, char, Nbytes + 1); 28 read (device, data, Nbytes); 32 status = read (device, data, Nbytes); 33 if (status != Nbytes) { 34 free (data); 35 return NULL; 36 } 37 29 38 data[Nbytes] = 0; 30 39 … … 108 117 int KiiSendCommandV (int device, int length, char *format, va_list argp) { 109 118 119 int Nwrite; 110 120 char *string; 111 121 … … 116 126 vsnprintf (string, length + 1, format, argp); 117 127 118 write (device, string, length); 128 Nwrite = write (device, string, length); 129 if (Nwrite != length) return (FALSE); 119 130 120 131 if (DEBUG) fprintf (stderr, "send: %s\n", string); -
trunk/Ohana/src/libkapa/src/KapaOpen.c
r16810 r27588 228 228 sprintf (line, "%s -name '%s' &", kapa_exec, kapa_name); 229 229 } 230 system (line); 230 if (system (line) == -1) { 231 fprintf (stderr, "failed to launch kapa\n"); 232 return 0; 233 } 231 234 232 235 # define NTRY 500 … … 273 276 sprintf (temp, "%s -socket %s -name %s &", kapa_exec, socket_name, name); 274 277 } 275 system (temp); 278 if (system (temp) == -1) { 279 fprintf (stderr, "failed to launch kapa\n"); 280 return 0; 281 } 276 282 277 283 AddressLength = sizeof (Address); -
trunk/Ohana/src/libkapa/src/KapaWindow.c
r25757 r27588 232 232 int KapaPlotVector (int fd, int Npts, float *values, char *type) { 233 233 234 int Nbytes ;234 int Nbytes, Nwrite; 235 235 int swap; 236 236 … … 256 256 KiiSendMessage (fd, "%s %d %d %d", type, Npts, Nbytes, swap); 257 257 258 write (fd, values, Nbytes); 258 Nwrite = write (fd, values, Nbytes); 259 if (Nwrite != Nbytes) { 260 fprintf (stderr, "error sending data\n"); 261 return FALSE; 262 } 259 263 KiiWaitAnswer (fd, "DONE"); 260 264 return (TRUE); -
trunk/Ohana/src/libkapa/src/KiiOpen.c
r5852 r27588 29 29 sprintf (temp, "%s %s -name %s &", kii_exec, socket_name, name); 30 30 } 31 system (temp); 31 if (system (temp) == -1) { 32 fprintf (stderr, "error starting Kapa\n"); 33 } 34 32 35 33 36 AddressLength = sizeof (Address); -
trunk/Ohana/src/libkapa/src/KiiOverlay.c
r26891 r27588 52 52 int KiiLoadOverlay (int fd, KiiOverlay *overlay, int Noverlay, char *overname) { 53 53 54 int i, overnum, Ntextdata, NTEXTDATA, Ntext, Nchar ;54 int i, overnum, Ntextdata, NTEXTDATA, Ntext, Nchar, nchar; 55 55 char *textdata; 56 56 KiiOverlayBase *buffer; … … 88 88 89 89 // we could break this into segments if we want to trap an interrupt, but why bother? 90 Nchar = write (fd, buffer, Noverlay*sizeof(KiiOverlayBase)); 90 nchar = Noverlay*sizeof(KiiOverlayBase); 91 Nchar = write (fd, buffer, nchar); 92 if (Nchar != nchar) { 93 fprintf (stderr, "comm error\n"); 94 return FALSE; 95 } 91 96 KiiWaitAnswer (fd, "DONE"); 92 97 93 write (fd, textdata, Ntextdata); 98 Nchar = write (fd, textdata, Ntextdata); 99 if (Nchar != Ntextdata) { 100 fprintf (stderr, "comm error\n"); 101 return FALSE; 102 } 94 103 KiiWaitAnswer (fd, "DONE"); // this 'DONE' notes the end of the textdata buffer 95 104 -
trunk/Ohana/src/libkapa/src/KiiPicture.c
r20936 r27588 21 21 int KiiNewPicture1D (int fd, KiiImage *image, KapaImageData *data, Coords *coords) { 22 22 23 int N pix, Ncolors, size;23 int Nwrite, Npix, Ncolors, size; 24 24 float *in, min, max; 25 25 … … 44 44 45 45 /* send the image data */ 46 write (fd, image[0].data1d, size); 46 Nwrite = write (fd, image[0].data1d, size); 47 if (Nwrite != size) { 48 fprintf (stderr, "error reading picture\n"); 49 return (FALSE); 50 } 47 51 48 52 KiiWaitAnswer (fd, "DONE"); … … 53 57 54 58 int i; 55 int N pix, Ncolors, NNcolors, size;59 int Nwrite, Npix, Ncolors, NNcolors, size; 56 60 float *in, min, max; 57 61 char *out, *outbuffer; … … 99 103 100 104 /* send the image data */ 101 write (fd, outbuffer, size); 105 Nwrite = write (fd, outbuffer, size); 106 if (Nwrite != size) { 107 fprintf (stderr, "error reading picture\n"); 108 return (FALSE); 109 } 102 110 free (outbuffer); 103 111 … … 109 117 110 118 int j; 111 int N pix, Ncolors, size;119 int Nwrite, Nbytes, Npix, Ncolors, size; 112 120 float min, max; 113 121 … … 132 140 133 141 for (j = 0; j < image[0].Ny; j++) { 134 write (fd, image[0].data2d[j], image[0].Nx*sizeof(float)); 142 Nbytes = image[0].Nx*sizeof(float); 143 Nwrite = write (fd, image[0].data2d[j], Nbytes); 144 if (Nwrite != size) { 145 fprintf (stderr, "error reading picture\n"); 146 return (FALSE); 147 } 135 148 } 136 149 -
trunk/Ohana/src/relastro/src/UpdateObjects.c
r27581 r27588 50 50 double Tmin, Tmax, Tmean, Trange; 51 51 52 memset (&fit, 0, sizeof(fit)); 53 memset (&fitAve, 0, sizeof(fitAve)); 54 memset (&fitPM, 0, sizeof(fitPM)); 55 memset (&fitPAR, 0, sizeof(fitPAR)); 56 52 57 initObjectData (catalog, Ncatalog); 53 58 -
trunk/Ohana/src/relastro/src/plotstuff.c
r17203 r27588 125 125 if (PLOTDELAY > 500000) { 126 126 fprintf (stdout, "press return\n"); 127 fscanf (stdin, "%*c");127 if (fscanf (stdin, "%*c") != 0) fprintf (stderr, "\n"); 128 128 } else { 129 129 usleep (PLOTDELAY);
Note:
See TracChangeset
for help on using the changeset viewer.
