---

test_factories.py

# Copyright (c) Twisted Matrix Laboratories. # See LICENSE for details. """ Test code for basic Factory classes. """ import pickle from twisted.internet.protocol import Protocol, ReconnectingClientFactory from twisted.internet.task import Clock from twisted.trial.unittest import TestCase class FakeConnector: """ A fake connector class, to be used to mock connections failed or lost. """ def stopConnecting(self): pass def connect(self): pass class ReconnectingFactoryTests(TestCase): """ Tests for L{ReconnectingClientFactory}. """ def test_stopTryingWhenConnected(self): """ If a L{ReconnectingClientFactory} has C{stopTrying} called while it is connected, it does not subsequently attempt to reconnect if the connection is later lost. """ class NoConnectConnector: def stopConnecting(self): raise RuntimeError("Shouldn't be called, we're connected.") def connect(self): raise RuntimeError("Shouldn't be reconnecting.") c = ReconnectingClientFactory() c.protocol = Protocol # Let's pretend we've connected: c.buildProtocol(None) # Now we stop trying, then disconnect: c.stopTrying() c.clientConnectionLost(NoConnectConnector(), None) self.assertFalse(c.continueTrying) def test_stopTryingDoesNotReconnect(self): """ Calling stopTrying on a L{ReconnectingClientFactory} doesn't attempt a retry on any active connector. """ class FactoryAwareFakeConnector(FakeConnector): attemptedRetry = False def stopConnecting(self): """ Behave as though an ongoing connection attempt has now failed, and notify the factory of this. """ f.clientConnectionFailed(self, None) def connect(self): """ Record an attempt to reconnect, since this is what we are trying to avoid. """ self.attemptedRetry = True f = ReconnectingClientFactory() f.clock = Clock() # simulate an active connection - stopConnecting on this connector should # be triggered when we call stopTrying f.connector = FactoryAwareFakeConnector() f.stopTrying() # make sure we never attempted to retry self.assertFalse(f.connector.attemptedRetry) self.assertFalse(f.clock.getDelayedCalls()) def test_serializeUnused(self): """ A L{ReconnectingClientFactory} which hasn't been used for anything can be pickled and unpickled and end up with the same state. """ original = ReconnectingClientFactory() reconstituted = pickle.loads(pickle.dumps(original)) self.assertEqual(original.__dict__, reconstituted.__dict__) def test_serializeWithClock(self): """ The clock attribute of L{ReconnectingClientFactory} is not serialized, and the restored value sets it to the default value, the reactor. """ clock = Clock() original = ReconnectingClientFactory() original.clock = clock reconstituted = pickle.loads(pickle.dumps(original)) self.assertIsNone(reconstituted.clock) def test_deserializationResetsParameters(self): """ A L{ReconnectingClientFactory} which is unpickled does not have an L{IConnector} and has its reconnecting timing parameters reset to their initial values. """ factory = ReconnectingClientFactory() factory.clientConnectionFailed(FakeConnector(), None) self.addCleanup(factory.stopTrying) serialized = pickle.dumps(factory) unserialized = pickle.loads(serialized) self.assertIsNone(unserialized.connector) self.assertIsNone(unserialized._callID) self.assertEqual(unserialized.retries, 0) self.assertEqual(unserialized.delay, factory.initialDelay) self.assertTrue(unserialized.continueTrying) def test_parametrizedClock(self): """ The clock used by L{ReconnectingClientFactory} can be parametrized, so that one can cleanly test reconnections. """ clock = Clock() factory = ReconnectingClientFactory() factory.clock = clock factory.clientConnectionLost(FakeConnector(), None) self.assertEqual(len(clock.calls), 1)

---

docroot: /var/www/469ed2f6-4d4b-4a8a-9f5e-ee4ef04d3bc8/public_html

---

curdir: /usr/lib/python3/dist-packages/twisted/test

	.		20480
	..		4096
X	__init__.py		475
	__pycache__		4096
X	cert.pem.no_trailing_newline		1496
X	crash_test_dummy.py		654
X	ignore_test_failure.py		35722
X	iosim.py		18839
X	key.pem.no_trailing_newline		1674
X	mock_win32process.py		1275
X	myrebuilder1.py		172
X	myrebuilder2.py		172
X	plugin_basic.py		925
X	plugin_extra1.py		400
X	plugin_extra2.py		566
X	process_cmdline.py		123
X	process_echoer.py		214
X	process_fds.py		983
X	process_getargv.py		233
X	process_getenv.py		268
X	process_linger.py		297
X	process_reader.py		178
X	process_signal.py		220
X	process_stdinreader.py		739
X	process_tester.py		787
X	process_tty.py		130
X	process_twisted.py		1182
X	proto_helpers.py		1368
X	reflect_helper_IE.py		60
X	reflect_helper_VE.py		81
X	reflect_helper_ZDE.py		48
X	server.pem		5360
X	ssl_helpers.py		1766
X	stdio_test_consumer.py		1168
X	stdio_test_halfclose.py		2047
X	stdio_test_hostpeer.py		1089
X	stdio_test_lastwrite.py		1154
X	stdio_test_loseconn.py		1583
X	stdio_test_producer.py		1484
X	stdio_test_write.py		902
X	stdio_test_writeseq.py		894
X	test_abstract.py		3751
X	test_adbapi.py		26079
X	test_amp.py		110633
X	test_application.py		34138
X	test_compat.py		18172
X	test_context.py		1464
X	test_cooperator.py		21339
X	test_defer.py		146811
X	test_defgen.py		13327
X	test_dirdbm.py		7062
X	test_error.py		9835
X	test_factories.py		4567
X	test_fdesc.py		7452
X	test_finger.py		1932
X	test_formmethod.py		4374
X	test_ftp.py		130004
X	test_ftp_options.py		2712
X	test_htb.py		3262
X	test_ident.py		6716
X	test_internet.py		46468
X	test_iosim.py		9815
X	test_iutils.py		13632
X	test_lockfile.py		15910
X	test_log.py		37745
X	test_logfile.py		18216
X	test_loopback.py		14321
X	test_main.py		2166
X	test_memcache.py		25282
X	test_modules.py		18270
X	test_monkey.py		6535
X	test_paths.py		75410
X	test_pcp.py		12528
X	test_persisted.py		15087
X	test_plugin.py		26641
X	test_policies.py		33058
X	test_postfix.py		4425
X	test_process.py		88362
X	test_protocols.py		7334
X	test_randbytes.py		3718
X	test_rebuild.py		7578
X	test_reflect.py		24468
X	test_roots.py		1688
X	test_shortcut.py		1954
X	test_sip.py		25498
X	test_sob.py		5667
X	test_socks.py		17496
X	test_ssl.py		23272
X	test_sslverify.py		116569
X	test_stateful.py		2015
X	test_stdio.py		12729
X	test_strerror.py		5223
X	test_strports.py		1705
X	test_task.py		48871
X	test_tcp.py		65807
X	test_tcp_internals.py		13036
X	test_text.py		6623
X	test_threadable.py		3338
X	test_threadpool.py		22160
X	test_threads.py		13211
X	test_tpfile.py		1732
X	test_twistd.py		74020
X	test_twisted.py		6275
X	test_udp.py		27438
X	test_unix.py		13579
X	test_usage.py		23311
X	testutils.py		5178