|
|
@ -15,6 +15,7 @@ class SyslogServer: |
|
|
|
self.port = port |
|
|
|
self.port = port |
|
|
|
self.server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) |
|
|
|
self.server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) |
|
|
|
self.server.bind((self.host, self.port)) |
|
|
|
self.server.bind((self.host, self.port)) |
|
|
|
|
|
|
|
self.server.settimeout(0.5) # Set timeout to allow checking self.running |
|
|
|
self.start_time = None |
|
|
|
self.start_time = None |
|
|
|
self.running = True |
|
|
|
self.running = True |
|
|
|
|
|
|
|
|
|
|
@ -28,6 +29,8 @@ class SyslogServer: |
|
|
|
try: |
|
|
|
try: |
|
|
|
data, address = self.server.recvfrom(1024) |
|
|
|
data, address = self.server.recvfrom(1024) |
|
|
|
self.handle_message(data) |
|
|
|
self.handle_message(data) |
|
|
|
|
|
|
|
except socket.timeout: |
|
|
|
|
|
|
|
continue # Check self.running again |
|
|
|
except KeyboardInterrupt: |
|
|
|
except KeyboardInterrupt: |
|
|
|
self.running = False |
|
|
|
self.running = False |
|
|
|
|
|
|
|
|
|
|
|