Gw.h

// OBECA - Open Broadcast Edge Cache Appliance
// Receive Process
//
// Copyright (C) 2021 Klaus Kühnhammer (Österreichische Rundfunksender GmbH & Co KG)
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
// 
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Affero General Public License for more details.
// 
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.
//
 
#pragma once
#include <string>
#include <libconfig.h++>
#include "srslte/srslte.h"
#include "srslte/upper/rlc.h"
#include "srslte/asn1/rrc_asn1.h"
 
#include "Phy.h"
 
class Gw : public srsue::gw_interface_stack {
  public:
    Gw(const libconfig::Config& cfg, Phy& phy)
      : _cfg(cfg)
        , _phy(phy)
      {}
 
    virtual ~Gw();
 
    void init();
 
    void write_pdu_mch(uint32_t lcid, srslte::unique_byte_buffer_t pdu) override;
 
    // Unused interface methods
    void add_mch_port(uint32_t lcid, uint32_t port) override {};
    void write_pdu(uint32_t lcid, srslte::unique_byte_buffer_t pdu) override {};
    int setup_if_addr(uint32_t lcid, uint8_t pdn_type, uint32_t ip_addr, uint8_t* ipv6_if_id, char* err_str) override { return -1; };
    int apply_traffic_flow_template(const uint8_t& eps_bearer_id, const uint8_t& lcid, const LIBLTE_MME_TRAFFIC_FLOW_TEMPLATE_STRUCT* tft) override { return -1; };
    void set_test_loop_mode(const test_loop_mode_state_t mode, const uint32_t ip_pdu_delay_ms = 0) override {};
 
  private:
    const libconfig::Config& _cfg;
 
    std::mutex _wr_mutex;
    int32_t _tun_fd = -1;
    Phy& _phy;
};