mirror of
https://github.com/FAUSheppy/skillbird
synced 2025-12-06 14:51:36 +01:00
32 lines
1.0 KiB
Python
32 lines
1.0 KiB
Python
import TrueSkillWrapper as TS
|
|
import time
|
|
import threading
|
|
import insurgencyParsing as iparse
|
|
|
|
def readfile(filename, start_at_end, exit_on_eof, parsingBackend, cpus=1):
|
|
|
|
f = open(filename)
|
|
if start_at_end:
|
|
f.seek(0,2)
|
|
|
|
try:
|
|
if cpus > 1:
|
|
raise NotImplementedError("Multiprocessing not implemeted yet")
|
|
else:
|
|
if callable(parsingBackend):
|
|
parsingBackend(f, exit_on_eof, start_at_end)
|
|
else:
|
|
parsingBackend.parse(f, exit_on_eof, start_at_end)
|
|
except TypeError:
|
|
raise RuntimeError("parsingBackend musst be callable or have .parse() callable")
|
|
|
|
f.close()
|
|
|
|
def readfiles(filenames, start_at_end=False, nofollow=False,parsingBackend=iparse, oneThread=False):
|
|
for f in filenames:
|
|
if oneThread:
|
|
readfile(f, start_at_end, nofollow, parsingBackend)
|
|
else:
|
|
threading.Thread(target=readfile,args=\
|
|
(f, start_at_end, nofollow, parsingBackend,)).start()
|