mirror of https://github.com/voidlizard/hbs2
wip
This commit is contained in:
parent
ca72d543d7
commit
72549d01de
|
@ -42,7 +42,7 @@ defProtoPipelineSize :: Int
|
||||||
defProtoPipelineSize = 65536*2
|
defProtoPipelineSize = 65536*2
|
||||||
|
|
||||||
defCookieTimeoutSec :: Timeout 'Seconds
|
defCookieTimeoutSec :: Timeout 'Seconds
|
||||||
defCookieTimeoutSec = 1200
|
defCookieTimeoutSec = 3600
|
||||||
|
|
||||||
defCookieTimeout :: TimeSpec
|
defCookieTimeout :: TimeSpec
|
||||||
defCookieTimeout = toTimeSpec defCookieTimeoutSec
|
defCookieTimeout = toTimeSpec defCookieTimeoutSec
|
||||||
|
|
|
@ -533,14 +533,15 @@ postponedLoop env0 = do
|
||||||
forever do
|
forever do
|
||||||
pause @'Seconds 10
|
pause @'Seconds 10
|
||||||
wip1 <- asks (view blockWip) >>= liftIO . Cache.keys
|
wip1 <- asks (view blockWip) >>= liftIO . Cache.keys
|
||||||
|
wip2 <- liftIO $ readTVarIO twip
|
||||||
|
|
||||||
when (wip0 == length wip1) do
|
when (length wip1 == wip2) do
|
||||||
trace "download stuck"
|
trace "download stuck"
|
||||||
for_ wip1 $ \h -> do
|
for_ wip1 $ \h -> do
|
||||||
removeFromWip h
|
removeFromWip h
|
||||||
addDownload h
|
addDownload h
|
||||||
wip2 <- asks (view blockWip) >>= liftIO . Cache.keys
|
wip3 <- asks (view blockWip) >>= liftIO . Cache.keys
|
||||||
liftIO $ atomically $ writeTVar twip (length wip2)
|
liftIO $ atomically $ writeTVar twip (length wip3)
|
||||||
|
|
||||||
void $ liftIO $ async $ withPeerM e $ withDownload env0 do
|
void $ liftIO $ async $ withPeerM e $ withDownload env0 do
|
||||||
forever do
|
forever do
|
||||||
|
|
|
@ -120,7 +120,7 @@ downloadQueue conf denv = do
|
||||||
debug "downloadQueue okay"
|
debug "downloadQueue okay"
|
||||||
|
|
||||||
-- TODO: remove-downloadQueue-pause-hardcode
|
-- TODO: remove-downloadQueue-pause-hardcode
|
||||||
pause @'Seconds 300
|
pause @'Seconds 150
|
||||||
-- FIXME: only-debug-20-sec
|
-- FIXME: only-debug-20-sec
|
||||||
|
|
||||||
where
|
where
|
||||||
|
|
Loading…
Reference in New Issue