X-Git-Url: https://git.rvb.name/vpproxy.git/blobdiff_plain/1e2c0e679beb33f10c2e551768c17ccd77576b54..68a65fd06255411599601a0b9857be6ef2e8eba2:/vlcclient/vlcclient.py?ds=sidebyside

diff --git a/vlcclient/vlcclient.py b/vlcclient/vlcclient.py
index ebe83f7..b222699 100644
--- a/vlcclient/vlcclient.py
+++ b/vlcclient/vlcclient.py
@@ -109,7 +109,7 @@ class VlcClient(object):
         except EOFError as e:
             raise VlcException("Vlc Write error! ERROR: " + repr(e))
 
-    def _broadcast(self, brtype, stream_name, input=None, muxer='ts', pre_access=''):
+    def _broadcast(self, brtype, stream_name, input=None, muxer='ts', pre_access='', qtype='default'):
         if self._shuttingDown.isSet():
             return
 
@@ -127,8 +127,8 @@ class VlcClient(object):
         self._resultlock.acquire()
         # Write message to VLC socket
         if brtype == True:
-            self._write(VlcMessage.request.startBroadcast(
-                stream_name, input, self._out_port, muxer, pre_access))
+            msg = VlcMessage.request.startBroadcast(stream_name, input, self._out_port, muxer, pre_access, qtype)
+            self._write(msg)
         else:
             self._write(VlcMessage.request.stopBroadcast(stream_name))
 
@@ -149,8 +149,9 @@ class VlcClient(object):
         else:
             logger.debug("Broadcast stopped")
 
-    def startBroadcast(self, stream_name, input, muxer='ts', pre_access=''):
-        return self._broadcast(True, stream_name, input, muxer, pre_access)
+    def startBroadcast(self, stream_name, input, muxer='ts', pre_access='', qtype='default'):
+        print "Starting broadcast......"
+        return self._broadcast(True, stream_name, input, muxer, pre_access, qtype)
 
     def stopBroadcast(self, stream_name):
         return self._broadcast(False, stream_name)