/curl/tests/http/testenv/ |
H A D | vsftpd.py | 49 self._port = self.env.ftps_port 52 self._port = self.env.ftp_port 55 self._run_dir = os.path.join(self._vsftpd_dir, 'run') 56 self._docs_dir = os.path.join(self._vsftpd_dir, 'docs') 57 self._tmp_dir = os.path.join(self._vsftpd_dir, 'tmp') 78 self._rmf(self._error_log) 100 self._mkpath(self._tmp_dir) 113 self._mkpath(self._tmp_dir) 164 self._mkpath(self._docs_dir) 165 self._mkpath(self._tmp_dir) [all …]
|
H A D | caddy.py | 47 self._docs_dir = os.path.join(self._caddy_dir, 'docs') 48 self._conf_file = os.path.join(self._caddy_dir, 'Caddyfile') 50 self._tmp_dir = os.path.join(self._caddy_dir, 'tmp') 52 self._rmf(self._error_log) 63 self._rmf(self._error_log) 77 self._mkpath(self._tmp_dir) 96 self._mkpath(self._tmp_dir) 109 curl = CurlClient(env=self.env, run_dir=self._tmp_dir) 122 curl = CurlClient(env=self.env, run_dir=self._tmp_dir) 148 self._mkpath(self._docs_dir) [all …]
|
H A D | httpd.py | 68 self._run_dir = os.path.join(self._apache_dir, 'run') 70 self._docs_dir = os.path.join(self._apache_dir, 'docs') 71 self._conf_dir = os.path.join(self._apache_dir, 'conf') 73 self._logs_dir = os.path.join(self._apache_dir, 'logs') 75 self._tmp_dir = os.path.join(self._apache_dir, 'tmp') 94 self._rmf(self._error_log) 102 self._rmf(self._error_log) 225 self._mkpath(self._conf_dir) 226 self._mkpath(self._logs_dir) 227 self._mkpath(self._tmp_dir) [all …]
|
H A D | env.py | 62 self.gen_dir = os.path.join(self.tests_dir, 'gen') 128 self.httpd = self.config['httpd']['httpd'] 129 self.apachectl = self.config['httpd']['apachectl'] 130 self.apxs = self.config['httpd']['apxs'] 139 self.htdocs_dir = os.path.join(self.gen_dir, 'htdocs') 156 self.nghttpx = self.config['nghttpx']['nghttpx'] 172 self.caddy = self.config['caddy']['caddy'] 192 self.vsftpd = self.config['vsftpd']['vsftpd'] 245 hv = self.versiontuple(self.httpd_version) 251 hv = self.versiontuple(self.caddy_version) [all …]
|
H A D | nghttpx.py | 55 self._tmp_dir = os.path.join(self._run_dir, 'tmp') 57 self._rmf(self._pid_file) 58 self._rmf(self._error_log) 59 self._mkpath(self._run_dir) 67 return self._cmd and os.path.exists(self._cmd) 70 self._rmf(self._error_log) 71 self._rmf(self._stderr) 93 self._mkpath(self._tmp_dir) 200 self._mkpath(self._tmp_dir) 203 creds = self.env.get_credentials(self.env.domain1) [all …]
|
H A D | curl.py | 83 self._psu = psutil.Process(pid=self._pid) 95 self._duration = datetime.now() - self._started_at 478 self._rmrf(self._run_dir) 479 self._mkpath(self._run_dir) 555 self._rmf(self.download_file(i)) 670 self._rmf(self.download_file(i)) 761 self._rmf(self._stdoutfile) 762 self._rmf(self._stderrfile) 763 self._rmf(self._headerfile) 769 tcpdump = RunTcpDump(self.env, self._run_dir) [all …]
|
H A D | client.py | 46 self.name = name 48 self.env = env 55 self._rmrf(self._run_dir) 56 self._mkpath(self._run_dir) 72 def _rmf(self, path): argument 76 def _rmrf(self, path): argument 84 def run(self, args): argument 85 self._rmf(self._stdoutfile) 86 self._rmf(self._stderrfile) 92 if self._run_env: [all …]
|
H A D | certs.py | 85 self._name = name 98 if self._name: 106 if self.domains and len(self.domains): 108 elif self.client: 110 elif self.name: 117 def __init__(self, argument 122 self._name = name 123 self._cert = cert 124 self._pkey = pkey 140 def key_type(self): argument [all …]
|
/curl/tests/http/ |
H A D | test_11_unix.py | 44 self._done = False 45 self._socket = None 48 def path(self): argument 51 def start(self): argument 52 def process(self): argument 54 self._process() 62 self._socket.bind(self._uds_path) 63 self._thread = Thread(target=process, daemon=True, args=[self]) 66 def stop(self): argument 67 self._done = True [all …]
|
H A D | scorecard.py | 56 self.env = env 64 def info(self, msg): argument 143 curl = CurlClient(env=self.env, silent=self._silent_curl, 172 curl = CurlClient(env=self.env, silent=self._silent_curl, 202 curl = CurlClient(env=self.env, silent=self._silent_curl, 269 curl = CurlClient(env=self.env, silent=self._silent_curl, 297 curl = CurlClient(env=self.env, silent=self._silent_curl, 326 curl = CurlClient(env=self.env, silent=self._silent_curl, 391 curl = CurlClient(env=self.env, silent=self._silent_curl, 431 def score(self, argument [all …]
|
H A D | test_16_info.py | 40 def _class_scope(self, env, httpd, nghttpx): argument 47 def _class_scope(self, env, httpd): argument 66 self.check_stat(idx, s, r, dl_size=30, ul_size=0) 118 self.check_stat_times(s, idx) 120 self.check_stat_positive(s, idx, 'size_request') 122 self.check_stat_positive(s, idx, 'size_header') 130 def check_stat_positive(self, s, idx, key): argument 134 def check_stat_zero(self, s, key): argument 138 def check_stat_times(self, s, idx): argument 157 self.check_stat_zero(s, key) [all …]
|
H A D | test_03_goaway.py | 42 def _class_scope(self, env, httpd, nghttpx): argument 49 def test_03_01_h2_goaway(self, env: Env, httpd, nghttpx, repeat): argument 52 self.r = None 59 self.r = curl.http_download(urls=[urln], alpn_proto=proto) 68 r: ExecResult = self.r 81 def test_03_02_h3_goaway(self, env: Env, httpd, nghttpx, repeat): argument 88 self.r = None 104 r: ExecResult = self.r 115 def test_03_03_h1_goaway(self, env: Env, httpd, nghttpx, repeat): argument 118 self.r = None [all …]
|
H A D | test_30_vsftpd.py | 44 def vsftpd(self, env): argument 61 def _class_scope(self, env, vsftpd): argument 93 self.check_downloads(curl, srcfile, count) 105 self.check_downloads(curl, srcfile, count) 119 self.check_downloads(curl, srcfile, count) 128 self._rmf(dstfile) 133 self.check_upload(env, vsftpd, docname=docname) 135 def _rmf(self, path): argument 158 self._rmf(dstfile) 176 self.check_downloads(curl, srcfile, count) [all …]
|
H A D | test_31_vsftpds.py | 46 def vsftpds(self, env): argument 68 def _class_scope(self, env, vsftpds): argument 100 self.check_downloads(curl, srcfile, count) 112 self.check_downloads(curl, srcfile, count) 126 self.check_downloads(curl, srcfile, count) 135 self._rmf(dstfile) 142 def _rmf(self, path): argument 166 self._rmf(dstfile) 183 self._rmf(dstfile) 214 self._rmf(dstfile) [all …]
|
H A D | test_20_websockets.py | 45 def check_alive(self, env, timeout=5): argument 56 def _mkpath(self, path): argument 60 def _rmrf(self, path): argument 65 def ws_echo(self, env): argument 68 self._rmrf(run_dir) 69 self._mkpath(run_dir) 77 assert self.check_alive(env) 81 def test_20_01_basic(self, env: Env, ws_echo, repeat): argument 107 def test_20_04_data_small(self, env: Env, ws_echo, repeat): argument 116 def test_20_05_data_med(self, env: Env, ws_echo, repeat): argument [all …]
|
H A D | test_02_download.py | 45 def _class_scope(self, env, httpd, nghttpx): argument 52 def _class_scope(self, env, httpd): argument 94 def test_02_04_download_parallel(self, env: Env, argument 150 def test_02_07_download_reuse(self, env: Env, argument 169 def test_02_07b_download_reuse(self, env: Env, argument 183 def test_02_08_1MB_serial(self, env: Env, argument 194 def test_02_09_1MB_parallel(self, env: Env, argument 209 def test_02_10_10MB_serial(self, env: Env, argument 222 def test_02_11_10MB_parallel(self, env: Env, argument 250 def test_02_13_head_serial_h2c(self, env: Env, argument [all …]
|
H A D | test_08_caddy.py | 45 def caddy(self, env): argument 51 def _make_docs_file(self, docs_dir: str, fname: str, fsize: int): argument 62 def _class_scope(self, env, caddy): argument 72 def test_08_01_download_1(self, env: Env, caddy: Caddy, repeat, proto): argument 84 def test_08_02_download_1mb_sequential(self, env: Env, caddy: Caddy, argument 98 def test_08_03_download_1mb_parallel(self, env: Env, caddy: Caddy, argument 121 def test_08_04a_download_10mb_sequential(self, env: Env, caddy: Caddy, argument 153 def test_08_05_download_1mb_parallel(self, env: Env, caddy: Caddy, argument 214 def test_08_08_earlydata(self, env: Env, httpd, caddy, proto): argument 230 self.check_downloads(client, srcfile, count) [all …]
|
H A D | test_06_eyeballs.py | 39 def _class_scope(self, env, httpd, nghttpx): argument 47 def test_06_01_h3_only(self, env: Env, httpd, nghttpx, repeat): argument 56 def test_06_02_h3_only(self, env: Env, httpd, nghttpx, repeat): argument 65 def test_06_03_h3_fallback_h2(self, env: Env, httpd, nghttpx, repeat): argument 75 def test_06_04_h3_fallback_h1(self, env: Env, httpd, nghttpx, repeat): argument 84 def test_06_10_stats_success(self, env: Env, httpd, nghttpx, repeat): argument 93 def test_06_11_stats_fail_verify(self, env: Env, httpd, nghttpx, repeat): argument 104 def test_06_12_stats_fail_tcp(self, env: Env, httpd, nghttpx, repeat): argument
|
H A D | test_04_stuttered.py | 42 def _class_scope(self, env, httpd, nghttpx): argument 50 def test_04_01_download_1(self, env: Env, httpd, nghttpx, repeat, argument 66 def test_04_02_100_100_10(self, env: Env, argument 81 t_avg, i_min, t_min, i_max, t_max = self.stats_spread(r.stats[warmups:], 'time_total') 89 def test_04_03_1000_10_1(self, env: Env, httpd, nghttpx, repeat, proto): argument 103 t_avg, i_min, t_min, i_max, t_max = self.stats_spread(r.stats[warmups:], 'time_total') 111 def test_04_04_1000_10_1(self, env: Env, httpd, nghttpx, repeat, proto): argument 125 t_avg, i_min, t_min, i_max, t_max = self.stats_spread(r.stats[warmups:], 'time_total') 129 def stats_spread(self, stats: List[Dict], key: str) -> Tuple[float, int, float, int, float]: argument
|
H A D | test_13_proxy_auth.py | 42 def _class_scope(self, env, httpd, nghttpx_fwd): argument 52 def get_tunnel_proto_used(self, r: ExecResult): argument 61 def test_13_01_proxy_no_auth(self, env: Env, httpd, repeat): argument 69 def test_13_02_proxy_auth(self, env: Env, httpd, repeat): argument 81 def test_13_03_proxys_no_auth(self, env: Env, httpd, nghttpx_fwd, repeat): argument 92 def test_13_04_proxys_auth(self, env: Env, httpd, nghttpx_fwd, repeat): argument 101 def test_13_05_tunnel_http_no_auth(self, env: Env, httpd, repeat): argument 110 def test_13_06_tunnel_http_auth(self, env: Env, httpd, repeat): argument 134 assert self.get_tunnel_proto_used(r) == 'HTTP/2' \ 142 def test_13_08_tunnels_auth(self, env: Env, httpd, proto, tunnel, repeat): argument [all …]
|
H A D | test_01_basic.py | 40 def _class_scope(self, env, nghttpx): argument 45 def test_01_01_http_get(self, env: Env, httpd): argument 54 def test_01_02_https_get(self, env: Env, httpd): argument 63 def test_01_03_h2_get(self, env: Env, httpd): argument 72 def test_01_04_h2_unsupported(self, env: Env, httpd): argument 81 def test_01_05_h3_get(self, env: Env, httpd, nghttpx): argument 91 def test_01_06_timings(self, env: Env, httpd, nghttpx, repeat, proto): argument 106 def test_01_07_head(self, env: Env, httpd, nghttpx, repeat, proto): argument 121 def test_01_08_h2_upgrade(self, env: Env, httpd): argument 133 def test_01_09_h2_prior_knowledge(self, env: Env, httpd): argument
|
H A D | test_10_proxy.py | 42 def _class_scope(self, env, httpd, nghttpx_fwd): argument 53 def get_tunnel_proto_used(self, r: ExecResult): argument 62 def test_10_01_proxy_http(self, env: Env, httpd, repeat): argument 161 assert self.get_tunnel_proto_used(r) == 'HTTP/2' \ 189 assert self.get_tunnel_proto_used(r) == 'HTTP/2' \ 218 assert self.get_tunnel_proto_used(r) == 'HTTP/2' \ 240 assert self.get_tunnel_proto_used(r) == 'HTTP/2' \ 263 assert self.get_tunnel_proto_used(r1) == 'HTTP/2' \ 288 assert self.get_tunnel_proto_used(r1) == 'HTTP/2' \ 314 assert self.get_tunnel_proto_used(r1) == 'HTTP/2' \ [all …]
|
/curl/tests/ |
H A D | util.py | 40 def __init__(self, filename): argument 43 self.setStream(None) 45 def emit(self, record): argument 47 self.setStream(fp) 49 self.setStream(None) 51 def setStream(self, stream): argument 55 if stream is self.stream: 58 result = self.stream 59 self.acquire() 61 self.flush() [all …]
|
H A D | negtelnetserver.py | 127 self.state = self.NO_NEG 152 elif self.state in [self.WILL, self.WONT, self.DO, self.DONT]: 159 self.state = self.NO_NEG 169 self.state = self.START_NEG 182 self.state = self.WILL 187 self.state = self.WONT 191 self.state = self.DO 195 self.state = self.DONT 201 self.state = self.NO_NEG 212 self.state = self.NO_NEG [all …]
|
H A D | smbserver.py | 75 def __init__(self, server): argument 77 self.server = server 80 def __enter__(self): argument 81 self.start() 85 def __exit__(self, *_): argument 87 self.shutdown_event.set() 89 self.join() 102 def run(self): argument 106 self.server.shutdown() 168 def __init__(self, argument [all …]
|