We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c7dbc41 commit 2f232feCopy full SHA for 2f232fe
store/postgres/src/pool/mod.rs
@@ -724,10 +724,12 @@ impl PoolInner {
724
async fn indexing_permit(&self) -> tokio::sync::OwnedSemaphorePermit {
725
let start = Instant::now();
726
let permit = self.indexing_semaphore.cheap_clone().acquire_owned().await;
727
+ let elapsed = start.elapsed();
728
self.indexing_semaphore_wait_stats
729
.write()
730
.unwrap()
- .add_and_register(start.elapsed(), &self.indexing_semaphore_wait_gauge);
731
+ .add_and_register(elapsed, &self.indexing_semaphore_wait_gauge);
732
+ self.wait_meter.add_conn_wait_time(elapsed);
733
permit.unwrap()
734
}
735
0 commit comments