From 0f7e2b21b327f382c8e086e0c28e3aef1d62b6e2 Mon Sep 17 00:00:00 2001
From: Carsten Patzke <carsten.patzke@desy.de>
Date: Tue, 5 Dec 2017 10:07:15 +0100
Subject: [PATCH] *
---
.../src/dummy_detector.h | 1 -
receiver/src/main.cpp | 0
receiver/src/main.cpp.cpp | 4 ----
receiver/src/receiver.cpp | 20 +++++++++++++++++++
receiver/src/receiver.h | 9 +++++++++
5 files changed, 29 insertions(+), 5 deletions(-)
create mode 100644 receiver/src/main.cpp
delete mode 100644 receiver/src/main.cpp.cpp
diff --git a/producer/dummy-event-detector-cpp/src/dummy_detector.h b/producer/dummy-event-detector-cpp/src/dummy_detector.h
index 6e1f3bf0b..8ad0b8ece 100644
--- a/producer/dummy-event-detector-cpp/src/dummy_detector.h
+++ b/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
diff --git a/receiver/src/main.cpp b/receiver/src/main.cpp
new file mode 100644
index 000000000..e69de29bb
diff --git a/receiver/src/main.cpp.cpp b/receiver/src/main.cpp.cpp
deleted file mode 100644
index 7c1b2d554..000000000
--- a/receiver/src/main.cpp.cpp
+++ /dev/null
@@ -1,4 +0,0 @@
-//
-// Created by cpatzke on 30.11.17.
-//
-
diff --git a/receiver/src/receiver.cpp b/receiver/src/receiver.cpp
index ab046f92f..f9cc6f26b 100644
--- a/receiver/src/receiver.cpp
+++ b/receiver/src/receiver.cpp
@@ -1 +1,21 @@
+#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);
+}
diff --git a/receiver/src/receiver.h b/receiver/src/receiver.h
index eb5483390..624aa1b7f 100644
--- a/receiver/src/receiver.h
+++ b/receiver/src/receiver.h
@@ -1,10 +1,19 @@
#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();
};
--
GitLab