Merge branch 'master' into ab/pclient-disconnected

transport: update PClient.connected on exit
2026-08-30 22:48:26 +00:00 · 2024-07-15 19:24:55 +01:00 · 2024-05-01 15:55:44 +03:00
1 changed files with 3 additions and 2 deletions
@@ -506,8 +506,9 @@ getProtocolClient g transportSession@(_, srv, _) cfg@ProtocolClientConfig {qSize
          atomically $ do
            writeTVar (connected c) True
            putTMVar cVar $ Right c'
-          raceAny_ ([send c' th, process c', receive c' th] <> [monitor c' | smpPingInterval > 0])
-            `finally` disconnected c'
+          raceAny_ ([send c' th, process c', receive c' th] <> [monitor c' | smpPingInterval > 0]) `finally` do
+            atomically $ writeTVar (connected c) False
+            disconnected c'

    send :: Transport c => ProtocolClient v err msg -> THandle v c 'TClient -> IO ()
    send ProtocolClient {client_ = PClient {sndQ}} h = forever $ atomically (readTBQueue sndQ) >>= sendPending
Author	SHA1	Message	Date
Evgeny Poberezkin	fd3a78a545	Merge branch 'master' into ab/pclient-disconnected	2024-07-15 19:24:55 +01:00
Alexander Bondarenko	36511d0413	transport: update PClient.connected on exit	2024-05-01 15:55:44 +03:00