mirror of
https://github.com/simplex-chat/simplexmq.git
synced 2026-09-01 18:08:36 +00:00
Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d88b6352f9 |
@@ -438,8 +438,9 @@ setUserNetworkInfo c@AgentClient {userNetworkInfo, userNetworkDelay} netInfo = w
|
|||||||
let off = wasOnline && not (isOnline netInfo)
|
let off = wasOnline && not (isOnline netInfo)
|
||||||
when off $ writeTVar userNetworkDelay d
|
when off $ writeTVar userNetworkDelay d
|
||||||
pure off
|
pure off
|
||||||
liftIO . when off . void . forkIO $
|
-- liftIO . when off . void . forkIO $
|
||||||
growOfflineDelay 0 d ni
|
-- growOfflineDelay 0 d ni
|
||||||
|
pure ()
|
||||||
where
|
where
|
||||||
growOfflineDelay elapsed d ni = do
|
growOfflineDelay elapsed d ni = do
|
||||||
online <- waitOnlineOrDelay c d
|
online <- waitOnlineOrDelay c d
|
||||||
|
|||||||
@@ -856,9 +856,9 @@ getNetworkConfig c = do
|
|||||||
_ -> fastCfg
|
_ -> fastCfg
|
||||||
|
|
||||||
waitForUserNetwork :: AgentClient -> IO ()
|
waitForUserNetwork :: AgentClient -> IO ()
|
||||||
waitForUserNetwork c =
|
waitForUserNetwork c = pure ()
|
||||||
unlessM (atomically $ isNetworkOnline c) $
|
-- unlessM (atomically $ isNetworkOnline c) $
|
||||||
readTVarIO (userNetworkDelay c) >>= void . waitOnlineOrDelay c
|
-- readTVarIO (userNetworkDelay c) >>= void . waitOnlineOrDelay c
|
||||||
|
|
||||||
waitOnlineOrDelay :: AgentClient -> Int64 -> IO Bool
|
waitOnlineOrDelay :: AgentClient -> Int64 -> IO Bool
|
||||||
waitOnlineOrDelay c t = do
|
waitOnlineOrDelay c t = do
|
||||||
|
|||||||
Reference in New Issue
Block a user