Mirrors/libwebsockets
1
0
Fork 0
mirror of https://github.com/warmcat/libwebsockets.git synced 2025-03-16 00:00:07 +01:00
Code Issues Releases Wiki Activity

Make sure every handle is closed before destroying the uv loop

Browse source
This commit is contained in:
Alex Hultman 2016-02-20 15:32:57 +01:00 • committed by Andy Green
parent f2ee57e734
commit a3a0792012
2 changed files with 20 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
changelog
View file

@ -1,6 +1,11 @@
Changelog Changelog
--------- ---------
Fixes
-----
1) libuv one-per-session valgrind leak fixed
v1.7.1 v1.7.1
====== ======

16
lib/libuv.c
View file

@ -115,6 +115,16 @@ lws_uv_initloop(struct lws_context *context, uv_loop_t *loop, uv_signal_cb cb,
return status; return status;
} }
void lws_uv_close_cb(uv_handle_t *handle)
{
}
void lws_uv_walk_cb(uv_handle_t *handle, void *arg)
{
uv_close(handle, lws_uv_close_cb);
}
void void
lws_libuv_destroyloop(struct lws_context *context, int tsi) lws_libuv_destroyloop(struct lws_context *context, int tsi)
{ {
@ -132,8 +142,12 @@ lws_libuv_destroyloop(struct lws_context *context, int tsi)
for (m = 0; m < ARRAY_SIZE(sigs); m++) for (m = 0; m < ARRAY_SIZE(sigs); m++)
uv_signal_stop(&pt->signals[m]); uv_signal_stop(&pt->signals[m]);
if (!pt->ev_loop_foreign) { if (!pt->ev_loop_foreign) {
uv_stop(pt->io_loop_uv);
uv_walk(pt->io_loop_uv, lws_uv_walk_cb, NULL);
while (uv_run(pt->io_loop_uv, UV_RUN_NOWAIT));
m = uv_loop_close(pt->io_loop_uv); m = uv_loop_close(pt->io_loop_uv);
lwsl_debug("%s: uv_loop_close: %d\n", __func__, m); if (m == UV_EBUSY)
lwsl_debug("%s: uv_loop_close: UV_EBUSY\n", __func__);
lws_free(pt->io_loop_uv); lws_free(pt->io_loop_uv);
} }
} }