Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source.
   * Copyright 2014 Red Hat, Inc., and individual contributors
   * as indicated by the @author tags.
   *
   * 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 io.undertow.server.protocol.spdy;
 
 import org.xnio.Pool;
 
Open listener for SPDY server

Author(s):
David M. Lloyd
 
 public final class SpdyOpenListener implements ChannelListener<StreamConnection>, DelegateOpenListener {
 
     public static final String SPDY_3_1 = "spdy/3.1";
 
     private final Pool<ByteBufferbufferPool;
     private final Pool<ByteBufferheapBufferPool;
     private final int bufferSize;
 
     private volatile HttpHandler rootHandler;
 
     private volatile OptionMap undertowOptions;
 
     public SpdyOpenListener(final Pool<ByteBufferpoolfinal Pool<ByteBufferheapBufferPool) {
         this(poolheapBufferPool.);
     }
 
     public SpdyOpenListener(final Pool<ByteBufferpoolfinal Pool<ByteBufferheapBufferPoolfinal OptionMap undertowOptions) {
         this. = undertowOptions;
         this. = pool;
         Pooled<ByteBufferbuf = pool.allocate();
         this. = buf.getResource().remaining();
         buf.free();
         this. = heapBufferPool;
         Pooled<ByteBufferbuff = heapBufferPool.allocate();
         try {
             if (!buff.getResource().hasArray()) {
                 throw ..mustProvideHeapBuffer();
             }
         } finally {
             buff.free();
         }
     }
 
     @Override
     public void handleEvent(StreamConnection channel) {
         handleEvent(channelnull);
     }
 
     public void handleEvent(final StreamConnection channelPooled<ByteBufferbuffer) {
 
         //cool, we have a spdy connection.
         SpdyChannel spdyChannel = new SpdyChannel(channelbufferfalse);
         Integer idleTimeout = .get(.);
         if (idleTimeout != null && idleTimeout > 0) {
             spdyChannel.setIdleTimeout(idleTimeout);
         }
 
         spdyChannel.resumeReceives();
     }
 
     @Override
     public HttpHandler getRootHandler() {
         return ;
     }
 
     @Override
     public void setRootHandler(final HttpHandler rootHandler) {
         this. = rootHandler;
     }
    @Override
    public OptionMap getUndertowOptions() {
        return ;
    }
    @Override
    public void setUndertowOptions(final OptionMap undertowOptions) {
        if (undertowOptions == null) {
            throw ..argumentCannotBeNull("undertowOptions");
        }
        this. = undertowOptions;
    }
    @Override
    public Pool<ByteBuffergetBufferPool() {
        return ;
    }
New to GrepCode? Check out our FAQ X