(self, dataLen)
| 32 | self.txLen = 0 |
| 33 | |
| 34 | def wait(self, dataLen): |
| 35 | with self.lock: |
| 36 | self.txLen += dataLen |
| 37 | self.total += dataLen |
| 38 | while state.shutdown == 0: |
| 39 | self.recalculate() |
| 40 | if self.limit == 0: |
| 41 | break |
| 42 | if self.txLen < self.limit: |
| 43 | break |
| 44 | self.timer.wait(0.2) |
| 45 | |
| 46 | def getSpeed(self): |
| 47 | self.recalculate() |
no test coverage detected