Web   ·   Wiki   ·   Activities   ·   Blog   ·   Lists   ·   Chat   ·   Meeting   ·   Bugs   ·   Git   ·   Translate   ·   Archive   ·   People   ·   Donate
summaryrefslogtreecommitdiffstats
path: root/sugar-network
diff options
context:
space:
mode:
authorAleksey Lim <alsroot@sugarlabs.org>2013-03-25 19:27:19 (GMT)
committer Aleksey Lim <alsroot@sugarlabs.org>2013-03-25 19:27:19 (GMT)
commitaba33995a1a976552b8198e140ee6a8256d04cbb (patch)
tree564b568b1bf4acb5a9e298a285098f77cc1c4fee /sugar-network
parent0e67a344e3948ab64fbe6502cabdcaf7cf7aecf4 (diff)
Fix OOB usecase
Diffstat (limited to 'sugar-network')
-rwxr-xr-xsugar-network22
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)