ready to check missing trigger

.gitignore

@@ -2,3 +2,4 @@ r
 build
 old
 dump
+spdlog

.gitmodules

@@ -1,3 +0,0 @@
-[submodule "loguru"]
-	path = loguru
-	url = https://github.com/emilk/loguru

Makefile

@@ -1,10 +1,10 @@
 target = r
 CXX = g++
-CXX_FLAGS := -std=c++14 -Iloguru -Wall
+CXX_FLAGS := -std=c++14 -I/home/daq/sw/include -Wall -DSPDLOG_COMPILED_LIB 
-LD_FLAGS := -lpthread -ldl
+LD_FLAGS := -lpthread -ldl -L/home/daq/sw/lib64 -lspdlog
-# LOGURU_FLAG := -DLOGURU_SCOPE_TIME_PRECISION=9
+
 BUILD := ./build
-OBJS := $(BUILD)/client.o $(BUILD)/loguru.o
+OBJS = $(BUILD)/client.o $(BUILD)/channel.o
 
 all: $(target)
 
@@ -12,10 +12,6 @@ $(BUILD)/%.o: %.cc
 	@mkdir -p $(BUILD)
 	g++ -c $< -o $@ $(CXX_FLAGS) 
 
-$(BUILD)/loguru.o:
-	@mkdir -p $(BUILD)
-	g++ -c loguru/loguru.cpp -Iloguru -o $@ $(CXX_FLAGS) $(LOGURU_FLAG)
-
 r: $(OBJS)
 	g++ -o $@ $^ $(LD_FLAGS)
 

channel.cc

@@ -0,0 +1,56 @@
+#include "channel.h"
+#include "spdlog/spdlog.h"
+
+Channel::Channel(char const * ptr, size_t len) {
+   valid = true;
+   uint32_t * wordData = (uint32_t *)ptr;
+   size = ((wordData[0] & 0xFFFFFF00) >> 8) * sizeof(uint32_t);
+   if (size != len) valid = false;
+
+   version = wordData[0] && 0xFF;
+   if (version != 0x1) valid = false;
+
+   for (int i = 0; i < 3; i++) 
+      integral[i] = (wordData[i + 1] & 0xFFFFFF00)>>8;
+
+   crossing = wordData[4] & 0x00FFFFFF;
+   block_count = (wordData[5] &0xFF000000) >> 24;
+   id = (wordData[5] & 0x00FF0000) >> 16;
+   spill = (wordData[5] & 0x0000FFFF);
+   if ((id > 8) || (id < 1)) {
+      valid = false;
+   }
+
+}
+
+Channel::Channel(char const * ptr, size_t len, uint32_t board) {
+   board_id = board;
+   valid = true;
+   uint32_t * wordData = (uint32_t *)ptr;
+   size = ((wordData[0] & 0xFFFFFF00) >> 8) * sizeof(uint32_t);
+   if (size != len) valid = false;
+
+   version = wordData[0] && 0xFF;
+   if (version != 0x1) valid = false;
+
+   for (int i = 0; i < 3; i++) 
+      integral[i] = (wordData[i + 1] & 0xFFFFFF00)>>8;
+
+   crossing = wordData[4] & 0x00FFFFFF;
+   block_count = (wordData[5] &0xFF000000) >> 24;
+   id = (wordData[5] & 0x00FF0000) >> 16;
+   spill = (wordData[5] & 0x0000FFFF);
+   if ((id > 8) || (id < 1)) {
+      valid = false;
+   }
+
+}
+void Channel::Print(){
+   if (valid) {
+      spdlog::get("zynqDump")->debug("board {}, channel {}, spill {}, size {}, blocks {}, crossing {}, integrals {}, {}, {}",
+            board_id, id, spill, size, block_count, crossing, integral[0], integral[1], integral[2]);
+   }
+   else {
+      spdlog::get("zynqDump")->info("Invalid channel");
+   }
+}

channel.h

@@ -5,6 +5,7 @@
 #include <cstdlib>
 
 class Channel {
+   uint32_t board_id;
    uint32_t id;
    uint32_t size;
    uint32_t version;
@@ -16,39 +17,8 @@ class Channel {
    bool valid;
    public:
    Channel(char const * ptr, size_t len);
+   Channel(char const * ptr, size_t len, uint32_t board);
    void Print();
 
 };
-Channel::Channel(char const * ptr, size_t len) {
-   valid = true;
-   uint32_t * wordData = (uint32_t *)ptr;
-   size = ((wordData[0] & 0xFFFFFF00) >> 8) * sizeof(uint32_t);
-   if (size != len) valid = false;
-
-   version = wordData[0] && 0xFF;
-   if (version != 0x1) valid = false;
-
-   for (int i = 0; i < 3; i++) 
-      integral[i] = (wordData[i + 1] & 0xFFFFFF00)>>8;
-
-   crossing = wordData[4] & 0x00FFFFFF;
-   block_count = (wordData[5] &0xFF000000) >> 24;
-   id = (wordData[5] & 0x00FF0000) >> 16;
-   spill = (wordData[5] & 0x0000FFFF);
-   if ((id > 8) || (id < 1)) {
-      valid = false;
-   }
-
-}
-
-#include <iostream>
-void Channel::Print(){
-   if (valid) {
-      printf("channel %u, spill %u, size %u, blocks %u, crossing %u, integrals %d, %d, %d\n",
-            id, spill, size, block_count, crossing, integral[0], integral[1], integral[2]);
-   }
-   else {
-      printf("Invalid channel\n");
-   }
-}
 #endif /* end of include guard */

client.cc

@@ -13,8 +13,9 @@
 #include <ctime>
 #include <iomanip>
 #include <csignal>
-#include "loguru.hpp"
 #include "channel.h"
+#include "spdlog/spdlog.h"
+#include "spdlog/sinks/rotating_file_sink.h"
 
 const char * HOST = "192.168.30.89";
 const uint32_t PORT = 9999;
@@ -32,72 +33,16 @@ bool bad_data = true;
 int open_socket();
 void signalHandler( int signum );
 void setup_logger();
-size_t process_channel(char const * ptr, size_t len);
+size_t process_channel(char const * ptr, size_t len, uint32_t board_id);
 size_t process_block(char const * ptr, size_t len);
 size_t process_block(char const * ptr, size_t len){
    return len;
 }
-size_t process_channel(char const * ptr, size_t len){
-   if ((len < MIN_CHANNEL_SIZE) || (len > MAX_CHANNEL_SIZE)) {
-      LOG_SCOPE_F(WARNING, "channel length must be between %lu and %lu.",
-            MIN_CHANNEL_SIZE, MAX_CHANNEL_SIZE);
-      return len;
-   }
-
-   size_t bytes_left = len;
-   bool valid_channel = false;
-   uint32_t * wordData = (uint32_t *)ptr;
-
-   while ((bytes_left > 0) && !valid_channel) {
-      if ((ptr[0] & 0xFF) != CHANNEL_MARKER){
-         LOG_SCOPE_F(WARNING, "bad_data, expecting %02X, received %02X",
-               static_cast<uint32_t>(CHANNEL_MARKER), static_cast<uint32_t>(ptr[0]));
-         bytes_left -= 4;
-      } else {
-         valid_channel = true;
-
-         size_t channel_size = ((wordData[0] & 0xFFFFFF00) >> 8) * sizeof(uint32_t);
-         if ((channel_size > MAX_CHANNEL_SIZE) || (channel_size < MIN_CHANNEL_SIZE)) {
-            LOG_SCOPE_F(WARNING, "Invalid channel size: %lu", channel_size);
-         }
-         uint32_t version = wordData[0] && 0xFF;
-         LOG_SCOPE_F(INFO, "channel size %lu, version %u", channel_size, version);
-
-         int32_t integral[3];
-         for (int i = 0; i < 3; i++) 
-            integral[i] = (wordData[i + 1] & 0xFFFFFF00)>>8;
-         LOG_SCOPE_F(INFO, "integrals: %d, %d, %d", integral[0], integral[1], integral[2]);
-
-         uint32_t crossing_count = wordData[4] & 0x00FFFFFF;
-         uint32_t block_count = (wordData[5] &0xFF000000) >> 24;
-         uint32_t channel = (wordData[5] & 0x00FF0000) >> 16;
-         uint32_t spill_id = (wordData[5] & 0x0000FFFF);
-         LOG_SCOPE_F(INFO, "crossing_count %u, block_count %u, channel %u, spill_id %u",
-               crossing_count, block_count, channel, spill_id);
-
-         for (uint32_t i = 0; i < block_count; i++) {
-            process_block(ptr, channel_size); // not correct yet!
-         }
-
-         // the number of bytes cosumed by this function, regardless of block
-         // processing
-         bytes_left -= channel_size;
-
-         Channel c(ptr, channel_size);
-         c.Print();
-      }
-   }
-
-   // return number of bytes cosumed of the channel
-   LOG_SCOPE_F(INFO, "processed %lu bytes out of %lu", (len - bytes_left), len);
-   return len - bytes_left;
-}
 
 
 int main(int argc, char * argv[])
 {
    setup_logger();
-   loguru::init(argc, argv);
    signal(SIGINT, signalHandler);
    int ret = open_socket();
    if (ret != 0)
@@ -124,7 +69,7 @@ int main(int argc, char * argv[])
       else{
          // read in first 4 bytes
          nread = recv(sock, char_buffer, 4, 0);
-         LOG_F(INFO, "read in %ld bytes: 0x%08X", nread, wordData[0]);
+         spdlog::get("zynqDump")->debug("read in {:d} bytes: 0x{:X}", nread, wordData[0]);
          // if not A5 marker, go to next iteration (read in 4 more bytes)
          if ((char_buffer[0] & 0xFF) != 0xA5){
             bad_data = true;
@@ -141,14 +86,14 @@ int main(int argc, char * argv[])
             }
             else {
                // ok, this seems to be good data
-               LOG_F(INFO, "next %ld bytes (expecting %lu): %08X %08X %08X %08X",
+               spdlog::get("zynqDump")->debug("next {:d} bytes (expecting {:d}): {:X} {:X} {:X} {:X}",
                      nread, frameSize - 4, wordData[0], wordData[1], wordData[2], wordData[3]);
-               LOG_F(INFO, "%08X %08X %08X %08X", wordData[4], wordData[5], wordData[6], wordData[7]);
+               spdlog::get("zynqDump")->debug("{:X} {:X} {:X} {:X}", wordData[4], wordData[5], wordData[6], wordData[7]);
                uint8_t board_id = (wordData[0] >> 24) & 0xFF;
                uint8_t version = wordData[0] & 0xFF;
                uint16_t spill_id = (wordData[1] & 0x00FFFF00) >> 8;
                uint8_t channel_count = (wordData[1]) & 0x000000FF;
-               LOG_F(INFO, "board %u, version %u, spill %u, channel_count %u",
+               spdlog::get("zynqDump")->info("board {}, version {}, spill {}, channel_count {}",
                      static_cast<uint32_t>(board_id),
                      static_cast<uint32_t>(version),
                      static_cast<uint32_t>(spill_id),
@@ -162,10 +107,12 @@ int main(int argc, char * argv[])
                   size_t bytes_left = (frameSize - 3 * sizeof(uint32_t));
                   size_t bytes_processed = 0;
                   while ((bytes_left - bytes_processed >= MIN_CHANNEL_SIZE) && (bytes_processed < bytes_left)) {
-                     bytes_processed += process_channel(char_buffer + 2 * sizeof(uint32_t) + bytes_processed,
+                     bytes_processed += process_channel(
-                           bytes_left - bytes_processed);
+                           char_buffer + 2 * sizeof(uint32_t) + bytes_processed,
+                           bytes_left - bytes_processed,
+                           static_cast<uint32_t>(board_id));
                   }
-                  LOG_F(INFO, "Done, %lu bytes processed.", bytes_processed);
+                  spdlog::get("zynqDump")->debug("Done, {} bytes processed.", bytes_processed);
                }
 
             }
@@ -178,7 +125,7 @@ int main(int argc, char * argv[])
 }
 
 void signalHandler( int signum ) {
-   RAW_LOG_F(WARNING, "Interrupt signal (%d) received, exiting...", signum);
+   spdlog::get("zynqDump")->info("Interrupt signal ({}) received, exiting...", signum);
    running = false;
 }
 
@@ -207,13 +154,70 @@ int open_socket(){
 }
 
 void setup_logger(){
-   // loguru::g_stderr_verbosity = loguru::Verbosity_INFO;
+   try {
-   loguru::g_stderr_verbosity = loguru::Verbosity_WARNING;
+      auto max_size = 1048576 * 5;
-   loguru::g_preamble_date    = true; // The date field
+      auto max_files = 3;
-   loguru::g_preamble_time    = true; // The time of the current day
+      auto logger = spdlog::rotating_logger_mt("zynqDump", "logs/dump.txt", max_size, max_files);
-   loguru::g_preamble_uptime  = true; // The time since init call
+   }
-   loguru::g_preamble_thread  = false; // The logging thread
+   catch (const spdlog::spdlog_ex &ex) {
-   loguru::g_preamble_file    = false; // The file from which the log originates from
+      std::cerr << "Log init failed: " << ex.what() << std::endl;
-   loguru::g_preamble_verbose = false; // The verbosity field
+      exit(-1);
-   loguru::g_preamble_pipe    = false; // The pipe symbol right before the message
+   }
 }
+
+size_t process_channel(char const * ptr, size_t len, uint32_t board_id){
+   if ((len < MIN_CHANNEL_SIZE) || (len > MAX_CHANNEL_SIZE)) {
+      spdlog::debug("channel length must be between {} and {}.",
+            MIN_CHANNEL_SIZE, MAX_CHANNEL_SIZE);
+      return len;
+   }
+
+   size_t bytes_left = len;
+   bool valid_channel = false;
+   uint32_t * wordData = (uint32_t *)ptr;
+
+   while ((bytes_left > 0) && !valid_channel) {
+      if ((ptr[0] & 0xFF) != CHANNEL_MARKER){
+         spdlog::debug("bad_data, expecting {0:x}, received {0:x}",
+               static_cast<uint32_t>(CHANNEL_MARKER), static_cast<uint32_t>(ptr[0]));
+         bytes_left -= 4;
+      } else {
+         valid_channel = true;
+
+         size_t channel_size = ((wordData[0] & 0xFFFFFF00) >> 8) * sizeof(uint32_t);
+         if ((channel_size > MAX_CHANNEL_SIZE) || (channel_size < MIN_CHANNEL_SIZE)) {
+            spdlog::debug("Invalid channel size: {}", channel_size);
+         }
+         uint32_t version = wordData[0] && 0xFF;
+         spdlog::debug("channel size {}, version {}", channel_size, version);
+
+         int32_t integral[3];
+         for (int i = 0; i < 3; i++) 
+            integral[i] = (wordData[i + 1] & 0xFFFFFF00)>>8;
+         spdlog::debug("integrals: {}, {}, {}", integral[0], integral[1], integral[2]);
+
+         uint32_t crossing_count = wordData[4] & 0x00FFFFFF;
+         uint32_t block_count = (wordData[5] &0xFF000000) >> 24;
+         uint32_t channel = (wordData[5] & 0x00FF0000) >> 16;
+         uint32_t spill_id = (wordData[5] & 0x0000FFFF);
+         spdlog::debug("crossing_count {}, block_count {}, channel {}, spill_id {}",
+               crossing_count, block_count, channel, spill_id);
+
+         for (uint32_t i = 0; i < block_count; i++) {
+            process_block(ptr, channel_size); // not correct yet!
+         }
+
+         // the number of bytes consumed by this function, regardless of block
+         // processing
+         bytes_left -= channel_size;
+
+         Channel c(ptr, channel_size, board_id);
+         c.Print();
+      }
+   }
+
+   // return number of bytes cosumed of the channel
+   spdlog::debug("processed {} bytes out of {}", (len - bytes_left), len);
+   return len - bytes_left;
+}
+