From 7a995c5f04cce7fc358523ea4367166f89d426a3 Mon Sep 17 00:00:00 2001 From: yomguy Date: Tue, 10 Jan 2012 19:55:46 +0100 Subject: [PATCH] first outside webm streaming test --- tests/push_webm_2.py | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) create mode 100644 tests/push_webm_2.py diff --git a/tests/push_webm_2.py b/tests/push_webm_2.py new file mode 100644 index 0000000..0afefbe --- /dev/null +++ b/tests/push_webm_2.py @@ -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() + + -- 2.39.5