YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-02 10:45:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

aquatic ws load test: use longer value for request offer/answer fields

Browse source
This commit is contained in:
Joakim Frostegård 2020-08-01 22:57:13 +02:00
parent 6f2dc6a510
commit 953154824e
3 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
aquatic_ws_load_test/src/common.rs
View file

@ -5,6 +5,10 @@ use rand_distr::Pareto;
pub use aquatic_ws_protocol::*; pub use aquatic_ws_protocol::*;
/// JSON string used as fake announce offer / offer response
pub const JSON_VALUE: &str = r#"{ "offer": "abcdefghabcdefghabcdefghabcdefghabcdefghabcdefghabcdefghabcdefghabcdefghabcdefghabcdefghabcdefghabcdefghabcdefghabcdefgh" }"#;
#[derive(PartialEq, Eq, Clone)] #[derive(PartialEq, Eq, Clone)]
pub struct TorrentPeer { pub struct TorrentPeer {
pub info_hash: InfoHash, pub info_hash: InfoHash,

2
aquatic_ws_load_test/src/network.rs
View file

@ -201,7 +201,7 @@ impl Connection {
if let Some((peer_id, offer_id)) = self.send_answer { if let Some((peer_id, offer_id)) = self.send_answer {
r.to_peer_id = Some(peer_id); r.to_peer_id = Some(peer_id);
r.offer_id = Some(offer_id); r.offer_id = Some(offer_id);
r.answer = Some(JsonValue(::serde_json::Value::from("{}"))); r.answer = Some(JsonValue(::serde_json::Value::from(JSON_VALUE)));
r.offers = None; r.offers = None;
} }

2
aquatic_ws_load_test/src/utils.rs
View file

@ -62,7 +62,7 @@ fn create_announce_request(
for _ in 0..10 { for _ in 0..10 {
offers.push(AnnounceRequestOffer { offers.push(AnnounceRequestOffer {
offer_id: OfferId(rng.gen()), offer_id: OfferId(rng.gen()),
offer: JsonValue(::serde_json::Value::from("{}")), offer: JsonValue(::serde_json::Value::from(JSON_VALUE)),
}) })
} }