/**

 * 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 RTP Feedback Messages

 * 

 * In line with RFC 4585, this packet currently only supports NACKs

 * 

 * @author Arne Kepp

 */

public class RtcpPktRTPFB extends RtcpPkt {

	/** If this packet was for a different SSRC */

	protected boolean notRelevant = false;

	/** SSRC we are sending feeback to */

	protected long ssrcMediaSource = -1;

	/** RTP sequence numbers of lost packets */

	protected int PID[];

	/** bitmask of following lost packets, shared index with PID */

	protected int BLP[];

	/**

	 * Constructor for RTP Feedback Message

	 * 

	 * @param ssrcPacketSender

	 *            SSRC of sender, taken from RTPSession

	 * @param ssrcMediaSource

	 *            SSRC of recipient of this message

	 * @param FMT

	 *            the Feedback Message Subtype

	 * @param PID

	 *            RTP sequence numbers of lost packets

	 * @param BLP

	 *            bitmask of following lost packets, shared index with PID

	 */

	protected RtcpPktRTPFB(long ssrcPacketSender, long ssrcMediaSource,

			int FMT, int[] PID, int[] BLP) {

		super.packetType = 205; // RTPFB

		super.itemCount = FMT;

		this.PID = PID;

		this.BLP = BLP;

	}

	/**

	 * 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 RtcpPktRTPFB(byte[] aRawPkt, int start, RTPSession rtpSession) {

		if (RTPSession.rtpDebugLevel > 8) {

			System.out.println("  -> RtcpPktRTPFB(byte[], int start)");

		}

		rawPkt = aRawPkt;

		if (!super.parseHeaders(start) || packetType != 205 || super.length < 2) {

			if (RTPSession.rtpDebugLevel > 2) {

				System.out

						.println(" <-> RtcpPktRTPFB.parseHeaders() etc. problem");

			}

			super.problem = -205;

		} else {

			// FMT = super.itemCount;

			ssrcMediaSource = StaticProcs.bytesToUIntLong(aRawPkt, 8 + start);

			if (ssrcMediaSource == rtpSession.ssrc) {

				super.ssrc = StaticProcs.bytesToUIntLong(aRawPkt, 4 + start);

				int loopStop = super.length - 2;

				PID = new int[loopStop];

				BLP = new int[loopStop];

				int curStart = 12;

				// Loop over Feedback Control Information (FCI) fields

				for (int i = 0; i < loopStop; i++) {

					PID[i] = StaticProcs.bytesToUIntInt(aRawPkt, curStart);

					BLP[i] = StaticProcs.bytesToUIntInt(aRawPkt, curStart + 2);

					curStart += 4;

				}

				rtpSession.rtcpAVPFIntf.RTPFBPktReceived(super.ssrc,

						super.itemCount, PID, BLP);

			}

		}

		if (RTPSession.rtpDebugLevel > 8) {

			System.out.println("  <- RtcpPktRTPFB()");

		}

	}

	/**

	 * Encode the packet into a byte[], saved in .rawPkt

	 * 

	 * CompRtcpPkt will call this automatically

	 */

	protected void encode() {

		super.rawPkt = new byte[12 + this.PID.length * 4];

		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);

		// Loop over Feedback Control Information (FCI) fields

		int curStart = 12;

		for (int i = 0; i < this.PID.length; i++) {

			someBytes = StaticProcs.uIntIntToByteWord(PID[i]);

			super.rawPkt[curStart++] = someBytes[0];

			super.rawPkt[curStart++] = someBytes[1];

			someBytes = StaticProcs.uIntIntToByteWord(BLP[i]);

			super.rawPkt[curStart++] = someBytes[0];

			super.rawPkt[curStart++] = someBytes[1];

		}

		writeHeaders();

	}

	/**

	 * Get the FMT (Feedback Message Type)

	 * 

	 * @return value stored in .itemcount, same field

	 */

	protected int getFMT() {

		return this.itemCount;

	}

	/**

	 * Debug purposes only

	 */

	protected void debugPrint() {

		System.out.println("->RtcpPktRTPFB.debugPrint() ");

		System.out.println("  ssrcPacketSender: " + super.ssrc

				+ "  ssrcMediaSource: " + ssrcMediaSource);

		if (this.PID != null && this.PID.length < 1) {

			System.out

					.println("  No Feedback Control Information (FCI) fields");

		}

		for (int i = 0; i < this.PID.length; i++) {

			System.out.println("  FCI -> PID: " + PID[i] + "  BLP: " + BLP[i]);

		}

		System.out.println("<-RtcpPktRTPFB.debugPrint() ");

	}

}