BlinkenLib

@@ -196,6 +196,7 @@ static int serial_settings_set(int fd, int settings, int speed)

 // returns error code (not for device-errors, 0 for success)

 static int recv_and_out(SOCKET udpSocket, int dev_fd,

                         int *p_device_output_active,

+                        unsigned int min_interval_ms,

                         unsigned int format_change,

                         unsigned int format_height, unsigned int format_width,

                         unsigned int format_channels,

@@ -205,10 +206,12 @@ static int recv_and_out(SOCKET udpSocket, int dev_fd,

   fd_set readFds, errFds;

   stBlinkenFrame *pFrame;

   char buffer[65536];   // 64kB is more than maximum UDP size

-  int maxFd, len, dev_eof;

+  int maxFd, len, dev_eof, out_ok;

   struct timeval start, timeout, *p_timeout, end;

+  struct timeval out_last, out_now;

   dev_eof = 0;

+  gettimeofday(&out_last, NULL);

   for (;;) {

     // wait for next frame

     FD_ZERO(&readFds);

@@ -272,8 +275,19 @@ static int recv_and_out(SOCKET udpSocket, int dev_fd,

         // free frame

         BlinkenFrameFree(pFrame);

+        // check if minimum interval between output frames is met

+        gettimeofday(&out_now, NULL);

+        if (out_now.tv_sec > out_last.tv_sec - min_interval_ms / 1000)

+          out_ok = 1;

+        else if ((out_now.tv_sec - out_last.tv_sec) * 1000 +

+                 ((long)out_now.tv_usec - (long)out_last.tv_usec) / 1000 >

+                 min_interval_ms)

+          out_ok = 1;

+        else

+          out_ok = 0;

+

         // output data to device

-        if (dev_fd != -1 && len > 0) {

+        if (dev_fd != -1 && len > 0 && out_ok) {

           if (write(dev_fd, buffer, len) != len) {

             if (*p_device_output_active)

               printf("error writing to device\n");

@@ -283,6 +297,8 @@ static int recv_and_out(SOCKET udpSocket, int dev_fd,

           if (!*p_device_output_active)

             printf("restarted output to device...\n");

           *p_device_output_active = 1;

+          // remember last time of output

+          out_last = out_now;

         }

       }

     }

@@ -331,7 +347,9 @@ static int recv_and_out(SOCKET udpSocket, int dev_fd,

 static int open_and_output(SOCKET udpSocket, char *device,

                            int *p_device_output_active,

                            int serial_settings_change, int serial_settings,

-                           int serial_speed, unsigned int format_change,

+                           int serial_speed,

+                           unsigned int min_interval_ms,

+                           unsigned int format_change,

                            unsigned int format_height,

                            unsigned int format_width,

                            unsigned int format_channels,

@@ -360,6 +378,7 @@ static int open_and_output(SOCKET udpSocket, char *device,

   }

   // receive frames and output to device

   err = recv_and_out(udpSocket, dev_fd, p_device_output_active,

+                     min_interval_ms,

                      format_change, format_height, format_width,

                      format_channels, format_colors, proto, 0, 0);

@@ -376,6 +395,7 @@ static int open_and_output_loop(SOCKET udpSocket, char *device,

                                 int serial_settings, int serial_speed,

                                 int reopen_device,

                                 unsigned int reopen_device_ms,

+                                unsigned int min_interval_ms,

                                 unsigned int format_change,

                                 unsigned int format_height,

                                 unsigned int format_width,

@@ -394,7 +414,8 @@ static int open_and_output_loop(SOCKET udpSocket, char *device,

     err = open_and_output(udpSocket, device,

                           &device_output_active,

                           serial_settings_change, serial_settings,

-                          serial_speed, format_change, format_height,

+                          serial_speed, min_interval_ms,

+                          format_change, format_height,

                           format_width, format_channels, format_colors,

                           proto);

     if (err != 0 || !reopen_device)

@@ -407,6 +428,7 @@ static int open_and_output_loop(SOCKET udpSocket, char *device,

     // only fetch data from socket for a short time

     err = recv_and_out(udpSocket, -1, &device_output_active,

+                       min_interval_ms,

                        format_change, format_height, format_width,

                        format_channels, format_colors, proto, 1,

                        reopen_device_ms);

@@ -430,7 +452,8 @@ int main(int argCnt, char **args)

   etBlinkenProto proto;

   unsigned int format_change, format_height, format_width, format_channels,

       format_colors;

-  unsigned int height, width, channels, colors, reopen_device_ms;

+  unsigned int height, width, channels, colors;

+  unsigned int reopen_device_ms, min_interval_ms;

   int serial_settings_change, reopen_device;

   char txt[64];

   unsigned short port;

@@ -466,6 +489,8 @@ int main(int argCnt, char **args)

            "     settings to use for serial devices (defaults to no change)\n"

            "  -o <milliseconds>\n"

            "     reopen device after short time on error (defaults to not reopen)\n"

+           "  -i <milliseconds>\n"

+           "     minimum interval between two frames on output (defaults to 0)\n"

            "\n", args[0]);

     return 0;

   }

@@ -489,6 +514,7 @@ int main(int argCnt, char **args)

   serial_speed = 0;

   serial_settings_change = 0;

   reopen_device = 0;

+  min_interval_ms = 0;

   for (i = 1; i < argCnt; i++) {

     // local address

@@ -601,6 +627,17 @@ int main(int argCnt, char **args)

       } else

         printf("missing time for \"-o\"\n");

     }

+    // minimum interval between two frame on output

+    else if (strcmp(args[i], "-i") == 0) {

+      if (i + 1 < argCnt) {

+        i++;

+        if (sscanf(args[i], "%u", &min_interval_ms) != 1) {

+          min_interval_ms = 0;

+          printf("invalid number of milliseconds \"%s\"\n", args[i]);

+        }

+      } else

+        printf("missing time for \"-i\"\n");

+    }

     // unknown parameter

     else

       printf

@@ -627,7 +664,7 @@ int main(int argCnt, char **args)

   // open device and output frames in a loop

   open_and_output_loop(udpSocket, device,

                        serial_settings_change, serial_settings, serial_speed,

-                       reopen_device, reopen_device_ms,

+                       reopen_device, reopen_device_ms, min_interval_ms,

                        format_change, format_height, format_width,

                        format_channels, format_colors, proto);

@@ -1,3 +1,7 @@

+0.7.2 2013-12-27

+----------------

+added minimum time between output option to BlinkenOutput

+

 0.7.1 2011-11-19

 ----------------

 added missing status output for BlinkenConv -C

@@ -1,5 +1,5 @@

 # BlinkenLib

-# Copyright 2004-2011 Stefan Schuermans <stefan@blinkenarea.org>

+# Copyright 2004-2013 Stefan Schuermans <stefan@blinkenarea.org>

 # Copyleft GNU public license - http://www.gnu.org/copyleft/gpl.html

 # a blinkenarea.org project