update log info

Author: Guo-Shiyu

.vscode/settings.json

@@ -0,0 +1,6 @@
+{
+    "files.associations": {
+        "center_head": "cpp",
+        "common_head": "cpp"
+    }
+}

Src/Center/Center.cpp

@@ -76,6 +76,13 @@ void center::read_config()
         //交换主副配置指针
         swap(telemeter::setting_copy, telemeter::setting);  //atomic operation
 
+        LOG_INFO << "read config, interval: " << next_read_interval * 1000 << "s, current setting:";
+        LOG_INFO << "load record interval: " << telemeter::setting->mir_load_record_interval_;
+        LOG_INFO << "load database interval: " << telemeter::setting->mir_dblog_interval_;
+        LOG_INFO << "load balance interval: " << telemeter::setting->load_balance_interval_;
+        LOG_INFO << "max disbeat interval: " << telemeter::setting->mir_max_disbeat_time_;
+        LOG_INFO << "clear mirs data time: " << telemeter::setting->clear_mirs_data_time_; 
+        LOG_INFO << "login cache time: " << telemeter::setting->cli_login_cache_time_;
         //挂起该进程
         sleep(next_read_interval * 1000);
     }
@@ -92,6 +99,7 @@ void center::wait_cli_login()
 
     //纠正树形结构中cli信息的任务, 将交给线程池异步执行
     auto correct_tree_structure = [&](uuid cli_id){
+        LOG_INFO << "correct info in tree-like structure of client id: " << cli_id;
         for(auto& kvp : mirs_data_)
         {
             if(kvp.second.contains(cli_id))
@@ -196,6 +204,7 @@ void center::wait_cli_login()
 
             //数据库记录日志
             //dblog(cli_login, uid);
+            LOG_INFO << "client login, uid: " << uid << ", reply mirs ip: " << available_mir.to_string();
             if(this->all_cli_.count(uid) == 0)
                 this->all_cli_.insert(uid);
             else
@@ -220,8 +229,10 @@ void center::wait_cli_login()
                             if(atom_mutex_ == false)
                             {
                                 atom_mutex_ = true;
+                                uuid id = cookie_.front();
                                 cookie_.pop_front();
                                 atom_mutex_ = false;
+                                LOG_INFO << "erase login cache of client: " << id;
                             }
                             else
                                 continue;
@@ -314,6 +325,7 @@ void center::listen_mir_beat()
                         int i = 3;  //占位避免编译器报warning
                         //dblog(MIR_DISCONECT);
                         mirs_data_.erase(kvp.first);
+                        LOG_INFO << "mirror disconnect: " << const_cast<IP*>(&kvp.first)->to_string();
                     }
                 }
             }
@@ -324,16 +336,28 @@ void center::listen_mir_beat()
 
 void center::clear_mirs_data()
 {
-    //while(true)
+    auto get_next_zeropoint = [](){
+        time_t t = time(NULL); 
+        struct tm * tm= localtime(&t);  
+        tm->tm_mday += 1;
+        tm->tm_hour = 0;  
+        tm->tm_min = 0;  
+        tm->tm_sec = 0;
+        return mktime(tm);
+    };
+
+    while(true)
     {
-        //sleep(nowtime - nextzeropoint + setting->clear_mirsdata_time);
-        //mirs_data_.clear();
-        //all_cli_.clear();
+        sleep(get_next_zeropoint() - time(NULL) + telemeter::setting->clear_mirs_data_time_);
+        mirs_data_.clear();
+        all_cli_.clear();
+        LOG_INFO << "clear mirrors data successfully";
     }
 }
 
 IP center::load_balance()
 {
+    LOG_INFO << "load balance occurs";
     //暂时不优化
     for(auto& kvp : mirs_data_)
     {
@@ -379,7 +403,7 @@ void center::log_info(std::exception& e, const char* crush_file)
     log << "Mirrors & dispatched client:\n";
     for(auto& kvp : mirs_data_)
     {
-        log << "ip: " << kvp.first
+        log << "ip: " << const_cast<IP*>(&kvp.first)->to_string()
             << " load state: " << tostring(kvp.second.get_load_level()) << '\n';
         log << "dispatched client: \n";
         for(auto uid : kvp.second.get_dispatched_cli())

include/Common/Udp.hpp

@@ -64,6 +64,11 @@ struct IP {
         this->seg2 = res[2];
         this->seg3 = res[3];
     }
+
+    std::string to_string()
+    {
+        return std::to_string(this->seg0) + '.' + std::to_string(this->seg1) + '.' + std::to_string(this->seg2) + '.' + std::to_string(this->seg3);
+    }
 };
 
 bool GetHostInfo(std::string& hostName, std::string& Ip) {

include/center/center.h

@@ -16,6 +16,7 @@
 #include <thread>
 
 #include <muduo/base/ThreadPool.h>
+#include <muduo/base/Logging.h>
 
 #include <common_head>