(self)
| 22 | self.resetChunkSize() |
| 23 | |
| 24 | def recalculate(self): |
| 25 | with self.lock: |
| 26 | now = int(time.time()) |
| 27 | if now > self.txTime: |
| 28 | self.speed = self.txLen / (now - self.txTime) |
| 29 | self.txLen -= self.limit * (now - self.txTime) |
| 30 | self.txTime = now |
| 31 | if self.txLen < 0 or self.limit == 0: |
| 32 | self.txLen = 0 |
| 33 | |
| 34 | def wait(self, dataLen): |
| 35 | with self.lock: |