diff --git a/scalyr_agent/builtin_monitors/syslog_monitor.py b/scalyr_agent/builtin_monitors/syslog_monitor.py index 141de7f86..0fc3253c2 100644 --- a/scalyr_agent/builtin_monitors/syslog_monitor.py +++ b/scalyr_agent/builtin_monitors/syslog_monitor.py @@ -632,6 +632,12 @@ def read(self): try: data = self._socket.recv(self._max_buffer_size) + + global_log.log( + scalyr_logging.DEBUG_LEVEL_5, + f"Syslog Monitor - Received data from {self._socket}: {data}" + ) + if not data: self.is_closed = True raise SocketClosed() @@ -1102,6 +1108,10 @@ def __init__(self, port, bind_address, verifier, global_config=None): six.moves.socketserver.UDPServer.__init__(self, address, SyslogUDPHandler) def verify_request(self, request, client_address): + global_log.log( + scalyr_logging.DEBUG_LEVEL_5, + f"Syslog Monitor - Incoming UDP request from {client_address}: {request}" + ) return self.__verifier.verify_request(client_address) def set_run_state(self, run_state): @@ -1152,6 +1162,10 @@ def __init__( six.moves.socketserver.TCPServer.__init__(self, address, handler_cls) def verify_request(self, request, client_address): + global_log.log( + scalyr_logging.DEBUG_LEVEL_5, + f"Syslog Monitor - Incoming TCP request from {client_address}: {request}" + ) return self.__verifier.verify_request(client_address) def set_run_state(self, run_state):