sm/smbinterp
1
0
Fork 0
Code Issues Pull Requests Activity

added a server

Browse Source
This commit is contained in:
Stephen Mardson McQuay 2011-03-02 23:26:04 -07:00
parent 58d651969e
commit 8b1670fdc0
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
bin/server.py Normal file
View File

@ -0,0 +1,16 @@
#!/usr/bin/env python
from multiprocessing.managers import BaseManager
import Queue
inqueue = Queue.Queue()
outqueue = Queue.Queue()
class QueueManager(BaseManager):
pass
QueueManager.register('get_inqueue', callable=lambda:inqueue)
QueueManager.register('get_outqueue', callable=lambda:outqueue)
m = QueueManager(address=('', 50000), authkey='asdf')
s = m.get_server()
s.serve_forever()