purger
This commit is contained in:
parent
ee54ce4727
commit
bc918a5ad5
|
@ -578,6 +578,7 @@ impl Crdt {
|
||||||
.name("solana-gossip".to_string())
|
.name("solana-gossip".to_string())
|
||||||
.spawn(move || loop {
|
.spawn(move || loop {
|
||||||
let _ = Self::run_gossip(&obj, &blob_sender, &blob_recycler);
|
let _ = Self::run_gossip(&obj, &blob_sender, &blob_recycler);
|
||||||
|
obj.write().unwrap().purge(timestamp());
|
||||||
if exit.load(Ordering::Relaxed) {
|
if exit.load(Ordering::Relaxed) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue