mmucklo /
DtcQueueBundle
| @@ 44-55 (lines=12) @@ | ||
| 41 | parent::__construct($runManager, $jobTimingManager, $jobClass, $jobArchiveClass); |
|
| 42 | } |
|
| 43 | ||
| 44 | protected function getFetchCount($totalCount) |
|
| 45 | { |
|
| 46 | $fetchCount = intval($totalCount / 10); |
|
| 47 | if ($fetchCount < self::FETCH_COUNT_MIN) { |
|
| 48 | $fetchCount = self::FETCH_COUNT_MIN; |
|
| 49 | } |
|
| 50 | if ($fetchCount > self::FETCH_COUNT_MAX) { |
|
| 51 | $fetchCount = self::FETCH_COUNT_MAX; |
|
| 52 | } |
|
| 53 | ||
| 54 | return $fetchCount; |
|
| 55 | } |
|
| 56 | ||
| 57 | protected function getSaveCount($totalCount) |
|
| 58 | { |
|
| @@ 57-68 (lines=12) @@ | ||
| 54 | return $fetchCount; |
|
| 55 | } |
|
| 56 | ||
| 57 | protected function getSaveCount($totalCount) |
|
| 58 | { |
|
| 59 | $saveCount = intval($totalCount / 10); |
|
| 60 | if ($saveCount < self::SAVE_COUNT_MIN) { |
|
| 61 | $saveCount = self::SAVE_COUNT_MIN; |
|
| 62 | } |
|
| 63 | if ($saveCount > self::SAVE_COUNT_MAX) { |
|
| 64 | $saveCount = self::SAVE_COUNT_MAX; |
|
| 65 | } |
|
| 66 | ||
| 67 | return $saveCount; |
|
| 68 | } |
|
| 69 | ||
| 70 | /** |
|
| 71 | * @return ObjectManager |
|
