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.nio.DirectNIOBuffer; 21 import org.eclipse.jetty.io.nio.IndirectNIOBuffer; 22 import org.eclipse.jetty.server.AbstractConnector; 23 24 /* ------------------------------------------------------------ */ 25 /** 26 * 27 * 28 */ 29 public abstract class AbstractNIOConnector extends AbstractConnector implements NIOConnector 30 { 31 private boolean _useDirectBuffers=true; 32 33 /* ------------------------------------------------------------------------------- */ 34 public boolean getUseDirectBuffers() 35 { 36 return _useDirectBuffers; 37 } 38 39 /* ------------------------------------------------------------------------------- */ 40 /** 41 * @param direct If True (the default), the connector can use NIO direct buffers. 42 * Some JVMs have memory management issues (bugs) with direct buffers. 43 */ 44 public void setUseDirectBuffers(boolean direct) 45 { 46 _useDirectBuffers=direct; 47 } 48 49 /* ------------------------------------------------------------------------------- */ 50 @Override 51 public Buffer newRequestBuffer(int size) 52 { 53 return _useDirectBuffers?new DirectNIOBuffer(size):new IndirectNIOBuffer(size); 54 } 55 56 /* ------------------------------------------------------------------------------- */ 57 @Override 58 public Buffer newRequestHeader(int size) 59 { 60 return new IndirectNIOBuffer(size); 61 } 62 63 /* ------------------------------------------------------------------------------- */ 64 @Override 65 public Buffer newResponseBuffer(int size) 66 { 67 return _useDirectBuffers?new DirectNIOBuffer(size):new IndirectNIOBuffer(size); 68 } 69 70 /* ------------------------------------------------------------------------------- */ 71 @Override 72 public Buffer newResponseHeader(int size) 73 { 74 return new IndirectNIOBuffer(size); 75 } 76 77 /* ------------------------------------------------------------------------------- */ 78 @Override 79 protected boolean isRequestHeader(Buffer buffer) 80 { 81 return buffer instanceof IndirectNIOBuffer; 82 } 83 84 /* ------------------------------------------------------------------------------- */ 85 @Override 86 protected boolean isResponseHeader(Buffer buffer) 87 { 88 return buffer instanceof IndirectNIOBuffer; 89 } 90 }