fix(torture): handle large overflow values

torture/src/supervisor/comms.rs

@@ -80,7 +80,16 @@ impl RequestResponse {
         wr_stream.send(Envelope { reqno, message }).await?;
         drop(wr_stream);
 
-        let message = timeout(self.shared.timeout, rx).await??;
+        // TODO: Spawning a blocking task to handle the reception of the message
+        // in the one shot channel is a workaround to make it possible to handle
+        // large messages. Using the standard `timeout(self.shared.timeout, rx).await??;`
+        // does not work, it hangs when the expected value to be received is larger than 15KiB.
+        let message = timeout(
+            self.shared.timeout,
+            tokio::task::spawn_blocking(|| rx.blocking_recv()),
+        )
+        .await???;
+
         Ok(message)
     }
 

torture/src/supervisor/workload.rs

@@ -164,12 +164,7 @@ impl WorkloadState {
         // - Different power of two sizes.
         // - Change it to be a non-even.
         let len = if self.rng.gen_bool(self.biases.overflow) {
-            // TODO: handle multiple overflow page scenario.
-            // Currently, using a value that is too large causes the channel to hang
-            // when the agent is responding with the queried value.
-            // However MAX_LEAF_VALUE_SIZE is 1332 thus 2000 is enough
-            // to test simple overflow values where only one additional page is used.
-            2000
+            32 * 1024
         } else {
             32
         };