THENG
/
ZLMediaKit
mirror of https://gitcode.com/gh_mirrors/zlme/ZLMediaKit.git
6
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

修复udp发送相关bug

This commit is contained in:
xiongziliang 2018-12-20 16:59:54 +08:00
parent 166bbb0be0
commit c64bf1ea7a
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Rtsp/RtpBroadCaster.cpp
View File

@ -129,7 +129,7 @@ RtpBroadCaster::RtpBroadCaster(const string &strLocalIp,const string &strVhost,c
auto &pSock = _apUdpSock[i]; auto &pSock = _apUdpSock[i];
auto &peerAddr = _aPeerUdpAddr[i]; auto &peerAddr = _aPeerUdpAddr[i];
BufferRtp::Ptr buffer(new BufferRtp(pkt,4)); BufferRtp::Ptr buffer(new BufferRtp(pkt,4));
pSock->send(buffer,SOCKET_DEFAULE_FLAGS | FLAG_MORE,(struct sockaddr *)(&peerAddr)); pSock->send(buffer,SOCKET_DEFAULE_FLAGS,(struct sockaddr *)(&peerAddr));
}); });
_pReader->setDetachCB([this](){ _pReader->setDetachCB([this](){
unordered_map<void * , onDetach > _mapDetach_copy; unordered_map<void * , onDetach > _mapDetach_copy;

2
src/Rtsp/RtspSession.cpp
View File

@ -998,7 +998,7 @@ inline void RtspSession::sendRtpPacket(const RtpPacket::Ptr & pkt) {
} }
BufferRtp::Ptr buffer(new BufferRtp(pkt,4)); BufferRtp::Ptr buffer(new BufferRtp(pkt,4));
_ui64TotalBytes += buffer->size(); _ui64TotalBytes += buffer->size();
pSock->send(buffer,kSockFlags, peerAddr.get()); pSock->send(buffer,SOCKET_DEFAULE_FLAGS, peerAddr.get());
} }
break; break;
default: default: