GRIN/nym
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Extra argument to cover traffic stream

Browse Source
This commit is contained in:
Jedrzej Stuczynski
2020-01-31 16:10:00 +00:00
parent 409bfb4f08
commit 6432e708d6
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
nym-client/src/client/cover_traffic_stream.rs
+3 -4
View File
@@ -1,22 +1,21 @@
use crate::client::mix_traffic::MixMessage;
use crate::client::topology_control::TopologyInnerRef;
use crate::client::LOOP_COVER_AVERAGE_DELAY;
use futures::channel::mpsc;
use log::{error, info, trace, warn};
use sphinx::route::Destination;
use std::time::Duration;
use std::time;
use topology::NymTopology;
pub(crate) async fn start_loop_cover_traffic_stream<T: NymTopology>(
tx: mpsc::UnboundedSender<MixMessage>,
our_info: Destination,
topology_ctrl_ref: TopologyInnerRef<T>,
average_delay_duration: time::Duration,
) {
info!("Starting loop cover traffic stream");
loop {
trace!("next cover message!");
let delay = mix_client::poisson::sample(LOOP_COVER_AVERAGE_DELAY);
let delay_duration = Duration::from_secs_f64(delay);
let delay_duration = mix_client::poisson::sample_from_duration(average_delay_duration);
tokio::time::delay_for(delay_duration).await;
let read_lock = topology_ctrl_ref.read().await;