Lines Matching refs:data
60 self.data = b''
66 def sendall(self, data):
68 self.data += data
94 def sendall(self, data):
95 if self.pipe_trigger in data:
97 self.data += data
109 data = io.BytesIO.read(self, n)
110 if data == b'':
112 return data
115 data = io.BytesIO.readline(self, length)
116 if data == b'':
118 return data
276 self.assertTrue(sock.data.startswith(expected))
284 self.assertTrue(sock.data.startswith(expected))
405 _, _, body = self._parse_request(conn.sock.data)
418 _, headers, body = self._parse_request(conn.sock.data)
430 _, headers, body = self._parse_request(conn.sock.data)
442 _, headers, body = self._parse_request(conn.sock.data)
454 _, headers, body = self._parse_request(conn.sock.data)
468 _, headers, body = self._parse_request(conn.sock.data)
484 def _parse_request(self, data):
485 lines = data.split(b'\r\n')
497 def _parse_chunked(self, data):
501 lines = data.split(b'\r\n')
517 # malformed data
715 # how much data is left and does not raise IncompleteRead
777 # all data was read
793 # all data was read
881 # Test that the library doesn't attempt to read any data
894 # Test that the library doesn't attempt to read any data
928 self.assertTrue(sock.data.startswith(expected), '%r != %r' %
929 (sock.data[:len(expected)], expected))
937 self.assertEqual(expected, sock.data)
938 sock.data = b''
940 self.assertEqual(expected, sock.data)
941 sock.data = b''
943 self.assertEqual(expected, sock.data)
946 def data():
947 yield 'data'
953 d = data()
957 expected = b'data'
963 self.assertEqual(sock.data, expected)
980 self.assertEqual(sock.data, expected)
991 body = sock.data.split(b"\r\n\r\n", 1)[1]
1003 self.assertEqual(sock.data, expected)
1366 s.sendall(b"proxied data\n")
1373 self.assertEqual(result, b"proxied data\n")
1514 data = resp.read1()
1515 if not data:
1517 all.append(data)
1524 data = resp.read1(10)
1525 if not data:
1527 self.assertLessEqual(len(data), 10)
1528 all.append(data)
1570 data = []
1580 # read more data
1581 data.append(read)
1587 data.append(read[:idx])
1589 return b"".join(data)
1591 self.remainder = b"".join(data)
2041 f = io.BytesIO(self.sock.data)
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)
2229 msg=f'unexpected proxy data sent {proxy_setup_data_sent!r}')
2236 self.assertIn(b'CONNECT destination.com', self.conn.sock.data)
2237 self.assertIn(b'Host: destination.com', self.conn.sock.data)