logger: remove json-log event queue

Closes: aptos-labs#9960

consensus/src/block_storage/block_tree.rs

@@ -16,7 +16,6 @@ use diem_crypto::HashValue;
 use diem_logger::prelude::*;
 use diem_types::{block_info::BlockInfo, ledger_info::LedgerInfoWithSignatures};
 use mirai_annotations::{checked_verify_eq, precondition};
-use short_hex_str::AsShortHexStr;
 use std::{
     collections::{vec_deque::VecDeque, HashMap, HashSet},
     sync::Arc,
@@ -448,12 +447,6 @@ impl BlockTree {
             committed_round = committed_round,
             block_id = block_to_commit.id(),
         );
-        event!("committed",
-            "block_id": block_to_commit.id().short_str(),
-            "epoch": block_to_commit.epoch(),
-            "round": committed_round,
-            "parent_id": block_to_commit.parent_id().short_str(),
-        );
 
         let id_to_remove = self.find_blocks_to_prune(block_to_commit.id());
         if let Err(e) = storage.prune_tree(id_to_remove.clone().into_iter().collect()) {

crates/debug-interface/src/lib.rs

@@ -2,7 +2,6 @@
 // SPDX-License-Identifier: Apache-2.0
 
 use anyhow::Result;
-use diem_logger::json_log::JsonLogEntry;
 use reqwest::{blocking, Url};
 use std::collections::HashMap;
 
@@ -79,14 +78,6 @@ impl NodeDebugClient {
             })
             .collect()
     }
-
-    pub fn get_events(&self) -> Result<Vec<JsonLogEntry>> {
-        let mut url = self.url.clone();
-        url.set_path("events");
-        let response = self.client.get(url).send()?;
-
-        Ok(response.json()?)
-    }
 }
 
 /// Implement default utility client for AsyncNodeDebugInterface
@@ -129,14 +120,4 @@ impl AsyncNodeDebugClient {
             })
             .collect()
     }
-
-    pub async fn get_events(&mut self) -> Result<Vec<JsonLogEntry>> {
-        let response = self
-            .client
-            .get(&format!("{}/events", self.addr))
-            .send()
-            .await?;
-
-        Ok(response.json().await?)
-    }
 }

crates/debug-interface/src/node_debug_service.rs

@@ -4,7 +4,7 @@
 //! Debug interface to access information in a specific node.
 
 use diem_config::config::NodeConfig;
-use diem_logger::{info, json_log, Filter, Logger};
+use diem_logger::{info, Filter, Logger};
 use diem_metrics::json_metrics::get_git_rev;
 use serde::{Deserialize, Serialize};
 use std::{net::SocketAddr, sync::Arc};
@@ -36,9 +36,6 @@ impl NodeDebugService {
         let metrics =
             warp::path("metrics").map(|| warp::reply::json(&diem_metrics::get_all_metrics()));
 
-        // GET /events
-        let events = warp::path("events").map(|| warp::reply::json(&json_log::pop_last_entries()));
-
         // Post /log/filter
         let local_filter = {
             let logger = logger.clone();
@@ -83,7 +80,7 @@ impl NodeDebugService {
         };
         let node_info_route = warp::path("node-info").map(move || warp::reply::json(&node_info));
 
-        let routes = log.or(warp::get().and(metrics.or(events).or(node_info_route)));
+        let routes = log.or(warp::get().and(metrics.or(node_info_route)));
 
         runtime
             .handle()

crates/diem-logger/src/lib.rs

@@ -137,13 +137,12 @@ pub mod prelude {
     pub use crate::{
         debug,
         diem_logger::FileWriter,
-        error, event, info, sample,
+        error, info, sample,
         sample::{SampleRate, Sampling},
         security::SecurityEvent,
         trace, warn,
     };
 }
-pub mod json_log;
 
 mod diem_logger;
 mod event;