Searched refs:_conn (Results 1 – 14 of 14) sorted by relevance
33 self._conn = h2.connection.H2Connection(client_side=False)58 self._conn.initiate_connection()60 self.transport.write(self._conn.data_to_send())67 events = self._conn.receive_data(data)72 if self._conn.data_to_send:73 self.transport.write(self._conn.data_to_send())94 self.transport.write(self._conn.data_to_send())101 self._conn.acknowledge_received_data(len(event.data), event.stream_id)108 self._conn.send_headers(117 self.transport.write(self._conn.data_to_send())[all …]
37 self._base_server._conn.initiate_connection()38 self._base_server._conn.update_settings(42 self._base_server._conn.data_to_send())
51 self._base_server._conn.close_connection(error_code=0,
31 self._conn = h2.connection.H2Connection(client_side=False)56 self._conn.initiate_connection()58 self.transport.write(self._conn.data_to_send())65 events = self._conn.receive_data(data)70 if self._conn.data_to_send:71 self.transport.write(self._conn.data_to_send())85 self.transport.write(self._conn.data_to_send())92 self._conn.acknowledge_received_data(len(event.data), event.stream_id)99 self._conn.send_headers(108 self.transport.write(self._conn.data_to_send())[all …]
35 self._base_server._conn.initiate_connection()36 self._base_server._conn.update_settings(39 self._base_server.transport.write(self._base_server._conn.data_to_send())
48 …self._base_server._conn.close_connection(error_code=0, additional_data=None, last_stream_id=stream…
200 self._conn = conn214 return self._conn.remotecall(self._oid, "frame_attr",218 cid = self._conn.remotecall(self._oid, "frame_code", (self._fid,), {})219 return CodeProxy(self._conn, self._oid, cid)222 did = self._conn.remotecall(self._oid, "frame_globals",227 did = self._conn.remotecall(self._oid, "frame_locals",234 dp = DictProxy(self._conn, self._oid, did)242 self._conn = conn248 return self._conn.remotecall(self._oid, "code_name",251 return self._conn.remotecall(self._oid, "code_filename",[all …]
204 self._conn = conn218 return self._conn.remotecall(self._oid, "frame_attr",222 cid = self._conn.remotecall(self._oid, "frame_code", (self._fid,), {})223 return CodeProxy(self._conn, self._oid, cid)226 did = self._conn.remotecall(self._oid, "frame_globals",231 did = self._conn.remotecall(self._oid, "frame_locals",238 dp = DictProxy(self._conn, self._oid, did)246 self._conn = conn252 return self._conn.remotecall(self._oid, "code_name",255 return self._conn.remotecall(self._oid, "code_filename",[all …]
1161 self._conn = conn1179 (self._conn.host, self._conn.port) = self._conn._get_hostport(host, port)1180 self._conn.connect()1196 response = self._conn.getresponse()1200 response = self._conn.getresponse(buffering)1207 self.file = self._conn.sock.makefile('rb', 0)1220 self._conn.close()
897 self._conn = {}905 for conn in self._conn.values():907 self._conn = {}937 self._conn[(task_type, task_id)] = conn1961 for conn in self._conn.values():965 for (task_type, task_id), conn in self._conn.items():
447 self._conn = conn455 self._conn.send_bytes(s)457 s = self._conn.recv_bytes()
462 c = http._conn750 self.assertEqual(self.conn._conn.host, HOST)751 self.assertEqual(self.conn._conn.port, self.port)758 self.assertNotEqual(self.conn._conn.host, testhost)759 self.assertNotEqual(self.conn._conn.port, testport)760 self.assertEqual(self.conn._conn.host, HOST)761 self.assertEqual(self.conn._conn.port, self.port)
772 self._conn = conn780 self._conn.send_bytes(s)782 s = self._conn.recv_bytes()
102 #define wsi_for_each_display_mode(_mode, _conn) \ argument104 &(_conn)->display_modes, list)106 #define wsi_for_each_connector(_conn, _dev) \ argument107 list_for_each_entry_safe(struct wsi_display_connector, _conn, \