Skip to content
Snippets Groups Projects
Commit 22f17b9c authored by Vincent Lucas's avatar Vincent Lucas
Browse files

Logs RTCP sender report sent and received to correct wrong statistics (RTT, loss rate).

parent c55ebea3
No related branches found
No related tags found
No related merge requests found
...@@ -105,6 +105,19 @@ public RawPacket transform(RawPacket pkt) ...@@ -105,6 +105,19 @@ public RawPacket transform(RawPacket pkt)
{ {
RTCPSenderReport report = new RTCPSenderReport( RTCPSenderReport report = new RTCPSenderReport(
data, offset, length); data, offset, length);
long currentTime = System.currentTimeMillis();
StringBuffer logDebugRTCPSenderReport
= new StringBuffer("Send new RTCPFeedback: "
+ "\n\tcurrentTime: " + currentTime
+ " (" + Long.toHexString(currentTime) + ")"
+ "\n\tNTPTimeStampMSW: "
+ report.getNTPTimeStampMSW() + " ("
+ Long.toHexString(report.getNTPTimeStampMSW())
+ ")"
+ "\n\tNTPTimeStampLSW: "
+ report.getNTPTimeStampLSW() + " ("
+ Long.toHexString(report.getNTPTimeStampLSW())
+ ")");
if(report.getFeedbackReports().size() > 0) if(report.getFeedbackReports().size() > 0)
{ {
...@@ -155,7 +168,20 @@ public RawPacket transform(RawPacket pkt) ...@@ -155,7 +168,20 @@ public RawPacket transform(RawPacket pkt)
.append((int) (feedback.getDLSR() / 65.536)) .append((int) (feedback.getDLSR() / 65.536))
.append("ms ]"); .append("ms ]");
logger.info(buff); logger.info(buff);
logDebugRTCPSenderReport.append(
"\n\tDLSR: " + feedback.getDLSR() + " ("
+ Long.toHexString(feedback.getDLSR()) + ")"
+ "\n\tLSR: " + feedback.getLSR() + " ("
+ Long.toHexString(feedback.getLSR()) + ")"
+ "\n\tXntdSeqNum: " + feedback.getXtndSeqNum()
+ "\n\tnumLost: " + feedback.getNumLost()
+ "\n\tjitter: " + feedback.getJitter());
} }
// log RTCP sender report received to correct wrong
// computation (RTT, loss rate, etc).
logger.info(logDebugRTCPSenderReport.toString());
} }
} }
catch(Throwable t) catch(Throwable t)
...@@ -190,14 +216,41 @@ public RawPacket reverseTransform(RawPacket pkt) ...@@ -190,14 +216,41 @@ public RawPacket reverseTransform(RawPacket pkt)
RTCPSenderReport report = new RTCPSenderReport( RTCPSenderReport report = new RTCPSenderReport(
data, offset, length); data, offset, length);
long currentTime = System.currentTimeMillis();
StringBuffer logDebugRTCPSenderReport
= new StringBuffer("Receive new RTCPFeedback: "
+ "\n\tcurrentTime: " + currentTime
+ " (" + Long.toHexString(currentTime) + ")"
+ "\n\tNTPTimeStampMSW: "
+ report.getNTPTimeStampMSW() + " ("
+ Long.toHexString(report.getNTPTimeStampMSW())
+ ")"
+ "\n\tNTPTimeStampLSW: "
+ report.getNTPTimeStampLSW() + " ("
+ Long.toHexString(report.getNTPTimeStampLSW())
+ ")");
if(report.getFeedbackReports().size() > 0) if(report.getFeedbackReports().size() > 0)
{ {
RTCPFeedback feedback = RTCPFeedback feedback = (RTCPFeedback)
(RTCPFeedback)report.getFeedbackReports().get(0); report.getFeedbackReports().get(0);
this.mediaStream.getMediaStreamStats() this.mediaStream.getMediaStreamStats()
.updateNewReceivedFeedback(feedback); .updateNewReceivedFeedback(feedback);
logDebugRTCPSenderReport.append(
"\n\tDLSR: " + feedback.getDLSR() + " ("
+ Long.toHexString(feedback.getDLSR()) + ")"
+ "\n\tLSR: " + feedback.getLSR() + " ("
+ Long.toHexString(feedback.getLSR()) + ")"
+ "\n\tXntdSeqNum: " + feedback.getXtndSeqNum()
+ "\n\tnumLost: " + feedback.getNumLost()
+ "\n\tjitter: " + feedback.getJitter());
} }
// log RTCP sender report received to correct wrong
// computation (RTT, loss rate, etc).
logger.info(logDebugRTCPSenderReport.toString());
} }
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment