diff --git a/libp2pdht/private/eth/p2p/discoveryv5/protocol.nim b/libp2pdht/private/eth/p2p/discoveryv5/protocol.nim index 4c7ef8c..2d0a4ee 100644 --- a/libp2pdht/private/eth/p2p/discoveryv5/protocol.nim +++ b/libp2pdht/private/eth/p2p/discoveryv5/protocol.nim @@ -478,12 +478,12 @@ proc waitResponse*[T: SomeMessage](d: Protocol, node: Node, msg: T): result = d.waitMessage(node, reqId) sendRequest(d, node, msg, reqId) -proc waitMessage(d: Protocol, fromNode: Node, reqId: RequestId): +proc waitMessage(d: Protocol, fromNode: Node, reqId: RequestId, timeout = ResponseTimeout): Future[Option[Message]] = result = newFuture[Option[Message]]("waitMessage") let res = result let key = (fromNode.id, reqId) - sleepAsync(ResponseTimeout).addCallback() do(data: pointer): + sleepAsync(timeout).addCallback() do(data: pointer): d.awaitedMessages.del(key) if not res.finished: res.complete(none(Message))