Skip to content
This repository was archived by the owner on May 20, 2025. It is now read-only.

Commit 29b12d2

Browse files
committed
Remove unused code
1 parent 41fe578 commit 29b12d2

2 files changed

Lines changed: 1 addition & 20 deletions

File tree

src/load_generator.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,12 +46,12 @@ pub async fn run(targets: Targets, sender: JobSender, interval: &Duration, messa
4646
);
4747

4848
let context = Arc::new(Context {
49-
identity: format!("benchmark#benchmark"),
5049
body,
5150
retry_limit: 0,
5251
});
5352

5453
loop {
54+
tracing::info!("Iteration Start!");
5555
for target in &targets.targets {
5656
let _ = interval.tick().await;
5757

src/request.rs

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@ pub type JobReceiver = async_channel::Receiver<Job>;
88
pub struct Context {
99
pub retry_limit: usize,
1010
pub body: bytes::Bytes,
11-
pub identity: String,
1211
}
1312

1413
#[derive(Clone, Debug)]
@@ -25,21 +24,3 @@ impl Request {
2524
self
2625
}
2726
}
28-
29-
impl Drop for Context {
30-
fn drop(&mut self) {
31-
tracing::info!("{} Sent!", self.identity);
32-
}
33-
}
34-
35-
impl Drop for Request {
36-
fn drop(&mut self) {
37-
let count = Arc::strong_count(&self.context);
38-
match count {
39-
1000 | 100 | 10 => {
40-
tracing::info!("{} Last {count: >4}! ", self.context.identity);
41-
},
42-
_ => {},
43-
}
44-
}
45-
}

0 commit comments

Comments
 (0)