(self, hashId, stream=1)
| 51 | self.poissonTimeout()) |
| 52 | |
| 53 | def setHashStream(self, hashId, stream=1): |
| 54 | with self.lock: |
| 55 | if hashId in self.hashMap: |
| 56 | self.hashMap[hashId] = Stem( |
| 57 | self.hashMap[hashId].child, |
| 58 | stream, |
| 59 | self.poissonTimeout()) |
| 60 | |
| 61 | def removeHash(self, hashId, reason="no reason specified"): |
| 62 | logging.debug("%s entering fluff mode due to %s.", ''.join('%02x'%ord(i) for i in hashId), reason) |
no test coverage detected