package com.beem.project.beem.jingle;

import java.io.IOException;

import java.net.DatagramSocket;

import java.net.ServerSocket;

import org.jlibrtp.jlibrtp.DataFrame;

import org.jlibrtp.jlibrtp.Participant;

import org.jlibrtp.jlibrtp.RTPAppIntf;

import org.jlibrtp.jlibrtp.RTPSession;

public class RTPReceiver implements Runnable, RTPAppIntf {

    public RTPReceiver(int rtpPort) {

	DatagramSocket rtpSocket = null;

	try {

	    rtpSocket = new DatagramSocket(rtpPort);

	    return;

	}

	mRtpSession = new RTPSession(rtpSocket, null);

	mRtpSession.naivePktReception(true);

	mRtpSession.RTPSessionRegister(this, null, null);

    }

    @Override

    public int frameSize(int payloadType) {

	return 1;

    }

    protected int getFreePort() {

	ServerSocket ss;

	int freePort = 0;

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

	    freePort = (int) (10000 + Math.round(Math.random() * 10000));

	    try {

		ss = new ServerSocket(freePort);

		freePort = ss.getLocalPort();

		ss.close();

		return freePort;

	    } catch (IOException e) {

		e.printStackTrace();

	    }

	}

	try {

	    ss = new ServerSocket(0);

	    freePort = ss.getLocalPort();

	    ss.close();

	} catch (IOException e) {

	    e.printStackTrace();

	}

	return freePort;

    }

    @Override

    public void receiveData(DataFrame frame, Participant participant) {

	// byte[] data = frame.getConcatenatedData();

    }

    @Override

    public void run() {

	start();

    }

    private void start() {

	while (!mKillme) {

	    try {

		Thread.sleep(1000);

	    }

	}

	try {

	    Thread.sleep(200);

	}

	this.mRtpSession.endSession();

    }

    public void stop() {

	this.mKillme = true;

    }

    @Override

    public void userEvent(int arg0, Participant[] arg1) {

	// TODO Auto-generated method stub

    }

}