log: logging query_finalized_custodian_cells

godwokenrises · Jan 19, 2022 · d058e2f · d058e2f
1 parent 0c976ea
commit d058e2f
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/crates/rpc-client/src/rpc_client.rs b/crates/rpc-client/src/rpc_client.rs
@@ -28,6 +28,7 @@ use gw_types::{
 use rand::prelude::*;
 use serde_json::json;
 
+use std::time::Instant;
 use std::{collections::HashSet, time::Duration};
 
 fn to_cell_info(cell: Cell) -> CellInfo {
@@ -974,6 +975,11 @@ impl RPCClient {
         max_cells: usize,
     ) -> Result<QueryResult<CollectedCustodianCells>> {
         const MAX_CELLS: usize = 50;
+
+        let mut query_indexer_times = 0;
+        let mut query_indexer_cells = 0;
+        let now = Instant::now();
+
         let rollup_context = &self.rollup_context;
 
         let parse_sudt_amount = |cell: &Cell| -> Result<u128> {
@@ -1002,7 +1008,8 @@ impl RPCClient {
             script_type: ScriptType::Lock,
             filter,
         };
-        let order = Order::Desc;
+        // order by ASC so we can search more cells
+        let order = Order::Asc;
         let limit = Uint32::from(DEFAULT_QUERY_LIMIT as u32);
 
         let mut collected = CollectedCustodianCells::default();
@@ -1036,6 +1043,9 @@ impl RPCClient {
             }
             cursor = Some(cells.last_cursor);
 
+            query_indexer_times += 1;
+            query_indexer_cells += cells.objects.len();
+
             for cell in cells.objects.into_iter() {
                 if collected.cells_info.len() >= max_cells {
                     return Ok(QueryResult::NotEnough(collected));
@@ -1130,12 +1140,14 @@ impl RPCClient {
                     if collected.capacity >= required_capacity {
                         break;
                     } else {
+                        log::debug!("[query finalized custodian cells] query indexer times: {} query indexer cells: {} duration: {}ms", query_indexer_times, query_indexer_cells, now.elapsed().as_millis());
                         return Ok(QueryResult::NotEnough(collected));
                     }
                 }
             }
         }
 
+        log::debug!("[query finalized custodian cells] query indexer times: {} query indexer cells: {} duration: {}ms", query_indexer_times, query_indexer_cells, now.elapsed().as_millis());
         Ok(QueryResult::Full(collected))
     }