D4581.1767354386.diff
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

D4581.1767354386.diff
View Options

	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
	@@ -1,7 +1,55 @@
	+#[path = "./blob/blob_utils.rs"]
	+mod blob_utils;
	#[path = "./lib/tools.rs"]
	mod tools;

	+use bytesize::ByteSize;
	+
	+use tokio::runtime::Runtime;
	+use tools::Error;
	+
	+use blob_utils::BlobData;
	+
	#[tokio::test]
	-async fn blob_performance_test() {
	- assert!(false, "not implemented");
	+async fn blob_performance_test() -> Result<(), Error> {
	+
	+ // change this value to test more simultaneous connections
	+ const NUMBER_OF_THREADS: usize = 5;
	+
	+ let mut blob_data = vec![];
	+
	+ for i in 0..NUMBER_OF_THREADS {
	+ let index: u64 = (i as u64) % 10;
	+ blob_data.push(BlobData {
	+ holder: format!("test_holder_{}", i),
	+ hash: format!("test_hash_{}", i),
	+ chunks_sizes: vec![
	+ ByteSize::kib(200 + (300 - index * 20)).as_u64() as usize,
	+ ByteSize::kib(500 + (400 - index * 20)).as_u64() as usize,
	+ ByteSize::kib(700 + (500 - index * 25)).as_u64() as usize,
	+ ],
	+ })
	+ }
	+
	+ let rt = Runtime::new().unwrap();
	+ tokio::task::spawn_blocking(move \|\| {
	+ // PUT
	+ rt.block_on(async {
	+ println!("performing PUT operations");
	+ });
	+
	+ // GET
	+ rt.block_on(async {
	+ println!("performing GET operations");
	+ });
	+
	+ // REMOVE
	+ rt.block_on(async {
	+ println!("performing REMOVE operations");
	+ });
	+ })
	+ .await
	+ .expect("Task panicked");
	+
	+ Ok(())
	}