Commit ba46694b authored by David Johnson's avatar David Johnson

Fix bugs in allpairs service half; improve debuggability.

parent 875d06d0
Pipeline #1247 skipped
......@@ -68,8 +68,8 @@ def main():
while True:
(node,info,flow,name) = (None,None,None,None)
try:
print "rp0 recv"
node = rp0.recv()
print "service_rp recv"
node = service_rp.recv()
print "node info"
info = node.info()
print "node flow"
......@@ -89,7 +89,7 @@ def main():
a = nodes[name]
for (bname,b) in nodes.iteritems():
# Don't give caps to send to us.
if b.info.name == me:
if b.info.name == myname:
continue
print "Sending flow ->%s to %s" % (b.info.name,name)
......@@ -105,7 +105,9 @@ def main():
traceback.print_exc()
pass
pass
sys.stdout.flush()
sys.stderr.flush()
time.sleep(2)
pass
......
......@@ -104,14 +104,18 @@ def main():
print "Exception: ",e
pass
pass
elif not node is None:
elif node:
try:
print "Sending cap to %s to allpairs service" % (info.name,)
service_rp.send(node)
print "Sent cap to %s to allpairs service" % (info.name,)
except Exception, e:
print "Exception: ",e
pass
pass
sys.stdout.flush()
sys.stderr.flush()
time.sleep(2)
pass
......
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