add try catch in swtich for no core

JimmyShi22 · Mar 21, 2024 · b729daa · b729daa
1 parent 033ff7a
commit b729daa
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 3 deletions.
diff --git a/bcos-scheduler/src/BlockExecutive.cpp b/bcos-scheduler/src/BlockExecutive.cpp
@@ -578,7 +578,8 @@ void BlockExecutive::asyncCommit(std::function<void(Error::UniquePtr)> callback)
                                     ++status->failed;
                                     SCHEDULER_LOG(ERROR)
                                         << BLOCK_NUMBER(number())
-                                        << "asyncPrepare executor failed: " << error->what();
+                                        << "asyncPrepare executor failed: "
+                                        << LOG_KV("code", error->errorCode()) << error->what();
 
                                     if (error->errorCode() ==
                                         bcos::executor::ExecuteError::SCHEDULER_TERM_ID_ERROR)

diff --git a/bcos-scheduler/src/SchedulerManager.cpp b/bcos-scheduler/src/SchedulerManager.cpp
@@ -220,8 +220,19 @@ void SchedulerManager::asyncSwitchTerm(
     // Will update scheduler session, clear all scheduler & executor block pipeline cache and
     // re-dispatch executor
     m_pool.enqueue([this, callback = std::move(callback), schedulerSeq]() {
-        switchTerm(schedulerSeq);
-        callback(nullptr);
+        try
+        {
+            switchTerm(schedulerSeq);
+            callback(nullptr);
+        }
+        catch (std::exception const& _e)
+        {
+            SCHEDULER_LOG(ERROR) << "asyncSwitchTerm failed" << boost::diagnostic_information(_e);
+        }
+        catch (...)
+        {
+            SCHEDULER_LOG(ERROR) << "asyncSwitchTerm failed";
+        }
     });
 }