/* * TCPConnectionListener.java * * Created on November 19, 2003, 10:38 AM */package gov.nist.applet.phone.media.protocol.transport;import java.net.ServerSocket;import java.net.Socket;/** * This class is a thread waiting for connection on this TCP port and ip address * As soon as it gets a connection it notifies the Adapter for RTP. * @author  DERUELLE Jean */public class TCPConnectionListener implements Runnable {    private ServerSocket serverSocket;    private Socket socket;    //private TCPReceiveAdapter adapter;    private Thread listener;    private boolean ctrl;    private boolean connected;        /** Creates a new instance of TCPConnectionListener.     * @param serverSocket - ServerSocket that will be waiting for connection.     * @param adapter - the TCP Adapter for RTP we have to notify that we get a new connection.     * @param ctrl - boolean to know if it's RTP connection (false) or a RTCP connection (true).     */    public TCPConnectionListener(ServerSocket serverSocket, boolean ctrl) {        this.serverSocket=serverSocket;        //this.adapter=adapter;        this.ctrl=ctrl;        connected=false;    }        /**     * Start the listener thread.     */    public void start(){        if(listener==null){			listener=new Thread(this);			listener.setName("TCPConnectionListener Thread");        }                    listener.start();    }        /**     * Task of the listener thread.     */    public void run() {        try{            socket=serverSocket.accept();             System.out.println("Socket from "+ socket.getInetAddress() +                                " connected to the port "+socket.getLocalPort()+                                " control : "+ctrl);            //adapter.setRemoteSocket(socket,ctrl);            connected=true;            listener=null;        }        catch(java.io.IOException ioe){            ioe.printStackTrace();        }    }        /**     * Tells if this listener for TCP Connection has received a connection     * @return the socket when the listener has received a new connection     */    public Socket waitForConnections(){        while(!connected){            try{                Thread.sleep(1);            }            catch(InterruptedException ie){                ie.printStackTrace();            }        }        return socket;    }}