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

Improve logical spacing in profile testing

Browse Source 
Signed-off-by: Loren Eteval <loren.eteval@proton.me>
This commit is contained in:
Loren Eteval
2026-09-19 21:09:55 +08:00
parent e3fc1469bf
commit 213613f9b2
2 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Furious/Service/ProfileTesting.py
+2
View File
@@ -531,6 +531,7 @@ class _LatencyScheduler(QtCore.QObject):
continue
job.state = ProfileTestJobState.Running
worker = self.pingWorkerFactory(job, self)
self.activeJobs[id(job)] = (job, worker)
@@ -1269,6 +1270,7 @@ class _DownloadSpeedScheduler(QtCore.QObject):
return
_, job, port = active
lease = worker.takeRuntimeLease()
# Completion may notify reentrant consumers. Establish the durable
tests/test_profile_test_jobs.py
+10
View File
@@ -428,6 +428,7 @@ class ProfileTestServiceTest(unittest.TestCase):
self.assertEqual(runtime.isRunning(), failure == 'stop')
runtime.failure = None
worker._releaseRuntime()
self.assertIsNone(worker._runtimeLease)
@@ -446,16 +447,19 @@ class ProfileTestServiceTest(unittest.TestCase):
if concurrent
else manager._serialDownloadScheduler
)
results = []
manager.resultApplied.connect(
lambda _profile, result: results.append(result)
)
manager.testDownloadSpeed(profiles, concurrent=concurrent)
processQtEvents()
worker, runtime = workers[0], runtimes[0]
port = worker.port
lease = worker._runtimeLease
destroyed = []
worker.destroyed.connect(lambda: destroyed.append(True))
results.clear()
@@ -479,9 +483,11 @@ class ProfileTestServiceTest(unittest.TestCase):
runtime.publishExit(RuntimeExit(1, RuntimeExitReason.Unexpected))
processQtEvents()
self.assertEqual(len(results), 1)
runtime.failure = None
scheduler.scheduleDrain()
processQtEvents()
@@ -500,7 +506,9 @@ class ProfileTestServiceTest(unittest.TestCase):
manager.testDownloadSpeed(profiles[:1], concurrent=False)
manager.testDownloadSpeed(profiles[1:], concurrent=True)
processQtEvents()
self.assertEqual(len(workers), 2)
runtimes[1].failure = None
with self.assertLogs('Furious.Service.RuntimeLease', level='ERROR'):
@@ -516,9 +524,11 @@ class ProfileTestServiceTest(unittest.TestCase):
manager.testDownloadSpeed(profiles)
processQtEvents()
self.assertEqual(len(workers), 2)
runtimes[0].failure = None
manager.shutdown()
processQtEvents()