From 2f214c38876a71ec2d4b3401cb9a4b78f487be64 Mon Sep 17 00:00:00 2001 From: alya Date: Tue, 28 Jan 2025 00:10:48 +0200 Subject: [PATCH] dns: wait forever for msgs in queues, dont use a timeout --- modules/flowalerts/dns.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/modules/flowalerts/dns.py b/modules/flowalerts/dns.py index 724858b0c..56db8fab2 100644 --- a/modules/flowalerts/dns.py +++ b/modules/flowalerts/dns.py @@ -264,16 +264,14 @@ def check_dns_without_connection_of_all_pending_flows(self): flows in the pending_dns_without_conn queue before stopping slips, doesnt matter if the 30 mins passed or not""" while self.pending_dns_without_conn.qsize() > 0: - profileid, twid, pending_flow = self.pending_dns_without_conn.get( - timeout=4 - ) + profileid, twid, pending_flow = self.pending_dns_without_conn.get() self.check_dns_without_connection( profileid, twid, pending_flow, waited_for_the_conn=True ) def get_dns_flow_from_queue(self): """Fetch and parse the DNS message from the dns_msgs queue.""" - msg: str = self.dns_msgs.get(timeout=4) + msg: str = self.dns_msgs.get() msg: dict = json.loads(msg["data"]) flow = self.classifier.convert_to_flow_obj(msg["flow"]) return flow