| 152 | return 1.0 |
| 153 | |
| 154 | def clearHashes(self, objectHash=None): |
| 155 | if objectHash is None: |
| 156 | if self.lastCleared > time.time() - self.clearDelay: |
| 157 | return |
| 158 | objects = self.hashes.keys() |
| 159 | else: |
| 160 | objects = objectHash, |
| 161 | with self.lock: |
| 162 | for i in objects: |
| 163 | try: |
| 164 | if self.hashes[i]['sendCount'] > 0 and ( |
| 165 | len(self.hashes[i]['peers']) == 0 or |
| 166 | self.hashes[i]['created'] + self.objectWait < time.time()): |
| 167 | del self.hashes[i] |
| 168 | except KeyError: |
| 169 | pass |
| 170 | self.lastCleared = time.time() |
| 171 | |
| 172 | def delete(self, objectHash=None): |
| 173 | if not hasattr(current_thread(), 'peer'): |