Skip to content
Snippets Groups Projects
Commit 9739482f authored by Paul McCarthy's avatar Paul McCarthy :mountain_bicyclist:
Browse files

Async unit tests are now idle unit tests

parent 8b7f2cfa
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing
with 46 additions and 46 deletions
tests/test_async.py → tests/test_idle.py
+ 46
− 46
View file @ 9739482f
#!/usr/bin/env python
#
# test_async.py -
# test_idle.py -
#
# Author: Paul McCarthy <pauldmccarthy@gmail.com>
#
......@@ -14,12 +14,12 @@ from six.moves import reload_module
import pytest
import mock
import fsl.utils.async as async
import fsl.utils.idle as idle
from fsl.utils.platform import platform as fslplatform
# We use a single wx.App object because wx.GetApp()
# will still return an old App objectd after its
# mainloop has exited. and therefore async.idle
# mainloop has exited. and therefore idle.idle
# will potentially register on EVT_IDLE with the
# wrong wx.App object.
_wxapp = None
......@@ -65,7 +65,7 @@ def _run_with_wx(func, *args, **kwargs):
wx.CallLater(startingDelay, wrap)
_wxapp.MainLoop()
async.idleReset()
idle.idleReset()
if raised[0] and propagateRaise:
raise raised[0]
......@@ -82,7 +82,7 @@ def _wait_for_idle_loop_to_clear():
def busywait():
idleDone[0] = True
async.idle(busywait)
idle.idle(busywait)
while not idleDone[0]:
wx.Yield()
......@@ -109,7 +109,7 @@ def _test_run():
def onError(e):
onErrorCalled[0] = True
t = async.run(task)
t = idle.run(task)
if t is not None:
t.join()
......@@ -118,7 +118,7 @@ def _test_run():
taskRun[0] = False
t = async.run(task, onFinish, onError)
t = idle.run(task, onFinish, onError)
if t is not None:
t.join()
......@@ -128,7 +128,7 @@ def _test_run():
taskRun[ 0] = False
onFinishCalled[0] = False
t = async.run(errtask, onFinish, onError)
t = idle.run(errtask, onFinish, onError)
if t is not None:
t.join()
......@@ -141,12 +141,12 @@ def _test_run():
def test_idleTimeout():
async.idleReset()
default = async.getIdleTimeout()
async.setIdleTimeout(999)
assert async.getIdleTimeout() == 999
async.setIdleTimeout()
assert async.getIdleTimeout() == default
idle.idleReset()
default = idle.getIdleTimeout()
idle.setIdleTimeout(999)
assert idle.getIdleTimeout() == 999
idle.setIdleTimeout()
assert idle.getIdleTimeout() == default
def test_idle():
......@@ -159,24 +159,24 @@ def test_idle():
def errtask(arg, kwarg1=None):
raise Exception('Task which was supposed to crash crashed!')
assert async.getIdleTimeout() > 0
assert idle.getIdleTimeout() > 0
# Run directly
async.idle(task, 1, kwarg1=2, name='direct')
idle.idle(task, 1, kwarg1=2, name='direct')
assert called[0]
called[0] = False
# Run on wx idle loop
_run_with_wx(async.idle, task, 1, kwarg1=2)
_run_with_wx(idle.idle, task, 1, kwarg1=2)
assert called[0]
# Run a crashing task directly
with pytest.raises(Exception):
async.idle(errtask, 1, kwarg1=2)
idle.idle(errtask, 1, kwarg1=2)
# Run a crashing task on idle loop - error should not propagate
_run_with_wx(async.idle, errtask, 1, kwarg1=2)
_run_with_wx(idle.idle, errtask, 1, kwarg1=2)
def test_inidle():
......@@ -189,8 +189,8 @@ def test_inidle():
def queuetask():
async.idle(task, after=0.01, name=name)
assert async.inIdle(name)
idle.idle(task, after=0.01, name=name)
assert idle.inIdle(name)
_run_with_wx(queuetask)
......@@ -207,8 +207,8 @@ def test_cancelidle():
def queuetask():
async.idle(task, after=0.01, name=name)
async.cancelIdle(name)
idle.idle(task, after=0.01, name=name)
idle.cancelIdle(name)
_run_with_wx(queuetask)
......@@ -229,8 +229,8 @@ def test_idle_skipIfQueued():
def queuetask():
async.idle(task1, after=0.01, name=name)
async.idle(task2, after=0.01, name=name, skipIfQueued=True)
idle.idle(task1, after=0.01, name=name)
idle.idle(task2, after=0.01, name=name, skipIfQueued=True)
_run_with_wx(queuetask)
......@@ -252,8 +252,8 @@ def test_idle_dropIfQueued():
def queuetask():
async.idle(task1, after=0.01, name=name)
async.idle(task2, after=0.01, name=name, dropIfQueued=True)
idle.idle(task1, after=0.01, name=name)
idle.idle(task2, after=0.01, name=name, dropIfQueued=True)
_run_with_wx(queuetask)
......@@ -279,10 +279,10 @@ def test_idle_alwaysQueue1():
# The task should be run
# when the mainloop starts
async.idle(task, alwaysQueue=True)
idle.idle(task, alwaysQueue=True)
# Second call to async.idle
_run_with_wx(async.idle, nop)
# Second call to idle.idle
_run_with_wx(idle.idle, nop)
assert called[0]
......@@ -299,7 +299,7 @@ def test_idle_alwaysQueue2():
called[0] = True
def queue():
async.idle(task, alwaysQueue=True)
idle.idle(task, alwaysQueue=True)
_run_with_wx(None, callAfterApp=queue)
......@@ -321,7 +321,7 @@ def test_idle_alwaysQueue3():
def task():
called[0] = True
_run_with_wx(async.idle, task, alwaysQueue=True)
_run_with_wx(idle.idle, task, alwaysQueue=True)
assert called[0]
......@@ -339,11 +339,11 @@ def test_idle_alwaysQueue4():
import fsl.utils.platform
with mock.patch.dict('sys.modules', {'wx' : None}):
# async uses the platform module to
# idle uses the platform module to
# determine whether a GUI is available,
# so we have to reload it
reload_module(fsl.utils.platform)
async.idle(task, alwaysQueue=True)
idle.idle(task, alwaysQueue=True)
with pytest.raises(ImportError):
import wx
......@@ -360,7 +360,7 @@ def test_idle_timeout():
def task():
called[0] = True
_run_with_wx(async.idle, task, timeout=0.0000000000000001)
_run_with_wx(idle.idle, task, timeout=0.0000000000000001)
assert not called[0]
......@@ -378,9 +378,9 @@ def test_idleWhen():
def task():
called[0] = True
async.setIdleTimeout(1)
idle.setIdleTimeout(1)
_run_with_wx(async.idleWhen, task, condition, pollTime=0.001)
_run_with_wx(idle.idleWhen, task, condition, pollTime=0.001)
assert called[0]
assert timesPolled[0] == 50
......@@ -409,7 +409,7 @@ def _test_wait():
for t in threads:
t.start()
t = async.wait(threads, waittask, wait_direct=wait_direct)
t = idle.wait(threads, waittask, wait_direct=wait_direct)
if t is not None:
t.join()
......@@ -427,7 +427,7 @@ def test_TaskThread():
def task():
called[0] = True
tt = async.TaskThread()
tt = idle.TaskThread()
tt.start()
tt.enqueue(task)
......@@ -451,7 +451,7 @@ def test_TaskThread_onFinish():
def onFinish():
onFinishCalled[0] = True
tt = async.TaskThread()
tt = idle.TaskThread()
tt.start()
tt.enqueue(task, onFinish=onFinish)
......@@ -475,7 +475,7 @@ def test_TaskThread_isQueued():
def realTask():
called[0] = True
tt = async.TaskThread()
tt = idle.TaskThread()
tt.start()
tt.enqueue(busyTask)
......@@ -504,7 +504,7 @@ def test_TaskThread_dequeue():
def realTask():
called[0] = True
tt = async.TaskThread()
tt = idle.TaskThread()
tt.start()
tt.enqueue(busyTask)
......@@ -529,12 +529,12 @@ def test_TaskThread_TaskVeto():
def task():
taskCalled[0] = True
raise async.TaskThreadVeto()
raise idle.TaskThreadVeto()
def onFinish():
onFinishCalled[0] = True
tt = async.TaskThread()
tt = idle.TaskThread()
tt.start()
tt.enqueue(task, onFinish=onFinish)
......@@ -553,13 +553,13 @@ def test_mutex():
class Thing(object):
@async.mutex
@idle.mutex
def method1(self):
self.method1start = time.time()
time.sleep(0.5)
self.method1end = time.time()
@async.mutex
@idle.mutex
def method2(self):
self.method2start = time.time()
time.sleep(0.5)
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment