voidlizard
/
hbs2
mirror of https://github.com/voidlizard/hbs2
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

wip, debug

This commit is contained in:
voidlizard 2024-11-02 21:10:26 +03:00
parent 141595bd28
commit 5e15744f60
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbs2-core/lib/HBS2/Net/Messaging/TCP.hs
View File

@ -188,10 +188,12 @@ runMessagingTCP env@MessagingTCP{..} = liftIO do
void $ flip runContT pure do void $ flip runContT pure do
p1 <- ContT $ withAsync runClient forever do
p2 <- ContT $ withAsync runServer
waitAnyCatchCancel [p1,p2] p1 <- ContT $ withAsync runClient
p2 <- ContT $ withAsync runServer
waitAnyCatchCancel [p1,p2]
-- waitAnyCatchCancel [p2] -- waitAnyCatchCancel [p2]
-- waitAnyCatchCancel [p1] -- waitAnyCatchCancel [p1]
@ -277,9 +279,9 @@ runMessagingTCP env@MessagingTCP{..} = liftIO do
void $ ContT $ bracket none $ const do void $ ContT $ bracket none $ const do
debug $ "SHUTDOWN SOCKET AND SHIT" <+> pretty remote debug $ "SHUTDOWN SOCKET AND SHIT" <+> pretty remote
shutdown so ShutdownBoth
cancel rd cancel rd
cancel wr cancel wr
shutdown so ShutdownBoth
atomically do atomically do
modifyTVar _tcpSent (HM.delete newP) modifyTVar _tcpSent (HM.delete newP)
@ -312,7 +314,7 @@ runMessagingTCP env@MessagingTCP{..} = liftIO do
mzero mzero
-- FIXME: !!! -- FIXME: !!!
liftIO $ asyncLinked do liftIO $ async do
let (L4Address _ (IPAddrPort (ip,port))) = whoAddr let (L4Address _ (IPAddrPort (ip,port))) = whoAddr
connect (show ip) (show port) $ \(so, remoteAddr) -> do connect (show ip) (show port) $ \(so, remoteAddr) -> do
flip runContT pure $ callCC \exit -> do flip runContT pure $ callCC \exit -> do