Skip to content

Commit 8a0fd1f

Browse files
committed
fix: Potential OOM due to recursion while recovering Cube Store websocket
1 parent f590a20 commit 8a0fd1f

File tree

1 file changed

+5
-7
lines changed

1 file changed

+5
-7
lines changed

packages/cubejs-cubestore-driver/src/WebSocketConnection.ts

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -177,14 +177,12 @@ export class WebSocketConnection {
177177
reject(err);
178178
}
179179
});
180-
socket.sentMessages[messageId] = {
181-
resolve,
182-
reject,
183-
buffer
184-
};
185-
} else {
186-
resolve(this.sendMessage(messageId, buffer));
187180
}
181+
socket.sentMessages[messageId] = {
182+
resolve,
183+
reject,
184+
buffer
185+
};
188186
});
189187
}
190188

0 commit comments

Comments
 (0)