diff --git a/producer/dummy-event-detector-cpp/src/dummy_detector.h b/producer/dummy-event-detector-cpp/src/dummy_detector.h index 6e1f3bf0b9bc1ed5d1feda0a9912f34e64236c3d..8ad0b8ece57f01858b1745c887cbb93478c4d995 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 0000000000000000000000000000000000000000..e69de29bb2d1d6434b8b29ae775ad8c2e48c5391 diff --git a/receiver/src/main.cpp.cpp b/receiver/src/main.cpp.cpp deleted file mode 100644 index 7c1b2d554f5e55c7012b834035bd5efc433b3b1d..0000000000000000000000000000000000000000 --- 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 ab046f92fd52ca713638bb62de92600cfcdbeb63..f9cc6f26b43b1105f5267b3b1143244de06c3570 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 eb5483390aa83ef4caa635a6127381257c316006..624aa1b7f9cc5ba514c72072e4fd46e54dccf9e0 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(); };