diff --git a/src/Common/MediaSink.cpp b/src/Common/MediaSink.cpp index 13b9ab40..02bf904a 100644 --- a/src/Common/MediaSink.cpp +++ b/src/Common/MediaSink.cpp @@ -13,19 +13,21 @@ //最多等待未初始化的Track 10秒,超时之后会忽略未初始化的Track #define MAX_WAIT_MS_READY 10000 -//如果添加Track,最多等待3秒 -#define MAX_WAIT_MS_ADD_TRACK 3000 - +//如果添加Track,最多等待5秒 +#define MAX_WAIT_MS_ADD_TRACK 5000 namespace mediakit{ void MediaSink::addTrack(const Track::Ptr &track_in) { lock_guard lck(_mtx); + if (_all_track_ready) { + WarnL << "all track is ready, add this track too late!"; + return; + } //克隆Track,只拷贝其数据,不拷贝其数据转发关系 auto track = track_in->clone(); auto codec_id = track->getCodecId(); _track_map[codec_id] = track; - _all_track_ready = false; _track_ready_callback[codec_id] = [this, track]() { onTrackReady(track); }; diff --git a/src/Rtp/RtpServer.cpp b/src/Rtp/RtpServer.cpp index 5b92226b..d417e148 100644 --- a/src/Rtp/RtpServer.cpp +++ b/src/Rtp/RtpServer.cpp @@ -25,7 +25,15 @@ RtpServer::~RtpServer() { void RtpServer::start(uint16_t local_port, const string &stream_id, bool enable_tcp, const char *local_ip) { //创建udp服务器 Socket::Ptr udp_server = Socket::createSocket(nullptr, false); - if (!udp_server->bindUdpSock(local_port, local_ip)) { + if (local_port == 0) { + //随机端口,rtp端口采用偶数 + Socket::Ptr rtcp_server = Socket::createSocket(nullptr, false); + auto pair = std::make_pair(udp_server, rtcp_server); + makeSockPair(pair, local_ip); + //取偶数端口 + udp_server = pair.first; + } else if (!udp_server->bindUdpSock(local_port, local_ip)) { + //用户指定端口 throw std::runtime_error(StrPrinter << "bindUdpSock on " << local_ip << ":" << local_port << " failed:" << get_uv_errmsg(true)); } //设置udp socket读缓存