snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-22 18:17:39 +08:00
Code Issues Actions 9 Packages Projects Releases Wiki Activity

Add more stats about the channel message sent

Browse Source
This commit is contained in:
Clément Renault 2024-09-23 15:13:52 +02:00
parent 3c63d4a1e5
commit f00664247d
No known key found for this signature in database
GPG Key ID: F250A4C4E3AE5F5F
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
milli/src/update/new/channel.rs
View File

@ -20,7 +20,8 @@ pub fn merger_writer_channel(cap: usize) -> (MergerSender, WriterReceiver) {
MergerSender { MergerSender {
sender, sender,
send_count: Default::default(), send_count: Default::default(),
contentious_count: Default::default(), writer_contentious_count: Default::default(),
merger_contentious_count: Default::default(),
}, },
WriterReceiver(receiver), WriterReceiver(receiver),
) )
@ -181,16 +182,20 @@ pub struct MergerSender {
/// The number of message we send in total in the channel. /// The number of message we send in total in the channel.
send_count: std::cell::Cell<usize>, send_count: std::cell::Cell<usize>,
/// The number of times we sent something in a channel that was full. /// The number of times we sent something in a channel that was full.
contentious_count: std::cell::Cell<usize>, writer_contentious_count: std::cell::Cell<usize>,
/// The number of times we sent something in a channel that was empty.
merger_contentious_count: std::cell::Cell<usize>,
} }
impl Drop for MergerSender { impl Drop for MergerSender {
fn drop(&mut self) { fn drop(&mut self) {
tracing::info!( tracing::info!(
"Merger channel stats: {} sends, {} were contentious (ratio {})", "Merger channel stats: {} sends, {} writer contentions ({}%), {} merger contentions ({}%)",
self.send_count.get(), self.send_count.get(),
self.contentious_count.get(), self.writer_contentious_count.get(),
self.contentious_count.get() as f64 / self.send_count.get() as f64 (self.writer_contentious_count.get() as f32 / self.send_count.get() as f32) * 100.0,
self.merger_contentious_count.get(),
(self.merger_contentious_count.get() as f32 / self.send_count.get() as f32) * 100.0
) )
} }
} }
@ -225,7 +230,10 @@ impl MergerSender {
fn send(&self, op: WriterOperation) -> StdResult<(), SendError<()>> { fn send(&self, op: WriterOperation) -> StdResult<(), SendError<()>> {
if self.sender.is_full() { if self.sender.is_full() {
self.contentious_count.set(self.contentious_count.get() + 1); self.writer_contentious_count.set(self.writer_contentious_count.get() + 1);
}
if self.sender.is_empty() {
self.merger_contentious_count.set(self.merger_contentious_count.get() + 1);
} }
self.send_count.set(self.send_count.get() + 1); self.send_count.set(self.send_count.get() + 1);
match self.sender.send(op) { match self.sender.send(op) {