Page MenuHomePhabricator
Files F2906814

D4274.diff
No OneTemporary
Actions

D4274.diff
View Options

diff --git a/services/commtest/tests/blob/put.rs b/services/commtest/tests/blob/put.rs
new file mode 100644
--- /dev/null
+++ b/services/commtest/tests/blob/put.rs
@@ -0,0 +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<tonic::transport::Channel>,
+ blob_data: &BlobData,
+) -> Result<bool, Error> {
+ 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);
+
+ let outbound = async_stream::stream! {
+ println!(" - sending holder");
+ let request = PutRequest {
+ data: Some(Holder(cloned_holder.to_string())),
+ };
+ yield request;
+ println!(" - sending hash");
+ 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);
+ 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)
+}

File Metadata

Mime Type
text/plain
Expires
Mon, Oct 7, 10:06 AM (21 h, 36 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2253614
Default Alt Text
D4274.diff (1 KB)

Event Timeline