projects
/
vpproxy.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Сделана корректная обработка "неаккуратных" файлов с пропущенными кавычками вокруг...
[vpproxy.git]
/
vlcclient
/
vlcclient.py
diff --git
a/vlcclient/vlcclient.py
b/vlcclient/vlcclient.py
index b2226997e7a2d38d4cfdb0b3b2bc45ebdc122ff9..69d9fb92f00507d2b71604ac833d04a4bf741049 100644
(file)
--- a/
vlcclient/vlcclient.py
+++ b/
vlcclient/vlcclient.py
@@
-25,8
+25,8
@@
class VlcClient(object):
'''
def __init__(
'''
def __init__(
- self, host='127.0.0.1', port=4212, password='admin', connect_timeout=
5
,
- result_timeout=
5
, out_port=8081):
+ self, host='127.0.0.1', port=4212, password='admin', connect_timeout=
10
,
+ result_timeout=
10
, out_port=8081):
# Receive buffer
self._recvbuffer = None
# Output port
# Receive buffer
self._recvbuffer = None
# Output port
@@
-98,13
+98,16
@@
class VlcClient(object):
pass
def _write(self, message):
pass
def _write(self, message):
+
+ logger = logging.getLogger("VlcClient_write")
+
# Return if in the middle of destroying
if self._shuttingDown.isSet():
return
try:
# Write message
# Return if in the middle of destroying
if self._shuttingDown.isSet():
return
try:
# Write message
- print 'VLC command:',message
+ logger.debug('VLC command: ' + message)
self._socket.write(message + "\r\n")
except EOFError as e:
raise VlcException("Vlc Write error! ERROR: " + repr(e))
self._socket.write(message + "\r\n")
except EOFError as e:
raise VlcException("Vlc Write error! ERROR: " + repr(e))
@@
-150,7
+153,8
@@
class VlcClient(object):
logger.debug("Broadcast stopped")
def startBroadcast(self, stream_name, input, muxer='ts', pre_access='', qtype='default'):
logger.debug("Broadcast stopped")
def startBroadcast(self, stream_name, input, muxer='ts', pre_access='', qtype='default'):
- print "Starting broadcast......"
+ logger = logging.getLogger("VlcClient_startBroadcast")
+ logger.debug("Starting broadcast......")
return self._broadcast(True, stream_name, input, muxer, pre_access, qtype)
def stopBroadcast(self, stream_name):
return self._broadcast(True, stream_name, input, muxer, pre_access, qtype)
def stopBroadcast(self, stream_name):