updated to oatpp veraion 0.19.4

Author: lganzzzo

main/CMakeLists.txt

@@ -16,7 +16,7 @@ add_library(${project_name}-lib
 
 ## link libs
 
-find_package(oatpp 0.19.1 REQUIRED)
+find_package(oatpp 0.19.4 REQUIRED)
 
 target_link_libraries(${project_name}-lib
         PUBLIC oatpp::oatpp

main/src/AppComponent.hpp

@@ -23,13 +23,24 @@
  */
 class AppComponent {
 public:
-  
+
+  /**
+   * Create Async Executor
+   */
+  OATPP_CREATE_COMPONENT(std::shared_ptr<oatpp::async::Executor>, executor)([] {
+    return std::make_shared<oatpp::async::Executor>(
+      4 /* Data-Processing threads */,
+      1 /* I/O threads */,
+      1 /* Timer threads */
+    );
+  }());
+
   /**
    *  Create ConnectionProvider component which listens on the port
    */
   OATPP_CREATE_COMPONENT(std::shared_ptr<oatpp::network::ServerConnectionProvider>, serverConnectionProvider)([] {
     /* non_blocking connections should be used with AsyncHttpConnectionHandler for AsyncIO */
-    return oatpp::network::server::SimpleTCPConnectionProvider::createShared(8000, true /* true for non_blocking */);
+    return oatpp::network::server::SimpleTCPConnectionProvider::createShared(8000);
   }());
 
   /**
@@ -44,8 +55,8 @@ class AppComponent {
    */
   OATPP_CREATE_COMPONENT(std::shared_ptr<oatpp::network::server::ConnectionHandler>, serverConnectionHandler)([] {
     OATPP_COMPONENT(std::shared_ptr<oatpp::web::server::HttpRouter>, router); // get Router component
-    /* Async ConnectionHandler for Async IO and Coroutine based endpoints */
-    return oatpp::web::server::AsyncHttpConnectionHandler::createShared(router);
+    OATPP_COMPONENT(std::shared_ptr<oatpp::async::Executor>, executor); // get Async executor component
+    return oatpp::web::server::AsyncHttpConnectionHandler::createShared(router, executor);
   }());
 
   /**

main/src/Logger.cpp

@@ -11,6 +11,6 @@
 #include <iostream>
 
 void Logger::log(v_int32 priority, const std::string& tag, const std::string& message) {
-  oatpp::concurrency::SpinLock lock(m_atom);
+  std::lock_guard<oatpp::concurrency::SpinLock> lock(m_lock);
   std::cout << tag << ":" << message << "\n";
 }

main/src/Logger.hpp

@@ -19,12 +19,8 @@
  */
 class Logger : public oatpp::base::Logger {
 private:
-  oatpp::concurrency::SpinLock::Atom m_atom;
+  oatpp::concurrency::SpinLock m_lock;
 public:
-  
-  Logger()
-    : m_atom(false)
-  {}
 
   void log(v_int32 priority, const std::string& tag, const std::string& message) override;