diff --git a/services/commtest/tests/blob/get.rs b/services/commtest/tests/blob/get.rs --- a/services/commtest/tests/blob/get.rs +++ b/services/commtest/tests/blob/get.rs @@ -13,7 +13,7 @@ blob_data: &BlobData, ) -> Result, Error> { let cloned_holder = blob_data.holder.clone(); - println!("get {}", cloned_holder); + println!("[{}] get", cloned_holder); let response = client .get(Request::new(GetRequest { diff --git a/services/commtest/tests/blob/put.rs b/services/commtest/tests/blob/put.rs --- a/services/commtest/tests/blob/put.rs +++ b/services/commtest/tests/blob/put.rs @@ -18,21 +18,21 @@ let cloned_holder = blob_data.holder.clone(); let cloned_hash = blob_data.hash.clone(); let cloned_chunks_sizes = blob_data.chunks_sizes.clone(); - println!("put {}", cloned_holder); + println!("[{}] put", cloned_holder); let outbound = async_stream::stream! { - println!(" - sending holder"); + println!("[{}] - sending holder", cloned_holder); let request = PutRequest { data: Some(Holder(cloned_holder.to_string())), }; yield request; - println!(" - sending hash"); + println!("[{}] - sending hash", cloned_holder); let request = PutRequest { data: Some(BlobHash(cloned_hash.to_string())), }; yield request; for chunk_size in cloned_chunks_sizes { - println!(" - sending data chunk {}", chunk_size); + println!("[{}] - sending data chunk {}", cloned_holder, chunk_size); let request = PutRequest { data: Some(DataChunk(generate_nbytes(chunk_size, None))), }; diff --git a/services/commtest/tests/blob/remove.rs b/services/commtest/tests/blob/remove.rs --- a/services/commtest/tests/blob/remove.rs +++ b/services/commtest/tests/blob/remove.rs @@ -13,7 +13,7 @@ blob_data: &BlobData, ) -> Result<(), Error> { let cloned_holder = blob_data.holder.clone(); - println!("remove {}", cloned_holder); + println!("[{}] remove", cloned_holder); client .remove(Request::new(RemoveRequest { diff --git a/services/commtest/tests/blob_performance_test.rs b/services/commtest/tests/blob_performance_test.rs --- a/services/commtest/tests/blob_performance_test.rs +++ b/services/commtest/tests/blob_performance_test.rs @@ -51,7 +51,6 @@ let item_cloned = item.clone(); let mut client_cloned = client.clone(); handlers.push(tokio::spawn(async move { - println!("--- PUT {}", item_cloned.holder); let data_exists: bool = put::run(&mut client_cloned, &item_cloned).await.unwrap(); assert!(!data_exists, "test data should not exist"); @@ -72,7 +71,6 @@ let item_cloned = item.clone(); let mut client_cloned = client.clone(); handlers.push(tokio::spawn(async move { - println!("--- GET {}", item_cloned.holder); let received_sizes = get::run(&mut client_cloned, &item_cloned).await.unwrap(); let expected_data_size = @@ -100,7 +98,6 @@ let item_cloned = item.clone(); let mut client_cloned = client.clone(); handlers.push(tokio::spawn(async move { - println!("--- REMOVE {}", item_cloned.holder); remove::run(&mut client_cloned, &item_cloned).await.unwrap(); assert!( get::run(&mut client_cloned, &item_cloned).await.is_err(),