srv.cpp

chronolaw · chronolaw · commit c135fe0aeec6 · 2020-04-10T17:09:39.000+08:00
diff --git a/section5/Config.hpp b/section5/Config.hpp
@@ -45,7 +45,7 @@ class Config final
     }
 
     template<typename T>
-    T get(string_view_type key)
+    T get(string_view_type key) const
     {
         if (!std::regex_match(key, m_what, m_reg)) {
             throw std::runtime_error("config key error");
@@ -64,8 +64,8 @@ class Config final
 private:
     vm_type     m_vm {luaL_newstate(), lua_close};
 
-    regex_type  m_reg {R"(^(\w+)\.(\w+)$)"};
-    match_type  m_what;
+    regex_type          m_reg {R"(^(\w+)\.(\w+)$)"};
+    mutable match_type  m_what;
 };
 
 END_NAMESPACE(cpp_study)
diff --git a/section5/conf.lua b/section5/conf.lua
@@ -18,7 +18,7 @@ config = {
 
     best_n  = 3,
 
-    time_interval = 1,
+    time_interval = 1,  -- seconds
 
 }
 
diff --git a/section5/srv.cpp b/section5/srv.cpp
@@ -1,8 +1,8 @@
 // Copyright (c) 2020 by Chrono
 //
-// g++ srv.cpp -std=c++14 -I../common -I../common/include -I/usr/local/include/luajit-2.1 -lluajit-5.1 -ldl -lzmq -lpthread -o a.out;./a.out
-// g++ srv.cpp -std=c++14 -I../common -I../common/include -I/usr/local/include/luajit-2.1 -lluajit-5.1 -ldl -lzmq -lpthread -g -O0 -o a.out
-// g++ srv.cpp -std=c++14 -I../common -I../common/include -I/usr/local/include/luajit-2.1 -lluajit-5.1 -ldl -lzmq -lpthread -g -O0 -o a.out;./a.out
+// g++ srv.cpp -std=c++14 -I../common -I../common/include -I/usr/local/include/luajit-2.1 -lluajit-5.1 -ldl -lzmq -lpthread -lcpr -lcurl -o a.out;./a.out
+// g++ srv.cpp -std=c++14 -I../common -I../common/include -I/usr/local/include/luajit-2.1 -lluajit-5.1 -ldl -lzmq -lpthread -lcpr -lcurl -g -O0 -o a.out
+// g++ srv.cpp -std=c++14 -I../common -I../common/include -I/usr/local/include/luajit-2.1 -lluajit-5.1 -ldl -lzmq -lpthread -lcpr -lcurl -g -O0 -o a.out;./a.out
 
 //#include <iostream>
 
@@ -14,6 +14,8 @@
 // you should put json.hpp in ../common
 #include "json.hpp"
 
+#include <cpr/cpr.h>
+
 USING_NAMESPACE(std);
 USING_NAMESPACE(cpp_study);
 
@@ -44,7 +46,7 @@ try
     std::atomic_int count {0};
 
     // todo: try-catch
-    auto cycle = [&](const auto& addr)
+    auto recv_cycle = [&](const auto& addr)
     {
         using zmq_ctx = ZmqContext<1>;
 
@@ -89,7 +91,38 @@ try
         }
     };
 
-    auto fu = std::async(cycle,
+    auto log_cycle = [&]()
+    {
+        auto http_addr = conf.get<string>("config.http_addr");
+        auto time_interval = conf.get<int>("config.time_interval");
+
+        for(;;) {
+            std::this_thread::sleep_for(time_interval * 1s);
+            //cout << "log_cycle" << endl;
+
+            using json_t = nlohmann::json;
+
+            json_t j;
+
+            j["count"] = static_cast<int>(count);
+
+            auto res = cpr::Post(
+                       cpr::Url{http_addr},
+                       cpr::Body{j.dump()},
+                       cpr::Timeout{200ms}
+            );
+
+            if (res.status_code != 200) {
+                cout << "http post failed" << endl;
+            }
+        }
+    };
+
+    // launch log_cycle
+    std::async(std::launch::async, log_cycle);
+
+    // launch recv_cycle then wait
+    auto fu = std::async(recv_cycle,
                 conf.get<string>("config.zmq_ipc_addr"));
 
     fu.wait();

Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ config = {`
`18`	`18`
`19`	`19`	`best_n = 3,`
`20`	`20`
`21`		`- time_interval = 1,`
	`21`	`+ time_interval = 1, -- seconds`
`22`	`22`
`23`	`23`	`}`
`24`	`24`