--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jlibrtp/RtcpPktSR.java Fri Nov 20 19:29:42 2009 +0100
@@ -0,0 +1,190 @@
+/**
+ * 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
+ StaticProcs.uIntLongToByteWord(super.ssrc, super.rawPkt, 4);
+ StaticProcs.uIntLongToByteWord(ntpTs1, super.rawPkt, 8);
+ StaticProcs.uIntLongToByteWord(ntpTs2, super.rawPkt, 12);
+ StaticProcs.uIntLongToByteWord(rtpTs, super.rawPkt, 16);
+ StaticProcs.uIntLongToByteWord(sendersPktCount, super.rawPkt, 20);
+ StaticProcs.uIntLongToByteWord(sendersOctCount, super.rawPkt, 24);
+
+ 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.");
+ }
+ }
+}