[GIE/engine] Bug fix; (#2250)

Co-authored-by: Longbin Lai <longbin.lailb@alibaba-inc.com>
alibaba · Nov 30, 2022 · 07efc74 · 07efc74
1 parent 5ea5b87
commit 07efc74
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/interactive_engine/executor/engine/pegasus/executor/src/reactor.rs b/interactive_engine/executor/engine/pegasus/executor/src/reactor.rs
@@ -506,7 +506,7 @@ impl DirectExecutorRuntime {
         std::thread::Builder::new()
             .name("direct-boss".into())
             .spawn(move || {
-                while SHUTDOWN_HOOK.load(Ordering::SeqCst) {
+                while !SHUTDOWN_HOOK.load(Ordering::SeqCst) {
                     match self.0.recv_timeout(Duration::from_secs(1)) {
                         Ok(g) => {
                             let name = g

diff --git a/interactive_engine/executor/engine/pegasus/pegasus/src/communication/decorator/exchange.rs b/interactive_engine/executor/engine/pegasus/pegasus/src/communication/decorator/exchange.rs
@@ -535,7 +535,7 @@ impl<D: Data> BlockPush for ExchangeByDataPush<D> {
                                         .get_mut(tag)
                                         .expect("expect has block;");
                                     while let Some(x) = blocks.pop_front() {
-                                        b.push_front(x);
+                                        b.push_back(x);
                                     }
                                 }
                                 Ok(false)