sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-04-23 15:30:42 +02:00
Code Issues Packages Projects Releases Wiki Activity

Remove pulse_id stream from streamer

Browse Source 
This is not needed anymore since we have a different architecture.
This commit is contained in:
babic_a
2021-01-13 15:54:28 +01:00
parent c90114bec9
commit 6ee8f7d89d
2 changed files with 0 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-stream/include/ZmqLiveSender.hpp
-1
View File
@@ -12,7 +12,6 @@ class ZmqLiveSender {
void* socket_streamvis_;
void* socket_live_;
void* socket_pulse_;
public:
ZmqLiveSender(void* ctx,
sf-stream/src/ZmqLiveSender.cpp
-24
View File
@@ -43,26 +43,6 @@ ZmqLiveSender::ZmqLiveSender(
}
}
{
socket_pulse_ = zmq_socket(ctx, ZMQ_PUB);
if (zmq_bind(socket_pulse_, config.pulse_address.c_str()) != 0) {
throw runtime_error(zmq_strerror(errno));
}
const int sndhwm = PULSE_ZMQ_SNDHWM;
if (zmq_setsockopt(
socket_pulse_, ZMQ_SNDHWM, &sndhwm, sizeof(sndhwm)) != 0) {
throw runtime_error(zmq_strerror(errno));
}
const int linger = 0;
if (zmq_setsockopt(
socket_pulse_, ZMQ_LINGER, &linger, sizeof(linger)) != 0) {
throw runtime_error(zmq_strerror(errno));
}
}
}
ZmqLiveSender::~ZmqLiveSender()
@@ -79,10 +59,6 @@ void ZmqLiveSender::send(const ImageMetadata& meta, const char *data)
auto& header_alloc = header.GetAllocator();
string text_header;
if(zmq_send(socket_pulse_, &meta.pulse_id, sizeof(uint64_t), 0) == -1) {
throw runtime_error(zmq_strerror(errno));
}
// TODO: Here we need to send to streamvis and live analysis metadata(probably need to operate still on them) and data(not every frame)
header.AddMember("frame", meta.frame_index, header_alloc);
header.AddMember("is_good_frame", meta.is_good_image, header_alloc);