bugfix in test
@@ -252,15 +252,14 @@ async def sendMsgAndCheck(nodes: TestNodeSet,
msg: Optional[Tuple]=None,
timeout: Optional[int]=15
):
+ msg = msg if msg else randomMsg()
sendMsg(nodes, frm, to, msg)
await eventually(checkMsg, msg, nodes, to, retryWait=.1, timeout=timeout,
ratchetSteps=10)
-def sendMsg(nodes: TestNodeSet, frm: NodeRef, to: NodeRef,
- msg: Optional[Tuple]=None):
+def sendMsg(nodes: TestNodeSet, frm: NodeRef, to: NodeRef, msg):
logger.debug("Sending msg from {} to {}".format(frm, to))
- msg = msg if msg else randomMsg()
frmnode = nodes.getNode(frm)
rid = frmnode.nodestack.getRemote(nodes.getNodeName(to)).uid
frmnode.nodestack.send(msg, rid)
