webadmin/bpfire
1
0
Fork 0
mirror of https://github.com/vincentmli/bpfire.git synced 2026-05-11 09:48:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

unbound-dhcp-leases-bridge: Store all messages in a queue

Browse Source 
Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
This commit is contained in:
Michael Tremer
2024-05-10 16:32:07 +01:00
parent e4cc1eefd5
commit d9348a16f1
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
config/unbound/unbound-dhcp-leases-bridge
View File

@@ -28,6 +28,7 @@ import ipaddress
import logging import logging
import logging.handlers import logging.handlers
import os import os
import queue
import re import re
import signal import signal
import socket import socket
@@ -87,6 +88,9 @@ class UnboundDHCPLeasesBridge(object):
self.socket = None self.socket = None
# Create a queue for all received events
self.queue = queue.Queue()
self.unbound = UnboundConfigWriter(unbound_leases_file) self.unbound = UnboundConfigWriter(unbound_leases_file)
# Load all required data # Load all required data
@@ -120,7 +124,8 @@ class UnboundDHCPLeasesBridge(object):
for key in message: for key in message:
log.debug(" %-20s = %s" % (key, message[key])) log.debug(" %-20s = %s" % (key, message[key]))
# TODO # Add the message to the queue
self.queue.put(message)
conn.send(b"OK\n") conn.send(b"OK\n")