diff -r 9bdff6cbd120 -r 2bf440c54ca5 src/jlibrtp/RtcpPktSR.java --- 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."); - } - } -}