context.h

Go to the documentation of this file.

/*
 * Copyright (c) 2020 Roc Streaming authors
 *
 * 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 http://mozilla.org/MPL/2.0/.
 */
 
//! @file roc_node/context.h
//! @brief Node context.
 
#ifndef ROC_NODE_CONTEXT_H_
#define ROC_NODE_CONTEXT_H_
 
#include "roc_audio/sample.h"
#include "roc_core/allocation_policy.h"
#include "roc_core/atomic.h"
#include "roc_core/buffer_factory.h"
#include "roc_core/iarena.h"
#include "roc_core/ref_counted.h"
#include "roc_ctl/control_loop.h"
#include "roc_netio/network_loop.h"
#include "roc_packet/packet_factory.h"
#include "roc_rtp/format_map.h"
 
namespace roc {
namespace node {
 
//! Node context config.
struct ContextConfig {
    //! Maximum size in bytes of a network packet.
    size_t max_packet_size;
 
    //! Maximum size in bytes of an audio frame.
    size_t max_frame_size;
 
    ContextConfig()
        : max_packet_size(2048)
        , max_frame_size(4096) {
    }
};
 
//! Node context.
class Context : public core::RefCounted<Context, core::ManualAllocation> {
public:
    //! Initialize.
    explicit Context(const ContextConfig& config, core::IArena& arena);
 
    //! Deinitialize.
    ~Context();
 
    //! Check if successfully constructed.
    bool is_valid();
 
    //! Get arena.
    core::IArena& arena();
 
    //! Get packet factory.
    packet::PacketFactory& packet_factory();
 
    //! Get byte buffer factory.
    core::BufferFactory<uint8_t>& byte_buffer_factory();
 
    //! Get sample buffer factory.
    core::BufferFactory<audio::sample_t>& sample_buffer_factory();
 
    //! Get format map.
    rtp::FormatMap& format_map();
 
    //! Get network event loop.
    netio::NetworkLoop& network_loop();
 
    //! Get control event loop.
    ctl::ControlLoop& control_loop();
 
private:
    core::IArena& arena_;
 
    packet::PacketFactory packet_factory_;
    core::BufferFactory<uint8_t> byte_buffer_factory_;
    core::BufferFactory<audio::sample_t> sample_buffer_factory_;
 
    rtp::FormatMap format_map_;
 
    netio::NetworkLoop network_loop_;
    ctl::ControlLoop control_loop_;
};
 
} // namespace node
} // namespace roc
 
#endif // ROC_NODE_CONTEXT_H_