185 initialTasks = 2 * NumberOfProcesses |
185 initialTasks = 2 * NumberOfProcesses |
186 for task in argumentsList[:initialTasks]: |
186 for task in argumentsList[:initialTasks]: |
187 taskQueue.put(task) |
187 taskQueue.put(task) |
188 |
188 |
189 # Start worker processes |
189 # Start worker processes |
190 for i in range(NumberOfProcesses): |
190 for _ in range(NumberOfProcesses): |
191 multiprocessing.Process(target=worker, args=(taskQueue, doneQueue))\ |
191 multiprocessing.Process(target=worker, args=(taskQueue, doneQueue))\ |
192 .start() |
192 .start() |
193 |
193 |
194 # Get and send results |
194 # Get and send results |
195 endIndex = len(argumentsList) - initialTasks |
195 endIndex = len(argumentsList) - initialTasks |
215 |
215 |
216 if i < endIndex: |
216 if i < endIndex: |
217 taskQueue.put(argumentsList[i + initialTasks]) |
217 taskQueue.put(argumentsList[i + initialTasks]) |
218 |
218 |
219 # Tell child processes to stop |
219 # Tell child processes to stop |
220 for i in range(NumberOfProcesses): |
220 for _ in range(NumberOfProcesses): |
221 taskQueue.put('STOP') |
221 taskQueue.put('STOP') |
222 |
222 |
223 |
223 |
224 def worker(inputQueue, outputQueue): |
224 def worker(inputQueue, outputQueue): |
225 """ |
225 """ |
320 complexityChecker.run() |
320 complexityChecker.run() |
321 stats.update(complexityChecker.counters) |
321 stats.update(complexityChecker.counters) |
322 errors += complexityChecker.errors |
322 errors += complexityChecker.errors |
323 |
323 |
324 errorsDict = {} |
324 errorsDict = {} |
325 for fname, lineno, position, text in errors: |
325 for _fname, lineno, position, text in errors: |
326 if lineno > len(source): |
326 if lineno > len(source): |
327 lineno = len(source) |
327 lineno = len(source) |
328 # inverse processing of messages and fixes |
328 # inverse processing of messages and fixes |
329 errorLine = errorsDict.setdefault(lineno, []) |
329 errorLine = errorsDict.setdefault(lineno, []) |
330 errorLine.append([position, text]) |
330 errorLine.append([position, text]) |