Page MenuHomePhabricator
Files F2905864

D4585.id14684.diff
No OneTemporary
Actions

D4585.id14684.diff
View Options

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<Vec<usize>, 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(),

File Metadata

Mime Type
text/plain
Expires
Mon, Oct 7, 8:36 AM (22 h, 1 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2252894
Default Alt Text
D4585.id14684.diff (3 KB)

Event Timeline