(self)
| 27 | self.stop.wait(10) |
| 28 | |
| 29 | def announceSelf(self): |
| 30 | for connection in BMConnectionPool().udpSockets.values(): |
| 31 | if not connection.announcing: |
| 32 | continue |
| 33 | for stream in state.streamsInWhichIAmParticipating: |
| 34 | addr = (stream, state.Peer('127.0.0.1', BMConfigParser().safeGetInt("bitmessagesettings", "port")), time.time()) |
| 35 | connection.append_write_buf(BMProto.assembleAddr([addr])) |
no test coverage detected