1 // ======================================================================== 2 // Copyright (c) 2004-2009 Mort Bay Consulting Pty. Ltd. 3 // ------------------------------------------------------------------------ 4 // All rights reserved. This program and the accompanying materials 5 // are made available under the terms of the Eclipse Public License v1.0 6 // and Apache License v2.0 which accompanies this distribution. 7 // The Eclipse Public License is available at 8 // http://www.eclipse.org/legal/epl-v10.html 9 // The Apache License v2.0 is available at 10 // http://www.opensource.org/licenses/apache2.0.php 11 // You may elect to redistribute this code under either of these licenses. 12 // ======================================================================== 13 14 /** 15 * 16 */ 17 package org.eclipse.jetty.server.nio; 18 19 import org.eclipse.jetty.io.Buffer; 20 import org.eclipse.jetty.io.ByteArrayBuffer; 21 import org.eclipse.jetty.io.nio.DirectNIOBuffer; 22 import org.eclipse.jetty.io.nio.IndirectNIOBuffer; 23 import org.eclipse.jetty.io.nio.NIOBuffer; 24 import org.eclipse.jetty.server.AbstractConnector; 25 26 /* ------------------------------------------------------------ */ 27 /** 28 * 29 * 30 */ 31 public abstract class AbstractNIOConnector extends AbstractConnector implements NIOConnector 32 { 33 private boolean _useDirectBuffers=true; 34 35 /* ------------------------------------------------------------------------------- */ 36 public boolean getUseDirectBuffers() 37 { 38 return _useDirectBuffers; 39 } 40 41 /* ------------------------------------------------------------------------------- */ 42 /** 43 * @param direct If True (the default), the connector can use NIO direct buffers. 44 * Some JVMs have memory management issues (bugs) with direct buffers. 45 */ 46 public void setUseDirectBuffers(boolean direct) 47 { 48 _useDirectBuffers=direct; 49 } 50 51 /* ------------------------------------------------------------------------------- */ 52 public Buffer newRequestBuffer(int size) 53 { 54 return _useDirectBuffers?new DirectNIOBuffer(size):new IndirectNIOBuffer(size); 55 } 56 57 /* ------------------------------------------------------------------------------- */ 58 public Buffer newRequestHeader(int size) 59 { 60 return new IndirectNIOBuffer(size); 61 } 62 63 /* ------------------------------------------------------------------------------- */ 64 public Buffer newResponseBuffer(int size) 65 { 66 return _useDirectBuffers?new DirectNIOBuffer(size):new IndirectNIOBuffer(size); 67 } 68 69 /* ------------------------------------------------------------------------------- */ 70 public Buffer newResponseHeader(int size) 71 { 72 return new IndirectNIOBuffer(size); 73 } 74 75 /* ------------------------------------------------------------------------------- */ 76 protected boolean isRequestHeader(Buffer buffer) 77 { 78 return buffer instanceof IndirectNIOBuffer; 79 } 80 81 /* ------------------------------------------------------------------------------- */ 82 protected boolean isResponseHeader(Buffer buffer) 83 { 84 return buffer instanceof IndirectNIOBuffer; 85 } 86 }