(self, stream, hashId)
| 19 | self.name = "InvBroadcaster" |
| 20 | |
| 21 | def handleLocallyGenerated(self, stream, hashId): |
| 22 | Dandelion().addHash(hashId, stream=stream) |
| 23 | for connection in BMConnectionPool().inboundConnections.values() + \ |
| 24 | BMConnectionPool().outboundConnections.values(): |
| 25 | if state.dandelion and connection != Dandelion().objectChildStem(hashId): |
| 26 | continue |
| 27 | connection.objectsNewToThem[hashId] = time() |
| 28 | |
| 29 | def run(self): |
| 30 | while not state.shutdown: |
no test coverage detected