/*

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

 *

 * This code is free software; you can redistribute it and/or modify it

 * under the terms of the GNU General Public License version 2 only, as

 * particular file as subject to the "Classpath" exception as provided

 *

 * This code 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 General Public License

 * version 2 for more details (a copy is included in the LICENSE file that

 * accompanied this code).

 *

 * You should have received a copy of the GNU General Public License version

 * 2 along with this work; if not, write to the Free Software Foundation,

 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

 *

 */

package com.sun.corba.se.impl.transport;

import java.io.IOException;

import com.sun.corba.se.pept.transport.Acceptor;

import com.sun.corba.se.pept.transport.ListenerThread;

import com.sun.corba.se.pept.transport.Selector;

import com.sun.corba.se.spi.orb.ORB;

import com.sun.corba.se.spi.orbutil.threadpool.Work;

import com.sun.corba.se.impl.orbutil.ORBUtility;

public class ListenerThreadImpl

    implements

        ListenerThread,

        Work

{

    private ORB orb;

    private Acceptor acceptor;

    private Selector selector;

    private boolean keepRunning;

    private long enqueueTime;

    public ListenerThreadImpl(ORB orb, Acceptor acceptor, Selector selector)

    {

        this.orb = orb;

        this.acceptor = acceptor;

        this.selector = selector;

        keepRunning = true;

    }

    ////////////////////////////////////////////////////

    //

    // ListenerThread methods.

    //

    public Acceptor getAcceptor()

    {

        return acceptor;

    }

    public void close()

    {

        if (orb.transportDebugFlag) {

            dprint(".close: " + acceptor);

        }

        keepRunning = false;

    }

    ////////////////////////////////////////////////////

    //

    // Work methods.

    //

    // REVISIT - this needs alot more from previous ListenerThread

    public void doWork()

    {

        try {

            if (orb.transportDebugFlag) {

                dprint(".doWork: Start ListenerThread: " + acceptor);

            }

            while (keepRunning) {

                try {

                    if (orb.transportDebugFlag) {

                        dprint(".doWork: BEFORE ACCEPT CYCLE: " + acceptor);

                    }

                    acceptor.accept();

                    if (orb.transportDebugFlag) {

                        dprint(".doWork: AFTER ACCEPT CYCLE: " + acceptor);

                    }

                } catch (Throwable t) {

                    if (orb.transportDebugFlag) {

                        dprint(".doWork: Exception in accept: " + acceptor,t);

                    }

                    orb.getTransportManager().getSelector(0)

                        .unregisterForEvent(getAcceptor().getEventHandler());

                    getAcceptor().close();

                }

            }

        } finally {

            if (orb.transportDebugFlag) {

                dprint(".doWork: Terminated ListenerThread: " + acceptor);

            }

        }

    }

    public void setEnqueueTime(long timeInMillis)

    {

        enqueueTime = timeInMillis;

    }

    public long getEnqueueTime()

    {

        return enqueueTime;

    }

    public String getName() { return "ListenerThread"; }

    ////////////////////////////////////////////////////

    //

    // Implementation.

    //

    private void dprint(String msg)

    {

        ORBUtility.dprint("ListenerThreadImpl", msg);

    }

    private void dprint(String msg, Throwable t)

    {

        dprint(msg);

        t.printStackTrace(System.out);

    }

}

// End of file.