Lines Matching defs:conn
156 conn = client.HTTPConnection('example.com')
157 conn.sock = FakeSocket('blahblahblah')
158 conn._buffer = HeaderCountingBuffer()
164 conn.request('POST', '/', body, headers)
165 self.assertEqual(conn._buffer.count[header.lower()], 1)
184 conn = client.HTTPConnection('example.com')
185 conn.sock = FakeSocket(None)
186 conn._buffer = ContentLengthChecker()
187 conn.request(method, '/', body)
189 conn._buffer.content_length, b'0',
200 conn = client.HTTPConnection('example.com')
201 conn.sock = FakeSocket(None)
202 conn._buffer = ContentLengthChecker()
203 conn.request(method, '/', None)
205 conn._buffer.content_length, None,
213 conn = client.HTTPConnection('example.com')
214 conn.sock = FakeSocket(None)
215 conn._buffer = ContentLengthChecker()
216 conn.request(method, '/', '')
218 conn._buffer.content_length, b'0',
224 conn = client.HTTPConnection('example.com')
225 conn.sock = FakeSocket(None)
226 conn._buffer = ContentLengthChecker()
227 conn.request(method, '/', ' ')
229 conn._buffer.content_length, b'1',
234 conn = client.HTTPConnection('example.com')
235 conn.sock = FakeSocket(None)
236 conn.putrequest('GET','/')
237 conn.putheader('Content-length', 42)
238 self.assertIn(b'Content-length: 42', conn._buffer)
240 conn.putheader('Foo', ' bar ')
241 self.assertIn(b'Foo: bar ', conn._buffer)
242 conn.putheader('Bar', '\tbaz\t')
243 self.assertIn(b'Bar: \tbaz\t', conn._buffer)
244 conn.putheader('Authorization', 'Bearer mytoken')
245 self.assertIn(b'Authorization: Bearer mytoken', conn._buffer)
246 conn.putheader('IterHeader', 'IterA', 'IterB')
247 self.assertIn(b'IterHeader: IterA\r\n\tIterB', conn._buffer)
248 conn.putheader('LatinHeader', b'\xFF')
249 self.assertIn(b'LatinHeader: \xFF', conn._buffer)
250 conn.putheader('Utf8Header', b'\xc3\x80')
251 self.assertIn(b'Utf8Header: \xc3\x80', conn._buffer)
252 conn.putheader('C1-Control', b'next\x85line')
253 self.assertIn(b'C1-Control: next\x85line', conn._buffer)
254 conn.putheader('Embedded-Fold-Space', 'is\r\n allowed')
255 self.assertIn(b'Embedded-Fold-Space: is\r\n allowed', conn._buffer)
256 conn.putheader('Embedded-Fold-Tab', 'is\r\n\tallowed')
257 self.assertIn(b'Embedded-Fold-Tab: is\r\n\tallowed', conn._buffer)
258 conn.putheader('Key Space', 'value')
259 self.assertIn(b'Key Space: value', conn._buffer)
260 conn.putheader('KeySpace ', 'value')
261 self.assertIn(b'KeySpace : value', conn._buffer)
262 conn.putheader(b'Nonbreak\xa0Space', 'value')
263 self.assertIn(b'Nonbreak\xa0Space: value', conn._buffer)
264 conn.putheader(b'\xa0NonbreakSpace', 'value')
265 self.assertIn(b'\xa0NonbreakSpace: value', conn._buffer)
272 conn = client.HTTPConnection('[2001::]:81')
274 conn.sock = sock
275 conn.request('GET', '/foo')
280 conn = client.HTTPConnection('[2001:102A::]')
282 conn.sock = sock
283 conn.request('GET', '/foo')
327 conn = client.HTTPConnection('example.com')
328 conn.sock = FakeSocket('')
329 conn.putrequest('GET', '/')
354 conn.putheader(name, value)
391 conn = client.HTTPConnection('example.com')
392 conn.sock = FakeSocket(None)
393 conn.request(method=method, url="/")
400 conn = client.HTTPConnection('example.com')
401 conn.sock = FakeSocket(b'')
402 conn.putrequest('POST', '/')
403 conn.endheaders(self._make_body(), encode_chunked=True)
405 _, _, body = self._parse_request(conn.sock.data)
411 conn = client.HTTPConnection('example.com')
412 conn.sock = FakeSocket(b'')
415 conn.request(
418 _, headers, body = self._parse_request(conn.sock.data)
424 conn = client.HTTPConnection('example.com')
425 conn.sock = FakeSocket(b'')
426 conn.request(
430 _, headers, body = self._parse_request(conn.sock.data)
436 conn = client.HTTPConnection('example.com')
437 conn.sock = FakeSocket(b'')
438 conn.request('POST', '/',
442 _, headers, body = self._parse_request(conn.sock.data)
449 conn = client.HTTPConnection('example.com')
450 conn.sock = FakeSocket(b'')
451 conn.request(
454 _, headers, body = self._parse_request(conn.sock.data)
465 conn = client.HTTPConnection('example.com')
466 conn.sock = FakeSocket(b'')
467 conn.request('POST', '/', ())
468 _, headers, body = self._parse_request(conn.sock.data)
924 conn = client.HTTPConnection('example.com')
926 conn.sock = sock
927 conn.request('GET', '/foo', body)
933 conn = client.HTTPConnection('example.com')
935 conn.sock = sock
936 conn.send(expected)
939 conn.send(array.array('b', expected))
942 conn.send(io.BytesIO(expected))
959 conn = client.HTTPConnection('example.com')
961 conn.sock = sock
962 conn.send(UpdatingFile())
976 conn = client.HTTPConnection('example.com')
978 conn.sock = sock
979 conn.request('GET', '/foo', body(), {'Content-Length': '11'})
985 conn = client.HTTPConnection('example.com', blocksize=blocksize)
987 conn.sock = sock
989 conn.request("PUT", "/", io.BytesIO(expected), {"Content-Length": "9"})
997 conn = client.HTTPConnection('example.com', blocksize=blocksize)
999 conn.sock = sock
1001 conn.send(io.BytesIO(expected))
1007 conn = client.HTTPConnection('example.com')
1008 conn.sock = FakeSocket('')
1010 conn.request('POST', 'test', conn)
1160 conn = client.HTTPConnection("example.com")
1161 conn.sock = sock
1163 lambda: conn.request("PUT", "/url", "body"))
1164 resp = conn.getresponse()
1224 conn = client.HTTPConnection('example.com')
1231 conn.response_class = Response
1232 conn.sock = FakeSocket('Invalid status line')
1233 conn.request('GET', '/')
1234 self.assertRaises(client.BadStatusLine, conn.getresponse)
1236 self.assertTrue(conn.sock.file_closed)
1345 [conn, address] = serv.accept()
1346 with conn, conn.makefile("rb") as reader:
1352 conn.sendall(b"HTTP/1.1 200 Connection established\r\n\r\n")
1359 conn = client.HTTPConnection(*serv.getsockname())
1360 conn.request("CONNECT", "dummy:1234")
1361 response = conn.getresponse()
1371 conn.close()
1384 conn = UnsafeHTTPConnection('example.com')
1385 conn.sock = FakeSocket('')
1386 conn.putrequest('GET', '/\x00')
1393 conn = UnsafeHTTPConnection('example.com\r\n')
1394 conn.sock = FakeSocket('')
1397 conn.putrequest('GET', '/', skip_host=1)
1409 conn = UnsafeHTTPConnection('example.com')
1410 conn.sock = FakeSocket('')
1411 conn.putrequest('GET', '/☃')
1686 self.conn = None
1689 if self.conn:
1690 self.conn.close()
1691 self.conn = None
1696 self.conn = client.HTTPConnection(HOST, self.port,
1698 self.conn.connect()
1699 self.assertEqual(self.conn.sock.getsockname()[1], self.source_port)
1704 self.conn = client.HTTPSConnection(HOST, self.port,
1778 conn = FakeSocketHTTPConnection(msg)
1779 self.assertIsNone(conn.sock)
1780 conn.request('GET', '/open-connection')
1781 with conn.getresponse() as response:
1782 self.assertEqual(conn.sock is None, not reuse)
1784 self.assertEqual(conn.sock is None, not reuse)
1785 self.assertEqual(conn.connections, 1)
1786 conn.request('GET', '/subsequent-request')
1787 self.assertEqual(conn.connections, 1 if reuse else 2)
1808 conn = FakeSocketHTTPConnection(b'', stream_factory)
1809 conn.request('GET', '/eof-response')
1810 self.assertRaises(exception, conn.getresponse)
1811 self.assertIsNone(conn.sock)
1813 conn.request('GET', '/reconnect')
1814 self.assertEqual(conn.connections, 2)
1817 conn = FakeSocketHTTPConnection(
1822 conn.request('GET', '/', headers={'Expect': '100-continue'})
1823 self.assertRaises(client.RemoteDisconnected, conn.getresponse)
1824 self.assertIsNone(conn.sock)
1825 conn.request('GET', '/reconnect')
1826 self.assertEqual(conn.connections, 2)
2036 self.conn = client.HTTPConnection('example.com')
2037 self.conn.sock = self.sock = FakeSocket("")
2038 self.conn.sock = self.sock
2056 self.conn = client.HTTPConnection('example.com')
2057 self.conn.sock = self.sock = FakeSocket('')
2059 self.conn.request('PUT', '/url', body)
2069 self.conn.request("PUT", "/url", "body",
2076 self.conn.request("PUT", "/url", "body")
2084 self.conn.request("PUT", "/url", "body\xc1")
2092 self.conn.request("PUT", "/url", b"body\xc1")
2104 self.conn.request("PUT", "/url", f)
2119 self.conn.request("PUT", "/url", f)
2171 self.conn = client.HTTPConnection(self.host)
2172 self.conn._create_connection = self._create_connection(response_text)
2175 self.conn.close()
2186 self.conn.set_tunnel(tunnel_host, port=tunnel_port,
2188 self.conn.request('HEAD', '/', '')
2189 self.assertEqual(self.conn.sock.host, self.host)
2190 self.assertEqual(self.conn.sock.port, client.HTTP_PORT)
2191 self.assertEqual(self.conn._tunnel_host, tunnel_host)
2192 self.assertEqual(self.conn._tunnel_port, tunnel_port)
2193 self.assertEqual(self.conn._tunnel_headers, tunnel_headers)
2197 self.conn.connect()
2198 self.assertRaises(RuntimeError, self.conn.set_tunnel,
2202 self.conn.set_tunnel('destination.com')
2203 self.conn.request('HEAD', '/', '')
2204 self.assertEqual(self.conn.sock.host, self.host)
2205 self.assertEqual(self.conn.sock.port, client.HTTP_PORT)
2206 self.assertIn(b'CONNECT destination.com', self.conn.sock.data)
2208 self.assertNotIn(b'Host: destination.com:None', self.conn.sock.data)
2209 self.assertIn(b'Host: destination.com', self.conn.sock.data)
2212 self.assertNotIn(b'Host: proxy.com', self.conn.sock.data)
2216 with mock.patch.object(self.conn, 'send') as mock_send:
2217 self.conn.set_tunnel('destination.com')
2218 self.conn.connect()
2219 self.conn.request('GET', '/')
2232 self.conn.set_tunnel('destination.com')
2233 self.conn.request('PUT', '/', '')
2234 self.assertEqual(self.conn.sock.host, self.host)
2235 self.assertEqual(self.conn.sock.port, client.HTTP_PORT)
2236 self.assertIn(b'CONNECT destination.com', self.conn.sock.data)
2237 self.assertIn(b'Host: destination.com', self.conn.sock.data)
2243 self.conn.set_debuglevel(1)
2244 self.conn._create_connection = self._create_connection(response_text)
2245 self.conn.set_tunnel('destination.com')
2248 self.conn.request('PUT', '/', '')
2264 self.conn._create_connection = _create_connection
2265 self.conn.set_tunnel('destination.com')
2268 self.conn.request('HEAD', '/', '')