Commit a1d1224d authored by Josh Kunz's avatar Josh Kunz

Add some debugging statements and hacks

Hack: Add a sleep to see if that lets the trans_rp drain
before we call recv_wait on it. Proper solution outlined in
capnet#24

Debugging: Make sure that recv_iter actually works.
parent c37c54a6
Pipeline #1847 passed with stage
in 2 seconds
......@@ -65,8 +65,14 @@ def main():
trans_rp = membrane_ext.recv_wait()
assert trans_rp.__class__ == cn.RP
def trans_rp_recv_iter_debug_wrapper(it):
for x in it:
print "trans rp iter got:", repr(x)
yield x
ts('recvnodes',0,'start')
nodes = capnet.util.recv_nodes(p, trans_rp.recv_iter())
_it = trans_rp_recv_iter_debug_wrapper(trans_rp.recv_iter())
nodes = capnet.util.recv_nodes(p, _it)
master = None
resourcemanager = None
slaves = {}
......
......@@ -76,6 +76,9 @@ def main():
for (name, node) in nodes.iteritems():
trans_rp.send(node.node)
ts('service-node-send',0,'stop')
# Wait until the service wfa has read all of our nodes
time.sleep(10.0)
ts('trans-recv',0,'start')
master_grant = trans_rp.recv_wait()
......
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