Update Forking class

This commit is contained in:
DariusIII
2018-01-15 11:51:53 +01:00
parent 452ba6e5e6
commit b8ec2d626c
+2 -3
View File
@@ -851,8 +851,7 @@ class Forking extends \fork_daemon
$this->register_child_run([0 => $this, 1 => 'postProcessChildWorker']);
$qry = Release::query()
->where('nzbstatus', '=', NZB::NZB_ADDED)
->whereBetween('nfostatus', [$this->maxRetries, Nfo::NFO_UNPROC])
->select(['leftguid as id']);
->whereBetween('nfostatus', [$this->maxRetries, Nfo::NFO_UNPROC]);
if ($this->maxSize > 0) {
$qry->where('size', '<', $this->maxSize * 1073741824);
@@ -862,7 +861,7 @@ class Forking extends \fork_daemon
$qry->where('size', '>', $this->minSize * 1048576);
}
$this->work = $qry->groupBy('leftguid')->limit(16)->get()->toArray();
$this->work = $qry->select(['leftguid as id'])->groupBy('leftguid')->limit(16)->get()->toArray();
$maxProcesses = (int) Settings::settingValue('..nfothreads');
}