andpp/mopidy
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Exceptions won't jump over the multiprocessing connection

Browse Source
This commit is contained in:
Stein Magnus Jodal 2010-03-20 02:24:20 +01:00
parent a2d728d78c
commit 38cecde96b
1 changed files with 10 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
mopidy/mpd/server.py
View File

@ -74,20 +74,16 @@ class MpdSession(asynchat.async_chat):
self.handle_request(input)
def handle_request(self, input):
try:
my_end, other_end = multiprocessing.Pipe()
self.core_queue.put({
'command': 'mpd_request',
'request': input,
'reply_to': pickle_connection(other_end),
})
my_end.poll(None)
response = my_end.recv()
if response is not None:
self.handle_response(response)
except MpdAckError, e:
logger.warning(e)
return self.send_response(u'ACK %s' % e)
my_end, other_end = multiprocessing.Pipe()
self.core_queue.put({
'command': 'mpd_request',
'request': input,
'reply_to': pickle_connection(other_end),
})
my_end.poll(None)
response = my_end.recv()
if response is not None:
self.handle_response(response)
def handle_response(self, response):
self.send_response(LINE_TERMINATOR.join(response))