lucaspalomodevelop/core
1
0
Fork 0
mirror of https://github.com/lucaspalomodevelop/core.git synced 2026-03-14 08:34:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

firewall: cleanup previous

Browse Source
This commit is contained in:
Stephan de Wit 2024-10-18 15:49:51 +02:00
parent c6a828f46e
commit 77036e161c
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/opnsense/scripts/filter/read_log.py
View File

@ -181,9 +181,9 @@ if __name__ == '__main__':
line_threshold = 10
line_count = 0
throttle_interval = 100 # ms
counter = {}
start_t_ms = time.time() * 1000
try:
counter = {}
start_t_ms = (time.time() * 1000)
while True:
ready, _, _ = select.select([f.stdout], [], [], 1)
if not ready:
@ -199,8 +199,7 @@ if __name__ == '__main__':
running_conf_descr = fetch_rule_details()
rule = parse_record({'line': line}, running_conf_descr)
if rule != None:
if rule['rid'] != '0':
counter[rule['rid']] = counter.get(rule['rid'], 0) + 1
counter[rule['rid']] = counter.get(rule['rid'], 0) + 1
rule['counter'] = counter[rule['rid']]
line_count += 1
@ -209,7 +208,7 @@ if __name__ == '__main__':
print(f"event: message\ndata: {ujson.dumps(rule)}\n\n", flush=True)
elif elapsed >= throttle_interval:
line_count = 0
start_t_ms = (time.time() * 1000)
start_t_ms = time.time() * 1000
else:
break
except KeyboardInterrupt: