aboutsummaryrefslogtreecommitdiff
path: root/src/http/websocket_http_client.zig
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-10-01 18:06:01 -0700
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-10-01 18:06:01 -0700
commitbff3b902e8b55296d785e7224652de78d14914c2 (patch)
tree91c60acadc2d3551a57e2dccf94871407d92ed1d /src/http/websocket_http_client.zig
parent3b4900193ba4a6ee40b3d5935650b5f68baf0729 (diff)
downloadbun-bff3b902e8b55296d785e7224652de78d14914c2.tar.gz
bun-bff3b902e8b55296d785e7224652de78d14914c2.tar.zst
bun-bff3b902e8b55296d785e7224652de78d14914c2.zip
Fix unref'ing websocket
Diffstat (limited to 'src/http/websocket_http_client.zig')
-rw-r--r--src/http/websocket_http_client.zig4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/http/websocket_http_client.zig b/src/http/websocket_http_client.zig
index 2dfed4d7a..b1b4eea4b 100644
--- a/src/http/websocket_http_client.zig
+++ b/src/http/websocket_http_client.zig
@@ -790,6 +790,7 @@ pub fn NewWebSocketClient(comptime ssl: bool) type {
}
pub fn clearData(this: *WebSocket) void {
+ this.poll_ref.unref(this.globalThis.bunVM());
this.clearReceiveBuffers(true);
this.clearSendBuffers(true);
this.ping_len = 0;
@@ -1371,6 +1372,7 @@ pub fn NewWebSocketClient(comptime ssl: bool) type {
fn dispatchClose(this: *WebSocket) void {
var out = this.outgoing_websocket orelse return;
+ this.poll_ref.unref(this.globalThis.bunVM());
JSC.markBinding();
WebSocket__didCloseWithErrorCode(out, ErrorCode.closed);
}
@@ -1459,8 +1461,6 @@ pub fn NewWebSocketClient(comptime ssl: bool) type {
pub fn finalize(this: *WebSocket) callconv(.C) void {
this.clearData();
- this.poll_ref.unref(this.globalThis.bunVM());
-
this.outgoing_websocket = null;
if (this.tcp.isClosed())