7ea411b923
git-svn-id: svn://svn.cy55.de/Zope3/src/loops/trunk@1858 fd906abe-77d9-0310-91a1-e0d9ade77398
64 lines
1.5 KiB
Python
Executable file
64 lines
1.5 KiB
Python
Executable file
#! /usr/bin/env python
|
|
#
|
|
# Run with ``trial2.4 tests.py`` to execute the twisted unit tests.
|
|
# Run with ``python tests.py`` to execute the doctests.
|
|
#
|
|
|
|
# $Id$
|
|
|
|
import unittest as standard_unittest
|
|
import doctest
|
|
import time
|
|
from twisted.internet import reactor
|
|
from twisted.internet.defer import Deferred
|
|
from twisted.trial import unittest
|
|
|
|
from loops.agent.core import Agent
|
|
from loops.agent.schedule import Job
|
|
|
|
|
|
class Tester(object):
|
|
|
|
def iterate(self, n=10, delays={}):
|
|
for i in range(n):
|
|
delay = delays.get(i, 0)
|
|
reactor.iterate(delay)
|
|
|
|
tester = Tester()
|
|
|
|
|
|
class TestJob(Job):
|
|
|
|
def execute(self, deferred, **kw):
|
|
d = super(TestJob, self).execute(**kw)
|
|
#print 'executing'
|
|
deferred.callback('Done')
|
|
return d
|
|
|
|
|
|
class Test(unittest.TestCase):
|
|
"Basic tests for the loops.agent package."
|
|
|
|
def setUp(self):
|
|
self.agent = Agent()
|
|
|
|
def tearDown(self):
|
|
pass
|
|
|
|
def testScheduling(self):
|
|
d = Deferred()
|
|
job = TestJob()
|
|
job.params['deferred'] = d
|
|
w = self.agent.scheduler.schedule(job, int(time.time())+1)
|
|
return d
|
|
|
|
|
|
def test_suite():
|
|
flags = doctest.NORMALIZE_WHITESPACE | doctest.ELLIPSIS
|
|
return standard_unittest.TestSuite((
|
|
#standard_unittest.makeSuite(Test),
|
|
doctest.DocFileSuite('README.txt', optionflags=flags),
|
|
))
|
|
|
|
if __name__ == '__main__':
|
|
standard_unittest.main(defaultTest='test_suite')
|