fix: throughput accuracy

Cargo.toml

@@ -25,6 +25,6 @@ tokio = "1"
 tokio-util = "0.7"
 tokio_chacha20 = { git = "https://github.com/Banyc/tokio_chacha20.git", rev = "40d2030f0ab6e7e32031e61618717d25f25e5509" }
 tokio_kcp = "0.9"
-tokio_throughput = { git = "https://github.com/Banyc/tokio_throughput.git", rev = "e45535cfce6aa87d903ef5665c6f3d3b25a9d1ab" }
+tokio_throughput = { git = "https://github.com/Banyc/tokio_throughput.git", rev = "80cbf0572623762665caff07781cee3e0d97cfc7" }
 tracing = "0.1"
 tracing-subscriber = "0.3"

common/src/stream/io_copy/mod.rs

@@ -8,7 +8,6 @@ use std::{
 use async_speed_limit::Limiter;
 use metrics::{counter, gauge};
 use scopeguard::defer;
-use strict_num::NormalizedF64;
 use tokio::io::{AsyncRead, AsyncWrite};
 use tokio_throughput::{ReadGauge, WriteGauge};
 use tracing::info;
@@ -22,7 +21,6 @@ use super::{
 pub mod tokio_io;
 
 pub const DEAD_SESSION_RETENTION_DURATION: Duration = Duration::from_secs(5);
-const ALPHA: f64 = 0.1;
 
 pub struct CopyBidirectional<DS, US, ST> {
     pub downstream: DS,
@@ -48,8 +46,8 @@ where
         log_prefix: &str,
     ) -> (StreamMetrics<ST>, Result<(), tokio_io::CopyBiErrorKind>) {
         let session = session_table.map(|s| {
-            let (up_handle, up) = tokio_throughput::gauge(NormalizedF64::new(ALPHA).unwrap());
-            let (dn_handle, dn) = tokio_throughput::gauge(NormalizedF64::new(ALPHA).unwrap());
+            let (up_handle, up) = tokio_throughput::gauge();
+            let (dn_handle, dn) = tokio_throughput::gauge();
             let r = ReadGauge(up);
             let w = WriteGauge(dn);
 
@@ -85,8 +83,8 @@ where
         Result<(), tokio_io::CopyBiErrorKind>,
     ) {
         let session = session_table.map(|s| {
-            let (up_handle, up) = tokio_throughput::gauge(NormalizedF64::new(ALPHA).unwrap());
-            let (dn_handle, dn) = tokio_throughput::gauge(NormalizedF64::new(ALPHA).unwrap());
+            let (up_handle, up) = tokio_throughput::gauge();
+            let (dn_handle, dn) = tokio_throughput::gauge();
             let r = ReadGauge(up);
             let w = WriteGauge(dn);
 

common/src/udp/io_copy.rs

@@ -11,7 +11,6 @@ use std::{
 use async_speed_limit::Limiter;
 use metrics::{counter, gauge};
 use scopeguard::defer;
-use strict_num::NormalizedF64;
 use thiserror::Error;
 use tokio::{net::UdpSocket, sync::mpsc};
 use tokio_throughput::{ReadGauge, WriteGauge};
@@ -26,7 +25,6 @@ use super::{
 };
 
 const DEAD_SESSION_RETENTION_DURATION: Duration = Duration::from_secs(5);
-const ALPHA: f64 = 0.1;
 
 pub trait UdpRecv {
     fn trait_recv(
@@ -73,8 +71,8 @@ where
         log_prefix: &str,
     ) -> Result<FlowMetrics, CopyBiError> {
         let session = session_table.as_ref().map(|s| {
-            let (up_handle, up) = tokio_throughput::gauge(NormalizedF64::new(ALPHA).unwrap());
-            let (dn_handle, dn) = tokio_throughput::gauge(NormalizedF64::new(ALPHA).unwrap());
+            let (up_handle, up) = tokio_throughput::gauge();
+            let (dn_handle, dn) = tokio_throughput::gauge();
             let r = ReadGauge(up);
             let w = WriteGauge(dn);
 
@@ -103,8 +101,8 @@ where
         log_prefix: &str,
     ) -> Result<FlowMetrics, CopyBiError> {
         let session = session_table.as_ref().map(|s| {
-            let (up_handle, up) = tokio_throughput::gauge(NormalizedF64::new(ALPHA).unwrap());
-            let (dn_handle, dn) = tokio_throughput::gauge(NormalizedF64::new(ALPHA).unwrap());
+            let (up_handle, up) = tokio_throughput::gauge();
+            let (dn_handle, dn) = tokio_throughput::gauge();
             let r = ReadGauge(up);
             let w = WriteGauge(dn);