From d0961ea3d0481906482ac909ff4816a814301b7c Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Thu, 9 Apr 2020 13:35:52 +0200 Subject: [PATCH] Temp disable compression --- core-writer/src/module/ZmqRecvModule.cpp | 34 +++++++++++++----------- 1 file changed, 19 insertions(+), 15 deletions(-) diff --git a/core-writer/src/module/ZmqRecvModule.cpp b/core-writer/src/module/ZmqRecvModule.cpp index ff3030a..1ced3a7 100644 --- a/core-writer/src/module/ZmqRecvModule.cpp +++ b/core-writer/src/module/ZmqRecvModule.cpp @@ -183,24 +183,28 @@ void ZmqRecvModule::receive_thread(const string& connect_address) } char* buffer = ring_buffer_.reserve(frame_metadata); - - auto compressed_size = compression::compress_bitshuffle( + memcpy( + buffer, static_cast(frame_data), - frame_metadata->frame_bytes_size, - 1, - buffer); + frame_metadata->frame_bytes_size); - #ifdef DEBUG_OUTPUT - using namespace date; - using namespace chrono; - cout << "[" << system_clock::now() << "]"; - cout << "[ZmqRecvModule::receive_thread]"; - cout << " Compressed image from "; - cout << frame_metadata->frame_bytes_size << " bytes to "; - cout << compressed_size << " bytes." << endl; - #endif +// auto compressed_size = compression::compress_bitshuffle( +// static_cast(frame_data), +// frame_metadata->frame_bytes_size, +// 1, +// buffer); +// +// #ifdef DEBUG_OUTPUT +// using namespace date; +// using namespace chrono; +// cout << "[" << system_clock::now() << "]"; +// cout << "[ZmqRecvModule::receive_thread]"; +// cout << " Compressed image from "; +// cout << frame_metadata->frame_bytes_size << " bytes to "; +// cout << compressed_size << " bytes." << endl; +// #endif - frame_metadata->frame_bytes_size = compressed_size; +// frame_metadata->frame_bytes_size = compressed_size; ring_buffer_.commit(frame_metadata); }