From 09a46daea0ada4f1a0c12cbffeeff31e1de1d7ba Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Wed, 22 Apr 2020 12:41:01 +0200
Subject: [PATCH] Send some data

---
 sf-buffer/src/sf_replay.cpp | 3 ++-
 sf-writer/sf_h5_writer.cpp  | 7 +++++--
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/sf-buffer/src/sf_replay.cpp b/sf-buffer/src/sf_replay.cpp
index 960840f..2ed0db8 100644
--- a/sf-buffer/src/sf_replay.cpp
+++ b/sf-buffer/src/sf_replay.cpp
@@ -129,7 +129,8 @@ int main (int argc, char *argv[]) {
 
             if ((i_frame>0) && (i_frame % 100 == 0)) {
                 // Waiting to send more.
-                zmq_recv(more_socket, nullptr, 0, 0);
+                uint64_t test = 0;
+                zmq_recv(more_socket, &test, sizeof(test), 0);
             }
         }
     }
diff --git a/sf-writer/sf_h5_writer.cpp b/sf-writer/sf_h5_writer.cpp
index a261252..73e64aa 100644
--- a/sf-writer/sf_h5_writer.cpp
+++ b/sf-writer/sf_h5_writer.cpp
@@ -6,6 +6,7 @@
 #include <RingBuffer.hpp>
 #include <BufferUtils.hpp>
 #include <jungfrau.hpp>
+#include <unordered_map>
 
 using namespace std;
 
@@ -58,7 +59,7 @@ int main (int argc, char *argv[])
     auto metadata_buffer = make_unique<ModuleFrame>();
 
     auto image_buffer = make_unique<uint16_t[]>(512 * 1024);
-    auto received_counter = unordered_map<uint64_t, int>();
+    unordered_map<uint64_t, int> received_counter;
 
     while (true) {
         auto n_bytes_metadata = zmq_recv(
@@ -97,7 +98,9 @@ int main (int argc, char *argv[])
         cout << "n frames in progress " << n_in_progress_frames << endl;
 
         if (n_in_progress_frames == 0) {
-            zmq_send(more_socket, nullptr, 0, 0);
+            uint64_t test = 0;
+            zmq_send(more_socket, &test, sizeof(test), 0);
+            cout << "SENT!!!" << endl;
         }
     }