logos-co
/
nomos-simulations
mirror of https://github.com/logos-co/nomos-simulations.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Make cache optional

This commit is contained in:
Gusto 2024-11-09 06:01:38 +02:00
parent 424585dd2a
commit 7694d48b83
No known key found for this signature in database
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
simlib/netrunner/src/streaming/mod.rs
View File

@ -217,12 +217,14 @@ impl<R> Default for StreamProducerInner<R> {
#[derive(Debug)] #[derive(Debug)]
pub struct StreamProducer<R> { pub struct StreamProducer<R> {
inner: Arc<Mutex<StreamProducerInner<R>>>, inner: Arc<Mutex<StreamProducerInner<R>>>,
with_cache: bool,
} }
impl<R> Default for StreamProducer<R> { impl<R> Default for StreamProducer<R> {
fn default() -> Self { fn default() -> Self {
Self { Self {
inner: Arc::new(Mutex::new(StreamProducerInner::default())), inner: Arc::new(Mutex::new(StreamProducerInner::default())),
with_cache: false,
} }
} }
} }
@ -231,6 +233,7 @@ impl<R> Clone for StreamProducer<R> {
fn clone(&self) -> Self { fn clone(&self) -> Self {
Self { Self {
inner: Arc::clone(&self.inner), inner: Arc::clone(&self.inner),
with_cache: self.with_cache,
} }
} }
} }
@ -247,7 +250,7 @@ where
{ {
pub fn send(&self, record: R) -> anyhow::Result<()> { pub fn send(&self, record: R) -> anyhow::Result<()> {
let mut inner = self.inner.lock().unwrap(); let mut inner = self.inner.lock().unwrap();
if inner.senders.is_empty() { if inner.senders.is_empty() && self.with_cache {
inner.record_cache.push(Arc::new(record)); inner.record_cache.push(Arc::new(record));
Ok(()) Ok(())
} else { } else {