/* -*- c++ -*- */
/*
 * Copyright 2006-2008,2013 Free Software Foundation, Inc.
 *
 * This file is part of GNU Radio
 *
 * SPDX-License-Identifier: GPL-3.0-or-later
 *
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#include "hier_block2_detail.h"
#include <gnuradio/flowgraph.h>
#include <gnuradio/hier_block2.h>
#include <gnuradio/io_signature.h>
#include <boost/make_unique.hpp>
#include <iostream>

namespace gr {

#define GR_HIER_BLOCK2_DEBUG 0

hier_block2_sptr make_hier_block2(const std::string& name,
                                  gr::io_signature::sptr input_signature,
                                  gr::io_signature::sptr output_signature)
{
    return gnuradio::make_block_sptr<hier_block2>(
        name, input_signature, output_signature);
}

hier_block2::hier_block2() {}

hier_block2::hier_block2(const std::string& name,
                         gr::io_signature::sptr input_signature,
                         gr::io_signature::sptr output_signature)
    : basic_block(name, input_signature, output_signature),
      d_detail(boost::make_unique<hier_block2_detail>(this)),
      hier_message_ports_in(pmt::PMT_NIL),
      hier_message_ports_out(pmt::PMT_NIL)
{
    // This bit of magic ensures that self() works in the constructors of derived classes.
    gnuradio::detail::sptr_magic::create_and_stash_initial_sptr(this);
}

hier_block2::~hier_block2()
{
    disconnect_all();
    gnuradio::detail::sptr_magic::cancel_initial_sptr(this);
}

hier_block2::opaque_self hier_block2::self() { return shared_from_this(); }

hier_block2_sptr hier_block2::to_hier_block2()
{
    return cast_to_hier_block2_sptr(shared_from_this());
}

void hier_block2::connect(basic_block_sptr block) { d_detail->connect(block); }

void hier_block2::connect(basic_block_sptr src,
                          int src_port,
                          basic_block_sptr dst,
                          int dst_port)
{
    d_detail->connect(src, src_port, dst, dst_port);
}

void hier_block2::msg_connect(basic_block_sptr src,
                              pmt::pmt_t srcport,
                              basic_block_sptr dst,
                              pmt::pmt_t dstport)
{
    if (!pmt::is_symbol(srcport)) {
        throw std::runtime_error("bad port id");
    }
    d_detail->msg_connect(src, srcport, dst, dstport);
}

void hier_block2::msg_connect(basic_block_sptr src,
                              std::string srcport,
                              basic_block_sptr dst,
                              std::string dstport)
{
    d_detail->msg_connect(src, pmt::mp(srcport), dst, pmt::mp(dstport));
}

void hier_block2::msg_disconnect(basic_block_sptr src,
                                 pmt::pmt_t srcport,
                                 basic_block_sptr dst,
                                 pmt::pmt_t dstport)
{
    if (!pmt::is_symbol(srcport)) {
        throw std::runtime_error("bad port id");
    }
    d_detail->msg_disconnect(src, srcport, dst, dstport);
}

void hier_block2::msg_disconnect(basic_block_sptr src,
                                 std::string srcport,
                                 basic_block_sptr dst,
                                 std::string dstport)
{
    d_detail->msg_disconnect(src, pmt::mp(srcport), dst, pmt::mp(dstport));
}

void hier_block2::disconnect(basic_block_sptr block) { d_detail->disconnect(block); }

void hier_block2::disconnect(basic_block_sptr src,
                             int src_port,
                             basic_block_sptr dst,
                             int dst_port)
{
    d_detail->disconnect(src, src_port, dst, dst_port);
}

void hier_block2::disconnect_all() { d_detail->disconnect_all(); }

void hier_block2::lock() { d_detail->lock(); }

void hier_block2::unlock() { d_detail->unlock(); }

flat_flowgraph_sptr hier_block2::flatten() const
{
    flat_flowgraph_sptr new_ffg = make_flat_flowgraph();
    d_detail->flatten_aux(new_ffg);
    return new_ffg;
}

void hier_block2::set_processor_affinity(const std::vector<int>& mask)
{
    d_detail->set_processor_affinity(mask);
}

void hier_block2::unset_processor_affinity() { d_detail->unset_processor_affinity(); }

std::vector<int> hier_block2::processor_affinity()
{
    return d_detail->processor_affinity();
}

void hier_block2::set_log_level(std::string level) { d_detail->set_log_level(level); }

std::string hier_block2::log_level() { return d_detail->log_level(); }

std::string dot_graph(hier_block2_sptr hierblock2)
{
    return dot_graph_fg(hierblock2->flatten());
}

int hier_block2::max_output_buffer(size_t port)
{
    if (port >= d_detail->d_max_output_buffer.size())
        throw std::invalid_argument(
            "hier_block2::max_output_buffer(int): port out of range.");
    return d_detail->d_max_output_buffer[port];
}

void hier_block2::set_max_output_buffer(int max_output_buffer)
{
    if (output_signature()->max_streams() > 0) {
        if (d_detail->d_max_output_buffer.empty()) {
            throw std::length_error("hier_block2::set_max_output_buffer(int): out_sig "
                                    "greater than zero, buff_vect isn't");
        }
        for (int idx = 0; idx < output_signature()->max_streams(); idx++) {
            d_detail->d_max_output_buffer[idx] = max_output_buffer;
        }
    }
}

void hier_block2::set_max_output_buffer(size_t port, int max_output_buffer)
{
    if (port >= d_detail->d_max_output_buffer.size()) {
        throw std::invalid_argument(
            "hier_block2::set_max_output_buffer(size_t,int): port out of range.");
    } else {
        d_detail->d_max_output_buffer[port] = max_output_buffer;
    }
}

int hier_block2::min_output_buffer(size_t port)
{
    if (port >= d_detail->d_min_output_buffer.size())
        throw std::invalid_argument(
            "hier_block2::min_output_buffer(size_t): port out of range.");
    return d_detail->d_min_output_buffer[port];
}

void hier_block2::set_min_output_buffer(int min_output_buffer)
{
    if (output_signature()->max_streams() > 0) {
        if (d_detail->d_min_output_buffer.empty()) {
            throw std::length_error("hier_block2::set_min_output_buffer(int): out_sig "
                                    "greater than zero, buff_vect isn't");
        }
        for (int idx = 0; idx < output_signature()->max_streams(); idx++) {
            d_detail->d_min_output_buffer[idx] = min_output_buffer;
        }
    }
}

void hier_block2::set_min_output_buffer(size_t port, int min_output_buffer)
{
    if (port >= d_detail->d_min_output_buffer.size())
        throw std::invalid_argument(
            "hier_block2::set_min_output_buffer(size_t,int): port out of range.");
    else {
        d_detail->d_min_output_buffer[port] = min_output_buffer;
    }
}

bool hier_block2::all_min_output_buffer_p(void)
{
    if (d_detail->d_min_output_buffer.empty()) {
        return false;
    }
    for (size_t idx = 1; idx < d_detail->d_min_output_buffer.size(); idx++) {
        if (d_detail->d_min_output_buffer[0] != d_detail->d_min_output_buffer[idx])
            return false;
    }
    return true;
}
bool hier_block2::all_max_output_buffer_p(void)
{
    if (d_detail->d_max_output_buffer.empty())
        return false;
    for (size_t idx = 1; idx < d_detail->d_max_output_buffer.size(); idx++) {
        if (d_detail->d_max_output_buffer[0] != d_detail->d_max_output_buffer[idx])
            return false;
    }
    return true;
}

} /* namespace gr */