From 0f31a74197cf1db35bad798b78e71edb6bf5c7e1 Mon Sep 17 00:00:00 2001 From: DarshanBPatel Date: Thu, 22 Aug 2024 16:20:37 +0530 Subject: [PATCH] exception handling in the PR --- .../peer_exchange_tester.nim | 17 ++++++++++++----- 1 file changed, 12 insertions(+), 5 deletions(-) diff --git a/apps/peer_exchange_tester/peer_exchange_tester.nim b/apps/peer_exchange_tester/peer_exchange_tester.nim index 0ec6db32d..0d2cb65c4 100644 --- a/apps/peer_exchange_tester/peer_exchange_tester.nim +++ b/apps/peer_exchange_tester/peer_exchange_tester.nim @@ -49,7 +49,7 @@ proc main() {.async.} = var iter = 0 var success = 0 - for i in 1 .. 60: + for i in 0 .. 60: echo "Seq No :- " & $i & " ---> " let response = await wakuApp.node.wakuPeerExchange.request(5, peer_info) @@ -64,15 +64,22 @@ proc main() {.async.} = let ma = peer_info.addrs echo $iter & ") -----> " & $ma[0] & " -- " & $peerId iter += 1 - let conn = await switch.dial(peerId, ma, "/vac/waku/metadata/1.0.0") + try: + let wait = 20000 + let conn = await switch + .dial(peerId, ma, "/vac/waku/metadata/1.0.0") + .withTimeout(wait) + except TimeoutError: + echo "Dialing peer " & $peerId & " timed out." + except: + echo "An error occurred while dialing peer " & $peerId + success += len(switch.connectedPeers(Direction.Out)) echo $success & " out of " & $iter & " operation successful" - # echo $switch.connectedPeers(Direction.Out) & " -- " & $switch.connectedPeers(Direction.In) + discard switch.disconnect(peerId) else: echo " ------------ response isn't not ok ------------------" - sleep(120000) - echo "---------------------------- Done ------------------------------- " when isMainModule: