From a63a38be13b327dd34c2ec09818f97e9f6977536 Mon Sep 17 00:00:00 2001 From: Loren Eteval Date: Tue, 27 Feb 2024 20:14:49 +0800 Subject: [PATCH] Rename msg produce threshold param name Signed-off-by: Loren Eteval --- Furious/Core/XrayCore.py | 2 +- Furious/QtFramework/CoreProcess.py | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/Furious/Core/XrayCore.py b/Furious/Core/XrayCore.py index f30df11a..7b81a592 100644 --- a/Furious/Core/XrayCore.py +++ b/Furious/Core/XrayCore.py @@ -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: diff --git a/Furious/QtFramework/CoreProcess.py b/Furious/QtFramework/CoreProcess.py index c12688b4..bbcebe4f 100644 --- a/Furious/QtFramework/CoreProcess.py +++ b/Furious/QtFramework/CoreProcess.py @@ -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()