update

from sliver branch

Author: jin1xiao3long2

.gitignore

@@ -1,3 +1,2 @@
 build/
 lib/
-include/

include/Telemeter.hpp

@@ -0,0 +1,91 @@
+#ifndef SRC_TELEMETER_H
+#define SRC_TELEMETER_H
+
+#pragma once
+
+#include <stdint.h>
+#include <cstring>
+
+enum class LoadLevel : uint8_t
+{
+  untapped  = 0, //no client dispatched on this mirror
+  light     = 1,  //[0% - 50%]
+  medium    = 2,  //[50% - 80%]
+  heavy     = 3,  //[ >= 80%]   
+};
+
+
+//POD type
+struct DetailLoadState
+{
+  uint8_t mem_load, serve_load, net_load_, reserve_seg_;
+};
+
+void copy(DetailLoadState* dest, const DetailLoadState* sour)
+{  memcpy(dest, sour, sizeof(DetailLoadState));  }
+
+#ifdef SRC_CENTER_H
+//center的setting, POD type
+struct Setting
+{
+  uint8_t mir_load_record_interval_;  //记录mirror负载到缓存的间隔(按照心跳包的个数来计数), 从配置文件中读
+  uint8_t mir_dblog_interval_;        //将mirror负载缓存更新到数据库(数据文件)的间隔(缓存了这么多之后打一次log), 从配置文件中读
+  uint8_t mir_max_disbeat_time_;      //多少个心跳轮无心跳视为断线
+  uint8_t cli_login_cache_time_;      //清空一个cli登录缓冲的时间
+};
+//第一字段为60表示一分钟(60个心跳包)记录一次mir的负载情况, 
+//第二字段为5表示5分钟(缓存5次)输出到遥测数据库一次
+
+const constexpr uint _permanent_thread_num_ = 3; //center的常驻线程数量
+
+#endif
+
+#ifdef SRC_MIRROR_H
+//mirror的setting, POD type
+struct Setting
+{
+  int center_ip_;
+  //int backup_center_ip_;
+  uint8_t mir_beat_interval_;
+  uint8_t //数据库ip?
+};
+
+#endif
+
+#define RESERVE_SEGMENG_INIT_VALUE 0
+
+namespace telemeter
+{
+  const constexpr char* klog_file = "TelemeterLog.txt";  //临时的遥测日志文件
+  
+#ifdef SRC_CENTER_H
+  //双缓冲配置表解决一写多读线程安全问题
+  Setting _set_cache_one = {60, 5, 15, 60}; 
+  Setting _set_cache_two = {60, 5, 15, 60};
+  //主要使用这个指针获取当前配置, 每次读取数据到第二个指针中, 然后交换两个指针的值
+  Setting* setting = &_set_cache_one;
+  Setting* setting_copy = &_set_cache_two;
+#endif
+
+#ifdef SRC_MIRROR_H
+#endif
+  
+    
+
+  
+  //获取本机负载情况的函数, 需要统计空闲内存占比, cpu负载, 空闲磁盘占比
+  LoadLevel getLocalLoadLevel();
+  
+  //int getLocalMemLoad();
+  //int getLocalSevLoad();
+  //int getLocalNetLoad();
+}
+
+
+
+
+
+
+
+
+#endif //SRC_TELEMETER_H

include/Type.hpp

@@ -0,0 +1,12 @@
+#ifndef SRC_TYPE_H
+#define SRC_TYPE_H
+
+#pragma once
+
+#include "boost/lockfree/queue.hpp"
+template<typename T>
+using lfqueue = boost::lockfree::queue;
+
+
+
+#endif //SRC_TYPE_H

include/Udp.hpp

@@ -0,0 +1,53 @@
+#ifndef SRC_UDP_H
+#define SRC_UDP_H
+
+#pragma once
+
+//暂时以int表示ip, 有需要则封装成类
+using IP = int;
+
+namespace port
+{
+  const constexpr int kCLI_LOGIN_  = 20800;
+  const constexpr int kCLI_BEAT_   = 20801;
+  const constexpr int kMIR_BEAT_   = 20802;
+  const constexpr int kINS_MSG_    = 20803; 
+}
+
+namespace udp
+{
+  void loop();
+
+  void recv();
+  void send();
+}
+
+
+#endif //SRC_UDP_H
+
+
+
+/*
+class IP
+{
+private:
+    union //IP地址共占4个字节
+    {
+        struct //这是一个由4个字节构成的匿名结构体
+        {
+            unsigned char seg0;
+            unsigned char seg1;
+            unsigned char seg2;
+            unsigned char seg3;
+        };  //4字节的IP地址可以看作4部分，每部分1字节
+        unsigned int address; //4字节的IP地址可以看成一个4字节的整体
+    };
+public:
+    IP(int=0,int=0,int=0,int=0);  //构造函数
+    void showIP();  //用四段法显示IP地址
+    bool sameSubnet(const IP &ip, const IP &mark);  //判断是否处于同一子网
+    char whatKind();  //返回属于哪一类网络
+};
+
+原文链接：https://blog.csdn.net/chongshangyunxiao321/article/details/51055658
+*/