sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-04 20:34:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix test to use template version of RingBuffer

Browse Source
This commit is contained in:
babic_a
2020-04-15 10:44:39 +02:00
parent b8d6b0deb5
commit 305aef31ba
4 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/module/ZmqRecvModule.cpp
-2
View File
@@ -144,8 +144,6 @@ void ZmqRecvModule::receive_thread(const string& connect_address)
continue;
}
cout <<" Something!!!"<< endl;
if (!is_saving_) {
continue;
}
core-writer/test/test_H5WriteModule.cpp
+2 -2
View File
@@ -11,7 +11,7 @@ using namespace std;
// Shape * 2 bytes/value (uint16_t)
size_t image_n_bytes = 1024*2*2;
void generate_frames(RingBuffer& ring_buffer, int n_frames)
void generate_frames(RingBuffer<FrameMetadata>& ring_buffer, int n_frames)
{
size_t y_length = 2;
size_t x_length = 1024;
@@ -47,7 +47,7 @@ TEST(H5WriteModule, basic_interaction)
{
TestH5Format format("start_dataset");
RingBuffer ring_buffer(10);
RingBuffer<FrameMetadata> ring_buffer(10);
ring_buffer.initialize(image_n_bytes);
H5WriteModule h5_write_module(ring_buffer, {}, format);
core-writer/test/test_ProcessManager.cpp
+1 -1
View File
@@ -7,7 +7,7 @@
TEST(ProcessManager, basic_interaction)
{
TestH5Format format("start_dataset");
RingBuffer ring_buffer(10);
RingBuffer<FrameMetadata> ring_buffer(10);
ZmqRecvModule recv_module(ring_buffer, {});
H5WriteModule write_module(ring_buffer, {}, format);
core-writer/test/test_ZmqRecvModule.cpp
+4 -4
View File
@@ -11,7 +11,7 @@ using namespace std;
TEST(ZmqRecvModule, basic_interaction)
{
RingBuffer ring_buffer(10);
RingBuffer<FrameMetadata> ring_buffer(10);
ZmqRecvModule zmq_recv_module(ring_buffer, {});
uint8_t n_receivers = 4;
@@ -36,11 +36,11 @@ TEST(ZmqRecvModule, simple_recv)
size_t n_msg = 10;
thread sender(generate_stream, n_msg);
RingBuffer ring_buffer(n_msg);
RingBuffer<FrameMetadata> ring_buffer(n_msg);
ZmqRecvModule zmq_recv_module(ring_buffer, {});
zmq_recv_module.start_saving();
zmq_recv_module.start_recv("tcp://127.0.0.1:11000", 4);
zmq_recv_module.start_recv(MOCK_STREAM_ADDRESS, 4);
sender.join();
this_thread::sleep_for(chrono::milliseconds(100));
@@ -68,7 +68,7 @@ TEST(ZmqRecvModule, stop_saving_and_clear_buffer)
size_t n_msg = 10;
thread sender(generate_stream, n_msg);
RingBuffer ring_buffer(n_msg);
RingBuffer<FrameMetadata> ring_buffer(n_msg);
ZmqRecvModule zmq_recv_module(ring_buffer, {});
zmq_recv_module.start_saving();