Lines Matching refs:inputs
93 """Generate inputs for multiprocessed merging.
102 inputs = []
114 inputs.extend([(keep, coverage_dir, executable, i, b)
116 return inputs
119 def merge_parallel(inputs, merge_fun=merge):
123 return pool.map(merge_fun, inputs)
136 inputs = generate_inputs(
140 (len(inputs), len(file_map)))
142 results = merge_parallel(inputs)
152 inputs = [(options.keep, options.coverage_dir, executable, None, files)
155 logging.info('Merging %d intermediate results.' % len(inputs))
157 merge_parallel(inputs)
196 inputs = [(options.swarming_output_dir, options.coverage_dir, f)
199 logging.info('Executing %d merge jobs in parallel.' % len(inputs))
200 merge_parallel(inputs, merge_two)