DROPME try

Author: tnull

.github/workflows/vss-integration.yml

@@ -75,7 +75,7 @@ jobs:
           cd ldk-node
           export TEST_VSS_BASE_URL="http://localhost:8080/vss"
           RUSTFLAGS="--cfg vss_test" cargo build --verbose --color always
-          RUSTFLAGS="--cfg vss_test" cargo test --test integration_tests_vss
+          RUSTFLAGS="--cfg vss_test --cfg tokio_unstable" cargo test --test integration_tests_vss -- --nocapture
 
       - name: Cleanup
         run: |

src/io/vss_store.rs

@@ -136,6 +136,8 @@ impl KVStore for VssStore {
 			store_id: self.store_id.clone(),
 			key: self.build_key(primary_namespace, secondary_namespace, key)?,
 		};
+
+		println!("READ: {}/{}/{}", primary_namespace, secondary_namespace, key);
 		let resp = self.runtime.block_on(self.client.get_object(&request)).map_err(|e| {
 			let msg = format!(
 				"Failed to read from key {}/{}/{}: {}",
@@ -146,6 +148,7 @@ impl KVStore for VssStore {
 				_ => Error::new(ErrorKind::Other, msg),
 			}
 		})?;
+		println!("READ DONE: {}/{}/{}", primary_namespace, secondary_namespace, key);
 		// unwrap safety: resp.value must be always present for a non-erroneous VSS response, otherwise
 		// it is an API-violation which is converted to [`VssError::InternalServerError`] in [`VssClient`]
 		let storable = Storable::decode(&resp.value.unwrap().value[..]).map_err(|e| {
@@ -176,13 +179,15 @@ impl KVStore for VssStore {
 			delete_items: vec![],
 		};
 
+		println!("WRITE: {}/{}/{}", primary_namespace, secondary_namespace, key);
 		self.runtime.block_on(self.client.put_object(&request)).map_err(|e| {
 			let msg = format!(
 				"Failed to write to key {}/{}/{}: {}",
 				primary_namespace, secondary_namespace, key, e
 			);
 			Error::new(ErrorKind::Other, msg)
 		})?;
+		println!("WRITE DONE: {}/{}/{}", primary_namespace, secondary_namespace, key);
 
 		Ok(())
 	}
@@ -200,19 +205,22 @@ impl KVStore for VssStore {
 			}),
 		};
 
+		println!("REMOVE: {}/{}/{}", primary_namespace, secondary_namespace, key);
 		self.runtime.block_on(self.client.delete_object(&request)).map_err(|e| {
 			let msg = format!(
 				"Failed to delete key {}/{}/{}: {}",
 				primary_namespace, secondary_namespace, key, e
 			);
 			Error::new(ErrorKind::Other, msg)
 		})?;
+		println!("REMOVE DONE: {}/{}/{}", primary_namespace, secondary_namespace, key);
 		Ok(())
 	}
 
 	fn list(&self, primary_namespace: &str, secondary_namespace: &str) -> io::Result<Vec<String>> {
 		check_namespace_key_validity(primary_namespace, secondary_namespace, None, "list")?;
 
+		println!("LIST: {}/{}", primary_namespace, secondary_namespace);
 		let keys = self
 			.runtime
 			.block_on(self.list_all_keys(primary_namespace, secondary_namespace))
@@ -223,6 +231,7 @@ impl KVStore for VssStore {
 				);
 				Error::new(ErrorKind::Other, msg)
 			})?;
+		println!("LIST DONE: {}/{}", primary_namespace, secondary_namespace);
 
 		Ok(keys)
 	}

src/runtime.rs

@@ -55,6 +55,15 @@ impl Runtime {
 		// to detect the outer context here, and otherwise use whatever was set during
 		// initialization.
 		let handle = tokio::runtime::Handle::try_current().unwrap_or(self.handle());
+		#[cfg(tokio_unstable)]
+		{
+			println!("Tokio blocking queue depth: {}", handle.metrics().blocking_queue_depth());
+			println!(
+				"Tokio num_blocking_threads {} / idle_blocking_threads {}",
+				handle.metrics().num_blocking_threads(),
+				handle.metrics().num_idle_blocking_threads()
+			);
+		}
 		tokio::task::block_in_place(move || handle.block_on(future))
 	}