--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jlibrtp/RtcpPktSR.java Sat Mar 14 22:15:41 2009 +0100
@@ -0,0 +1,178 @@
+/**
+ * Java RTP Library (jlibrtp)
+ * Copyright (C) 2006 Arne Kepp
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+package jlibrtp;
+
+/**
+ * RTCP packets for Sender Reports
+ *
+ * @author Arne Kepp
+ */
+public class RtcpPktSR extends RtcpPkt {
+ /** NTP timestamp, MSB */
+ protected long ntpTs1 = -1; //32 bits
+ /** NTP timestamp, LSB */
+ protected long ntpTs2 = -1; //32 bits
+ /** RTP timestamp */
+ protected long rtpTs = -1; //32 bits
+ /** Senders packet count */
+ protected long sendersPktCount = -1; //32 bits
+ /** Senders octet count */
+ protected long sendersOctCount = -1; //32 bits
+ /** RR packet with receiver reports that we can append */
+ protected RtcpPktRR rReports = null;
+
+ /**
+ * Constructor for a new Sender Report packet
+ *
+ * @param ssrc the senders SSRC, presumably from RTPSession
+ * @param pktCount packets sent in this session
+ * @param octCount octets sent in this session
+ * @param rReports receiver reports, as RR packets, to be included in this packet
+ */
+ protected RtcpPktSR(long ssrc, long pktCount, long octCount, RtcpPktRR rReports) {
+ // Fetch all the right stuff from the database
+ super.ssrc = ssrc;
+ super.packetType = 200;
+ sendersPktCount = pktCount;
+ sendersOctCount = octCount;
+ this.rReports = rReports;
+ }
+
+ /**
+ * Constructor that parses a received packet
+ *
+ * @param aRawPkt the raw packet
+ * @param start the position at which SR starts
+ * @param length used to determine number of included receiver reports
+ */
+ protected RtcpPktSR(byte[] aRawPkt, int start, int length) {
+ if(RTPSession.rtpDebugLevel > 9) {
+ System.out.println(" -> RtcpPktSR(rawPkt)");
+ }
+
+ super.rawPkt = aRawPkt;
+
+ if(!super.parseHeaders(start) || packetType != 200 ) {
+ if(RTPSession.rtpDebugLevel > 2) {
+ System.out.println(" <-> RtcpPktSR.parseHeaders() etc. problem: "+ (!super.parseHeaders(start) ) + " " + packetType + " " + super.length);
+ }
+ super.problem = -200;
+ } else {
+ super.ssrc = StaticProcs.bytesToUIntLong(aRawPkt,4+start);
+ if(length > 11)
+ ntpTs1 = StaticProcs.bytesToUIntLong(aRawPkt,8+start);
+ if(length > 15)
+ ntpTs2 = StaticProcs.bytesToUIntLong(aRawPkt,12+start);
+ if(length > 19)
+ rtpTs = StaticProcs.bytesToUIntLong(aRawPkt,16+start);
+ if(length > 23)
+ sendersPktCount = StaticProcs.bytesToUIntLong(aRawPkt,20+start);
+ if(length > 27)
+ sendersOctCount = StaticProcs.bytesToUIntLong(aRawPkt,24+start);
+
+ // RRs attached?
+ if(itemCount > 0) {
+ rReports = new RtcpPktRR(rawPkt,start,itemCount);
+ }
+ }
+
+ if(RTPSession.rtpDebugLevel > 9) {
+ System.out.println(" <- RtcpPktSR(rawPkt)");
+ }
+ }
+
+ /**
+ * Encode the packet into a byte[], saved in .rawPkt
+ *
+ * CompRtcpPkt will call this automatically
+ */
+ protected void encode() {
+ if(RTPSession.rtpDebugLevel > 9) {
+ if(this.rReports != null) {
+ System.out.println(" -> RtcpPktSR.encode() receptionReports.length: " + this.rReports.length );
+ } else {
+ System.out.println(" -> RtcpPktSR.encode() receptionReports: null");
+ }
+ }
+
+ if(this.rReports != null) {
+ super.itemCount = this.rReports.reportees.length;
+
+ byte[] tmp = this.rReports.encodeRR();
+ super.rawPkt = new byte[tmp.length+28];
+ //super.length = (super.rawPkt.length / 4) - 1;
+
+ System.arraycopy(tmp, 0, super.rawPkt, 28, tmp.length);
+
+ } else {
+ super.itemCount = 0;
+ super.rawPkt = new byte[28];
+ //super.length = 6;
+ }
+ //Write the common header
+ super.writeHeaders();
+
+ // Convert to NTP and chop up
+ long timeNow = System.currentTimeMillis();
+ ntpTs1 = 2208988800L + (timeNow/1000);
+ long ms = timeNow % 1000;
+ double tmp = ((double)ms) / 1000.0;
+ tmp = tmp * (double)4294967295L;
+ ntpTs2 = (long) tmp;
+ rtpTs = System.currentTimeMillis();
+
+ //Write SR stuff
+ byte[] someBytes;
+ someBytes = StaticProcs.uIntLongToByteWord(super.ssrc);
+ System.arraycopy(someBytes, 0, super.rawPkt, 4, 4);
+ someBytes = StaticProcs.uIntLongToByteWord(ntpTs1);
+ System.arraycopy(someBytes, 0, super.rawPkt, 8, 4);
+ someBytes = StaticProcs.uIntLongToByteWord(ntpTs2);
+ System.arraycopy(someBytes, 0, super.rawPkt, 12, 4);
+ someBytes = StaticProcs.uIntLongToByteWord(rtpTs);
+ System.arraycopy(someBytes, 0, super.rawPkt, 16, 4);
+ someBytes = StaticProcs.uIntLongToByteWord(sendersPktCount);
+ System.arraycopy(someBytes, 0, super.rawPkt, 20, 4);
+ someBytes = StaticProcs.uIntLongToByteWord(sendersOctCount);
+ System.arraycopy(someBytes, 0, super.rawPkt, 24, 4);
+
+ if(RTPSession.rtpDebugLevel > 9) {
+ System.out.println(" <- RtcpPktSR.encode() ntpTs1: "
+ + Long.toString(ntpTs1) + " ntpTs2: " + Long.toString(ntpTs2));
+ }
+ }
+
+ /**
+ * Debug purposes only
+ */
+ public void debugPrint() {
+ System.out.println("RtcpPktSR.debugPrint() ");
+ System.out.println(" SSRC:"+Long.toString(super.ssrc) +" ntpTs1:"+Long.toString(ntpTs1)
+ +" ntpTS2:"+Long.toString(ntpTs2)+" rtpTS:"+Long.toString(rtpTs)
+ +" senderPktCount:"+Long.toString(sendersPktCount)+" sendersOctetCount:"
+ +Long.toString(sendersOctCount));
+ if(this.rReports != null) {
+ System.out.print(" Part of Sender Report: ");
+ this.rReports.debugPrint();
+ System.out.println(" End Sender Report");
+ } else {
+ System.out.println("No Receiver Reports associated with this Sender Report.");
+ }
+ }
+}