@@ -13,7 +13,7 @@ use std::{
1313} ;
1414
1515use async_trait:: async_trait;
16- use mpz_common:: { scoped_futures :: ScopedFutureExt as _ , Context } ;
16+ use mpz_common:: Context ;
1717use mpz_core:: bitvec:: BitVec ;
1818use mpz_vm_core:: {
1919 memory:: { binary:: Binary , DecodeFuture , Memory , Slice , View } ,
@@ -308,8 +308,8 @@ where
308308 let mut zk = self . zk . clone ( ) . try_lock_owned ( ) . unwrap ( ) ;
309309 let mut mpc = self . mpc . clone ( ) . try_lock_owned ( ) . unwrap ( ) ;
310310 ctx. try_join (
311- |ctx| async move { zk. flush ( ctx) . await } . scope_boxed ( ) ,
312- |ctx| async move { mpc. flush ( ctx) . await } . scope_boxed ( ) ,
311+ async move |ctx| zk. flush ( ctx) . await ,
312+ async move |ctx| mpc. flush ( ctx) . await ,
313313 )
314314 . await
315315 . map_err ( VmError :: execute) ??;
@@ -326,8 +326,8 @@ where
326326 let mut zk = self . zk . clone ( ) . try_lock_owned ( ) . unwrap ( ) ;
327327 let mut mpc = self . mpc . clone ( ) . try_lock_owned ( ) . unwrap ( ) ;
328328 ctx. try_join (
329- |ctx| async move { zk. preprocess ( ctx) . await } . scope_boxed ( ) ,
330- |ctx| async move { mpc. preprocess ( ctx) . await } . scope_boxed ( ) ,
329+ async move |ctx| zk. preprocess ( ctx) . await ,
330+ async move |ctx| mpc. preprocess ( ctx) . await ,
331331 )
332332 . await
333333 . map_err ( VmError :: execute) ??;
@@ -360,29 +360,28 @@ mod tests {
360360 use mpz_circuits:: circuits:: AES128 ;
361361 use mpz_common:: context:: test_st_context;
362362 use mpz_core:: Block ;
363- use mpz_garble:: protocol:: semihonest:: { Evaluator , Generator } ;
363+ use mpz_garble:: protocol:: semihonest:: { Evaluator , Garbler } ;
364364 use mpz_ot:: ideal:: { cot:: ideal_cot, rcot:: ideal_rcot} ;
365365 use mpz_vm_core:: {
366366 memory:: { binary:: U8 , correlated:: Delta , Array } ,
367367 prelude:: * ,
368368 } ;
369369 use mpz_zk:: { Prover , Verifier } ;
370370 use rand:: { rngs:: StdRng , SeedableRng } ;
371- use rand06_compat:: Rand0_6CompatExt ;
372371
373372 use super :: * ;
374373
375374 #[ tokio:: test]
376375 async fn test_deap ( ) {
377376 let mut rng = StdRng :: seed_from_u64 ( 0 ) ;
378- let delta_mpc = Delta :: random ( & mut rng. compat_by_ref ( ) ) ;
379- let delta_zk = Delta :: random ( & mut rng. compat_by_ref ( ) ) ;
377+ let delta_mpc = Delta :: random ( & mut rng) ;
378+ let delta_zk = Delta :: random ( & mut rng) ;
380379
381380 let ( mut ctx_a, mut ctx_b) = test_st_context ( 8 ) ;
382381 let ( rcot_send, rcot_recv) = ideal_rcot ( Block :: ZERO , delta_zk. into_inner ( ) ) ;
383382 let ( cot_send, cot_recv) = ideal_cot ( delta_mpc. into_inner ( ) ) ;
384383
385- let gb = Generator :: new ( cot_send, [ 0u8 ; 16 ] , delta_mpc) ;
384+ let gb = Garbler :: new ( cot_send, [ 0u8 ; 16 ] , delta_mpc) ;
386385 let ev = Evaluator :: new ( cot_recv) ;
387386 let prover = Prover :: new ( rcot_recv) ;
388387 let verifier = Verifier :: new ( delta_zk, rcot_send) ;
@@ -457,14 +456,14 @@ mod tests {
457456 #[ tokio:: test]
458457 async fn test_malicious ( ) {
459458 let mut rng = StdRng :: seed_from_u64 ( 0 ) ;
460- let delta_mpc = Delta :: random ( & mut rng. compat_by_ref ( ) ) ;
461- let delta_zk = Delta :: random ( & mut rng. compat_by_ref ( ) ) ;
459+ let delta_mpc = Delta :: random ( & mut rng) ;
460+ let delta_zk = Delta :: random ( & mut rng) ;
462461
463462 let ( mut ctx_a, mut ctx_b) = test_st_context ( 8 ) ;
464463 let ( rcot_send, rcot_recv) = ideal_rcot ( Block :: ZERO , delta_zk. into_inner ( ) ) ;
465464 let ( cot_send, cot_recv) = ideal_cot ( delta_mpc. into_inner ( ) ) ;
466465
467- let gb = Generator :: new ( cot_send, [ 0u8 ; 16 ] , delta_mpc) ;
466+ let gb = Garbler :: new ( cot_send, [ 1u8 ; 16 ] , delta_mpc) ;
468467 let ev = Evaluator :: new ( cot_recv) ;
469468 let prover = Prover :: new ( rcot_recv) ;
470469 let verifier = Verifier :: new ( delta_zk, rcot_send) ;
0 commit comments