diff -r f5a5d9237d69 -r e8d6255306f8 src/jlibrtp/RtcpPktSR.java --- a/src/jlibrtp/RtcpPktSR.java Sat Jan 23 21:48:58 2010 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,190 +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 - 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."); - } - } -}