Commit e5501263 by Solo Group

update forwarder

1 parent 7439c77e
...@@ -298,10 +298,8 @@ class Parser(Log): ...@@ -298,10 +298,8 @@ class Parser(Log):
def run(self): def run(self):
from_iso = self.connection.job.raw_to_iso(self.raw) from_iso = self.connection.job.raw_to_iso(self.raw)
print("RUN from_iso", from_iso)
self.log_decode(from_iso) self.log_decode(from_iso)
iso = self.connection.job.process(from_iso) iso = self.connection.job.process(from_iso)
print("RUN iso", iso)
if iso: if iso:
self.log_encode(iso) self.log_encode(iso)
...@@ -416,7 +414,6 @@ def web_job(conn, iso): ...@@ -416,7 +414,6 @@ def web_job(conn, iso):
if ip_port not in web_response: if ip_port not in web_response:
continue continue
result = web_response[ip_port] result = web_response[ip_port]
print("Win Job", result)
if stan in result: if stan in result:
iso = result[stan] iso = result[stan]
del result[stan] del result[stan]
...@@ -527,6 +524,7 @@ def usage(argv): ...@@ -527,6 +524,7 @@ def usage(argv):
def check_connection(): def check_connection():
log_info("Check Connection")
for ip_port in ip_conf: for ip_port in ip_conf:
if ip_port in conn_mgr: if ip_port in conn_mgr:
index = -1 index = -1
...@@ -550,6 +548,7 @@ def check_connection(): ...@@ -550,6 +548,7 @@ def check_connection():
def check_job(): def check_job():
log_info("Check Job")
for ip_port, connection in conn_mgr: for ip_port, connection in conn_mgr:
if not connection.running: if not connection.running:
continue continue
...@@ -571,6 +570,7 @@ def check_job(): ...@@ -571,6 +570,7 @@ def check_job():
def check_parser(): def check_parser():
log_info("Check Parser")
i = -1 i = -1
while True: while True:
i += 1 i += 1
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!