Lines Matching refs:port_offset

60 def run_cert(iteration_id: int, port_offset: int, script: str, run_directory: str):
69         env['PORT_OFFSET'] = str(port_offset)
143         for port_offset in range(0, size):
144             self.release(port_offset)
149     def release(self, port_offset: int):
150         assert 0 <= port_offset < self._size, port_offset
151         self._pool.put_nowait(port_offset)
179     def result_callback(iteration_id, script, dic, port_offset):  argument
180         port_offset_pool.release(port_offset)
184         port_offset = port_offset_pool.allocate()
185         pool.apply_async(run_cert, [i, port_offset, script, run_directory],
186 …                callback=lambda ret, id=i, script=script, port_offset=port_offset: result_callback(
187                              id, script, script_successes, port_offset),
188 …          error_callback=lambda ret, id=i, script=script, port_offset=port_offset: result_callback(
189                              id, script, script_failures, port_offset))