Update asyncio library by terryluan12 · Pull Request #6601 · RustPython/RustPython

def test_rapid_restart(self):
    failing_test = "WithManagerTestManagerRestart"   # RUSTPYTHON
    rustpython_errors = False                        # RUSTPYTHON
    try:                                             # RUSTPYTHON
        authkey = os.urandom(32)
        manager = QueueManager(
            address=(socket_helper.HOST, 0), authkey=authkey,
            serializer=SERIALIZER, shutdown_timeout=SHUTDOWN_TIMEOUT)
        try:
            srvr = manager.get_server()
            addr = srvr.address
            # Close the connection.Listener socket which gets opened as a part
            # of manager.get_server(). It's not needed for the test.
            srvr.listener.close()
            manager.start()

            p = self.Process(target=self._putter, args=(manager.address, authkey))
            p.start()
            p.join()
            queue = manager.get_queue()
            self.assertEqual(queue.get(), 'hello world')
            del queue
        finally:
            if hasattr(manager, "shutdown"):
                manager.shutdown()

        manager = QueueManager(
            address=addr, authkey=authkey, serializer=SERIALIZER,
            shutdown_timeout=SHUTDOWN_TIMEOUT)
        try:
            manager.start()
            self.addCleanup(manager.shutdown)
        except OSError as e:
            if e.errno != errno.EADDRINUSE:
                raise
            # Retry after some time, in case the old socket was lingering
            # (sporadic failure on buildbots)
            time.sleep(1.0)
            manager = QueueManager(
                address=addr, authkey=authkey, serializer=SERIALIZER,
                shutdown_timeout=SHUTDOWN_TIMEOUT)
            if hasattr(manager, "shutdown"):
                self.addCleanup(manager.shutdown)
    except Exception as e:                           # RUSTPYTHON
        if self.__class__.__name__ != failing_test:  # RUSTPYTHON
            raise                                    # RUSTPYTHON
    else:                                            # RUSTPYTHON
        if self.__class__.__name__ == failing_test:  # RUSTPYTHON
            raise                                    # RUSTPYTHON