Lines Matching refs:proto
34 def ssl_protocol(self, *, waiter=None, proto=None):
36 if proto is None: # app protocol
37 proto = asyncio.Protocol()
38 ssl_proto = sslproto.SSLProtocol(self.loop, proto, sslcontext, waiter,
40 self.assertIs(ssl_proto._app_transport.get_protocol(), proto)
199 proto = Proto(1, usemv)
200 protocols._feed_data_to_buffered_proto(proto, b'12345')
201 self.assertEqual(proto.data, b'12345')
203 proto = Proto(2, usemv)
204 protocols._feed_data_to_buffered_proto(proto, b'12345')
205 self.assertEqual(proto.data, b'12345')
207 proto = Proto(2, usemv)
208 protocols._feed_data_to_buffered_proto(proto, b'1234')
209 self.assertEqual(proto.data, b'1234')
211 proto = Proto(4, usemv)
212 protocols._feed_data_to_buffered_proto(proto, b'1234')
213 self.assertEqual(proto.data, b'1234')
215 proto = Proto(100, usemv)
216 protocols._feed_data_to_buffered_proto(proto, b'12345')
217 self.assertEqual(proto.data, b'12345')
219 proto = Proto(0, usemv)
221 protocols._feed_data_to_buffered_proto(proto, b'12345')
250 def connection_made(proto, tr):
251 proto.con_made_cnt += 1
253 self.assertEqual(proto.con_made_cnt, 1)
267 tr, proto = await self.loop.create_connection(
271 new_tr = await self.loop.start_tls(tr, proto, client_context)
313 def connection_made(proto, tr):
315 proto.tr = tr
316 proto.con_made_cnt += 1
318 self.assertEqual(proto.con_made_cnt, 1)
332 tr, proto = await self.loop.create_connection(
418 tr, proto = await self.loop.create_connection(
422 new_tr = await self.loop.start_tls(tr, proto, client_context)
471 def connection_made(proto, tr):
472 proto.con_made_cnt += 1
474 self.assertEqual(proto.con_made_cnt, 1)
488 tr, proto = await self.loop.create_connection(
497 self.loop.start_tls(tr, proto, client_context),
553 async def main(proto, on_con, on_con_lost, on_got_hello):
557 self.assertEqual(proto.data, b'')
560 tr, proto, server_context,
563 proto.replace_transport(new_tr)
569 self.assertEqual(proto.data, HELLO_MSG)
576 proto = ServerProto(on_con, on_con_lost, on_got_hello)
579 lambda: proto, '127.0.0.1', 0)
585 main(proto, on_con, on_con_lost, on_got_hello),