]> git.parisson.com Git - deefuzzer.git/commitdiff
try different network buffer method
authorGuillaume Pellerin <yomguy@parisson.com>
Mon, 14 Dec 2009 20:09:28 +0000 (20:09 +0000)
committerGuillaume Pellerin <yomguy@parisson.com>
Mon, 14 Dec 2009 20:09:28 +0000 (20:09 +0000)
deefuzzer.py
tools/osc_relay.py

index af813c9193edb86fbc5cf3012870901dcf641900..17da6686a49146d6a5b7ddcc0f49f93687541922 100755 (executable)
@@ -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
 
index bec4c447e6ea42ff562a1c79a565bb1907784d34..3b2ffa2201a2e82b941bf250c13d61719450421d 100644 (file)
@@ -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)