--- a/src/jlibrtp/RtcpPktSR.java Thu May 28 14:26:06 2009 +0200
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,178 +0,0 @@
-/**
- * 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.");
- }
- }
-}