From e6a74c5bfefa99497e580c8f710ef00eb44c9966 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Wed, 12 Aug 2020 04:08:43 +0200 Subject: [PATCH] aquatic http load test: send Host header, downloaded&uploaded keys --- aquatic_http_load_test/src/network.rs | 3 ++- aquatic_http_protocol/src/request.rs | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/aquatic_http_load_test/src/network.rs b/aquatic_http_load_test/src/network.rs index ee2a50c..dc40c7c 100644 --- a/aquatic_http_load_test/src/network.rs +++ b/aquatic_http_load_test/src/network.rs @@ -91,9 +91,10 @@ impl Connection { state.statistics.responses_scrape .fetch_add(1, Ordering::SeqCst); }, - Response::Failure(_) => { + Response::Failure(response) => { state.statistics.responses_failure .fetch_add(1, Ordering::SeqCst); + println!("failure response: reason: {}", response.failure_reason); }, } diff --git a/aquatic_http_protocol/src/request.rs b/aquatic_http_protocol/src/request.rs index 9b46041..0967525 100644 --- a/aquatic_http_protocol/src/request.rs +++ b/aquatic_http_protocol/src/request.rs @@ -32,7 +32,7 @@ impl AnnounceRequest { output.write_all(b"&port=")?; output.write_all(itoa::Buffer::new().format(self.port).as_bytes())?; - output.write_all(b"&left=")?; + output.write_all(b"&uploaded=0&downloaded=0&left=")?; output.write_all(itoa::Buffer::new().format(self.bytes_left).as_bytes())?; match self.event { @@ -55,7 +55,7 @@ impl AnnounceRequest { output.write_all(::urlencoding::encode(key.as_str()).as_bytes())?; } - output.write_all(b" HTTP/1.1\r\nConnection: keep-alive\r\n\r\n")?; + output.write_all(b" HTTP/1.1\r\nHost: localhost\r\n\r\n")?; Ok(()) }