use the new callback interface

apache · Sep 16, 2019 · 647f48a · 647f48a
1 parent 5261f05
commit 647f48a
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/engine/threaded_engine.h b/src/engine/threaded_engine.h
@@ -383,14 +383,12 @@ class ThreadedEngine : public Engine {
             callback();
           }
         } catch (const std::exception& e) {
-          threaded_opr->opr_exception =
-              std::make_shared<std::exception_ptr>(std::current_exception());
-          callback();
+          callback(&e);
         }
         if (debug_info) {
           LOG(INFO) << "Fin ExecuteOprFn ";
         }
-      } catch (std::exception& e) {
+      } catch (const std::exception& e) {
         std::string what = e.what();
         if (what.find("driver shutting down") == std::string::npos &&
             !shutdown_phase_) {