Changeset 127:df5c2e3b1dd3 in roaraudio

Timestamp:

07/13/08 19:11:18 (16 years ago)

Author:

phi

Branch:

default

Phase:

public

Message:

better support for filter streams

File:

• roard/streams.c (modified) (2 diffs)

roard/streams.c

@@ -554 +554 @@
 int streams_send_filter(int id) {
  int fh;
+ int have = 0;
+ int len;
  struct roar_stream        *   s;
  struct roar_stream_server *  ss;
@@ -573 +575 @@
 
  if ( write(fh, g_output_buffer, g_output_buffer_len) == g_output_buffer_len ) {
-  if ( read(fh, g_output_buffer, g_output_buffer_len) == g_output_buffer_len ) {
-   return 0;
-  } else {
-   streams_delete(id);
-   return -1;
-  }
+  while ( have < g_output_buffer_len ) {
+   if ( (len = read(fh, g_output_buffer+have, g_output_buffer_len-have)) < 1 ) {
+    streams_delete(id);
+    return -1;
+   }
+   have += len;
+  }
+  return 0;
  }