(&self, event: CacheEvent)
| 105 | |
| 106 | #[inline] |
| 107 | fn send_cache_event(&self, event: CacheEvent) { |
| 108 | let sent_event = self.sender.try_send(event.clone()); |
| 109 | |
| 110 | if let Err(ref err) = sent_event { |
| 111 | info!( |
| 112 | "Failed to send asynchronously message to worker thread, \ |
| 113 | event: {event:?}, error: {err}" |
| 114 | ); |
| 115 | } |
| 116 | |
| 117 | #[cfg(test)] |
| 118 | { |
| 119 | let mut stats = self |
| 120 | .stats |
| 121 | .0 |
| 122 | .lock() |
| 123 | .expect("Failed to acquire worker stats lock"); |
| 124 | |
| 125 | if sent_event.is_ok() { |
| 126 | stats.sent += 1; |
| 127 | } else { |
| 128 | stats.dropped += 1; |
| 129 | } |
| 130 | } |
| 131 | } |
| 132 | |
| 133 | #[cfg(test)] |
| 134 | pub(super) fn events_dropped(&self) -> u32 { |
no test coverage detected