Fix tests by using supported value

Author: nazar-pc

crates/sp-lightclient/src/tests.rs

@@ -106,6 +106,7 @@ impl Farmer {
             sector_expiration: 100,
         };
         let sector_codec = SectorCodec::new(PLOT_SECTOR_SIZE as usize).unwrap();
+        let piece_receiver_batch_size = 20usize;
 
         block_on(plot_sector(
             &public_key,
@@ -117,7 +118,7 @@ impl Farmer {
             &sector_codec,
             Cursor::new(sector.as_mut_slice()),
             Cursor::new(sector_metadata.as_mut_slice()),
-            &tokio::sync::Semaphore::new(usize::MAX),
+            &tokio::sync::Semaphore::new(piece_receiver_batch_size),
         ))
         .unwrap();
 

crates/subspace-farmer-components/benches/auditing.rs

@@ -64,7 +64,8 @@ pub fn criterion_benchmark(c: &mut Criterion) {
     };
     let global_challenge = Blake2b256Hash::default();
     let solution_range = SolutionRange::MAX;
-    let piece_receiver_semaphore = Semaphore::new(usize::MAX);
+    let piece_receiver_batch_size = 20usize;
+    let piece_receiver_semaphore = Semaphore::new(piece_receiver_batch_size);
 
     let plotted_sector = {
         let mut plotted_sector = vec![0u8; PLOT_SECTOR_SIZE as usize];

crates/subspace-farmer-components/benches/plotting.rs

@@ -54,7 +54,8 @@ fn criterion_benchmark(c: &mut Criterion) {
         sector_expiration: 1,
     };
     let piece_receiver = BenchPieceReceiver::new(piece);
-    let piece_receiver_semaphore = Semaphore::new(usize::MAX);
+    let piece_receiver_batch_size = 20usize;
+    let piece_receiver_semaphore = Semaphore::new(piece_receiver_batch_size);
 
     let mut group = c.benchmark_group("sector-plotting");
     group.throughput(Throughput::Bytes(PLOT_SECTOR_SIZE));

test/subspace-test-client/src/lib.rs

@@ -251,6 +251,7 @@ where
         // TODO: This constant should come from the chain itself
         sector_expiration: 100,
     };
+    let piece_receiver_batch_size = 20usize;
 
     plot_sector(
         &public_key,
@@ -262,7 +263,7 @@ where
         sector_codec,
         Cursor::new(sector.as_mut_slice()),
         Cursor::new(sector_metadata.as_mut_slice()),
-        &tokio::sync::Semaphore::new(usize::MAX),
+        &tokio::sync::Semaphore::new(piece_receiver_batch_size),
     )
     .await
     .expect("Plotting one sector in memory must not fail");