Compare commits
8 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| a2e8997090 | |||
| e07831fcad | |||
| ec73a87d31 | |||
| e3fb134dbb | |||
| 6c3b0ceed4 | |||
| e5218cd885 | |||
| afc9b1d6fb | |||
|
|
f24628443f |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -2,4 +2,3 @@ r
|
||||
build
|
||||
old
|
||||
dump
|
||||
spdlog
|
||||
|
||||
15
CMakeLists.txt
Normal file
15
CMakeLists.txt
Normal 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})
|
||||
4
Makefile
4
Makefile
@@ -1,7 +1,7 @@
|
||||
target = r
|
||||
CXX = g++
|
||||
CXX_FLAGS := -std=c++14 -I/home/daq/sw/include -Wall -DSPDLOG_COMPILED_LIB
|
||||
LD_FLAGS := -lpthread -ldl -L/home/daq/sw/lib64 -lspdlog
|
||||
CXX_FLAGS := -std=c++14 -I./include -Wall
|
||||
LD_FLAGS := -lpthread -ldl
|
||||
|
||||
BUILD := ./build
|
||||
OBJS = $(BUILD)/client.o $(BUILD)/channel.o
|
||||
|
||||
38
channel.cc
38
channel.cc
@@ -1,32 +1,11 @@
|
||||
#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;
|
||||
block_data = (char *)ptr;
|
||||
size = ((wordData[0] & 0xFFFFFF00) >> 8) * sizeof(uint32_t);
|
||||
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;
|
||||
|
||||
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;
|
||||
block_count = (wordData[5] &0xFF000000) >> 24;
|
||||
block_count = wordData[5] >> 24;
|
||||
id = (wordData[5] & 0x00FF0000) >> 16;
|
||||
spill = (wordData[5] & 0x0000FFFF);
|
||||
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) {
|
||||
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]);
|
||||
}
|
||||
else {
|
||||
|
||||
@@ -16,9 +16,8 @@ class Channel {
|
||||
char * block_data;
|
||||
bool valid;
|
||||
public:
|
||||
Channel(char const * ptr, size_t len);
|
||||
Channel(char const * ptr, size_t len, uint32_t board);
|
||||
void Print();
|
||||
void Print(bool raw = false);
|
||||
|
||||
};
|
||||
#endif /* end of include guard */
|
||||
|
||||
18
client.cc
18
client.cc
@@ -17,7 +17,7 @@
|
||||
#include "spdlog/spdlog.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 size_t MAX_EVENT_SIZE = 33484; // 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];
|
||||
uint32_t * wordData = (uint32_t*) char_buffer;
|
||||
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
|
||||
struct timeval timeout; // Time value for time out
|
||||
@@ -70,6 +73,9 @@ int main(int argc, char * argv[])
|
||||
// read in first 4 bytes
|
||||
nread = recv(sock, char_buffer, 4, 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 ((char_buffer[0] & 0xFF) != 0xA5){
|
||||
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}",
|
||||
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]);
|
||||
for (uint32_t j = 0; j < nread; ++j) {
|
||||
output << char_buffer[j];
|
||||
}
|
||||
uint8_t board_id = (wordData[0] >> 24) & 0xFF;
|
||||
uint8_t version = wordData[0] & 0xFF;
|
||||
uint16_t spill_id = (wordData[1] & 0x00FFFF00) >> 8;
|
||||
@@ -156,8 +165,9 @@ int open_socket(){
|
||||
void setup_logger(){
|
||||
try {
|
||||
auto max_size = 1048576 * 5;
|
||||
auto max_files = 3;
|
||||
auto logger = spdlog::rotating_logger_mt("zynqDump", "logs/dump.txt", max_size, max_files);
|
||||
auto max_files = 20;
|
||||
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) {
|
||||
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;
|
||||
|
||||
Channel c(ptr, channel_size, board_id);
|
||||
c.Print();
|
||||
c.Print(true);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user