def testSamePathLengthTenAndDiscardAndFinalAsk(self):
        nodoc = 1
        """This test pushes a large number of messages into the system and
           does not wait for them to be processed.  At the end, it
           asks for a response on a final message with a 30 second
           timeout.  Unreliable transports (e.g. UDP) will probably
           drop some messages under a high message count load and end
           up timing out.
        """
        nMessages = 2000
        actorDepth = 10

        aS = ActorSystem()
        actors = [aS.createActor(TestActor) for X in range(actorDepth)]
        for ii,actor in enumerate(actors):
            if actor is None or not actor:
                raise ValueError('Actor address %s is %s!'%(ii, actor))
        starttime = datetime.now()
        for X in range(nMessages):  # messages to send
            msg = TestMessage(actors[1:])
            msg.origSender = None
            aS.tell(actors[0], msg)

        msg = TestMessage(actors[1:])
        rmsg = aS.ask(actors[0], msg, 30)
        endtime = datetime.now()
        elapsed = starttime - endtime
        report('Discard, Last Ask (%s)'%(rmsg.sum if rmsg else '<timeout>'),
               self.name, elapsed,
               nMessages, actorDepth)
        [aS.tell(A, ActorExitRequest()) for A in actors]
dataset/ETHPy150Open godaddy/Thespian/thespian/test/testLoad.py/LoadTester.testSamePathLengthTenAndDiscardAndFinalAsk/swapped operands of `-`