gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix logs

Browse Source
This commit is contained in:
Anatoly Yakovenko
2018-06-23 16:38:49 -07:00
committed by Greg Fitzgerald
parent 47583d48e7
commit 826e95afca
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/crdt.rs
View File

@ -558,9 +558,8 @@ impl Crdt {
let cur = self.table.values().filter(|x| x.current_leader_id != def); let cur = self.table.values().filter(|x| x.current_leader_id != def);
for v in cur { for v in cur {
let cnt = table.entry(&v.current_leader_id).or_insert(0); let cnt = table.entry(&v.current_leader_id).or_insert(0);
//let cnt = table.get_mut(&v.current_leader_id).unwrap();
*cnt += 1; *cnt += 1;
println!("leader {:?} {}", &v.current_leader_id[..4], *cnt); trace!("leader {:?} {}", &v.current_leader_id[..4], *cnt);
} }
let mut sorted: Vec<_> = table.iter().collect(); let mut sorted: Vec<_> = table.iter().collect();
sorted.sort_by_key(|a| a.1); sorted.sort_by_key(|a| a.1);
@ -855,6 +854,7 @@ impl TestNode {
#[cfg(test)] #[cfg(test)]
mod tests { mod tests {
use crdt::{parse_port_or_addr, Crdt, ReplicatedData, GOSSIP_SLEEP_MILLIS, MIN_TABLE_SIZE}; use crdt::{parse_port_or_addr, Crdt, ReplicatedData, GOSSIP_SLEEP_MILLIS, MIN_TABLE_SIZE};
use logger;
use packet::BlobRecycler; use packet::BlobRecycler;
use result::Error; use result::Error;
use signature::{KeyPair, KeyPairUtil}; use signature::{KeyPair, KeyPairUtil};
@ -1203,6 +1203,7 @@ mod tests {
/// delete this test after leader selection is correctly implemented /// delete this test after leader selection is correctly implemented
#[test] #[test]
fn test_update_leader() { fn test_update_leader() {
logger::setup();
let me = ReplicatedData::new_leader(&"127.0.0.1:1234".parse().unwrap()); let me = ReplicatedData::new_leader(&"127.0.0.1:1234".parse().unwrap());
let lead = ReplicatedData::new_leader(&"127.0.0.1:1234".parse().unwrap()); let lead = ReplicatedData::new_leader(&"127.0.0.1:1234".parse().unwrap());
let lead2 = ReplicatedData::new_leader(&"127.0.0.1:1234".parse().unwrap()); let lead2 = ReplicatedData::new_leader(&"127.0.0.1:1234".parse().unwrap());