Use read index raft message 2

Cargo.toml

@@ -454,7 +454,7 @@ codegen-units = 4
 
 [profile.test]
 opt-level = 0
-debug = true
+debug = 0
 codegen-units = 16
 lto = false
 incremental = true

components/raftstore/src/store/peer.rs

@@ -1704,6 +1704,7 @@ where
                 "msg_size" => msg.get_message().compute_size(),
                 "to" => to_peer_id,
                 "disk_usage" => ?msg.get_disk_usage(),
+                "!!!!msg" => ?msg
             );
 
             for (term, index) in msg

proxy_components/mock-engine-store/src/mock_cluster/v1/cluster.rs

@@ -447,6 +447,10 @@ impl<T: Simulator<TiFlashEngine>> Cluster<T> {
         }
     }
 
+    pub fn get_router(&self, node_id: u64) -> Option<RaftRouter<TiFlashEngine, ProxyRaftEngine>> {
+        self.sim.rl().get_router(node_id)
+    }
+
     fn valid_leader_id(&self, region_id: u64, leader_id: u64) -> bool {
         let store_ids = match self.voter_store_ids_of_region(region_id) {
             None => return false,

proxy_components/mock-engine-store/src/mock_store/mock_engine_store_server.rs

@@ -359,6 +359,7 @@ unsafe extern "C" fn ffi_release_pre_handled_snapshot(
 pub fn gen_engine_store_server_helper(
     wrap: Pin<&EngineStoreServerWrap>,
 ) -> EngineStoreServerHelper {
+    info!("mock gen_engine_store_server_helper");
     EngineStoreServerHelper {
         magic_number: interfaces_ffi::RAFT_STORE_PROXY_MAGIC_NUMBER,
         version: interfaces_ffi::RAFT_STORE_PROXY_VERSION,

proxy_components/proxy_ffi/src/read_index_helper.rs

@@ -82,7 +82,7 @@ fn into_read_index_response<S: engine_traits::Snapshot>(
     resp
 }
 
-fn gen_read_index_raft_cmd_req(req: &mut ReadIndexRequest) -> RaftCmdRequest {
+pub fn gen_read_index_raft_cmd_req(req: &mut ReadIndexRequest) -> RaftCmdRequest {
     let region_id = req.get_context().get_region_id();
     let mut cmd = RaftCmdRequest::default();
     {