expose block id number in apps web page

src/app.rs

@@ -273,6 +273,10 @@ impl App {
         }
     }
 
+    pub fn reported_block_id_number(&self) -> u64 {
+        self.block_id_manager.get_blocks_number().unwrap_or(0)
+    }
+
     pub fn huge_partition_number(&self) -> u64 {
         self.huge_partition_number.load(SeqCst)
     }

src/block_id_manager.rs

@@ -18,7 +18,7 @@ pub trait BlockIdManager: Send + Sync {
     async fn get_multi_block_ids(&self, ctx: GetMultiBlockIdsContext) -> Result<Bytes>;
     async fn report_multi_block_ids(&self, ctx: ReportMultiBlockIdsContext) -> Result<()>;
     async fn purge_block_ids(&self, shuffle_id: i32) -> Result<()>;
-    async fn get_blocks_number(&self) -> Result<u64>;
+    fn get_blocks_number(&self) -> Result<u64>;
 }
 
 #[derive(Clone, Debug, Serialize, Deserialize, PartialEq)]
@@ -96,7 +96,7 @@ impl BlockIdManager for PartitionedBlockIdManager {
         Ok(())
     }
 
-    async fn get_blocks_number(&self) -> Result<u64> {
+    fn get_blocks_number(&self) -> Result<u64> {
         let number = self.number.load(SeqCst);
         Ok(number)
     }
@@ -165,7 +165,7 @@ impl BlockIdManager for DefaultBlockIdManager {
         Ok(())
     }
 
-    async fn get_blocks_number(&self) -> Result<u64> {
+    fn get_blocks_number(&self) -> Result<u64> {
         Ok(self.number.load(SeqCst))
     }
 }
@@ -201,7 +201,7 @@ mod tests {
                 block_ids: partitioned_block_ids.clone(),
             })
             .await?;
-        assert_eq!(100 * 20, manager.get_blocks_number().await?);
+        assert_eq!(100 * 20, manager.get_blocks_number()?);
 
         // get by one partition
         for partition_id in 0..100 {
@@ -245,7 +245,7 @@ mod tests {
 
         // purge
         manager.purge_block_ids(shuffle_id).await?;
-        assert_eq!(0, manager.get_blocks_number().await?);
+        assert_eq!(0, manager.get_blocks_number()?);
 
         Ok(())
     }

src/http/apps.rs

@@ -51,6 +51,7 @@ fn table() -> Html<String> {
                 <th>duration (minutes)</th>
                 <th>resident data (gb)</th>
                 <th>partition number/huge partition</th>
+                <th>reported block id number</th>
             </tr>
     "#
     .to_string();
@@ -73,13 +74,14 @@ fn table() -> Html<String> {
             .to_string();
 
         html_content.push_str(&format!(
-            "<tr><td>{}</td><td>{}</td><td>{}</td><td>{}</td><td>{}/{}</td></tr>",
+            "<tr><td>{}</td><td>{}</td><td>{}</td><td>{}</td><td>{}/{}</td><td>{}</td></tr>",
             app_id,
             date,
             duration_min,
             bytes_to_gb(resident_bytes),
             app.partition_number(),
             app.huge_partition_number(),
+            app.reported_block_id_number(),
         ));
     }