diff -r f5a5d9237d69 -r e8d6255306f8 src/jlibrtp/RtcpPktPSFB.java --- a/src/jlibrtp/RtcpPktPSFB.java Sat Jan 23 21:48:58 2010 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,411 +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 Payload-Specific Feedback Messages - * - * @author Arne Kepp - */ -public class RtcpPktPSFB extends RtcpPkt { - /** If this packet was for a different SSRC */ - protected boolean notRelevant = false; - /** Parent RTP Session */ - private RTPSession rtpSession; - /** SSRC we are sending feeback to */ - protected long ssrcMediaSource = -1; - - /** SLI macroblock (MB) address of the first lost macroblock number */ - protected int[] sliFirst; - /** SLI number of lost macroblocks */ - protected int[] sliNumber; - /** SLI six least significant bits of the codec-specific identifier */ - protected int[] sliPictureId; - - // Picture loss indication - /** RPSI number of padded bits at end of bitString */ - protected int rpsiPadding = -1; - /** RPSI payloadType RTP payload type */ - protected int rpsiPayloadType = -1; - /** RPSI information as natively defined by the video codec */ - protected byte[] rpsiBitString; - - /** Application Layer Feedback Message */ - protected byte[] alfBitString; - - /** - * Generic constructor, then call make - * - * @param ssrcPacketSender - * @param ssrcMediaSource - */ - protected RtcpPktPSFB(long ssrcPacketSender, long ssrcMediaSource) { - super.ssrc = ssrcPacketSender; - this.ssrcMediaSource = ssrcMediaSource; - super.packetType = 206; // PSFB - } - - /** - * Make this packet a Picture loss indication - */ - protected void makePictureLossIndication() { - super.itemCount = 1; // FMT - } - - /** - * Make this packet a Slice Loss Indication - * - * @param sliFirst - * macroblock (MB) address of the first lost macroblock - * @param sliNumber - * number of lost macroblocks - * @param sliPictureId - * six least significant bits of the codec-specific identifier - */ - protected void makeSliceLossIndication(int[] sliFirst, int[] sliNumber, - int[] sliPictureId) { - super.itemCount = 2; // FMT - this.sliFirst = sliFirst; - this.sliNumber = sliNumber; - this.sliPictureId = sliPictureId; - } - - /** - * Make this packet a Reference Picture Selection Indication - * - * @param bitPadding - * number of padded bits at end of bitString - * @param payloadType - * RTP payload type for codec - * @param bitString - * RPSI information as natively defined by the video codec - */ - protected void makeRefPictureSelIndic(int bitPadding, int payloadType, - byte[] bitString) { - super.itemCount = 3; // FMT - this.rpsiPadding = bitPadding; - this.rpsiPayloadType = payloadType; - this.rpsiBitString = bitString; - } - - /** - * Make this packet an Application specific feedback message - * - * @param bitString - * the original application message - */ - protected void makeAppLayerFeedback(byte[] bitString) { - super.itemCount = 15; // FMT - this.alfBitString = bitString; - } - - /** - * Constructor that parses a raw packet to retrieve information - * - * @param aRawPkt - * the raw packet to be parsed - * @param start - * the start of the packet, in bytes - * @param rtpSession - * the session on which the callback interface resides - */ - protected RtcpPktPSFB(byte[] aRawPkt, int start, RTPSession rtpSession) { - if (RTPSession.rtpDebugLevel > 8) { - System.out.println(" -> RtcpPktPSFB(byte[], int start)"); - } - this.rtpSession = rtpSession; - - rawPkt = aRawPkt; - - if (!super.parseHeaders(start) || packetType != 206 || super.length < 2) { - if (RTPSession.rtpDebugLevel > 2) { - System.out - .println(" <-> RtcpPktRTPFB.parseHeaders() etc. problem"); - } - super.problem = -206; - } else { - // FMT = super.itemCount; - ssrcMediaSource = StaticProcs.bytesToUIntLong(aRawPkt, 8 + start); - - if (ssrcMediaSource == rtpSession.ssrc) { - super.ssrc = StaticProcs.bytesToUIntLong(aRawPkt, 4 + start); - - switch (super.itemCount) { - case 1: // Picture Loss Indication - decPictureLossIndic(); - break; - case 2: // Slice Loss Indication - decSliceLossIndic(aRawPkt, start + 12); - break; - case 3: // Reference Picture Selection Indication - decRefPictureSelIndic(aRawPkt, start + 12); - break; - case 15: // Application Layer Feedback Messages - decAppLayerFB(aRawPkt, start + 12); - break; - default: - System.out - .println("!!!! RtcpPktPSFB(byte[], int start) unexpected FMT " - + super.itemCount); - } - } else { - this.notRelevant = true; - } - } - if (RTPSession.rtpDebugLevel > 8) { - System.out.println(" <- RtcpPktPSFB()"); - } - } - - /** - * Decode Picture Loss indication - * - */ - private void decPictureLossIndic() { - if (this.rtpSession.rtcpAVPFIntf != null) { - this.rtpSession.rtcpAVPFIntf.PSFBPktPictureLossReceived(super.ssrc); - } - } - - /** - * Decode Slice Loss Indication - * - * @param aRawPkt - * @param start - */ - private void decSliceLossIndic(byte[] aRawPkt, int start) { - // 13 bit off-boundary numbers? That's rather cruel - // 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 - // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ - // | First | Number | PictureID | - // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ - - int count = super.length - 2; - - sliFirst = new int[count]; - sliNumber = new int[count]; - sliPictureId = new int[count]; - - // Loop over the FCI lines - for (int i = 0; i < count; i++) { - sliFirst[i] = StaticProcs.bytesToUIntInt(aRawPkt, start) >> 3; - sliNumber[i] = (int) (StaticProcs.bytesToUIntInt(aRawPkt, start) & 0x0007FFC0) >> 6; - sliPictureId[i] = (StaticProcs.bytesToUIntInt(aRawPkt, start + 2) & 0x003F); - start += 4; - } - - if (this.rtpSession.rtcpAVPFIntf != null) { - this.rtpSession.rtcpAVPFIntf.PSFBPktSliceLossIndic(super.ssrc, - sliFirst, sliNumber, sliPictureId); - } - } - - /** - * Decode Reference Picture Selection Indication - * - * @param aRawPkt - * @param start - */ - private void decRefPictureSelIndic(byte[] aRawPkt, int start) { - // 0 1 2 3 - // 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 - // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ - // | PB |0| Payload Type| Native RPSI bit string | - // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ - // | defined per codec ... | Padding (0) | - // +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ - - rpsiPadding = aRawPkt[start]; - - if (rpsiPadding > 32) { - System.out - .println("!!!! RtcpPktPSFB.decRefPictureSelcIndic paddingBits: " - + rpsiPadding); - } - - rpsiPayloadType = (int) rawPkt[start]; - if (rpsiPayloadType < 0) { - System.out - .println("!!!! RtcpPktPSFB.decRefPictureSelcIndic 8th bit not zero: " - + rpsiPayloadType); - } - - rpsiBitString = new byte[(super.length - 2) * 4 - 2]; - System.arraycopy(aRawPkt, start + 2, rpsiBitString, 0, - rpsiBitString.length); - - if (this.rtpSession.rtcpAVPFIntf != null) { - this.rtpSession.rtcpAVPFIntf.PSFBPktRefPictureSelIndic(super.ssrc, - rpsiPayloadType, rpsiBitString, rpsiPadding); - } - - } - - /** - * Decode Application specific feedback message - * - * @param aRawPkt - * @param start - */ - private void decAppLayerFB(byte[] aRawPkt, int start) { - // Application Message (FCI): variable length - int stringLength = (super.length - 2) * 4; - - alfBitString = new byte[stringLength]; - - System.arraycopy(aRawPkt, start, alfBitString, 0, stringLength); - - if (this.rtpSession.rtcpAVPFIntf != null) { - this.rtpSession.rtcpAVPFIntf.PSFBPktAppLayerFBReceived(super.ssrc, - alfBitString); - } - } - - /** - * Encode a Slice Loss Indication - */ - private void encSliceLossIndic() { - byte[] firstBytes; - byte[] numbBytes; - byte[] picBytes; - - int offset = 8; - // Loop over the FCI lines - for (int i = 0; i < sliFirst.length; i++) { - offset = 8 + 8 * i; - firstBytes = StaticProcs.uIntLongToByteWord(sliFirst[i] << 3); - numbBytes = StaticProcs.uIntLongToByteWord(sliNumber[i] << 2); - picBytes = StaticProcs.uIntIntToByteWord(sliPictureId[i]); - - super.rawPkt[offset] = firstBytes[2]; - super.rawPkt[offset + 1] = (byte) (firstBytes[3] | numbBytes[2]); - super.rawPkt[offset + 2] = numbBytes[3]; - super.rawPkt[offset + 3] = (byte) (numbBytes[3] | picBytes[1]); - } - } - - /** - * Encode a Reference Picture Selection Indication - * - */ - private void encRefPictureSelIndic() { - byte[] someBytes; - someBytes = StaticProcs.uIntIntToByteWord(rpsiPadding); - super.rawPkt[8] = someBytes[1]; - someBytes = StaticProcs.uIntIntToByteWord(rpsiPayloadType); - super.rawPkt[9] = someBytes[1]; - - System.arraycopy(rpsiBitString, 0, super.rawPkt, 10, - rpsiBitString.length); - } - - /** - * Encode Application Layer Feedback - * - */ - private void encAppLayerFB() { - // Application Message (FCI): variable length - System.arraycopy(alfBitString, 0, super.rawPkt, 8, alfBitString.length); - } - - /** - * Get the FMT (Feedback Message Type) - * - * @return value stored in .itemcount, same field - */ - protected int getFMT() { - return this.itemCount; - } - - /** - * Encode the packet into a byte[], saved in .rawPkt - * - * CompRtcpPkt will call this automatically - */ - protected void encode() { - switch (super.itemCount) { - case 1: // Picture Loss Indication - // Nothing to do really - super.rawPkt = new byte[24]; - break; - case 2: // Slice Loss Indication - super.rawPkt = new byte[24 + 4 * this.sliFirst.length]; - encSliceLossIndic(); - break; - case 3: // Reference Picture Selection Indication - super.rawPkt = new byte[24 + 2 + this.rpsiBitString.length / 4]; - encRefPictureSelIndic(); - break; - case 15: // Application Layer Feedback Messages - super.rawPkt = new byte[24 + this.alfBitString.length / 4]; - encAppLayerFB(); - break; - } - - byte[] someBytes = StaticProcs.uIntLongToByteWord(super.ssrc); - System.arraycopy(someBytes, 0, super.rawPkt, 4, 4); - someBytes = StaticProcs.uIntLongToByteWord(this.ssrcMediaSource); - System.arraycopy(someBytes, 0, super.rawPkt, 8, 4); - - writeHeaders(); - } - - /** - * Debug purposes only - */ - public void debugPrint() { - System.out.println("->RtcpPktPSFB.debugPrint() "); - - String str; - switch (super.itemCount) { - case 1: // Picture Loss Indication - System.out.println(" FMT: Picture Loss Indication"); - break; - case 2: // Slice Loss Indication - if (sliFirst != null) { - str = "sliFirst[].length: " + sliFirst.length; - } else { - str = "sliFirst[] is null"; - } - System.out.println(" FMT: Slice Loss Indication, " + str); - break; - case 3: // Reference Picture Selection Indication - if (rpsiBitString != null) { - str = "rpsiBitString[].length: " + rpsiBitString.length; - } else { - str = "rpsiBitString[] is null"; - } - System.out - .println(" FMT: Reference Picture Selection Indication, " - + str + " payloadType: " + this.rpsiPayloadType); - break; - case 15: // Application Layer Feedback Messages - if (alfBitString != null) { - str = "alfBitString[].length: " + alfBitString.length; - } else { - str = "alfBitString[] is null"; - } - System.out.println(" FMT: Application Layer Feedback Messages, " - + str); - break; - } - - System.out.println("<-RtcpPktPSFB.debugPrint() "); - } -}