forked from lvm/LiveOSC2
-
Notifications
You must be signed in to change notification settings - Fork 2
/
LO2OSC.py
executable file
·102 lines (73 loc) · 3.03 KB
/
LO2OSC.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
import OSC
import socket
import sys
import errno
import traceback
class LO2OSC(object):
@staticmethod
def set_log(func):
LO2OSC.log_message = func
@staticmethod
def set_message(func):
LO2OSC.show_message = func
@staticmethod
def release_attributes():
LO2OSC.log_message = None
LO2OSC.show_message = None
_in_error = False
def __init__(self, remotehost = '127.0.0.1', remoteport=9000, localhost='127.0.0.1', localport=9001):
self._socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
self._socket.setblocking(0)
self._local_addr = (localhost, localport)
self._remote_addr = (remotehost, remoteport)
try:
self._socket.bind(self._local_addr)
self.log_message('Starting on: ' + str(self._local_addr) + ', remote addr: '+ str(self._remote_addr))
except:
self._in_error = True
msg = 'ERROR: Cannot bind to ' + str(self._local_addr) + ', port in use'
self.show_message(msg)
self.log_message(msg)
self._callback_manager = OSC.CallbackManager()
self._callback_manager.add('/live/set_peer', self._set_peer)
def error(self):
return self._in_error
def send(self, address, msg):
oscmsg = OSC.OSCMessage(address, msg)
if len(oscmsg.error) > 0:
self.log_message('OSCMessage Error: ' + ''.join(oscmsg.error))
self._socket.sendto(oscmsg.getBinary(), self._remote_addr)
def send_message(self, message):
self._socket.sendto(message.getBinary(), self._remote_addr)
def process(self):
try:
while 1:
self._data, self._addr = self._socket.recvfrom(65536)
try:
self._callback_manager.handle(self._data, self._addr)
except OSC.NoSuchCallback, e:
errmsg = 'Unknown callback: '+str(e.args[0])
self.log_message('LiveOSC: '+errmsg)
self.send('/live/error', errmsg)
except Exception, e:
errmsg = type(e).__name__+': '+str(e.args[0])
tb = sys.exc_info()
stack = traceback.extract_tb(tb[2])
self.log_message('LiveOSC: error handling message ' + errmsg)
self.send('/live/error', errmsg)
self.log_message("".join(traceback.format_list(stack)))
except socket.error, e:
if e.errno == errno.EAGAIN:
return
self.log_message('LiveOSC: Socket unavailable')
except Exception, e:
self.log_message('LiveOSC: error handling message '+type(e).__name__+':'+str(e.args[0]))
def shutdown(self):
self._socket.close()
def _set_peer(self, msg, source):
host = msg[2]
if host == '':
host = source[0]
port = msg[3]
self.log_message('LiveOSC2: reconfigured to send to ' + host + ':' + str(port))
self._remote_addr = (host, port)