diff options
author | Aleksey Lim <alsroot@sugarlabs.org> | 2013-03-25 19:27:19 (GMT) |
---|---|---|
committer | Aleksey Lim <alsroot@sugarlabs.org> | 2013-03-25 19:27:19 (GMT) |
commit | aba33995a1a976552b8198e140ee6a8256d04cbb (patch) | |
tree | 564b568b1bf4acb5a9e298a285098f77cc1c4fee /sugar-network | |
parent | 0e67a344e3948ab64fbe6502cabdcaf7cf7aecf4 (diff) |
Fix OOB usecase
Diffstat (limited to 'sugar-network')
-rwxr-xr-x | sugar-network | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/sugar-network b/sugar-network index 50da26a..cbde4c8 100755 --- a/sugar-network +++ b/sugar-network @@ -28,7 +28,7 @@ from gevent import monkey from sugar_network import db, client, toolkit from sugar_network.resources.volume import Volume from sugar_network.client import IPCRouter -from sugar_network.client.commands import CachedClientCommands +from sugar_network.client.commands import ClientCommands from sugar_network.toolkit import printf, application, coroutine, util from sugar_network.toolkit import Option, BUFFER_SIZE, enforce @@ -146,29 +146,29 @@ class Application(application.Application): pid_path = None server = None - cli = None + cp = None try: - if not self.check_for_instance(): + if self.check_for_instance(): + cp = client.IPCClient() + else: pid_path = self.new_instance() if not client.anonymous.value: util.ensure_key(client.key_path()) home = Volume(client.path('db')) - cli = CachedClientCommands(home, offline=offline.value) + cp = ClientCommands(home, offline=offline.value) if not offline.value: - for __ in cli.subscribe(event='inline', state='online'): + for __ in cp.subscribe(event='inline', state='online'): break server = coroutine.WSGIServer( - ('localhost', client.ipc_port.value), IPCRouter(cli)) + ('localhost', client.ipc_port.value), IPCRouter(cp)) coroutine.spawn(server.serve_forever) coroutine.dispatch() - - result = client.IPCClient().call(request, response) - + result = cp.call(request, response) finally: if server is not None: server.close() - if cli is not None: - cli.close() + if cp is not None: + cp.close() if pid_path: os.unlink(pid_path) |