cargo fmt
This commit is contained in:
parent
77abc98f47
commit
db82618863
|
@ -516,14 +516,20 @@ fn consume_events_loop(
|
|||
let (req_header, req_seg0, req_seg1) = parse_event_queue(&req_inner)?;
|
||||
let event_q_len = seg0.len() + seg1.len();
|
||||
let req_q_len = req_seg0.len() + req_seg1.len();
|
||||
info!("Size of request queue is {}, market {}, coin {}, pc {}", req_q_len, market, coin_wallet, pc_wallet);
|
||||
info!(
|
||||
"Size of request queue is {}, market {}, coin {}, pc {}",
|
||||
req_q_len, market, coin_wallet, pc_wallet
|
||||
);
|
||||
|
||||
if event_q_len == 0 {
|
||||
debug_println!("Total event queue length: 0, returning early");
|
||||
let one_hundred_millis = time::Duration::from_millis(300);
|
||||
thread::sleep(one_hundred_millis);
|
||||
} else {
|
||||
info!("Total event queue length: {}, market {}, coin {}, pc {}", event_q_len, market, coin_wallet, pc_wallet);
|
||||
info!(
|
||||
"Total event queue length: {}, market {}, coin {}, pc {}",
|
||||
event_q_len, market, coin_wallet, pc_wallet
|
||||
);
|
||||
let accounts = seg0.iter().chain(seg1.iter()).map(|event| event.owner);
|
||||
let mut used_accounts = BTreeSet::new();
|
||||
for account in accounts {
|
||||
|
@ -533,7 +539,13 @@ fn consume_events_loop(
|
|||
}
|
||||
}
|
||||
let mut orders_accounts: Vec<_> = used_accounts.into_iter().collect();
|
||||
info!("Number of unique order accounts: {}, market {}, coin {}, pc {}", orders_accounts.len(), market, coin_wallet, pc_wallet);
|
||||
info!(
|
||||
"Number of unique order accounts: {}, market {}, coin {}, pc {}",
|
||||
orders_accounts.len(),
|
||||
market,
|
||||
coin_wallet,
|
||||
pc_wallet
|
||||
);
|
||||
info!(
|
||||
"First 5 accouts: {:?}",
|
||||
orders_accounts
|
||||
|
|
Loading…
Reference in New Issue