OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	03/31/2022 06:22:38 AM	rwxr-xr-x
📄 __init__.py	103 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📁 __pycache__	-	03/31/2022 06:22:39 AM	rwxr-xr-x
📄 cert.pem.no_trailing_newline	1.38 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 crash_test_dummy.py	543 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 iosim.py	17.3 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 key.pem.no_trailing_newline	1.67 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 mock_win32process.py	1.46 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 myrebuilder1.py	158 bytes	09/08/2017 10:38:35 AM	rw-r--r--
📄 myrebuilder2.py	158 bytes	09/08/2017 10:38:35 AM	rw-r--r--
📄 plugin_basic.py	943 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 plugin_extra1.py	407 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 plugin_extra2.py	579 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 process_cmdline.py	162 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 process_echoer.py	214 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 process_fds.py	945 bytes	09/08/2017 10:38:35 AM	rw-r--r--
📄 process_getargv.py	283 bytes	09/08/2017 10:38:35 AM	rw-r--r--
📄 process_getenv.py	268 bytes	09/08/2017 10:38:35 AM	rw-r--r--
📄 process_linger.py	286 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 process_reader.py	188 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 process_signal.py	214 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 process_stdinreader.py	857 bytes	09/08/2017 10:38:35 AM	rw-r--r--
📄 process_tester.py	1.01 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 process_tty.py	130 bytes	09/08/2017 10:38:35 AM	rw-r--r--
📄 process_twisted.py	1.18 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 proto_helpers.py	26.33 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 raiser.c	93.05 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 raiser.cpython-36m-x86_64-linux-gnu.so	19.16 KB	03/22/2022 11:03:56 AM	rw-r--r--
📄 raiser.pyx	466 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 reflect_helper_IE.py	61 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 reflect_helper_VE.py	82 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 reflect_helper_ZDE.py	47 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 server.pem	4.34 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 ssl_helpers.py	1.01 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 stdio_test_consumer.py	1.19 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 stdio_test_halfclose.py	1.89 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 stdio_test_hostpeer.py	1021 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 stdio_test_lastwrite.py	1.18 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 stdio_test_loseconn.py	1.51 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 stdio_test_producer.py	1.47 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 stdio_test_write.py	923 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 stdio_test_writeseq.py	915 bytes	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_abstract.py	3.42 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_adbapi.py	25.53 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_amp.py	107.96 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_application.py	32.05 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_compat.py	27.32 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_context.py	1.48 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_cooperator.py	20.96 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_defer.py	100.93 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_defgen.py	10.45 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_dict.py	1.41 KB	09/23/2017 05:52:22 AM	rw-r--r--
📄 test_dirdbm.py	6.76 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 test_error.py	8.39 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_factories.py	4.53 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_failure.py	29.92 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_fdesc.py	7.2 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_finger.py	1.95 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_formmethod.py	3.56 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_ftp.py	127.27 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_ftp_options.py	2.62 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_htb.py	3.12 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_ident.py	6.85 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_internet.py	45.33 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_iosim.py	8.49 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 test_iutils.py	13.13 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_lockfile.py	15.14 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_log.py	35.48 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_logfile.py	17.8 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_loopback.py	14.15 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_main.py	2.44 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 test_memcache.py	24.55 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_modules.py	17.47 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_monkey.py	5.5 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_nooldstyle.py	5.82 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 test_paths.py	72.61 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_pcp.py	12.26 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_persisted.py	14.28 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_plugin.py	25.5 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_policies.py	32.04 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_postfix.py	3.53 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_process.py	84.1 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_protocols.py	7.28 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_randbytes.py	3.28 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_rebuild.py	8.3 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_reflect.py	25.47 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_roots.py	1.77 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_shortcut.py	1.89 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 test_sip.py	24.69 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_sob.py	5.5 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_socks.py	17.32 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_ssl.py	23.29 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_sslverify.py	104.28 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_stateful.py	1.97 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_stdio.py	12.85 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_strerror.py	5.06 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_stringtransport.py	12.95 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_strports.py	1.75 KB	09/08/2017 10:38:35 AM	rw-r--r--
📄 test_task.py	38.4 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_tcp.py	64.07 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_tcp_internals.py	8.54 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_text.py	6.3 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_threadable.py	3.65 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_threadpool.py	22.47 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_threads.py	12.96 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_tpfile.py	1.56 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_twistd.py	61.05 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_twisted.py	18.42 KB	09/09/2017 05:11:54 AM	rw-r--r--
📄 test_udp.py	24.1 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_unix.py	14.8 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 test_usage.py	23.09 KB	09/08/2017 10:38:36 AM	rw-r--r--
📄 testutils.py	5.19 KB	09/08/2017 10:38:36 AM	rw-r--r--

Name

Size

Modified

Perms

📁 ..

03/31/2022 06:22:38 AM

rwxr-xr-x

📄 __init__.py

103 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📁 __pycache__

03/31/2022 06:22:39 AM

rwxr-xr-x

📄 cert.pem.no_trailing_newline

1.38 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 crash_test_dummy.py

543 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 iosim.py

17.3 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 key.pem.no_trailing_newline

1.67 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 mock_win32process.py

1.46 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 myrebuilder1.py

158 bytes

09/08/2017 10:38:35 AM

rw-r--r--

📄 myrebuilder2.py

158 bytes

09/08/2017 10:38:35 AM

rw-r--r--

📄 plugin_basic.py

943 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 plugin_extra1.py

407 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 plugin_extra2.py

579 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 process_cmdline.py

162 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 process_echoer.py

214 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 process_fds.py

945 bytes

09/08/2017 10:38:35 AM

rw-r--r--

📄 process_getargv.py

283 bytes

09/08/2017 10:38:35 AM

rw-r--r--

📄 process_getenv.py

268 bytes

09/08/2017 10:38:35 AM

rw-r--r--

📄 process_linger.py

286 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 process_reader.py

188 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 process_signal.py

214 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 process_stdinreader.py

857 bytes

09/08/2017 10:38:35 AM

rw-r--r--

📄 process_tester.py

1.01 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 process_tty.py

130 bytes

09/08/2017 10:38:35 AM

rw-r--r--

📄 process_twisted.py

1.18 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 proto_helpers.py

26.33 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 raiser.c

93.05 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 raiser.cpython-36m-x86_64-linux-gnu.so

19.16 KB

03/22/2022 11:03:56 AM

rw-r--r--

📄 raiser.pyx

466 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 reflect_helper_IE.py

61 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 reflect_helper_VE.py

82 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 reflect_helper_ZDE.py

47 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 server.pem

4.34 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 ssl_helpers.py

1.01 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 stdio_test_consumer.py

1.19 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 stdio_test_halfclose.py

1.89 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 stdio_test_hostpeer.py

1021 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 stdio_test_lastwrite.py

1.18 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 stdio_test_loseconn.py

1.51 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 stdio_test_producer.py

1.47 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 stdio_test_write.py

923 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 stdio_test_writeseq.py

915 bytes

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_abstract.py

3.42 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_adbapi.py

25.53 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_amp.py

107.96 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_application.py

32.05 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_compat.py

27.32 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_context.py

1.48 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_cooperator.py

20.96 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_defer.py

100.93 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_defgen.py

10.45 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_dict.py

1.41 KB

09/23/2017 05:52:22 AM

rw-r--r--

📄 test_dirdbm.py

6.76 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 test_error.py

8.39 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_factories.py

4.53 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_failure.py

29.92 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_fdesc.py

7.2 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_finger.py

1.95 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_formmethod.py

3.56 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_ftp.py

127.27 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_ftp_options.py

2.62 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_htb.py

3.12 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_ident.py

6.85 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_internet.py

45.33 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_iosim.py

8.49 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 test_iutils.py

13.13 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_lockfile.py

15.14 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_log.py

35.48 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_logfile.py

17.8 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_loopback.py

14.15 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_main.py

2.44 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 test_memcache.py

24.55 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_modules.py

17.47 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_monkey.py

5.5 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_nooldstyle.py

5.82 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 test_paths.py

72.61 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_pcp.py

12.26 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_persisted.py

14.28 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_plugin.py

25.5 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_policies.py

32.04 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_postfix.py

3.53 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_process.py

84.1 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_protocols.py

7.28 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_randbytes.py

3.28 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_rebuild.py

8.3 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_reflect.py

25.47 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_roots.py

1.77 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_shortcut.py

1.89 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 test_sip.py

24.69 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_sob.py

5.5 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_socks.py

17.32 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_ssl.py

23.29 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_sslverify.py

104.28 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_stateful.py

1.97 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_stdio.py

12.85 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_strerror.py

5.06 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_stringtransport.py

12.95 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_strports.py

1.75 KB

09/08/2017 10:38:35 AM

rw-r--r--

📄 test_task.py

38.4 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_tcp.py

64.07 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_tcp_internals.py

8.54 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_text.py

6.3 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_threadable.py

3.65 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_threadpool.py

22.47 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_threads.py

12.96 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_tpfile.py

1.56 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_twistd.py

61.05 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_twisted.py

18.42 KB

09/09/2017 05:11:54 AM

rw-r--r--

📄 test_udp.py

24.1 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_unix.py

14.8 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 test_usage.py

23.09 KB

09/08/2017 10:38:36 AM

rw-r--r--

📄 testutils.py

5.19 KB

09/08/2017 10:38:36 AM

rw-r--r--

Editing: test_iosim.py

# Copyright (c) Twisted Matrix Laboratories.
# See LICENSE for details.

"""
Tests for L{twisted.test.iosim}.
"""

from __future__ import absolute_import, division

from zope.interface import implementer

from twisted.internet.interfaces import IPushProducer
from twisted.internet.protocol import Protocol

from twisted.test.iosim import FakeTransport, connect
from twisted.trial.unittest import TestCase

class FakeTransportTests(TestCase):
    """
    Tests for L{FakeTransport}.
    """

def test_connectionSerial(self):
        """
        Each L{FakeTransport} receives a serial number that uniquely identifies
        it.
        """
        a = FakeTransport(object(), True)
        b = FakeTransport(object(), False)
        self.assertIsInstance(a.serial, int)
        self.assertIsInstance(b.serial, int)
        self.assertNotEqual(a.serial, b.serial)

def test_writeSequence(self):
        """
        L{FakeTransport.writeSequence} will write a sequence of L{bytes} to the
        transport.
        """
        a = FakeTransport(object(), False)

a.write(b"a")
        a.writeSequence([b"b", b"c", b"d"])

self.assertEqual(b"".join(a.stream), b"abcd")

@implementer(IPushProducer)
class StrictPushProducer(object):
    """
    An L{IPushProducer} implementation which produces nothing but enforces
    preconditions on its state transition methods.
    """
    _state = u"running"

def stopProducing(self):
        if self._state == u"stopped":
            raise ValueError(u"Cannot stop already-stopped IPushProducer")
        self._state = u"stopped"

def pauseProducing(self):
        if self._state != u"running":
            raise ValueError(
                u"Cannot pause {} IPushProducer".format(self._state)
            )
        self._state = u"paused"

def resumeProducing(self):
        if self._state != u"paused":
            raise ValueError(
                u"Cannot resume {} IPushProducer".format(self._state)
            )
        self._state = u"running"

class StrictPushProducerTests(TestCase):
    """
    Tests for L{StrictPushProducer}.
    """
    def _initial(self):
        """
        @return: A new L{StrictPushProducer} which has not been through any state
            changes.
        """
        return StrictPushProducer()

def _stopped(self):
        """
        @return: A new, stopped L{StrictPushProducer}.
        """
        producer = StrictPushProducer()
        producer.stopProducing()
        return producer

def _paused(self):
        """
        @return: A new, paused L{StrictPushProducer}.
        """
        producer = StrictPushProducer()
        producer.pauseProducing()
        return producer

def _resumed(self):
        """
        @return: A new L{StrictPushProducer} which has been paused and resumed.
        """
        producer = StrictPushProducer()
        producer.pauseProducing()
        producer.resumeProducing()
        return producer

def assertStopped(self, producer):
        """
        Assert that the given producer is in the stopped state.

@param producer: The producer to verify.
        @type producer: L{StrictPushProducer}
        """
        self.assertEqual(producer._state, u"stopped")

def assertPaused(self, producer):
        """
        Assert that the given producer is in the paused state.

@param producer: The producer to verify.
        @type producer: L{StrictPushProducer}
        """
        self.assertEqual(producer._state, u"paused")

def assertRunning(self, producer):
        """
        Assert that the given producer is in the running state.

@param producer: The producer to verify.
        @type producer: L{StrictPushProducer}
        """
        self.assertEqual(producer._state, u"running")

def test_stopThenStop(self):
        """
        L{StrictPushProducer.stopProducing} raises L{ValueError} if called when
        the producer is stopped.
        """
        self.assertRaises(ValueError, self._stopped().stopProducing)

def test_stopThenPause(self):
        """
        L{StrictPushProducer.pauseProducing} raises L{ValueError} if called when
        the producer is stopped.
        """
        self.assertRaises(ValueError, self._stopped().pauseProducing)

def test_stopThenResume(self):
        """
        L{StrictPushProducer.resumeProducing} raises L{ValueError} if called when
        the producer is stopped.
        """
        self.assertRaises(ValueError, self._stopped().resumeProducing)

def test_pauseThenStop(self):
        """
        L{StrictPushProducer} is stopped if C{stopProducing} is called on a paused
        producer.
        """
        producer = self._paused()
        producer.stopProducing()
        self.assertStopped(producer)

def test_pauseThenPause(self):
        """
        L{StrictPushProducer.pauseProducing} raises L{ValueError} if called on a
        paused producer.
        """
        producer = self._paused()
        self.assertRaises(ValueError, producer.pauseProducing)

def test_pauseThenResume(self):
        """
        L{StrictPushProducer} is resumed if C{resumeProducing} is called on a
        paused producer.
        """
        producer = self._paused()
        producer.resumeProducing()
        self.assertRunning(producer)

def test_resumeThenStop(self):
        """
        L{StrictPushProducer} is stopped if C{stopProducing} is called on a
        resumed producer.
        """
        producer = self._resumed()
        producer.stopProducing()
        self.assertStopped(producer)

def test_resumeThenPause(self):
        """
        L{StrictPushProducer} is paused if C{pauseProducing} is called on a
        resumed producer.
        """
        producer = self._resumed()
        producer.pauseProducing()
        self.assertPaused(producer)

def test_resumeThenResume(self):
        """
        L{StrictPushProducer.resumeProducing} raises L{ValueError} if called on a
        resumed producer.
        """
        producer = self._resumed()
        self.assertRaises(ValueError, producer.resumeProducing)

def test_stop(self):
        """
        L{StrictPushProducer} is stopped if C{stopProducing} is called in the
        initial state.
        """
        producer = self._initial()
        producer.stopProducing()
        self.assertStopped(producer)

def test_pause(self):
        """
        L{StrictPushProducer} is paused if C{pauseProducing} is called in the
        initial state.
        """
        producer = self._initial()
        producer.pauseProducing()
        self.assertPaused(producer)

def test_resume(self):
        """
        L{StrictPushProducer} raises L{ValueError} if C{resumeProducing} is called
        in the initial state.
        """
        producer = self._initial()
        self.assertRaises(ValueError, producer.resumeProducing)

class IOPumpTests(TestCase):
    """
    Tests for L{IOPump}.
    """
    def _testStreamingProducer(self, mode):
        """
        Connect a couple protocol/transport pairs to an L{IOPump} and then pump
        it.  Verify that a streaming producer registered with one of the
        transports does not receive invalid L{IPushProducer} method calls and
        ends in the right state.

@param mode: C{u"server"} to test a producer registered with the
            server transport.  C{u"client"} to test a producer registered with
            the client transport.
        """
        serverProto = Protocol()
        serverTransport = FakeTransport(serverProto, isServer=True)

clientProto = Protocol()
        clientTransport = FakeTransport(clientProto, isServer=False)

pump = connect(
            serverProto, serverTransport,
            clientProto, clientTransport,
            greet=False,
        )

producer = StrictPushProducer()
        victim = {
            u"server": serverTransport,
            u"client": clientTransport,
        }[mode]
        victim.registerProducer(producer, streaming=True)

pump.pump()
        self.assertEqual(u"running", producer._state)

def test_serverStreamingProducer(self):
        """
        L{IOPump.pump} does not call C{resumeProducing} on a L{IPushProducer}
        (stream producer) registered with the server transport.
        """
        self._testStreamingProducer(mode=u"server")

def test_clientStreamingProducer(self):
        """
        L{IOPump.pump} does not call C{resumeProducing} on a L{IPushProducer}
        (stream producer) registered with the client transport.
        """
        self._testStreamingProducer(mode=u"client")