diff options
Diffstat (limited to 'src/system')
-rw-r--r-- | src/system/aggregator.rs | 5 | ||||
-rw-r--r-- | src/system/mod.rs | 4 |
2 files changed, 7 insertions, 2 deletions
diff --git a/src/system/aggregator.rs b/src/system/aggregator.rs index 8fbdfdd..52b1a8c 100644 --- a/src/system/aggregator.rs +++ b/src/system/aggregator.rs @@ -20,13 +20,14 @@ pub struct MessageAggregator { impl MessageAggregator { pub fn new(system_size: usize) -> Self { - let (tx, rx) = channel::<MessageEvent>(system_size * 2); + let buf_size = std::cmp::max(system_size * 2, 1); + let (tx, rx) = channel::<MessageEvent>(buf_size); Self { state: Arc::new(RwLock::new( AggregatorState { tx, rx, - message_cache: LruCache::new(NonZeroUsize::new(system_size * 2).unwrap()), + message_cache: LruCache::new(NonZeroUsize::new(buf_size).unwrap()), system_emitter: None, })) diff --git a/src/system/mod.rs b/src/system/mod.rs index d993731..44c6da8 100644 --- a/src/system/mod.rs +++ b/src/system/mod.rs @@ -82,6 +82,10 @@ impl Manager { self.start_bot(member_id).await; } + if self.config.members.len() < 1 { + println!("WARNING: System {} has no configured members", &self.name); + } + loop { match system_receiver.recv().await { Some(SystemEvent::GatewayConnected(member_id, user_id)) => { |