(self)
| 120 | return self.nodeMap[node] |
| 121 | |
| 122 | def expire(self): |
| 123 | with self.lock: |
| 124 | deadline = time() |
| 125 | # only expire those that have a child node, i.e. those without a child not will stick around |
| 126 | toDelete = [[v.stream, k, v.child] for k, v in self.hashMap.iteritems() if v.timeout < deadline and v.child] |
| 127 | for row in toDelete: |
| 128 | self.removeHash(row[1], 'expiration') |
| 129 | invQueue.put((row[0], row[1], row[2])) |
| 130 | |
| 131 | def reRandomiseStems(self): |
| 132 | with self.lock: |
no test coverage detected