diff --git a/services/commtest/tests/blob/get.rs b/services/commtest/tests/blob/get.rs index d201ec49e..7799b0f85 100644 --- a/services/commtest/tests/blob/get.rs +++ b/services/commtest/tests/blob/get.rs @@ -1,29 +1,29 @@ #[path = "./blob_utils.rs"] mod blob_utils; #[path = "../lib/tools.rs"] mod tools; use tonic::Request; use crate::blob_utils::{proto::GetRequest, BlobData, BlobServiceClient}; use crate::tools::Error; pub async fn run( client: &mut BlobServiceClient, 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 { holder: cloned_holder, })) .await?; let mut inbound = response.into_inner(); let mut sizes: Vec = Vec::new(); while let Some(response) = inbound.message().await? { sizes.push(response.data_chunk.len()); } Ok(sizes) } diff --git a/services/commtest/tests/blob/put.rs b/services/commtest/tests/blob/put.rs index 730dc2c41..86fe4a216 100644 --- a/services/commtest/tests/blob/put.rs +++ b/services/commtest/tests/blob/put.rs @@ -1,50 +1,50 @@ #[path = "./blob_utils.rs"] mod blob_utils; #[path = "../lib/tools.rs"] mod tools; use crate::blob_utils::{ proto::put_request::Data::*, proto::PutRequest, BlobData, BlobServiceClient, }; use tonic::Request; use crate::tools::{generate_nbytes, Error}; pub async fn run( client: &mut BlobServiceClient, blob_data: &BlobData, ) -> Result { 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))), }; yield request; } }; let mut data_exists: bool = false; let response = client.put(Request::new(outbound)).await?; let mut inbound = response.into_inner(); while let Some(response) = inbound.message().await? { data_exists = data_exists || response.data_exists; } Ok(data_exists) } diff --git a/services/commtest/tests/blob/remove.rs b/services/commtest/tests/blob/remove.rs index 8c98c1a2e..fd4a60b68 100644 --- a/services/commtest/tests/blob/remove.rs +++ b/services/commtest/tests/blob/remove.rs @@ -1,24 +1,24 @@ #[path = "./blob_utils.rs"] mod blob_utils; #[path = "../lib/tools.rs"] mod tools; use tonic::Request; use crate::blob_utils::{proto::RemoveRequest, BlobData, BlobServiceClient}; use crate::tools::Error; pub async fn run( client: &mut BlobServiceClient, 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 { holder: cloned_holder, })) .await?; Ok(()) }