mirror of https://github.com/sipwise/jitsi.git
Damian Minkov
15 years ago
parent
8a23901ba4
commit
2a29e3645e
Binary file not shown.
@ -0,0 +1,183 @@
|
||||
/*
|
||||
* SIP Communicator, the OpenSource Java VoIP and Instant Messaging client.
|
||||
*
|
||||
* Distributable under LGPL license.
|
||||
* See terms of license at gnu.org.
|
||||
*/
|
||||
package net.java.sip.communicator.impl.neomedia.transform.rtcp;
|
||||
|
||||
import com.sun.media.rtp.*;
|
||||
import net.java.sip.communicator.impl.neomedia.*;
|
||||
import net.java.sip.communicator.impl.neomedia.transform.*;
|
||||
|
||||
import net.java.sip.communicator.util.*;
|
||||
import net.sf.fmj.media.rtp.*;
|
||||
|
||||
/**
|
||||
* @author Damian Minkov
|
||||
*/
|
||||
public class StatisticsEngine
|
||||
implements TransformEngine,
|
||||
PacketTransformer
|
||||
{
|
||||
/**
|
||||
* The <tt>Logger</tt> used by the <tt>StatisticsEngine</tt> class
|
||||
* and its instances for logging output.
|
||||
*/
|
||||
private static final Logger logger
|
||||
= Logger.getLogger(StatisticsEngine.class);
|
||||
|
||||
/**
|
||||
* Number of sender reports send.
|
||||
* Used only for logging and debug purposes.
|
||||
*/
|
||||
private long numberOfSenderReports = 0;
|
||||
|
||||
/**
|
||||
* The minimum inter arrival jitter value we have reported.
|
||||
*/
|
||||
private long maxInterArrivalJitter = 0;
|
||||
|
||||
/**
|
||||
* The minimum inter arrival jitter value we have reported.
|
||||
*/
|
||||
private long minInterArrivalJitter = -1;
|
||||
|
||||
/**
|
||||
* Number of lost packets reported.
|
||||
*/
|
||||
private long lost = 0;
|
||||
|
||||
/**
|
||||
* Finds the info needed for statistics in the packet and stores it.
|
||||
* Then returns the same packet as we are not modifying it.
|
||||
*
|
||||
* @param pkt the packet
|
||||
* @return the packet
|
||||
*/
|
||||
public RawPacket transform(RawPacket pkt)
|
||||
{
|
||||
if(!logger.isTraceEnabled())
|
||||
return pkt;
|
||||
|
||||
try
|
||||
{
|
||||
numberOfSenderReports++;
|
||||
|
||||
byte[] data = pkt.getBuffer();
|
||||
int offset = pkt.getOffset();
|
||||
int length = pkt.getLength();
|
||||
|
||||
RTCPHeader header = new RTCPHeader(
|
||||
data, offset, length);
|
||||
if (header.getPacketType() == RTCPPacket.SR)
|
||||
{
|
||||
RTCPSenderReport report = new RTCPSenderReport(
|
||||
data, offset, length);
|
||||
|
||||
if(report.getFeedbackReports().size() > 0)
|
||||
{
|
||||
RTCPFeedback feedback =
|
||||
(RTCPFeedback)report.getFeedbackReports().get(0);
|
||||
|
||||
long jitter = feedback.getJitter();
|
||||
|
||||
if(jitter < getMinInterArrivalJitter()
|
||||
|| getMinInterArrivalJitter() == -1)
|
||||
minInterArrivalJitter = jitter;
|
||||
|
||||
if(getMaxInterArrivalJitter() < jitter)
|
||||
maxInterArrivalJitter = jitter;
|
||||
|
||||
lost = feedback.getNumLost();
|
||||
|
||||
// As sender reports are send on every 5 seconds
|
||||
// print every 4th packet, on every 20 seconds
|
||||
if(numberOfSenderReports%4 != 1)
|
||||
return pkt;
|
||||
|
||||
StringBuilder buff = new StringBuilder(
|
||||
"Sending report to remote party [packetCount:");
|
||||
|
||||
buff.append(report.getSenderPacketCount())
|
||||
.append(", bytes:").append(report.getSenderByteCount())
|
||||
.append(", interarrival jitter:")
|
||||
.append(jitter)
|
||||
.append(", lost:").append(feedback.getNumLost())
|
||||
.append(", lastSRBefore:")
|
||||
.append((int) (feedback.getDLSR() / 65.536))
|
||||
.append("ms ]");
|
||||
logger.trace(buff.toString());
|
||||
}
|
||||
}
|
||||
}
|
||||
catch(Throwable t)
|
||||
{
|
||||
t.printStackTrace();
|
||||
}
|
||||
|
||||
return pkt;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the packet as we are listening just for sending packages.
|
||||
*
|
||||
* @param pkt the packet without any change.
|
||||
* @return the packet without any change.
|
||||
*/
|
||||
public RawPacket reverseTransform(RawPacket pkt)
|
||||
{
|
||||
return pkt;
|
||||
}
|
||||
|
||||
/**
|
||||
* Always returns <tt>null</tt> since this engine does not require any
|
||||
* RTP transformations.
|
||||
*
|
||||
* @return <tt>null</tt> since this engine does not require any
|
||||
* RTP transformations.
|
||||
*/
|
||||
public PacketTransformer getRTPTransformer()
|
||||
{
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns a reference to this class since it is performing RTP
|
||||
* transformations in here.
|
||||
*
|
||||
* @return a reference to <tt>this</tt> instance of the
|
||||
* <tt>StatisticsEngine</tt>.
|
||||
*/
|
||||
public PacketTransformer getRTCPTransformer()
|
||||
{
|
||||
return this;
|
||||
}
|
||||
|
||||
/**
|
||||
* The minimum inter arrival jitter value we have reported.
|
||||
* @return minimum inter arrival jitter value we have reported.
|
||||
*/
|
||||
public long getMaxInterArrivalJitter()
|
||||
{
|
||||
return maxInterArrivalJitter;
|
||||
}
|
||||
|
||||
/**
|
||||
* The maximum inter arrival jitter value we have reported.
|
||||
* @return maximum inter arrival jitter value we have reported.
|
||||
*/
|
||||
public long getMinInterArrivalJitter()
|
||||
{
|
||||
return minInterArrivalJitter;
|
||||
}
|
||||
|
||||
/**
|
||||
* Number of lost packets reported.
|
||||
* @return number of lost packets reported.
|
||||
*/
|
||||
public long getLost()
|
||||
{
|
||||
return lost;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in new issue