修复组播相关bug

This commit is contained in:
xiongziliang 2019-04-09 21:05:30 +08:00
parent 1a3d1eb4fb
commit 5ac0be52cb

View File

@ -124,7 +124,7 @@ RtpBroadCaster::RtpBroadCaster(const string &strLocalIp,const string &strVhost,c
bzero(&(peerAddr.sin_zero), sizeof peerAddr.sin_zero);
_apUdpSock[i]->setSendPeerAddr((struct sockaddr *)&peerAddr);
}
_pReader = src->getRing()->attach(nullptr);
_pReader = src->getRing()->attach(EventPollerPool::Instance().getPoller());
_pReader->setReadCB([this](const RtpPacket::Ptr &pkt){
int i = (int)(pkt->type);
auto &pSock = _apUdpSock[i];