Changeset 42456

Timestamp:

Apr 21, 2023, 4:41:05 PM (3 years ago)

Author:

eugene

Message:

add queuesave function

Location:

trunk/Ohana/src/opihi

Files:

• cmd.data/Makefile (modified) (1 diff)
• cmd.data/init.c (modified) (2 diffs)
• cmd.data/queuesave.c (added)
• include/data.h (modified) (1 diff)
• lib.data/queues.c (modified) (1 diff)

trunk/Ohana/src/opihi/cmd.data/Makefile

@@ -135 +135 @@
 $(SRC)/queuepop.$(ARCH).o       \
 $(SRC)/queueprint.$(ARCH).o     \
+$(SRC)/queuesave.$(ARCH).o      \
 $(SRC)/queuesubstr.$(ARCH).o    \
 $(SRC)/queueinit.$(ARCH).o      \

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

@@ -122 +122 @@
 int queueprint       PROTO((int, char **));
 int queuepush        PROTO((int, char **));
+int queuesave        PROTO((int, char **));
 int queuesubstr      PROTO((int, char **));
 int queuesize        PROTO((int, char **));
@@ -333 +334 @@
   {1, "queueprint",   queueprint,       "print the contents of a queue"},
   {1, "queuepush",    queuepush,        "push value onto queue"},
+  {1, "queuesave",    queuesave,        "save the contents of a queue in a filex"},
   {1, "queuesize",    queuesize,        "show queue size"},
   {1, "queuesubstr",  queuesubstr,      "bulk replace strings in queue"},

trunk/Ohana/src/opihi/include/data.h

@@ -124 +124 @@
 int DeleteQueue (Queue *queue);
 int PrintQueue (Queue *queue);
+int SaveQueue (Queue *queue, char *filename);
 
 /* in fft.c */

trunk/Ohana/src/opihi/lib.data/queues.c

@@ -398 +398 @@
 }
 
+int SaveQueue (Queue *queue, char *filename) {
+
+  if (queue[0].Nlines == 0) return (TRUE);
+
+  FILE *f = fopen (filename, "a");
+  if (!f) {
+    gprint (GP_ERR, "unable to open output file %s\n", filename);
+    return FALSE;
+  }
+
+  for (int i = 0; i < queue[0].Nlines; i++) {
+    fprintf (f, "%s\n", queue[0].lines[i]);
+  }
+  fclose (f);
+  return (TRUE);
+}
+