Changeset 2993:daefb5b9bc41 in roaraudio

Timestamp:

10/26/09 18:28:50 (15 years ago)

Author:

phi

Branch:

default

Phase:

public

Message:

added --io-flush

File:

• roarclients/roarphone.c (modified) (7 diffs)

roarclients/roarphone.c

@@ -59 +59 @@
  int64_t dtx_threshold;
  size_t jumbo_mtu;
+ int    ioflush_interval;
  struct {
   struct {
@@ -104 +105 @@
  printf("  --server   SERVER    - Set server hostname\n"
         " --jumbo-mtu MTU       - Sets the MTU for Jumbo Packets\n"
+        " --io-flush  INTERVAL  - Flushs output every INTERVAL packets\n"
        );
 
@@ -317 +319 @@
  void * outbuf, * micbuf;
  ssize_t outlen, miclen;
+ unsigned long int pkg_count = 0;
 
  ROAR_DBG("run_stream(*): g_conf.samples = %i, info->bits = %i", g_conf.samples, info->bits);
@@ -348 +351 @@
   }
 
+  if ( g_conf.ioflush_interval != -1 ) {
+   if ( !(pkg_count % g_conf.ioflush_interval) )
+    roar_vio_sync(s1);
+  }
+
   if ( g_conf.transcode ) {
    ROAR_DBG("run_stream(*): outbuf=%p, len=%lu", outbuf, (unsigned long) len);
@@ -369 +377 @@
   if ( roar_vio_write(s0, outbuf, outlen) != outlen )
    break;
+
+  pkg_count++;
  }
 
@@ -394 +404 @@
  memset(&g_conf, 0, sizeof(g_conf));
 
- g_conf.antiecho      = AE_ROARD;
- g_conf.dtx_threshold = -1;
+ g_conf.antiecho         = AE_ROARD;
+ g_conf.dtx_threshold    = -1;
+ g_conf.ioflush_interval = -1;
 
  memset(&g_cons, 0, sizeof(g_cons));
@@ -412 +423 @@
   } else if ( strcmp(k, "--jumbo-mtu") == 0 ) {
    g_conf.jumbo_mtu = atoi(argv[++i]);
+  } else if ( strcmp(k, "--io-flush") == 0 ) {
+   g_conf.ioflush_interval = atoi(argv[++i]);
   } else if ( strcmp(k, "--rate") == 0 ) {
    info.rate = atoi(argv[++i]);