]> git.parisson.com Git - telecaster-cgi.git/commitdiff
first outside webm streaming test
authoryomguy <yomguy@parisson.com>
Tue, 10 Jan 2012 18:55:46 +0000 (19:55 +0100)
committeryomguy <yomguy@parisson.com>
Tue, 10 Jan 2012 18:55:46 +0000 (19:55 +0100)
tests/push_webm_2.py [new file with mode: 0644]

diff --git a/tests/push_webm_2.py b/tests/push_webm_2.py
new file mode 100644 (file)
index 0000000..0afefbe
--- /dev/null
@@ -0,0 +1,36 @@
+
+import pycurl
+import urllib
+
+class RelayReader:
+       def __init__(self, relay):
+               self.relay = urllib.urlopen(relay)
+               
+       def read_callback(self, size):
+               return self.relay.read(size)
+                       
+
+class Streamer(object):
+       
+       BUFFER_SIZE = 0x10000
+       
+       def __init__(self, host, port, mount_point, relay):
+               self.host = host
+               self.port = port
+               self.mount_point = mount_point
+               self.relay = relay
+               self.url='http://'+self.host+':'+self.port+self.mount_point
+               
+
+       def stream(self):
+               c = pycurl.Curl()
+               c.setopt(pycurl.URL, self.url)
+               c.setopt(pycurl.UPLOAD, 1)
+               c.setopt(pycurl.READFUNCTION, RelayReader(self.relay).read_callback)
+               c.perform()
+               c.close()
+               
+s = Streamer('angus.parisson.com','8080','/publish/first?password=secret','http://127.0.0.1:9000/')
+s.stream()
+
+