BigBlueButton/bigbluebutton-Github
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

- init last seq num and last timestamp from first packet received. Don't assume that seq num always start at 0.

Browse Source
This commit is contained in:
Richard Alam 2010-09-09 13:33:32 -04:00
parent 5100fff24b
commit eef0c12091
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
bbb-voice/src/main/java/org/bigbluebutton/voiceconf/red5/media/RtpStreamReceiver.java
View File

@ -42,6 +42,7 @@ public class RtpStreamReceiver {
private final int payloadLength;
private int lastSequenceNumber = 0;
private long lastPacketTimestamp = 0;
private boolean firstPacket = true;
public RtpStreamReceiver(DatagramSocket socket, int expectedPayloadLength) {
this.payloadLength = expectedPayloadLength;
@ -87,12 +88,16 @@ public class RtpStreamReceiver {
rtpSocket.receive(rtpPacket);
packetReceivedCounter++;
if (shouldHandlePacket(rtpPacket)) {
processRtpPacket(rtpPacket);
processRtpPacket(rtpPacket);
} else {
if (isFirstPacket()) {
if (firstPacket) {
firstPacket = false;
log.debug("First packet seqNum[rtpSeqNum=" + rtpPacket.getSeqNum() + ",lastSeqNum=" + lastSequenceNumber
+ "][rtpTS=" + rtpPacket.getTimestamp() + ",lastTS=" + lastPacketTimestamp + "][port=" + rtpSocket.getDatagramSocket().getLocalPort() + "]");
processRtpPacket(rtpPacket);
} else {
log.info("Corrupt packet seqNum[rtpSeqNum=" + rtpPacket.getSeqNum() + ",lastSeqNum=" + lastSequenceNumber +"][rtpTS=" + rtpPacket.getTimestamp() + ",lastTS=" + lastPacketTimestamp + "]");
log.debug("Corrupt packet seqNum[rtpSeqNum=" + rtpPacket.getSeqNum() + ",lastSeqNum=" + lastSequenceNumber
+ "][rtpTS=" + rtpPacket.getTimestamp() + ",lastTS=" + lastPacketTimestamp + "][port=" + rtpSocket.getDatagramSocket().getLocalPort() + "]");
}
}
} catch (IOException e) {