+ prev commit

Author: wangjia184

rho_runtime/src/interpreter/mod.rs

@@ -64,13 +64,13 @@ impl<S:Storage + std::marker::Send + std::marker::Sync> From<S> for InterpreterC
 impl<S : Storage + std::marker::Send + std::marker::Sync + 'static> InterpreterContext<S> {
 
     // this is the entrypoint, it must not be called by interpretered pars
-    pub async fn evaludate(self : &Arc<Self>, mut par : Par) {
+    pub async fn evaludate_par(self : &Arc<Self>, mut par : Par) {
         let env = Env::<Par>::default();
         if let Err(e) = par.evaluate(&self, &env)
         {
             self.push_error(e);
         }
-        self.wait_group.notify.notified();
+        self.wait_group.notify.notified().await;
     }
 
     #[inline]

rho_runtime/src/main.rs

@@ -95,7 +95,7 @@ async fn test<S>(storage : S, par : Par)
     let context = std::sync::Arc::new(interpreter::InterpreterContext::from(storage.clone()));
 
     let now = Instant::now();
-    context.evaludate(par).await;
+    context.evaludate_par(par).await;
     info!("Reduction took {} ms", now.elapsed().as_millis());
     /*
     for err in errors {