This commit is contained in:
Dmitry Zuikov 2023-01-22 14:53:15 +03:00
parent 9a497efea4
commit 6c0aef1e25
2 changed files with 2 additions and 5 deletions

View File

@ -258,14 +258,11 @@ instance ( HasProtocol e p
let sk = newSKey @(EventKey e p) k
void $ runMaybeT $ do
liftIO $ print $ "GOOD" <+> pretty me <+> pretty (hash sk)
subs <- MaybeT $ liftIO $ atomically $ readTVar se <&> HashMap.lookup sk
liftIO $ print $ "VERY GOOD" <+> pretty me
void $ liftIO $ atomically $ modifyTVar' se (HashMap.delete sk)
for_ subs $ \r -> do
ev <- MaybeT $ pure $ fromDynamic @(EventHandler e p (PeerM e IO)) r
lift $ ev d
liftIO $ print $ "FINE" <+> pretty me
runPeerM :: (MonadIO m, Pretty (Peer e)) => AnyStorage -> Fabriq e -> Peer e -> PeerM e m a -> m ()
runPeerM s bus p f = do

View File

@ -170,8 +170,8 @@ blockDownloadLoop :: forall e . ( HasProtocol e (BlockSize e)
blockDownloadLoop = do
let blks = [ "5KP4vM6RuEX6RA1ywthBMqZV5UJDLANC17UrF6zuWdRt"
-- , "81JeD7LNR6Q7RYfyWBxfjJn1RsWzvegkUXae6FUNgrMZ"
-- , "AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"
, "81JeD7LNR6Q7RYfyWBxfjJn1RsWzvegkUXae6FUNgrMZ"
, "AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"
]
for_ blks $ \h -> do