python/tests/protocol.py

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)