qiurui
/
uvgrtp-base
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

multiplex: refine socketfactory

This commit is contained in:
Heikki Tampio 2023-04-03 12:15:26 +03:00
parent ae6726731c
commit 8f29d88ac8
4 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/uvgrtp/session.hh
View File

@ -63,7 +63,7 @@ namespace uvgrtp {
uvgrtp::media_stream *create_stream(uint16_t src_port, uint16_t dst_port, rtp_format_t fmt, int rce_flags);
// socket factory, add docs
uvgrtp::media_stream* create_stream(uint16_t src_port, uint16_t dst_port, rtp_format_t fmt, int rce_flags, uvgrtp::socketfactory sf);
uvgrtp::media_stream* create_stream(uint16_t src_port, uint16_t dst_port, rtp_format_t fmt, int rce_flags);
/**
* \brief Create a unidirectional media_stream for an RTP session

3
src/session.cc
View File

@ -163,8 +163,9 @@ uvgrtp::media_stream* uvgrtp::session::create_stream(uint16_t src_port, uint16_t
return stream;
}
uvgrtp::media_stream* uvgrtp::session::create_stream(uint16_t src_port, uint16_t dst_port, rtp_format_t fmt, int rce_flags, uvgrtp::socketfactory sf)
uvgrtp::media_stream* uvgrtp::session::create_stream(uint16_t src_port, uint16_t dst_port, rtp_format_t fmt, int rce_flags)
{
uvgrtp::socketfactory socketfac;
if (rce_flags & RCE_OBSOLETE) {
UVG_LOG_WARN("You are using a flag that has either been removed or has been enabled by default. Consider updating RCE flags");
}

15
src/socketfactory.cc
View File

@ -1,4 +1,15 @@
#include "socketfactory.hh"
uvgrtp::socketfactory::socketfactory()
{}
uvgrtp::socketfactory::socketfactory() :
local_address_(""),
local_port_()
{}
uvgrtp::socketfactory::~socketfactory()
{}
void uvgrtp::socketfactory::set_local_interface(std::string local_addr, uint16_t local_port)
{
local_address_ = local_addr;
local_port_ = local_port;
}

2
src/socketfactory.hh
View File

@ -9,7 +9,9 @@ namespace uvgrtp {
public:
socketfactory();
~socketfactory();
void set_local_interface(std::string local_addr, uint16_t local_port);
private:
std::string local_address_;
uint16_t local_port_;