def connect(self):
try:
+ if self.socket == None:
+ self.socket = socket(AF_UNIX)
self.socket.connect(self.sck_path)
except error as err:
raise SuricataNetException(err)
def close(self):
self.socket.close()
+ self.socket = None
def execute(self, command):
full_cmd = command.split()
# try to reconnect and resend command
print("Connection lost, trying to reconnect")
try:
+ self.close()
self.connect()
except SuricataNetException as err:
print("Can't reconnect to suricata socket, discarding command")