Skip to content

Commit 77b7882

Browse files
committed
fix: fixed leaking timeout error during nodesFind
1 parent f72ba31 commit 77b7882

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

src/nodes/NodeManager.ts

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -707,7 +707,6 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
707707
}
708708

709709
while (true) {
710-
ctx.signal.throwIfAborted();
711710
const isDone = await nodeConnectionsQueue.withNodeSignal(
712711
async (nodeIdTarget, nodeIdSignaller) => {
713712
let nodeConnection: NodeConnection<Manifest> | undefined;
@@ -849,7 +848,6 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
849848
}
850849

851850
while (true) {
852-
ctx.signal.throwIfAborted();
853851
const isDone = await nodeConnectionsQueue.withNodeDirect(
854852
async (nodeIdTarget, nodeContact) => {
855853
if (!this.nodeConnectionManager.hasConnection(nodeIdTarget)) {
@@ -924,8 +922,7 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
924922
throw e;
925923
});
926924
}
927-
928-
if (connectionMade == null) {
925+
if (!connectionMade) {
929926
throw new nodesErrors.ErrorNodeManagerFindNodeFailed(
930927
'failed to find node via direct',
931928
);

0 commit comments

Comments
 (0)