Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
   * Copyright (c) 1997-2010 Oracle and/or its affiliates. All rights reserved.
   * The contents of this file are subject to the terms of either the GNU
   * General Public License Version 2 only ("GPL") or the Common Development
   * and Distribution License("CDDL") (collectively, the "License").  You
   * may not use this file except in compliance with the License.  You can
  * obtain a copy of the License at
  * or packager/legal/LICENSE.txt.  See the License for the specific
  * language governing permissions and limitations under the License.
  * When distributing the software, include this License Header Notice in each
  * file and include the License file at packager/legal/LICENSE.txt.
  * GPL Classpath Exception:
  * Oracle designates this particular file as subject to the "Classpath"
  * exception as provided by Oracle in the GPL Version 2 section of the License
  * file that accompanied this code.
  * Modifications:
  * If applicable, add the following below the License Header, with the fields
  * enclosed by brackets [] replaced by your own identifying information:
  * "Portions Copyright [year] [name of copyright owner]"
  * Contributor(s):
  * If you wish your version of this file to be governed by only the CDDL or
  * only the GPL Version 2, indicate your decision by adding "[Contributor]
  * elects to include this software in this distribution under the [CDDL or GPL
  * Version 2] license."  If you don't indicate a single choice of license, a
  * recipient has the option to distribute your version of this file under
  * either the CDDL, the GPL Version 2 or to extend the choice of license to
  * its licensees as provided above.  However, if you add GPL Version 2 code
  * and therefore, elected the GPL Version 2 license, then the option applies
  * only if the new code is made subject to such option by the copyright
  * holder.
 package com.sun.enterprise.web.connector.grizzly.algorithms;
Base class for StreamAlgorithm implementation.

Jeanfrancois Arcand
 public abstract class StreamAlgorithmBase implements StreamAlgorithm{
Is Grizzly embedded in GlassFish.
     protected static boolean embeddedInGlassFish = false;
     // Temporary hack to find if Grizzly is enbedded in GlassFish or not.
                 (Class.forName("org.apache.coyote.tomcat5.Constants") != null);
         } catch(Exception ex){
             ; //Swallow
     private int port = 8080;
Manipulate the bytes stream and determine if the process can continue.

true if the algorithm determines the process can continue.
     public abstract boolean parse(ByteBuffer byteBuffer);
The actual length of the stream we are able to read.
     protected int contentLength = -1;
The ByteBuffer current limit value
     protected int curLimit = -1;
The ByteBuffer current position value
    protected int curPosition = -1;
The position, within the ByteBuffer, when the HTTP headers are completely reads.
    protected int headerLength = -1;
In case we were'nt able to parse the request line, we will continue parsing from that position.
    protected int lastStatePosition = -1;    
If the stream wasn't read fully, keep the state of the http parsing.
    protected int state = 0;
If a new ByteBuffer is created because the stream is too small, cache the original byteBuffer and reuse it once the transaction has completed.
    protected ByteBuffer primaryByteBuffer = null;
If true, use a ByteBuffer view instead of ByteBuffer
    protected boolean useByteBufferView = false;
Are we using direct ByteBuffer
    protected boolean useDirectByteBuffer;
The SocketChannel associated with this algorithm.
    protected SocketChannel socketChannel;
An Handler implementation used to implement a static resources cache.
    protected Handler handler;
    public StreamAlgorithmBase() {
         = new DummyHandler();
    // ------------------------------------------------------- Methods ------//
Return the stream content-length. If the content-length wasn't parsed, return -1.
    public int contentLength(){
        return ;
Return the stream header length. The header length is the length between the start of the stream and the first occurance of character '\r\n' .
    public int headerLength(){
        return ;
Before parsing the bytes, initialize and prepare the algorithm.

byteBuffer the ByteBuffer used by this algorithm
ByteBuffer used by this algorithm
    public ByteBuffer preParse(ByteBuffer byteBuffer){
        if (byteBuffer.position() == byteBuffer.capacity()){
            // Add space at the end for \n\r
            int bufferSize =  > 0 ?
                                     +  + 5: 
                                    byteBuffer.capacity() * 2;
            byteBuffer = swapBuffer(byteBuffer,bufferSize);
        return byteBuffer;
After parsing the bytes, post process the ByteBuffer

byteBuffer the ByteBuffer used by this algorithm
ByteBuffer used by this algorithm
    public ByteBuffer postParse(ByteBuffer byteBuffer){
        // Swap buffer to its original size.
        if (  != null) {
            byteBuffer = ;
             = null;
        return byteBuffer;

Reset this object to its default state.
    public void recycle(){
         = -1;
        = -1;
         = -1; 
         = -1;
         = -1;
         = 0;
    // --------------------------------------------------- Utils --------------/
Allocate a ByteBuffer

useDirectByteBuffer to create a direct ByteBuffer
useByteBufferView to create ByteBuffer view
size the size of the ByteBuffer
a ByteBuffer
    public ByteBuffer allocate(boolean useDirectByteBuffer
                               boolean useByteBufferView
                               int size){
        ByteBuffer byteBuffer;
        if (useByteBufferView){
            byteBuffer = ByteBufferFactory.allocateView(size,
        } else if ( useDirectByteBuffer ){
            byteBuffer = ByteBuffer.allocateDirect(size);            
        } else {
            byteBuffer = ByteBuffer.allocate(size);                       
        return byteBuffer;
Allocate a new ByteBuffer and put the content of the current one into it.
    private ByteBuffer swapBuffer(ByteBuffer byteBufferint size){
        // Keep a pointer to the original one.
        if (  == null) {
             = byteBuffer;
        byteBuffer = tmp;
        return byteBuffer;
Rollback the ByteBuffer to its previous state in case an error as occured.
    public ByteBuffer rollbackParseState(ByteBuffer byteBuffer){
Set the ByteBuffer position/limit to the value they were before trying to process the stream.
        if ( != -1 &&  != -1){
            // Reset so we can process a new request.
             = -1;
             = -1;  
        return byteBuffer;
Dump the ByteBuffer content. This is used only for debugging purpose.
    protected String dump(ByteBuffer byteBuffer){                   
        ByteBuffer dd = byteBuffer.duplicate();
        int length = dd.limit();
        byte[] dump = new byte[length];
        return(new String(dump) + "\n----------------------------" + dd 
        + "\ncontentLength: " +  
        + "\nheaderLength: " + ); 
The SocketChannel used by this class.
    public void setSocketChannel(SocketChannel socketChannel){
        this. = socketChannel;
        if ( socketChannel != null)
Set the port
    public void setPort(int port){
        this. = port;
Return the port
    public int getPort(){
        return ;
Return the full name of the class responsible for handling OP_READ.
    public Class getReadTask(SelectorThread selectorThread){
        if ( selectorThread.getMaxReadWorkerThreads() <= 0 
                && !selectorThread.getEnableAsyncExecution())
            return com.sun.enterprise.web.connector.grizzly.DefaultReadTask.class;
            return com.sun.enterprise.web.connector.grizzly.AsyncReadTask.class;            
Empty handler used when Grizzly is bundled outside of GlassFish.

Jeanfrancois Arcand
    public static class DummyHandler implements Handler{
        public DummyHandler() {
        public int handle(Object eint handlerCodethrows IOException {
            return .;
        public void attachChannel(SocketChannel sc){
            ; // Not used.
New to GrepCode? Check out our FAQ X