Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
   * Copyright 2007-2008 Sun Microsystems, Inc. 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 glassfish/bootstrap/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 glassfish/bootstrap/legal/LICENSE.txt.
  * Sun designates this particular file as subject to the "Classpath" exception
  * as provided by Sun in the GPL Version 2 section of the License file that
  * accompanied this code.  If applicable, add the following below the License
  * Header, with the fields enclosed by brackets [] replaced by your own
  * identifying information: "Portions Copyrighted [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.grizzly.aio.http;
SelectorThread implementation based on AIO. Documentation to comes.

Jean-Francois Arcand
 public class AsyncAcceptorThread extends SelectorThread {
    // -------------------------------------------------------------- Init // 
Init the ExecutorServices used by the com.sun.grizzly.util.WorkerThreads.
     public void initThreadPool(){
         .info("Swithching Grizzly Http Thread Pool to: " 
                 + com.sun.grizzly.aio.http.WorkerThreadFactory.class.getName());      
         StatsThreadPool statsThreadPool = new StatsThreadPool(){
             public synchronized void execute(Runnable runnable) {
             public void stop() {
Initialize the Grizzly Framework classes.
    protected void initController(){
        if ( == null){
             = new AIOController();
        // Set the logger of the utils package to the same as this class.       
        // Set the controller logger
        TCPAIOHandler aioHandler = new TCPAIOHandler();
        final DefaultProtocolChain protocolChain = new DefaultProtocolChain(){
            public void execute(Context ctxthrows Exception {
                if () {
                    ByteBuffer byteBuffer =
                    // Switch ByteBuffer
                    if (byteBuffer != null){
                    if (.size() != 0){
                        int currentPosition = super.executeProtocolFilter(ctx);
                } else {
        DefaultProtocolChainInstanceHandler instanceHandler 
                = new DefaultProtocolChainInstanceHandler(){        

Always return instance of ProtocolChain.
            public ProtocolChain poll(){
                return protocolChain;

Pool an instance of ProtocolChain.
            public boolean offer(ProtocolChain instance){
                return true;
Create AIOProcessorTask objects and configure it to be ready to proceed request.
    protected ProcessorTask newProcessorTask(boolean initialize){                                                      
        DefaultProcessorTask task = 
                new AIOProcessorTask(initialize);
        return configureProcessorTask(task);       

Initialize the com.sun.grizzly.http.FileCacheFactory associated with this instance
    protected void initFileCacheFactory(){
        if ( != nullreturn;
         = FileCacheFactory.getFactory(AIOFileCache.class);

Adds and configures com.sun.grizzly.ProtocolChain's filters

<code>com.sun.grizzly.ProtocolChain to configure
    protected void configureFilters(ProtocolChain protocolChain) {
        if ( != null) {
        } else {
            AIOReadFilter readFilter = new AIOReadFilter();

Create HTTP parser com.sun.grizzly.ProtocolFilter

HTTP parser com.sun.grizzly.ProtocolFilter
    protected ProtocolFilter createHttpParserFilter() {
        return new AIOHttpParser();
New to GrepCode? Check out our FAQ X