diff --git a/src/worker.c b/src/worker.c index 72a8f36..8efca06 100644 --- a/src/worker.c +++ b/src/worker.c @@ -367,6 +367,7 @@ void worker_free(worker *wrk) { guint i; for (i = 0; i < wrk->timestamps->len; i++) g_string_free(g_array_index(wrk->timestamps, worker_ts, i).str, TRUE); + g_array_free(wrk->timestamps, TRUE); } g_async_queue_unref(wrk->new_con_queue); @@ -379,6 +380,8 @@ void worker_free(worker *wrk) { collect_watcher_cb(wrk->loop, &wrk->collect_watcher, 0); g_async_queue_unref(wrk->collect_queue); + g_string_free(wrk->tmp_str, TRUE); + g_slice_free(worker, wrk); }