Changeset 42082 for trunk/Ohana/src/opihi/cmd.data/queueload.c

Timestamp:

Feb 28, 2022, 12:17:32 PM (4 years ago)

Author:

eugene

Message:

add imresample, imcollapse functions; more usage documentation; option to catch failures in command when loading from shell command into queue; better handling of errors reading FITS table

File:

• trunk/Ohana/src/opihi/cmd.data/queueload.c (modified) (3 diffs)

trunk/Ohana/src/opihi/cmd.data/queueload.c

@@ -3 +3 @@
 int queueload (int argc, char **argv) {
   
-  char *A, *B, *val;
-  int i, status;
-  int Nread, Nbytes, NBYTES;
-  FILE *f;
-  Queue *queue;
+  int N;
+
+  // variable name to save the value
+  int TrapFailure = FALSE;
+  if ((N = get_argument (argc, argv, "-trap-failure"))) {
+    remove_argument (N, &argc, argv);
+    TrapFailure = TRUE;
+  }
+  if ((N = get_argument (argc, argv, "-trap"))) {
+    remove_argument (N, &argc, argv);
+    TrapFailure = TRUE;
+  }
 
   if (argc != 4) goto usage;
@@ -13 +20 @@
   
   /* will create a queue if none exists */
-  queue = CreateQueue (argv[1]);
+  Queue *queue = CreateQueue (argv[1]);
 
   /* val will hold the result of the command */
-  NBYTES = 1024;
-  ALLOCATE (val, char, NBYTES);
+  int NBYTES = 1024;
+  ALLOCATE_PTR (val, char, NBYTES);
     
   /* loop until command produces no more output,  REALLOCATE as needed. */
-  f = popen (argv[3], "r");
-  Nbytes = 0;
-  Nread = 1;
+  FILE *f = popen (argv[3], "r");
+
+  int Nbytes = 0;
+  int Nread = 1;
   while (Nread > 0) {
     Nread = fread (&val[Nbytes], 1, 1023, f);
@@ -35 +43 @@
   }
   val[Nbytes] = 0;
-  status = pclose (f);
+  int status = pclose (f);
     
+  // XXX 
   if (status) {
     gprint (GP_ERR, "warning: exit status of command %d\n", status);
+    if (TrapFailure) { free (val); return FALSE; }
   }
       
-  A = B = val;
-  for (i = 0; B != (char *) NULL;) {
+  char *A = val, *B = val;
+  for (int i = 0; B != (char *) NULL;) {
     while (isspace (*A) && (*A != 0)) A++;
     B = strchr (A, '\n');