Fix #595
This commit is contained in:
@@ -265,6 +265,9 @@ core.filter = async.throttle(
|
|||||||
local sources = {}
|
local sources = {}
|
||||||
for _, s in ipairs(self:get_sources({ source.SourceStatus.FETCHING, source.SourceStatus.COMPLETED })) do
|
for _, s in ipairs(self:get_sources({ source.SourceStatus.FETCHING, source.SourceStatus.COMPLETED })) do
|
||||||
if not s.incomplete and SOURCE_TIMEOUT > s:get_fetching_time() then
|
if not s.incomplete and SOURCE_TIMEOUT > s:get_fetching_time() then
|
||||||
|
-- Reserve filter call for timeout.
|
||||||
|
self.filter.timeout = SOURCE_TIMEOUT - s:get_fetching_time()
|
||||||
|
self:filter()
|
||||||
break
|
break
|
||||||
end
|
end
|
||||||
table.insert(sources, s)
|
table.insert(sources, s)
|
||||||
|
|||||||
Reference in New Issue
Block a user