*

producer/dummy-event-detector-cpp/src/dummy_detector.h

@@ -9,7 +9,6 @@ class DummyDetector
 
 public:
     int main(int argc, char* argv[]);
-    void handle_file_done(hidra2::FileReferenceId reference_id, hidra2::ProducerError producer_error);
 };
 
 #endif //HIDRA2_DUMMYEVENTDETECTOR__DUMMYDETECTOR_H

receiver/src/main.cpp.cpp

-//
-// Created by cpatzke on 30.11.17.
-//
-

receiver/src/receiver.cpp

+#include <sys/socket.h>
+#include <cstring>
+#include <netinet/in.h>
+#include <unistd.h>
 #include "receiver.h"
+
+const int Receiver::kMaxUnacceptedBacklog = 5;
+
+Receiver::Receiver(sockaddr_in listen_address) {
+  this->listen_address = listen_address;
+}
+
+void Receiver::start_listener() {
+  sockfd = socket(AF_INET,SOCK_STREAM, 0);
+  bind(sockfd, (struct sockaddr *)&listen_address, sizeof(listen_address));
+  listen(sockfd, kMaxUnacceptedBacklog);
+}
+
+void Receiver::stop_listener() {
+  close(sockfd);
+}

receiver/src/receiver.h

 #ifndef HIDRA2_RECEIVER_H
 #define HIDRA2_RECEIVER_H
 
+#import <string>
+
 
 class Receiver {
+ private:
+  static const int kMaxUnacceptedBacklog;
 public:
+  int sockfd, newsockfd, n, pid;
+  Receiver(sockaddr_in listen_address);
 
+  struct sockaddr listen_address;
+  void start_listener();
+  void stop_listener();
 };