Receiver.h

Go to the documentation of this file.

// libflute - FLUTE/ALC library
//
// Copyright (C) 2021 Klaus Kühnhammer (Österreichische Rundfunksender GmbH & Co KG)
//
// Licensed under the License terms and conditions for use, reproduction, and
// distribution of 5G-MAG software (the “License”).  You may not use this file
// except in compliance with the License.  You may obtain a copy of the License at
// https://www.5g-mag.com/reference-tools.  Unless required by applicable law or
// agreed to in writing, software distributed under the License is distributed on
// an “AS IS” BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
// or implied.
//
// See the License for the specific language governing permissions and limitations
// under the License.
//
#pragma once
#include <boost/asio.hpp>
#include <boost/bind/bind.hpp>
#include <string>
#include <map>
#include <mutex>
#include "File.h"
#include "FileDeliveryTable.h"
 
namespace LibFlute {
  class Receiver {
    public:
      typedef std::function<void(std::shared_ptr<LibFlute::File>)> completion_callback_t;
      Receiver( const std::string& iface, const std::string& address,
          short port, uint64_t tsi,
          boost::asio::io_context& io_context);
 
      virtual ~Receiver() = default;
 
      void enable_ipsec( uint32_t spi, const std::string& aes_key);
 
      std::vector<std::shared_ptr<LibFlute::File>> file_list();
 
      void remove_expired_files(unsigned max_age);
 
      void remove_file_with_content_location(const std::string& cl);
 
      void register_completion_callback(completion_callback_t cb) { _completion_cb = cb; };
 
      void stop() { _running = false; }
    private:
 
      void handle_receive_from(const boost::system::error_code& error,
          size_t bytes_recvd);
      boost::asio::ip::udp::socket _socket;
      boost::asio::ip::udp::endpoint _sender_endpoint;
 
      enum { max_length = 2048 };
      char _data[max_length];
      uint64_t _tsi;
      std::unique_ptr<LibFlute::FileDeliveryTable> _fdt;
      std::map<uint64_t, std::shared_ptr<LibFlute::File>> _files;
      std::mutex _files_mutex;
      std::string _mcast_address;
 
      completion_callback_t _completion_cb = nullptr;
 
      bool _running = true;
  };
};