Max/LorenEteval_Furious
1
0
Fork 0
mirror of https://github.com/LorenEteval/Furious.git synced 2026-10-12 09:18:26 +03:00
Code Issues Packages Projects Releases Wiki Activity

Rename msg produce threshold param name

Browse Source 
Signed-off-by: Loren Eteval <loren.eteval@proton.me>
This commit is contained in:
Loren Eteval
2024-02-27 20:14:49 +08:00
parent ff4f20a590
commit a63a38be13
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Furious/Core/XrayCore.py
+1 -1
View File
@@ -101,7 +101,7 @@ def startXrayCore(jsonString: str, msgQueue: multiprocessing.Queue):
pass
time.sleep(CoreProcess.MESG_PRODUCE_THRESHOLD / 1000)
time.sleep(CoreProcess.MSG_PRODUCE_THRESHOLD / 1000)
try:
if fileStreams:
Furious/QtFramework/CoreProcess.py
+3 -3
View File
@@ -39,7 +39,7 @@ logger = logging.getLogger(__name__)
class CoreProcess(CoreFactory, ABC):
MESG_PRODUCE_THRESHOLD = 250
MSG_PRODUCE_THRESHOLD = 250
def __init__(self, **kwargs):
exitCallback = kwargs.pop('exitCallback', None)
@@ -115,7 +115,7 @@ class CoreProcess(CoreFactory, ABC):
logger.info(f'{self.name()} {self.version()} started')
self._msgTimer.start(self.MESG_PRODUCE_THRESHOLD)
self._msgTimer.start(self.MSG_PRODUCE_THRESHOLD)
if waitCore:
# Wait for the core to start up completely
@@ -198,7 +198,7 @@ class StdoutRedirectHelper:
pass
time.sleep(CoreProcess.MESG_PRODUCE_THRESHOLD / 1000)
time.sleep(CoreProcess.MSG_PRODUCE_THRESHOLD / 1000)
msgThread = threading.Thread(target=produceMsg, daemon=True)
msgThread.start()