Commit 2a097dfa authored by David Wilson's avatar David Wilson

examples: import client/server.py test scripts as examples

parent ac4a42a4
import socket
import mitogen.master
import mitogen.unix
import mitogen.service
import mitogen.utils
PING = 500
mitogen.utils.log_to_file()
router, parent = mitogen.unix.connect('/tmp/mitosock')
with router:
print mitogen.service.call(parent, CONNECT_BY_ID, {})
# The service framework will fundamentally change (i.e. become much nicer, and
# hopefully lose those hard-coded magic numbers somehow), but meanwhile this is
# a taster of how it looks today.
import time
import mitogen
import mitogen.service
import mitogen.unix
class PingService(mitogen.service.Service):
well_known_id = 500
max_message_size = 1000
def dispatch(self, dct, msg):
return 'Hello, world'
@mitogen.main()
def main(router):
listener = mitogen.unix.Listener(router, path='/tmp/mitosock')
service = PingService(router)
service.run()
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment