/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */
/*
 * Copyright (c) 2001 by Sun Microsystems, Inc.
 * All rights reserved.
 *
 */

//  StreamListener.java: Listen to stream socket, spawn request to
//			  handle incoming request.
//  Author:           James Kempf
//  Created On:       Mon May 18 13:31:40 1998
//  Last Modified By: James Kempf
//  Last Modified On: Tue Jan 12 11:03:30 1999
//  Update Count:     24
//

package com.sun.slp;

import java.util.*;
import java.net.*;
import java.io.*;

/**
 * Listen on the SLP port for clients requesting a stream connection. Spawn
 * a request handler to handle the connection.
 *
 * @author James Kempf, Erik Guttman
 */

class StreamListener extends Thread {

    private ServerSocket serverSocket = null;		// The listening socket
    private InetAddress interfac = null;		// The interface.

    static private SLPConfig config   = null;		// Config object
    static private Hashtable listeners = new Hashtable(); // Stream listeners

    // Initialize a stream (TCP) listener on an interface.

    static void initializeStreamListenerOnInterface(InetAddress interfac)
	throws ServiceLocationException {

	// If we've got it, return.

	if (listeners.get(interfac) != null) {
	    return;

	}

	// Get config object.

	if (config == null) {
	    config = SLPConfig.getSLPConfig();

	}

	// Create the new stream listener.

	StreamListener listener = new StreamListener(interfac);

	// Start it running.

	listener.start();

    }

    private StreamListener(InetAddress interfac)
	throws ServiceLocationException {

	int qn = config.getServerSocketQueueLength();

	// Create a server socket for incoming Stream connections.

	try {
	    serverSocket = new ServerSocket(Defaults.iSLPPort,
					    qn,
					    interfac);

	} catch (IOException ex) {
	    throw new ServiceLocationException(
				ServiceLocationException.NETWORK_INIT_FAILED,
				"socket_creation_failure",
				new Object[] {interfac, ex.getMessage()});
	}

	// Record.

	listeners.put(interfac, this);

	this.interfac = interfac;

    }

    // Listen to port 427, accept incoming connections, pass the socket
    //  off to a new RequestHandler to process.

    public void run() {

	setName("SLP Stream Listener");

	long lLastIOE = 0;

	// Loop, blocking on acceptence of connections.

	while (true) {

	    Socket s = null;

	    try {
		s = serverSocket.accept(); // will block here

		if (config.traceMsg() && s != null) {
		    config.writeLog("sl_incoming",
				    new Object[] {
			s.getInetAddress().toString(),
			    interfac});
		}

		// Set socket timeout in case something goes wrong.

		if (s != null) {
		    s.setSoTimeout(config.getTCPTimeout());

		}

	    } catch (SocketException ex) {
		if (config.traceMsg()) {
		    config.writeLog("sl_sock_timeout",
				    new Object[] {
			s.getInetAddress().toString(),
			    interfac,
			    ex.getMessage()});

		}

		continue;

	    } catch (IOException ex) {
		long lThisIOE = System.currentTimeMillis();

		Assert.slpassert((lThisIOE - lLastIOE >= 250),
			      "sls_repeat_failure",
			      new Object[0]);

		lLastIOE = lThisIOE;
		continue;
	    }

	    RequestHandler rh = new RequestHandler(s, interfac, config);
	    rh.start();

	}
    }
}