Mercurial Hosting > luan
comparison src/org/eclipse/jetty/server/Connector.java @ 1046:a8c92b0a08ed
add JBuffer
| author | Franklin Schmidt <fschmidt@gmail.com> | 
|---|---|
| date | Mon, 07 Nov 2016 22:39:39 -0700 | 
| parents | 8c13b9224cff | 
| children | 1accf965d51a | 
   comparison
  equal
  deleted
  inserted
  replaced
| 1045:48506d03e230 | 1046:a8c92b0a08ed | 
|---|---|
| 28 | 28 | 
| 29 import javax.servlet.ServletRequest; | 29 import javax.servlet.ServletRequest; | 
| 30 | 30 | 
| 31 import org.eclipse.jetty.io.Buffer; | 31 import org.eclipse.jetty.io.Buffer; | 
| 32 import org.eclipse.jetty.io.Buffers; | 32 import org.eclipse.jetty.io.Buffers; | 
| 33 import org.eclipse.jetty.io.BufferUtil; | |
| 33 import org.eclipse.jetty.io.EndPoint; | 34 import org.eclipse.jetty.io.EndPoint; | 
| 34 import org.eclipse.jetty.io.EofException; | 35 import org.eclipse.jetty.io.EofException; | 
| 35 import org.eclipse.jetty.io.nio.DirectNIOBuffer; | 36 import org.eclipse.jetty.io.nio.DirectNIOBuffer; | 
| 36 import org.eclipse.jetty.io.nio.IndirectNIOBuffer; | 37 import org.eclipse.jetty.io.nio.IndirectNIOBuffer; | 
| 37 import org.eclipse.jetty.util.component.AggregateLifeCycle; | 38 import org.eclipse.jetty.util.component.AggregateLifeCycle; | 
| 251 | 252 | 
| 252 | 253 | 
| 253 // my own buffers | 254 // my own buffers | 
| 254 | 255 | 
| 255 protected Buffer newBuffer(int size) { | 256 protected Buffer newBuffer(int size) { | 
| 256 return new DirectNIOBuffer(size); | 257 // return new DirectNIOBuffer(size); | 
| 258 return BufferUtil.newDirectBuffer(size); | |
| 257 } | 259 } | 
| 258 | 260 | 
| 259 private class MyBuffers implements Buffers { | 261 private class MyBuffers implements Buffers { | 
| 260 private final int headerSize; | 262 private final int headerSize; | 
| 261 private final int bufferSize; | 263 private final int bufferSize; | 
| 265 this.bufferSize = bufferSize; | 267 this.bufferSize = bufferSize; | 
| 266 } | 268 } | 
| 267 | 269 | 
| 268 @Override | 270 @Override | 
| 269 public Buffer getHeader() { | 271 public Buffer getHeader() { | 
| 270 return new IndirectNIOBuffer(headerSize); | 272 // return new IndirectNIOBuffer(headerSize); | 
| 273 return BufferUtil.newBuffer(headerSize); | |
| 271 } | 274 } | 
| 272 | 275 | 
| 273 @Override | 276 @Override | 
| 274 public Buffer getBuffer() { | 277 public Buffer getBuffer() { | 
| 275 return newBuffer(bufferSize); | 278 return newBuffer(bufferSize); | 
