From 27f56080716ce1fc5fc1dd2fdb7e9f16c99e29d9 Mon Sep 17 00:00:00 2001
From: Guillaume Pellerin <yomguy@parisson.com>
Date: Mon, 14 Dec 2009 20:09:28 +0000
Subject: [PATCH] try different network buffer method

---
 deefuzzer.py       | 22 +++++++++++++++-------
 tools/osc_relay.py |  2 +-
 2 files changed, 16 insertions(+), 8 deletions(-)

diff --git a/deefuzzer.py b/deefuzzer.py
index af813c9..17da668 100755
--- a/deefuzzer.py
+++ b/deefuzzer.py
@@ -540,7 +540,7 @@ class Player(Thread):
 
     def __init__(self):
         Thread.__init__(self)
-        self.main_buffer_size = 0x200000
+        self.main_buffer_size = 0x100000
         self.sub_buffer_size = 0x10000
 
     def set_media(self, media):
@@ -602,14 +602,22 @@ class Player(Thread):
 
     def relay(self, url):
         """Read a distant media through its URL"""
-        media = urllib.urlopen(url)
+        m = urllib.urlopen(url)
         while True:
-            __chunk = media.read(self.sub_buffer_size)
-            if not __chunk:
+            __main_chunk = m.read(self.main_buffer_size)
+            if not __main_chunk:
                 break
-            yield __chunk
-        media.close()
-
+            i = 0
+            while True:
+                start = i * self.sub_buffer_size
+                end = self.sub_buffer_size + (i * self.sub_buffer_size)                
+                __sub_chunk = __main_chunk[start:end]
+                if not __sub_chunk:
+                    break
+                yield __sub_chunk
+                i += 1
+        m.close()
+        
     def run(self):
         pass
 
diff --git a/tools/osc_relay.py b/tools/osc_relay.py
index bec4c44..3b2ffa2 100644
--- a/tools/osc_relay.py
+++ b/tools/osc_relay.py
@@ -10,4 +10,4 @@ except liblo.AddressError, err:
     sys.exit()
 
 # send message "/foo/message1" with int, float and string arguments
-liblo.send(target, "/media/relay", 1)
+liblo.send(target, "/media/relay", 0)
-- 
2.39.5