Merge pull request #2536 from subspace/piece-encoding-concurrency

Record encoding concurrency

Author: nazar-pc

crates/pallet-subspace/src/mock.rs

@@ -465,6 +465,7 @@ pub fn create_signed_vote(
             downloading_semaphore: None,
             encoding_semaphore: None,
             table_generator: &mut table_generator,
+            abort_early: &Default::default(),
         }))
         .unwrap();
 

crates/subspace-farmer-components/Cargo.toml

@@ -25,6 +25,7 @@ futures = "0.3.29"
 hex = "0.4.3"
 libc = "0.2.152"
 parity-scale-codec = "3.6.9"
+parking_lot = "0.12.1"
 rand = "0.8.5"
 rayon = "1.8.1"
 schnorrkel = "0.11.4"
@@ -45,7 +46,6 @@ winapi = "0.3.9"
 [dev-dependencies]
 criterion = "0.5.1"
 futures = "0.3.29"
-parking_lot = "0.12.1"
 subspace-archiving = { version = "0.1.0", path = "../subspace-archiving" }
 subspace-proof-of-space = { version = "0.1.0", path = "../subspace-proof-of-space" }
 

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

@@ -129,6 +129,7 @@ pub fn criterion_benchmark(c: &mut Criterion) {
             downloading_semaphore: black_box(None),
             encoding_semaphore: black_box(None),
             table_generator: &mut table_generator,
+            abort_early: &Default::default(),
         }))
         .unwrap();
 

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

@@ -80,6 +80,7 @@ fn criterion_benchmark(c: &mut Criterion) {
                 downloading_semaphore: black_box(None),
                 encoding_semaphore: black_box(None),
                 table_generator: black_box(&mut table_generator),
+                abort_early: &Default::default(),
             }))
             .unwrap();
         })

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

@@ -136,6 +136,7 @@ pub fn criterion_benchmark(c: &mut Criterion) {
             downloading_semaphore: black_box(None),
             encoding_semaphore: black_box(None),
             table_generator: &mut table_generator,
+            abort_early: &Default::default(),
         }))
         .unwrap();
 

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

@@ -129,6 +129,7 @@ pub fn criterion_benchmark(c: &mut Criterion) {
             downloading_semaphore: black_box(None),
             encoding_semaphore: black_box(None),
             table_generator: &mut table_generator,
+            abort_early: &Default::default(),
         }))
         .unwrap();