Lines Matching refs:proto
163 self.proto = NullProtocol()
167 repr(self.proto),
173 self.proto.runstate,
179 self.proto.name,
185 self.proto.logger.name,
190 self.proto = NullProtocol('Steve')
193 self.proto.name,
198 self.proto.logger.name,
203 repr(self.proto),
211 self.proto = NullProtocol(type(self).__name__)
212 self.assertEqual(self.proto.runstate, Runstate.IDLE)
216 self.assertEqual(self.proto.runstate, Runstate.IDLE)
267 new_state = await self.proto.runstate_changed()
290 await self.proto.disconnect()
301 await self.proto.connect(('127.0.0.1', 0))
303 await self.proto.connect('/dev/null')
307 await self.proto.connect(addr)
345 state = await self.proto.runstate_changed()
369 state = await self.proto.runstate_changed()
384 state = await self.proto.runstate_changed()
412 assert self.proto.runstate == Runstate.CONNECTING
429 await self.proto.start_server_and_accept(('example.com', 1))
431 await self.proto.start_server_and_accept('/dev/null')
435 sock = os.path.join(tmpdir, type(self.proto).__name__ + ".sock")
436 await self.proto.start_server_and_accept(sock)
443 self.proto.fake_session = True
450 await self.proto.disconnect()
459 await self.proto.connect('/not/a/real/path')
460 self.assertEqual(self.proto.runstate, Runstate.RUNNING)
465 await self.proto.start_server_and_accept('/not/a/real/path')
466 self.assertEqual(self.proto.runstate, Runstate.RUNNING)
471 await self.proto.start_server_and_accept('/not/a/real/path')
473 logname = self.proto.logger.name
475 self.proto.trigger_input.set()
476 self.proto.trigger_input.clear()
487 await self.proto.start_server_and_accept('/not/a/real/path')
489 logname = self.proto.logger.name
492 await self.proto.send_msg()
509 await self.proto.start_server_and_accept('/not/a/real/path')
511 await self.proto.connect('/not/a/real/path')
520 await self.proto.start_server_and_accept('/not/a/real/path')
531 await self.proto.start_server_and_accept('/not/a/real/path')
542 await self.proto.start_server_and_accept('/not/a/real/path')
545 await self.proto.simulate_disconnect()
557 await self.proto.start_server_and_accept('/not/a/real/path')
560 await self.proto.simulate_disconnect()
581 await self.proto.disconnect()
591 sock = os.path.join(tmpdir, type(self.proto).__name__ + ".sock")
596 await self.proto.connect(sock)