nio/server/AcceptHandler.java

	AcceptHandler.java revision 0
286N/A/*
286N/A * Copyright 2004 Sun Microsystems, Inc.  All Rights Reserved.
286N/A *
286N/A * Redistribution and use in source and binary forms, with or without
286N/A * modification, are permitted provided that the following conditions
286N/A * are met:
286N/A *
286N/A *   - Redistributions of source code must retain the above copyright
286N/A *     notice, this list of conditions and the following disclaimer.
286N/A *
286N/A *   - Redistributions in binary form must reproduce the above copyright
286N/A *     notice, this list of conditions and the following disclaimer in the
286N/A *     documentation and/or other materials provided with the distribution.
286N/A *
286N/A *   - Neither the name of Sun Microsystems nor the names of its
286N/A *     contributors may be used to endorse or promote products derived
286N/A *     from this software without specific prior written permission.
286N/A *
286N/A * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS
286N/A * IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
286N/A * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
286N/A * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE COPYRIGHT OWNER OR
286N/A * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
286N/A * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
286N/A * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
286N/A * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
286N/A * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
286N/A * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
286N/A * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
286N/A */
286N/A
286N/Aimport java.io.*;
286N/Aimport java.nio.channels.*;
286N/Aimport javax.net.ssl.*;
286N/A
286N/A/**
286N/A * A single threaded Handler that performs accepts SocketChannels and
286N/A * registers the Channels with the read/write Selector.
286N/A *
286N/A * @author Mark Reinhold
286N/A * @author Brad R. Wetmore
286N/A */
286N/Aclass AcceptHandler implements Handler {
286N/A
286N/A    private ServerSocketChannel channel;
286N/A    private Dispatcher dsp;
286N/A
286N/A    private SSLContext sslContext;
286N/A
286N/A    AcceptHandler(ServerSocketChannel ssc, Dispatcher dsp,
286N/A            SSLContext sslContext) {
286N/A        channel = ssc;
286N/A        this.dsp = dsp;
286N/A        this.sslContext = sslContext;
286N/A    }
286N/A
286N/A    public void handle(SelectionKey sk) throws IOException {
286N/A
        if (!sk.isAcceptable())
            return;

        SocketChannel sc = channel.accept();
        if (sc == null) {
            return;
        }

        ChannelIO cio = (sslContext != null ?
            ChannelIOSecure.getInstance(
                sc, false /* non-blocking */, sslContext) :
            ChannelIO.getInstance(
                sc, false /* non-blocking */));

        RequestHandler rh = new RequestHandler(cio);
        dsp.register(cio.getSocketChannel(), SelectionKey.OP_READ, rh);
    }
}