http downloaded blocks stat

hbs2-peer/app/BlockHttpDownload.hs

@@ -127,6 +127,7 @@ blockHttpDownloadLoop denv = do
         case r of
           Right (Just block) -> do
               trace $ "SUCCESS" <+> pretty peer <+> "http-download block" <+> pretty h
+              liftIO $ atomically $ modifyTVar (_peerHttpDownloaded pinfo) (+1)
               sto <- getStorage
               liftIO $ putBlock sto block
               withDownload denv $ processBlock h

hbs2-peer/app/PeerInfo.hs

@@ -152,6 +152,7 @@ peerPingLoop cfg = do
       downMiss  <- liftIO $ readTVarIO (view peerDownloadMiss pinfo)
       down      <- liftIO $ readTVarIO (view peerDownloadedBlk pinfo)
       rtt       <- liftIO $ medianPeerRTT pinfo <&> fmap realToFrac
+      httpDownloaded <- liftIO $ readTVarIO (_peerHttpDownloaded pinfo)
       seen      <- liftIO $ readTVarIO (view peerLastWatched pinfo)
       let l = realToFrac (toNanoSecs $ now - seen) / 1e9
 
@@ -164,6 +165,7 @@ peerPingLoop cfg = do
                                    <+> "down:" <+> pretty down
                                    <+> "miss:" <+> pretty downMiss
                                    <+> "rtt:" <+> pretty rttMs
+                                   <+> "http:" <+> pretty httpDownloaded
                                    <+> "seen" <+> pretty ls
       pure ()
 

hbs2-peer/app/PeerTypes.hs

@@ -58,6 +58,7 @@ data PeerInfo e =
   , _peerRTTBuffer      :: TVar [Integer] -- ^ Contains a list of the last few round-trip time (RTT) values, measured in nanoseconds.
                                           -- Acts like a circular buffer.
   , _peerHttpApiAddress :: TVar (Either Int (Maybe String))
+  , _peerHttpDownloaded :: TVar Int
   }
   deriving stock (Generic,Typeable)
 
@@ -80,6 +81,7 @@ newPeerInfo = liftIO do
            <*> newTVarIO 0
            <*> newTVarIO []
            <*> newTVarIO (Left 0)
+           <*> newTVarIO 0
 
 type instance SessionData e (PeerInfo e) = PeerInfo e