(self, hashId, source=None, stream=1)
| 42 | return start + expovariate(1.0/average) + FLUFF_TRIGGER_FIXED_DELAY |
| 43 | |
| 44 | def addHash(self, hashId, source=None, stream=1): |
| 45 | if not state.dandelion: |
| 46 | return |
| 47 | with self.lock: |
| 48 | self.hashMap[hashId] = Stem( |
| 49 | self.getNodeStem(source), |
| 50 | stream, |
| 51 | self.poissonTimeout()) |
| 52 | |
| 53 | def setHashStream(self, hashId, stream=1): |
| 54 | with self.lock: |
no test coverage detected