Compare commits

8 Commits

Author SHA1 Message Date
a2e8997090 change spdlog library name 2021-06-09 15:33:06 -04:00
e07831fcad cmake use precompiled spdlog 2021-06-05 08:36:31 -04:00
ec73a87d31 remove spdlog submodule 2021-06-05 00:11:06 -04:00
e3fb134dbb add spdlog to CMakeLists 2021-06-04 22:59:02 -04:00
6c3b0ceed4 submodule added 2021-06-04 22:55:49 -04:00
e5218cd885 add submodule 2021-06-04 20:39:27 -04:00
afc9b1d6fb switch to cmake 2021-06-04 20:38:33 -04:00
Nam Tran
f24628443f correct interpretation of integrals 2020-11-25 18:48:43 -06:00
6 changed files with 44 additions and 35 deletions

1
.gitignore vendored
View File

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

15
CMakeLists.txt Normal file
View File

@@ -0,0 +1,15 @@
cmake_minimum_required(VERSION 3.0.0)
project(zynqDump VERSION 0.1.0)
set(TARGET zynqDump)
add_compile_options("-std=c++14")
include_directories("/home/nam/sw/include")
add_library(channel STATIC channel.cc)
find_library(SPDLOG
NAMES spdlog
HINTS "/home/nam/sw/lib"
)
add_executable(${TARGET} client.cc)
target_link_libraries(${TARGET} channel ${SPDLOG})

View File

@@ -1,7 +1,7 @@
target = r target = r
CXX = g++ CXX = g++
CXX_FLAGS := -std=c++14 -I/home/daq/sw/include -Wall -DSPDLOG_COMPILED_LIB CXX_FLAGS := -std=c++14 -I./include -Wall
LD_FLAGS := -lpthread -ldl -L/home/daq/sw/lib64 -lspdlog LD_FLAGS := -lpthread -ldl
BUILD := ./build BUILD := ./build
OBJS = $(BUILD)/client.o $(BUILD)/channel.o OBJS = $(BUILD)/client.o $(BUILD)/channel.o

View File

@@ -1,32 +1,11 @@
#include "channel.h" #include "channel.h"
#include "spdlog/spdlog.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) { Channel::Channel(char const * ptr, size_t len, uint32_t board) {
board_id = board; board_id = board;
valid = true; valid = true;
uint32_t * wordData = (uint32_t *)ptr; uint32_t * wordData = (uint32_t *)ptr;
block_data = (char *)ptr;
size = ((wordData[0] & 0xFFFFFF00) >> 8) * sizeof(uint32_t); size = ((wordData[0] & 0xFFFFFF00) >> 8) * sizeof(uint32_t);
if (size != len) valid = false; if (size != len) valid = false;
@@ -34,10 +13,10 @@ Channel::Channel(char const * ptr, size_t len, uint32_t board) {
if (version != 0x1) valid = false; if (version != 0x1) valid = false;
for (int i = 0; i < 3; i++) for (int i = 0; i < 3; i++)
integral[i] = (wordData[i + 1] & 0xFFFFFF00)>>8; integral[i] = ((int32_t)(wordData[i+1])) >> 8;
crossing = wordData[4] & 0x00FFFFFF; crossing = wordData[4] & 0x00FFFFFF;
block_count = (wordData[5] &0xFF000000) >> 24; block_count = wordData[5] >> 24;
id = (wordData[5] & 0x00FF0000) >> 16; id = (wordData[5] & 0x00FF0000) >> 16;
spill = (wordData[5] & 0x0000FFFF); spill = (wordData[5] & 0x0000FFFF);
if ((id > 8) || (id < 1)) { if ((id > 8) || (id < 1)) {
@@ -45,9 +24,16 @@ Channel::Channel(char const * ptr, size_t len, uint32_t board) {
} }
} }
void Channel::Print(){ void Channel::Print(bool raw){
if (valid) { if (valid) {
spdlog::get("zynqDump")->debug("board {}, channel {}, spill {}, size {}, blocks {}, crossing {}, integrals {}, {}, {}", if (raw) {
uint32_t * wordData = (uint32_t *)block_data;
spdlog::info("{:08X} {:08X} {:08X}", wordData[0], wordData[1], wordData[2]);
spdlog::info("{:08X} {:08X} {:08X}", wordData[3], wordData[4], wordData[5]);
}
// spdlog::get("channel_logger")->info("board {}, channel {}, spill {}, size {}, blocks {}, crossing {}, integrals {}, {}, {}",
// board_id, id, spill, size, block_count, crossing, integral[0], integral[1], integral[2]);
spdlog::info("board {}, channel {}, spill {}, size {}, blocks {}, crossing {}, integrals {}, {}, {}",
board_id, id, spill, size, block_count, crossing, integral[0], integral[1], integral[2]); board_id, id, spill, size, block_count, crossing, integral[0], integral[1], integral[2]);
} }
else { else {

View File

@@ -16,9 +16,8 @@ class Channel {
char * block_data; char * block_data;
bool valid; bool valid;
public: public:
Channel(char const * ptr, size_t len);
Channel(char const * ptr, size_t len, uint32_t board); Channel(char const * ptr, size_t len, uint32_t board);
void Print(); void Print(bool raw = false);
}; };
#endif /* end of include guard */ #endif /* end of include guard */

View File

@@ -17,7 +17,7 @@
#include "spdlog/spdlog.h" #include "spdlog/spdlog.h"
#include "spdlog/sinks/rotating_file_sink.h" #include "spdlog/sinks/rotating_file_sink.h"
const char * HOST = "192.168.30.89"; const char * HOST = "192.168.19.1";
const uint32_t PORT = 9999; const uint32_t PORT = 9999;
const size_t MAX_EVENT_SIZE = 33484; // in bytes const size_t MAX_EVENT_SIZE = 33484; // in bytes
const size_t MIN_EVENT_SIZE = 204; // in bytes const size_t MIN_EVENT_SIZE = 204; // in bytes
@@ -51,6 +51,9 @@ int main(int argc, char * argv[])
char char_buffer[MAX_EVENT_SIZE]; char char_buffer[MAX_EVENT_SIZE];
uint32_t * wordData = (uint32_t*) char_buffer; uint32_t * wordData = (uint32_t*) char_buffer;
ssize_t nread; ssize_t nread;
std::ofstream output;
std::string outputName = "dump.bin";
output.open (outputName, std::ios::out );
fd_set select_fds; // fd's used by select fd_set select_fds; // fd's used by select
struct timeval timeout; // Time value for time out struct timeval timeout; // Time value for time out
@@ -70,6 +73,9 @@ int main(int argc, char * argv[])
// read in first 4 bytes // read in first 4 bytes
nread = recv(sock, char_buffer, 4, 0); nread = recv(sock, char_buffer, 4, 0);
spdlog::get("zynqDump")->debug("read in {:d} bytes: 0x{:X}", nread, wordData[0]); spdlog::get("zynqDump")->debug("read in {:d} bytes: 0x{:X}", nread, wordData[0]);
for (uint32_t j = 0; j < nread; ++j) {
output << char_buffer[j];
}
// if not A5 marker, go to next iteration (read in 4 more bytes) // if not A5 marker, go to next iteration (read in 4 more bytes)
if ((char_buffer[0] & 0xFF) != 0xA5){ if ((char_buffer[0] & 0xFF) != 0xA5){
bad_data = true; bad_data = true;
@@ -89,6 +95,9 @@ int main(int argc, char * argv[])
spdlog::get("zynqDump")->debug("next {:d} bytes (expecting {:d}): {:X} {:X} {:X} {:X}", spdlog::get("zynqDump")->debug("next {:d} bytes (expecting {:d}): {:X} {:X} {:X} {:X}",
nread, frameSize - 4, wordData[0], wordData[1], wordData[2], wordData[3]); nread, frameSize - 4, wordData[0], wordData[1], wordData[2], wordData[3]);
spdlog::get("zynqDump")->debug("{:X} {:X} {:X} {:X}", wordData[4], wordData[5], wordData[6], wordData[7]); spdlog::get("zynqDump")->debug("{:X} {:X} {:X} {:X}", wordData[4], wordData[5], wordData[6], wordData[7]);
for (uint32_t j = 0; j < nread; ++j) {
output << char_buffer[j];
}
uint8_t board_id = (wordData[0] >> 24) & 0xFF; uint8_t board_id = (wordData[0] >> 24) & 0xFF;
uint8_t version = wordData[0] & 0xFF; uint8_t version = wordData[0] & 0xFF;
uint16_t spill_id = (wordData[1] & 0x00FFFF00) >> 8; uint16_t spill_id = (wordData[1] & 0x00FFFF00) >> 8;
@@ -156,8 +165,9 @@ int open_socket(){
void setup_logger(){ void setup_logger(){
try { try {
auto max_size = 1048576 * 5; auto max_size = 1048576 * 5;
auto max_files = 3; auto max_files = 20;
auto logger = spdlog::rotating_logger_mt("zynqDump", "logs/dump.txt", max_size, max_files); auto logger = spdlog::rotating_logger_mt("zynqDump", "output/run.txt", max_size, max_files);
auto channel_logger = spdlog::rotating_logger_mt("channel_logger", "output/chn.txt", max_size * 10, max_files);
} }
catch (const spdlog::spdlog_ex &ex) { catch (const spdlog::spdlog_ex &ex) {
std::cerr << "Log init failed: " << ex.what() << std::endl; std::cerr << "Log init failed: " << ex.what() << std::endl;
@@ -212,7 +222,7 @@ size_t process_channel(char const * ptr, size_t len, uint32_t board_id){
bytes_left -= channel_size; bytes_left -= channel_size;
Channel c(ptr, channel_size, board_id); Channel c(ptr, channel_size, board_id);
c.Print(); c.Print(true);
} }
} }