mirror of
https://github.com/simplex-chat/simplexmq.git
synced 2026-04-05 04:36:11 +00:00
more delay, less worker delay
This commit is contained in:
@@ -503,14 +503,14 @@ testNotificationsSMPRestartBatch :: Int -> ATransport -> APNSMockServer -> IO ()
|
||||
testNotificationsSMPRestartBatch n t APNSMockServer {apnsQ} = do
|
||||
a <- getSMPAgentClient' agentCfg initAgentServers2 testDB
|
||||
b <- getSMPAgentClient' agentCfg initAgentServers2 testDB2
|
||||
threadDelay 3000000
|
||||
threadDelay 5000000
|
||||
conns <- runServers $ do
|
||||
liftIO $ print 1
|
||||
conns <- replicateM (n :: Int) $ makeConnection a b
|
||||
liftIO $ print 2
|
||||
_ <- registerTestToken a "abcd" NMInstant apnsQ
|
||||
liftIO $ print 3
|
||||
liftIO $ threadDelay 3000000
|
||||
liftIO $ threadDelay 10000000
|
||||
liftIO $ print 4
|
||||
forM_ (zip [0..] conns) $ \(i, (aliceId, bobId)) -> do
|
||||
liftIO $ putStrLn $ "*** msg " <> show i
|
||||
|
||||
@@ -198,8 +198,8 @@ agentCfg =
|
||||
ntfCfg = defaultClientConfig {qSize = 1, defaultTransport = (ntfTestPort, transport @TLS)},
|
||||
reconnectInterval = defaultReconnectInterval {initialInterval = 50_000},
|
||||
xftpNotifyErrsOnRetry = False,
|
||||
ntfWorkerDelay = 1000,
|
||||
ntfSMPWorkerDelay = 1000,
|
||||
ntfWorkerDelay = 100,
|
||||
ntfSMPWorkerDelay = 100,
|
||||
caCertificateFile = "tests/fixtures/ca.crt",
|
||||
privateKeyFile = "tests/fixtures/server.key",
|
||||
certificateFile = "tests/fixtures/server.crt"
|
||||
|
||||
@@ -35,7 +35,7 @@ logCfg = LogConfig {lc_file = Nothing, lc_stderr = True}
|
||||
|
||||
main :: IO ()
|
||||
main = do
|
||||
setLogLevel LogError -- LogInfo
|
||||
setLogLevel LogInfo
|
||||
withGlobalLogging logCfg $ do
|
||||
setEnv "APNS_KEY_ID" "H82WD9K9AQ"
|
||||
setEnv "APNS_KEY_FILE" "./tests/fixtures/AuthKey_H82WD9K9AQ.p8"
|
||||
|
||||
Reference in New Issue
Block a user