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(()) }