(self)
| 143 | self.startWorkers(reason="More peers found") |
| 144 | |
| 145 | def getMaxWorkers(self): |
| 146 | if len(self.tasks) > 50: |
| 147 | return config.workers * 3 |
| 148 | else: |
| 149 | return config.workers |
| 150 | |
| 151 | # Add new worker |
| 152 | def addWorker(self, peer, multiplexing=False, force=False): |
no outgoing calls
no test coverage detected