Commit adb4e5bc authored by Tien-Thinh Nguyen's avatar Tien-Thinh Nguyen

Try multithread by default for pistache

parent 0d2d98f0
...@@ -121,13 +121,14 @@ int main(int argc, char** argv) { ...@@ -121,13 +121,14 @@ int main(int argc, char** argv) {
Pistache::Port(amf_cfg.n11.port)); Pistache::Port(amf_cfg.n11.port));
amf_api_server_1 = new AMFApiServer(addr, amf_app_inst); amf_api_server_1 = new AMFApiServer(addr, amf_app_inst);
amf_api_server_1->init(2); amf_api_server_1->init(2);
std::thread amf_http1_manager(&AMFApiServer::start, amf_api_server_1); // std::thread amf_http1_manager(&AMFApiServer::start, amf_api_server_1);
amf_api_server_1->start();
// AMF HTTP2 server // AMF HTTP2 server
amf_api_server_2 = new amf_http2_server( amf_api_server_2 = new amf_http2_server(
conv::toString(amf_cfg.n11.addr4), amf_cfg.sbi_http2_port, amf_app_inst); conv::toString(amf_cfg.n11.addr4), amf_cfg.sbi_http2_port, amf_app_inst);
amf_api_server_2->init(1); // amf_api_server_2->init(1);
std::thread amf_http2_manager(&amf_http2_server::start, amf_api_server_2); // std::thread amf_http2_manager(&amf_http2_server::start, amf_api_server_2);
amf_api_server_2->start();
// amf_http1_manager.join(); // amf_http1_manager.join();
// amf_http2_manager.join(); // amf_http2_manager.join();
......
...@@ -64,7 +64,7 @@ void AMFApiServer::start() { ...@@ -64,7 +64,7 @@ void AMFApiServer::start() {
"AMF handler for SubscriptionsCollectionDocumentApiImplEventExposure"); "AMF handler for SubscriptionsCollectionDocumentApiImplEventExposure");
m_httpEndpoint->setHandler(m_router->handler()); m_httpEndpoint->setHandler(m_router->handler());
m_httpEndpoint->serve(); m_httpEndpoint->serveThreaded();
} }
void AMFApiServer::shutdown() { void AMFApiServer::shutdown() {
m_httpEndpoint->shutdown(); m_httpEndpoint->shutdown();
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment