This commit is contained in:
wuaho 2021-05-11 16:04:31 +08:00
parent 9d2fa9ab6f
commit f55dbdc134

5
app.py
View File

@ -3,6 +3,7 @@ from multiprocessing import Process
from settings import settings from settings import settings
from v2 import * from v2 import *
from v2.struct_cache import StructCacheFile
class XProcess(Process): class XProcess(Process):
@ -15,8 +16,8 @@ class XProcess(Process):
def run(self): def run(self):
db_client = CK(**settings.CK_CONFIG) db_client = CK(**settings.CK_CONFIG)
sketch = Sketch(db_client) sketch = Sketch(db_client, StructCacheFile())
handler_event = HandlerEvent(db_client, settings.GAME,self.ipsearch) handler_event = HandlerEvent(db_client, settings.GAME, self.ipsearch)
handler_user = HandlerUser(db_client, settings.GAME) handler_user = HandlerUser(db_client, settings.GAME)
transmitter = Transmitter(db_client, settings.GAME, sketch, self.lock) transmitter = Transmitter(db_client, settings.GAME, sketch, self.lock)
transmitter.add_source(handler_event, 10000, 60) transmitter.add_source(handler_event, 10000, 60)