ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-12-06 17:27:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Catch unhandled exceptions in I/O service threads (RIPD-1166)

Browse Source
This commit is contained in:
Nik Bougalis
2016-06-29 18:15:14 -07:00
committed by seelabs
parent c4f8b38148
commit 16a38f3979
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/ripple/app/main/BasicApp.cpp
View File

@@ -20,6 +20,7 @@
#include <BeastConfig.h> #include <BeastConfig.h>
#include <ripple/app/main/BasicApp.h> #include <ripple/app/main/BasicApp.h>
#include <ripple/beast/core/Thread.h> #include <ripple/beast/core/Thread.h>
#include <ripple/core/ReportUncaughtException.h>
BasicApp::BasicApp(std::size_t numberOfThreads) BasicApp::BasicApp(std::size_t numberOfThreads)
{ {
@@ -27,11 +28,15 @@ BasicApp::BasicApp(std::size_t numberOfThreads)
threads_.reserve(numberOfThreads); threads_.reserve(numberOfThreads);
while(numberOfThreads--) while(numberOfThreads--)
threads_.emplace_back( threads_.emplace_back(
[this, numberOfThreads](){ [this, numberOfThreads]()
{
beast::Thread::setCurrentThreadName( beast::Thread::setCurrentThreadName(
std::string("io_service #") + std::string("io_service #") +
std::to_string(numberOfThreads)); std::to_string(numberOfThreads));
this->io_service_.run();
ripple::reportUncaughtException (&io_service_,
&boost::asio::io_service::run,
"io_service::run");
}); });
} }