cory/tildefriends
4
5
Fork 1
Code Issues 32 Pull Requests 1 Actions Releases 26 Wiki Activity

Another leak.

Browse Source 
git-svn-id: https://www.unprompted.com/svn/projects/tildefriends/trunk@3913 ed5197a5-7fde-0310-b194-c3ffbd925b24
This commit is contained in:
Cory McWilliams 2022-06-20 14:30:00 +00:00
parent 515999e570
commit b5c6cac048
2 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
core/httpd.js
View File

@ -237,7 +237,12 @@ function handleWebSocketRequest(request, response, client) {
var array = new Uint8Array(packet.length + message.length); var array = new Uint8Array(packet.length + message.length);
array.set(packet, 0); array.set(packet, 0);
array.set(message, packet.length); array.set(message, packet.length);
return client.write(array); try {
return client.write(array);
} catch (error) {
client.close();
throw error;
}
} }
response.onMessage = null; response.onMessage = null;

10
src/socket.js.c
View File

@ -891,13 +891,19 @@ int _socket_writeInternal(socket_t* socket, promiseid_t promise, const char* dat
uv_write_t* request = (uv_write_t*)rawBuffer; uv_write_t* request = (uv_write_t*)rawBuffer;
memcpy(rawBuffer + sizeof(uv_write_t), data, length); memcpy(rawBuffer + sizeof(uv_write_t), data, length);
uv_buf_t buffer = { uv_buf_t buffer =
{
.base = rawBuffer + sizeof(uv_write_t), .base = rawBuffer + sizeof(uv_write_t),
.len = length, .len = length,
}; };
request->data = (void*)(intptr_t)promise; request->data = (void*)(intptr_t)promise;
return uv_write(request, (uv_stream_t*)&socket->_socket, &buffer, 1, _socket_onWrite); int result = uv_write(request, (uv_stream_t*)&socket->_socket, &buffer, 1, _socket_onWrite);
if (result != 0)
{
tf_free(rawBuffer);
}
return result;
} }
static int _socket_write_tls(socket_t* socket, promiseid_t promise, const char* data, size_t size) static int _socket_write_tls(socket_t* socket, promiseid_t promise, const char* data, size_t size)