| @@ -1155,8 +1155,7 @@ public abstract class Broadcast | |||||
| || state == BroadcastState.PAUSING | || state == BroadcastState.PAUSING | ||||
| ) | ) | ||||
| { | { | ||||
| //remainingJobs--; | |||||
| completedJobCount++; | |||||
| incrementCompletedCount(); | |||||
| logJobCount("Completed a job"); | logJobCount("Completed a job"); | ||||
| if (getRemainingJobCount() == 0) | if (getRemainingJobCount() == 0) | ||||
| @@ -1181,6 +1180,11 @@ public abstract class Broadcast | |||||
| } | } | ||||
| } | } | ||||
| synchronized private void incrementCompletedCount() | |||||
| { | |||||
| completedJobCount++; | |||||
| } | |||||
| /** | /** | ||||
| * Logs effectiveJobCount, completedJobCount, readyQueue.size(), | * Logs effectiveJobCount, completedJobCount, readyQueue.size(), | ||||
| * active job count, and total which recipientList.size() | * active job count, and total which recipientList.size() | ||||