wip

linera-io · Jun 15, 2024 · 95d199e · 95d199e
1 parent cb95ff5
commit 95d199e
Show file tree

Hide file tree

Showing 5 changed files with 43 additions and 24 deletions.
diff --git a/clippy.toml b/clippy.toml
@@ -0,0 +1,2 @@
+stack-size-threshold = 200000
+future-size-threshold = 20000
diff --git a/linera-core/src/unit_tests/wasm_client_tests.rs b/linera-core/src/unit_tests/wasm_client_tests.rs
@@ -10,6 +10,7 @@
 // because they are slow and their behavior appears to be correctly check by the
 // test with memory.
 
+#![allow(clippy::large_futures)]
 #![cfg(any(feature = "wasmer", feature = "wasmtime"))]
 
 use std::collections::BTreeMap;

diff --git a/linera-service/src/unit_tests/faucet.rs b/linera-service/src/unit_tests/faucet.rs
@@ -1,6 +1,8 @@
 // Copyright (c) Zefchain Labs, Inc.
 // SPDX-License-Identifier: Apache-2.0
 
+#![allow(clippy::large_futures)]
+
 use std::sync::Arc;
 
 use async_trait::async_trait;

diff --git a/linera-views/src/scylla_db.rs b/linera-views/src/scylla_db.rs
@@ -433,10 +433,12 @@ impl AdminKeyValueStore for ScyllaDbStoreInternal {
 
     async fn connect(config: &Self::Config, namespace: &str) -> Result<Self, ScyllaDbContextError> {
         Self::check_namespace(namespace)?;
-        let session = SessionBuilder::new()
-            .known_node(config.uri.as_str())
-            .build()
-            .await?;
+        let session = Box::pin(
+            SessionBuilder::new()
+                .known_node(config.uri.as_str())
+                .build(),
+        )
+        .await?;
         let store = ScyllaDbClient::new(session, namespace.to_string());
         let store = Arc::new(store);
         let semaphore = config
@@ -452,10 +454,12 @@ impl AdminKeyValueStore for ScyllaDbStoreInternal {
     }
 
     async fn list_all(config: &Self::Config) -> Result<Vec<String>, ScyllaDbContextError> {
-        let session = SessionBuilder::new()
-            .known_node(config.uri.as_str())
-            .build()
-            .await?;
+        let session = Box::pin(
+            SessionBuilder::new()
+                .known_node(config.uri.as_str())
+                .build(),
+        )
+        .await?;
         let miss_msg = "'kv' not found in keyspaces";
         let mut paging_state = None;
         let mut namespaces = Vec::new();
@@ -500,21 +504,25 @@ impl AdminKeyValueStore for ScyllaDbStoreInternal {
     }
 
     async fn delete_all(store_config: &Self::Config) -> Result<(), ScyllaDbContextError> {
-        let session = SessionBuilder::new()
-            .known_node(store_config.uri.as_str())
-            .build()
-            .await?;
+        let session = Box::pin(
+            SessionBuilder::new()
+                .known_node(store_config.uri.as_str())
+                .build(),
+        )
+        .await?;
         let query = "DROP KEYSPACE IF EXISTS kv;".to_string();
         session.query(query, &[]).await?;
         Ok(())
     }
 
     async fn exists(config: &Self::Config, namespace: &str) -> Result<bool, ScyllaDbContextError> {
         Self::check_namespace(namespace)?;
-        let session = SessionBuilder::new()
-            .known_node(config.uri.as_str())
-            .build()
-            .await?;
+        let session = Box::pin(
+            SessionBuilder::new()
+                .known_node(config.uri.as_str())
+                .build(),
+        )
+        .await?;
         // We check the way the test can fail. It can fail in different ways.
         let query = format!("SELECT dummy FROM kv.{} LIMIT 1 ALLOW FILTERING", namespace);
 
@@ -551,10 +559,12 @@ impl AdminKeyValueStore for ScyllaDbStoreInternal {
 
     async fn create(config: &Self::Config, namespace: &str) -> Result<(), ScyllaDbContextError> {
         Self::check_namespace(namespace)?;
-        let session = SessionBuilder::new()
-            .known_node(config.uri.as_str())
-            .build()
-            .await?;
+        let session = Box::pin(
+            SessionBuilder::new()
+                .known_node(config.uri.as_str())
+                .build(),
+        )
+        .await?;
         // Create a keyspace if it doesn't exist
         let query = "CREATE KEYSPACE IF NOT EXISTS kv WITH REPLICATION = { \
             'class' : 'SimpleStrategy', \
@@ -575,10 +585,12 @@ impl AdminKeyValueStore for ScyllaDbStoreInternal {
 
     async fn delete(config: &Self::Config, namespace: &str) -> Result<(), ScyllaDbContextError> {
         Self::check_namespace(namespace)?;
-        let session = SessionBuilder::new()
-            .known_node(config.uri.as_str())
-            .build()
-            .await?;
+        let session = Box::pin(
+            SessionBuilder::new()
+                .known_node(config.uri.as_str())
+                .build(),
+        )
+        .await?;
         let query = format!("DROP TABLE IF EXISTS kv.{};", namespace);
         session.query(query, &[]).await?;
         Ok(())

diff --git a/linera-views/tests/views_tests.rs b/linera-views/tests/views_tests.rs
@@ -1,6 +1,8 @@
 // Copyright (c) Zefchain Labs, Inc.
 // SPDX-License-Identifier: Apache-2.0
 
+#![allow(clippy::large_futures)]
+
 #[cfg(any(with_dynamodb, with_rocksdb, with_scylladb))]
 use std::collections::BTreeSet;
 use std::{