msg_task.hpp

Go to the documentation of this file.

//
// Copyright 2011-2015 Ettus Research LLC
// Copyright 2018 Ettus Research, a National Instruments Company
// Copyright 2019 Ettus Research, a National Instruments Brand
//
// SPDX-License-Identifier: GPL-3.0-or-later
//
 
#pragma once
 
#include <uhd/config.hpp>
#include <uhd/transport/zero_copy.hpp>
#include <uhd/utils/noncopyable.hpp>
#include <stdint.h>
#include <boost/optional/optional.hpp>
#include <cstring>
#include <functional>
#include <memory>
#include <optional>
#include <vector>
 
namespace uhd {
class UHD_API msg_task : uhd::noncopyable
{
public:
    typedef std::shared_ptr<msg_task> sptr;
    typedef std::vector<uint8_t> msg_payload_t;
    typedef std::pair<uint32_t, msg_payload_t> msg_type_t;
    typedef std::function<std::optional<msg_type_t>(void)> task_fcn_type;
    typedef std::function<boost::optional<msg_type_t>(void)> task_fcn_type_legacy;
 
    /*
     * During shutdown message queues for radio control cores might not be available
     * anymore. Such stranded messages get pushed into a dump queue. With this function
     * radio_ctrl_core can check if one of the messages meant for it got stranded.
     */
    virtual msg_payload_t get_msg_from_dump_queue(uint32_t sid) = 0;
 
    UHD_INLINE static std::vector<uint8_t> buff_to_vector(uint8_t* p, size_t n)
    {
        if (p and n > 0) {
            std::vector<uint8_t> v(n);
            memcpy(&v.front(), p, n);
            return v;
        }
        return std::vector<uint8_t>();
    }
 
    virtual ~msg_task(void) = 0;

    static sptr make(const task_fcn_type& task_fcn);

    [[deprecated("Prefer std::optional over boost::optional.")]] static sptr make(
        const task_fcn_type_legacy& task_fcn)
    {
        return make([task_fcn]() -> std::optional<msg_type_t> {
            auto task_result = task_fcn();
            return bool(task_result) ? std::make_optional<msg_type_t>(*task_result)
                                     : std::nullopt;
        });
    }
};
} // namespace uhd