mirror of
https://github.com/simplex-chat/simplexmq.git
synced 2026-08-30 22:48:26 +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)
|
||||
when off $ writeTVar userNetworkDelay d
|
||||
pure off
|
||||
liftIO . when off . void . forkIO $
|
||||
growOfflineDelay 0 d ni
|
||||
-- liftIO . when off . void . forkIO $
|
||||
-- growOfflineDelay 0 d ni
|
||||
pure ()
|
||||
where
|
||||
growOfflineDelay elapsed d ni = do
|
||||
online <- waitOnlineOrDelay c d
|
||||
|
||||
@@ -856,9 +856,9 @@ getNetworkConfig c = do
|
||||
_ -> fastCfg
|
||||
|
||||
waitForUserNetwork :: AgentClient -> IO ()
|
||||
waitForUserNetwork c =
|
||||
unlessM (atomically $ isNetworkOnline c) $
|
||||
readTVarIO (userNetworkDelay c) >>= void . waitOnlineOrDelay c
|
||||
waitForUserNetwork c = pure ()
|
||||
-- unlessM (atomically $ isNetworkOnline c) $
|
||||
-- readTVarIO (userNetworkDelay c) >>= void . waitOnlineOrDelay c
|
||||
|
||||
waitOnlineOrDelay :: AgentClient -> Int64 -> IO Bool
|
||||
waitOnlineOrDelay c t = do
|
||||
|
||||
Reference in New Issue
Block a user