From 82a074bdf9b1985204888cf66b05ef5e317c2173 Mon Sep 17 00:00:00 2001 From: Stefan Machmeier Date: Tue, 30 Jan 2024 13:40:45 +0100 Subject: [PATCH] Another fix of memory leak --- heidpi/heiDPI_logger.py | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/heidpi/heiDPI_logger.py b/heidpi/heiDPI_logger.py index e308ab1..a86a3d9 100644 --- a/heidpi/heiDPI_logger.py +++ b/heidpi/heiDPI_logger.py @@ -37,29 +37,25 @@ def get_timestamp(): def heidpi_process_packet_events(json_dict, instance, current_flow, global_user_data): future = [POOL_PACKET.submit(heidpi_log_event, PACKET_CONFIG, json_dict, SHOW_PACKET_EVENTS, "packet_event_id", "packet_event_name", None)] - done, _ = wait(future, return_when=ALL_COMPLETED) - del done, future + _, _ = wait(future, return_when=ALL_COMPLETED) gc.collect() return True def heidpi_process_flow_events(json_dict, instance, current_flow, global_user_data): future = [POOL_FLOW.submit(heidpi_log_event, FLOW_CONFIG, json_dict, SHOW_FLOW_EVENTS, "flow_event_id", "flow_event_name", heidpi_flow_processing)] - done, _ = wait(future, return_when=ALL_COMPLETED) - del done, future + _, _ = wait(future, return_when=ALL_COMPLETED) gc.collect() return True def heidpi_process_daemon_events(json_dict, instance, current_flow, global_user_data): future = [POOL_DAEMON.submit(heidpi_log_event, DAEMON_CONFIG, json_dict, SHOW_DAEMON_EVENTS, "daemon_event_id", "daemon_event_name", None)] - done, _ = wait(future, return_when=ALL_COMPLETED) - del done, future + _, _ = wait(future, return_when=ALL_COMPLETED) gc.collect() return True def heidpi_process_error_events(json_dict, instance, current_flow, global_user_data): future = [POOL_ERROR.submit(heidpi_log_event, ERROR_CONFIG, json_dict, SHOW_ERROR_EVENTS, "error_event_id", "error_event_name", None)] - done, _ = wait(future, return_when=ALL_COMPLETED) - del done, future + _, _ = wait(future, return_when=ALL_COMPLETED) gc.collect() return True