Delay.cpp

Go to the documentation of this file.

// This file is part of INSTINCT, the INS Toolkit for Integrated
// Navigation Concepts and Training by the Institute of Navigation of
// the University of Stuttgart, Germany.
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at https://mozilla.org/MPL/2.0/.
 
#include "Delay.hpp"
 
#include "internal/FlowManager.hpp"
 
#include "NodeData/NodeData.hpp"
 
namespace NAV::experimental
{
 
Delay::Delay()
    : Node("z^-1")
{
    LOG_TRACE("{}: called", name);
 
    _hasConfig = true;
    _guiConfigDefaultWindowSize = { 305, 70 };
    kind = Kind::Simple;
 
    CreateInputPin("", Pin::Type::Flow, { NodeData::type() }, &Delay::delayObs);
    CreateOutputPin("", Pin::Type::Flow, { NodeData::type() });
}
 
Delay::~Delay()
{
    LOG_TRACE("{}: called", nameId());
}
 
std::string Delay::typeStatic()
{
    return "Delay";
}
 
std::string Delay::type() const
{
    return typeStatic();
}
 
std::string Delay::category()
{
    return "Experimental/Simple";
}
 
void Delay::guiConfig()
{
    if (ImGui::InputInt(fmt::format("Delay length##{}", size_t(id)).c_str(), &_delayLength))
    {
        _delayLength = std::max(_delayLength, 1);
        LOG_DEBUG("{}: delayLength changed to {}", nameId(), _delayLength);
        if (name.starts_with("z^-"))
        {
            name = fmt::format("z^-{}", _delayLength);
        }
 
        while (_buffer.size() > static_cast<size_t>(_delayLength))
        {
            _buffer.pop_front();
        }
    }
}
 
[[nodiscard]] json Delay::save() const
{
    LOG_TRACE("{}: called", nameId());
 
    json j;
 
    j["delayLength"] = _delayLength;
 
    return j;
}
 
void Delay::restore(json const& j)
{
    LOG_TRACE("{}: called", nameId());
 
    if (j.contains("delayLength"))
    {
        j.at("delayLength").get_to(_delayLength);
    }
}
 
bool Delay::initialize()
{
    LOG_TRACE("{}: called", nameId());
 
    _buffer.clear();
 
    return true;
}
 
void Delay::deinitialize()
{
    LOG_TRACE("{}: called", nameId());
}
 
bool Delay::onCreateLink(OutputPin& startPin, InputPin& endPin)
{
    LOG_TRACE("{}: called for {} ==> {}", nameId(), size_t(startPin.id), size_t(endPin.id));
 
    if (endPin.parentNode->id != id)
    {
        return true; // Link on Output Port
    }
 
    // New Link on the Input port, but the previously connected dataIdentifier is different from the new one.
    // Then remove all links.
    if (outputPins.at(OUTPUT_PORT_INDEX_FLOW).dataIdentifier != startPin.dataIdentifier)
    {
        outputPins.at(OUTPUT_PORT_INDEX_FLOW).deleteLinks();
    }
 
    // Update the dataIdentifier of the output pin to the same as input pin
    outputPins.at(OUTPUT_PORT_INDEX_FLOW).dataIdentifier = startPin.dataIdentifier;
 
    // Refresh all links connected to the output pin
    for (auto& link : outputPins.at(OUTPUT_PORT_INDEX_FLOW).links)
    {
        if (auto* connectedPin = link.getConnectedPin())
        {
            outputPins.at(OUTPUT_PORT_INDEX_FLOW).recreateLink(*connectedPin);
        }
    }
 
    return true;
}
 
void Delay::delayObs(NAV::InputPin::NodeDataQueue& queue, size_t /* pinIdx */)
{
    if (_buffer.size() == static_cast<size_t>(_delayLength))
    {
        auto oldest = _buffer.front();
        _buffer.pop_front();
        _buffer.push_back(queue.extract_front());
 
        LOG_DATA("{}: Delay pushing out message: {}", nameId(), _buffer.back()->insTime.toGPSweekTow());
 
        if (!(NAV::Node::callbacksEnabled))
        {
            NAV::Node::callbacksEnabled = true;
        }
 
        invokeCallbacks(OUTPUT_PORT_INDEX_FLOW, oldest);
    }
    else
    {
        _buffer.push_back(queue.extract_front());
    }
}
 
} // namespace NAV::experimental