media_stream.hh

#pragma once
 
#include "util.hh"
 
#include "uvgrtp/export.hh"
#include "uvgrtp/definitions.hh"
 
#include <unordered_map>
#include <memory>
#include <string>
#include <atomic>
#include <cstdint>
 
#ifndef _WIN32
#include <sys/socket.h>
#include <netinet/in.h>
#else
#include <ws2ipdef.h>
#endif
namespace uvgrtp {
 
    // forward declarations
    class rtcp;
    class socketfactory;
 
    namespace frame {
        struct rtp_frame;
    }
 
    namespace formats {
        class media;
    }
 
    class media_stream_internal;
 
    class UVGRTP_EXPORT media_stream {
        friend class session;
        public:
            ~media_stream();
 
            rtp_error_t start_zrtp();
 
            rtp_error_t add_srtp_ctx(uint8_t* key, uint8_t* salt);
 
            rtp_error_t push_frame(uint8_t* data, size_t data_len, int rtp_flags);
 
            rtp_error_t push_frame(uint8_t* data, size_t data_len, uint32_t ts, int rtp_flags);
 
            rtp_error_t push_frame(uint8_t* data, size_t data_len, uint32_t ts, uint64_t ntp_ts, int rtp_flags);
 
            uvgrtp::frame::rtp_frame* pull_frame();
 
            uvgrtp::frame::rtp_frame* pull_frame(size_t timeout_ms);
 
            rtp_error_t install_receive_hook(void* arg, void (*hook)(void*, uvgrtp::frame::rtp_frame*));
 
            rtp_error_t configure_ctx(int rcc_flag, ssize_t value);
 
            int get_configuration_value(int rcc_flag);
 
            uvgrtp::rtcp* get_rtcp();
 
            uint32_t get_ssrc() const;
 
            rtp_error_t stop();
 
 
#if UVGRTP_EXTENDED_API
 
            rtp_error_t push_frame(std::unique_ptr<uint8_t[]> data, size_t data_len, int rtp_flags);
 
            rtp_error_t push_frame(std::unique_ptr<uint8_t[]> data, size_t data_len, uint32_t ts, int rtp_flags);
 
 
            rtp_error_t push_frame(std::unique_ptr<uint8_t[]> data, size_t data_len, uint32_t ts, uint64_t ntp_ts, int rtp_flags);
 
  // End of EXTENDED_API group
#endif
 
        private:
 
            media_stream(std::string cname, std::string remote_addr, std::string local_addr, uint16_t src_port, uint16_t dst_port,
                rtp_format_t fmt, std::shared_ptr<uvgrtp::socketfactory> sfp, int rce_flags, uint32_t ssrc = 0);
 
           media_stream_internal* impl_;
    };
}
 
namespace uvg_rtp = uvgrtp;