equal
deleted
inserted
replaced
45 worker_id, _nworkers); |
45 worker_id, _nworkers); |
46 |
46 |
47 FOR_EACH_WEAK_PROCESSOR_PHASE(phase) { |
47 FOR_EACH_WEAK_PROCESSOR_PHASE(phase) { |
48 if (WeakProcessorPhases::is_serial(phase)) { |
48 if (WeakProcessorPhases::is_serial(phase)) { |
49 uint serial_index = WeakProcessorPhases::serial_index(phase); |
49 uint serial_index = WeakProcessorPhases::serial_index(phase); |
50 if (!_serial_phases_done.is_task_claimed(serial_index)) { |
50 if (_serial_phases_done.try_claim_task(serial_index)) { |
51 WeakProcessorPhaseTimeTracker pt(_phase_times, phase); |
51 WeakProcessorPhaseTimeTracker pt(_phase_times, phase); |
52 WeakProcessorPhases::processor(phase)(is_alive, keep_alive); |
52 WeakProcessorPhases::processor(phase)(is_alive, keep_alive); |
53 } |
53 } |
54 } else { |
54 } else { |
55 WeakProcessorPhaseTimeTracker pt(_phase_times, phase, worker_id); |
55 WeakProcessorPhaseTimeTracker pt(_phase_times, phase, worker_id); |