httpprotocolfilter.java

是离开的肌肤了卡机是离开的就富利卡及是了的开发及拉考试及的福利科技阿斯利康的肌肤莱卡及时的离开福建阿斯顿发

//========================================================================
// Parts Copyright 2006 Mort Bay Consulting Pty. Ltd.
//------------------------------------------------------------------------
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
// http://www.apache.org/licenses/LICENSE-2.0
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//========================================================================

package org.mortbay.jetty.grizzly;

import com.sun.grizzly.Context;
import com.sun.grizzly.Controller;
import com.sun.grizzly.ProtocolFilter;
import com.sun.grizzly.SelectorHandler;
import com.sun.grizzly.util.WorkerThread;
import java.io.EOFException;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.SocketChannel;
import java.util.logging.Level;
import org.mortbay.io.nio.NIOBuffer;
import org.mortbay.jetty.Handler;
import org.mortbay.jetty.HttpConnection;
import org.mortbay.jetty.HttpParser;

/**
 * Delegate the processing of the request to a <code>GrizzlyEndPoint</code>
 *
 * @author Jeanfrancois Arcand
 */
public class HttpProtocolFilter implements ProtocolFilter
{
    private Handler handler;
    
    private boolean keepAlive=true;
    private GrizzlyEndPoint endPoint;
    private GrizzlySocketChannel _channel = new GrizzlySocketChannel();
    private HttpParser parser;
    boolean isError = false;
    
    
    public HttpProtocolFilter()
    {
    }
    
    
    /**
     * Read available bytes and delegate the processing of them to the next
     * ProtocolFilter in the ProtocolChain.
     * @return <tt>true</tt> if the next ProtocolFilter on the ProtocolChain
     *                       need to bve invoked.
     */
    public boolean execute(Context ctx) throws IOException
    {
        ctx.getSelectionKey().attach(null);
        
        isError = false;
        _channel.setSelectionKey(ctx.getSelectionKey());
        _channel.setSocketChannel((SocketChannel)ctx.getSelectionKey().channel());
        endPoint.setChannel(_channel);
        ByteBuffer bb = ((WorkerThread)Thread.currentThread()).getByteBuffer();

        try
        {
            int nRead = 1;
            while (nRead > 0)
            {
                endPoint.handle();
                if (endPoint.isComplete())
                {
                    break;
                }
                else
                {
                    nRead = endPoint.fill(parser.getHeaderBuffer());
                }
            }
        }
        catch(Throwable t)
        {
            isError = true;
            Controller.logger().log(Level.FINE,"endPoint.handler",t);
            return false;
        }
        finally
        {
            if (isError)
            {
                endPoint.getHttpConnection().reset(true);
            }
            parser.reset(true);
            _channel.setSelectionKey(null);
            endPoint.setChannel(null);
        }
        bb.clear();
        if (parser.getBodyBuffer() != null) {
            ByteBuffer bodyBuffer = ((NIOBuffer)parser.getBodyBuffer()).getByteBuffer();
            if (bodyBuffer != null){
                bodyBuffer.clear();
                Thread.currentThread().dumpStack();
            }
        }
                    
        ctx.getSelectionKey().attach(null);
        return true;
    }
    
    /**
     * If no bytes were available, close the connection by cancelling the
     * SelectionKey. If bytes were available, register the SelectionKey
     * for new bytes.
     *
     * @return <tt>true</tt> if the previous ProtocolFilter postExecute method
     *         needs to be invoked.
     */
    public boolean postExecute(Context ctx) throws IOException
    {
        final SelectorHandler selectorHandler =
                ctx.getSelectorHandler();
        final SelectionKey key = ctx.getSelectionKey();
        
        if (!isError && endPoint.keepAlive())
        {
            ctx.setKeyRegistrationState(Context.KeyRegistrationState.REGISTER);
        }
        else
        {
            ctx.setKeyRegistrationState(Context.KeyRegistrationState.CANCEL);
        }
        return true;
    }
    
    public GrizzlyEndPoint getEndPoint()
    {
        return endPoint;
    }
    
    public void setEndPoint(GrizzlyEndPoint endPoint)
    {
        this.endPoint = endPoint;
    }
    
    public HttpParser getParser()
    {
        return parser;
    }
    
    public void setParser(HttpParser parser)
    {
        this.parser = parser;
    }
    
}