|
@@ -126,7 +126,7 @@ discard block |
|
|
block discarded – undo |
|
126
|
126
|
/** @var Lock $lock */ |
|
127
|
127
|
foreach ($locks as $lock) { |
|
128
|
128
|
if ($lock->isCommandLocked()) { |
|
129
|
|
- $lockNames[] = str_replace(sprintf('%s_', $channel), '', $lock->getChannel()) ; |
|
|
129
|
+ $lockNames[] = str_replace(sprintf('%s_', $channel), '', $lock->getChannel()); |
|
130
|
130
|
} |
|
131
|
131
|
} |
|
132
|
132
|
|
|
@@ -174,7 +174,7 @@ discard block |
|
|
block discarded – undo |
|
174
|
174
|
*/ |
|
175
|
175
|
private function calculateAvailableSlotsCount($lockNames, $fieldGroupIdentifierList, $maxConcurrentJobsCount) |
|
176
|
176
|
{ |
|
177
|
|
- $concurrentJobsCount = count(array_intersect($fieldGroupIdentifierList , $lockNames)); |
|
|
177
|
+ $concurrentJobsCount = count(array_intersect($fieldGroupIdentifierList, $lockNames)); |
|
178
|
178
|
|
|
179
|
179
|
return $maxConcurrentJobsCount - $concurrentJobsCount; |
|
180
|
180
|
} |
Please login to merge, or discard this patch.