Merge pull request #506 from bluecherrydvr/bc_stats

Bluecherry server based stats

lib/BCMK

@@ -12,7 +12,7 @@ CFLAGS		+= -fPIC -DETCDIR="\"$(etc_dir)\""
 SOLIB		= libbluecherry.so
 SOLIBVER	= $(SOLIB).0
 OBJS		= bc-core.o bc-utils.o bc-db-core.o bc-db-mysql.o \
-		  bc-key.o bc-media.o lavf_device.o bc-ptz.o \
+		  bc-key.o bc-media.o lavf_device.o bc-ptz.o bc-stats.o \
 		  input_device.o v4l2_device_solo6x10.o stream_elements.o \
 		  logging.o bc-syslog.o sliding_seq_window.o \
 		  v4l2_device_tw5864.o v4l2_device_solo6010-dkms.o

lib/bc-stats.h

@@ -0,0 +1,120 @@
+#ifndef __BC_STATS__
+#define __BC_STATS__
+
+#include <unordered_map>
+#include <string>
+#include <vector>
+
+#include <inttypes.h>
+#include <pthread.h>
+
+#define _BC_ALIGNED_ __attribute__((aligned))
+
+class bc_stats 
+{
+public:
+    struct memory {
+        uint64_t _BC_ALIGNED_ resident = 0;
+        uint64_t _BC_ALIGNED_ virt = 0;
+        uint64_t _BC_ALIGNED_ avail = 0;
+        uint64_t _BC_ALIGNED_ total = 0;
+        uint64_t _BC_ALIGNED_ free = 0;
+        uint64_t _BC_ALIGNED_ swap = 0;
+        uint64_t _BC_ALIGNED_ buff = 0;
+    };
+
+    struct cpu_info {
+        int cpu_id = 0; // -1 for sum
+
+        /* Calculated percents */
+        uint32_t _BC_ALIGNED_ soft_ints = 0;
+        uint32_t _BC_ALIGNED_ hard_ints = 0;
+        uint32_t _BC_ALIGNED_ user_niced = 0;
+        uint32_t _BC_ALIGNED_ kernel_space = 0;
+        uint32_t _BC_ALIGNED_ user_space = 0;
+        uint32_t _BC_ALIGNED_ idle_time = 0;
+        uint32_t _BC_ALIGNED_ io_wait = 0;
+
+        /* Raw information */
+        uint32_t _BC_ALIGNED_ soft_ints_raw = 0;
+        uint32_t _BC_ALIGNED_ hard_ints_raw = 0;
+        uint32_t _BC_ALIGNED_ user_niced_raw = 0;
+        uint32_t _BC_ALIGNED_ kernel_space_raw = 0;
+        uint32_t _BC_ALIGNED_ user_space_raw = 0;
+        uint32_t _BC_ALIGNED_ idle_time_raw = 0;
+        uint32_t _BC_ALIGNED_ io_wait_raw = 0;
+        uint64_t _BC_ALIGNED_ total_raw = 0;
+    };
+
+    struct net_iface {
+        std::string hwaddr = std::string("");
+        std::string ipaddr = std::string("");
+        std::string name = std::string("");
+
+        uint64_t bytes_recv_per_sec = 0;
+        uint64_t bytes_sent_per_sec = 0;
+        uint64_t pkts_recv_per_sec = 0;
+        uint64_t pkts_sent_per_sec = 0;
+
+        int64_t bytes_recv = 0;
+        int64_t bytes_sent = 0;
+        int64_t pkts_recv = 0;
+        int64_t pkts_sent = 0;
+        int32_t type = 0;
+    };
+
+    static void copy_cpu_info(bc_stats::cpu_info *dst, bc_stats::cpu_info *src);
+    static uint64_t parse_info(char *buffer, size_t size, const char *field);
+    static int load_file(const char *path, char *buffer, size_t size);
+
+    static uint32_t bc_float_to_u32(float value);
+    static float bc_u32_to_float(uint32_t value);
+
+    typedef std::unordered_map<std::string, net_iface>::iterator network_it;
+    typedef std::unordered_map<std::string, net_iface> network;
+    typedef std::vector<cpu_info> cpu_infos;
+
+    struct cpu {
+        struct process {
+            uint32_t _BC_ALIGNED_ kernel_space_usg = 0;
+            uint32_t _BC_ALIGNED_ user_space_usg = 0;
+            uint64_t _BC_ALIGNED_ kernel_space = 0;
+            uint64_t _BC_ALIGNED_ user_space = 0;
+            uint64_t _BC_ALIGNED_ total_time = 0;
+            int64_t _BC_ALIGNED_ kernel_childs = 0;
+            int64_t _BC_ALIGNED_ user_childs = 0;
+        } proc;
+
+        uint16_t _BC_ALIGNED_ core_count = 0;
+        uint32_t _BC_ALIGNED_ load_avg[3];
+
+        cpu_infos cores;
+        cpu_info sum;
+    };
+
+    void start_monithoring();
+    void stop_monithoring();
+    void display();
+
+    void get_proc_usage(bc_stats::cpu::process *proc);
+    void get_net_info(bc_stats::network *net);
+    void get_mem_info(bc_stats::memory *mem);
+    bool get_cpu_info(bc_stats::cpu *cpu);
+
+private:
+    void monithoring_thread();
+    bool update_net_info();
+    bool update_mem_info();
+    bool update_cpu_info();
+
+    uint8_t _BC_ALIGNED_ _active = 0;
+    uint8_t _BC_ALIGNED_ _cancel = 0;
+    uint8_t _monitoring_interval = 1;
+    pthread_mutex_t     _mutex;
+
+    bc_stats::network   _network;
+    bc_stats::memory    _memory;
+    bc_stats::cpu       _cpu;
+};
+
+#endif /* __BC_STATS__ */

nginx-configs/bluecherry.conf

@@ -24,4 +24,9 @@ server {
   location /hls {
       proxy_pass http://127.0.0.1:7003;
   }
+
+  # API proxy
+  location /api {
+      proxy_pass http://127.0.0.1:7005;
+  }
 }

server/BCMK

@@ -21,7 +21,7 @@ SERVER_OBJS	= bc-server.o bc-thread.o media_writer.o g723-dec.o \
 		  decoder.o encoder.o reencoder.o vaapi.o scaler.o \
 		  recorder.o motion_handler.o ffmpeg-init.o bt.o status_server.o \
 		  trigger_server.o substream-thread.o onvif_events.o \
-		  v3license_server.o v3license_processor.o hls.o
+		  v3license_server.o v3license_processor.o hls.o bc-api.o
 
 all: $(TARGETS) FORCE