Examples of DirectNIOBuffer

org.eclipse.jetty.io.nio.DirectNIOBuffer
org.mortbay.io.nio.DirectNIOBuffer
@author gregw

Examples of org.eclipse.jetty.io.nio.DirectNIOBuffer

    protected Buffer getDirectBuffer(Resource resource)
    {
        try
        {
            if (_useFileMappedBuffer && resource.getFile()!=null) 
                return new DirectNIOBuffer(resource.getFile());


            int len=(int)resource.length();
            if (len<0)
            {
                LOG.warn("invalid resource: "+String.valueOf(resource)+" "+len);
                return null;
            }
            Buffer buffer = new DirectNIOBuffer(len);
            InputStream is = resource.getInputStream();
            buffer.readFrom(is,len);
            is.close();
            return buffer;
        }
        catch(IOException e)
        {

View Full Code Here

Examples of org.eclipse.jetty.io.nio.DirectNIOBuffer

                try
                {
                    final ByteBuffer byteBuffer = (ByteBuffer)value;
                    synchronized (byteBuffer)
                    {
                        NIOBuffer buffer = byteBuffer.isDirect()?new DirectNIOBuffer(byteBuffer,true):new IndirectNIOBuffer(byteBuffer,true);
                        ((AbstractHttpConnection.Output)getServletResponse().getOutputStream()).sendResponse(buffer);
                    }
                }
                catch (IOException e)
                {

View Full Code Here

Examples of org.eclipse.jetty.io.nio.DirectNIOBuffer


      /* ------------------------------------------------------------------------------- */
      @Override
      public Buffer newRequestBuffer(int size)
      {
          return _useDirectBuffers?new DirectNIOBuffer(size):new IndirectNIOBuffer(size);
      }

View Full Code Here

Examples of org.eclipse.jetty.io.nio.DirectNIOBuffer


      /* ------------------------------------------------------------------------------- */
      @Override
      public Buffer newResponseBuffer(int size)
      {
          return _useDirectBuffers?new DirectNIOBuffer(size):new IndirectNIOBuffer(size);
      }

View Full Code Here

Examples of org.mortbay.io.nio.DirectNIOBuffer

        else if (size==_packetBufferSize)
        {   
            buffer = _packetBuffers.poll();
            if (buffer==null)
                buffer=getUseDirectBuffers()
                    ?(NIOBuffer)new DirectNIOBuffer(size)
                    :(NIOBuffer)new IndirectNIOBuffer(size);
        }
        else 
            buffer=super.getBuffer(size);

View Full Code Here

Examples of org.mortbay.io.nio.DirectNIOBuffer

        else if (size==_packetBufferSize)
        {   
            buffer = _packetBuffers.poll();
            if (buffer==null)
                buffer=getUseDirectBuffers()
                    ?(NIOBuffer)new DirectNIOBuffer(size)
                    :(NIOBuffer)new IndirectNIOBuffer(size);
        }
        else 
            buffer=super.getBuffer(size);

View Full Code Here

Examples of org.mortbay.io.nio.DirectNIOBuffer

            Resource resource=content.getResource();
            long length=resource.length();


            if (_useFileMappedBuffer && resource.getFile()!=null) 
            {    
                buffer = new DirectNIOBuffer(resource.getFile());
            } 
            else 
            {
                InputStream is = resource.getInputStream();
                try
                {
                    Connector connector = HttpConnection.getCurrentConnection().getConnector();
                    buffer = ((NIOConnector)connector).getUseDirectBuffers()?
                            (NIOBuffer)new DirectNIOBuffer((int)length):
                            (NIOBuffer)new IndirectNIOBuffer((int)length);
                                
                }
                catch(OutOfMemoryError e)
                {

View Full Code Here

Examples of org.mortbay.io.nio.DirectNIOBuffer

        {
            Buffer buf=null;
            if (size==getHeaderBufferSize())
                buf=new IndirectNIOBuffer(size);
            else if (_useDirectBuffers)
                buf=new DirectNIOBuffer(size);
            else
                buf=new IndirectNIOBuffer(size);
            return buf;
        }
        else

View Full Code Here

Examples of org.mortbay.io.nio.DirectNIOBuffer

    {   
        int size =32;
        ContentExchange httpExchange=new ContentExchange();


        Buffer babuf = new ByteArrayBuffer(size*36*1024);
        Buffer niobuf = new DirectNIOBuffer(size*36*1024);


        byte[] bytes="0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ".getBytes();


        for (int i=0;i<size*1024;i++)
        {
            babuf.put(bytes);
            niobuf.put(bytes);
        }
        
        httpExchange.setURL(_scheme+"localhost:"+_port+"/");
        httpExchange.setMethod(HttpMethods.POST);
        httpExchange.setRequestContentType("application/data");
        httpExchange.setRequestContent(babuf);
        
        _httpClient.send(httpExchange);
        int status = httpExchange.waitForDone();
        String result=httpExchange.getResponseContent();
        assertEquals(babuf.length(),result.length());
        assertEquals(HttpExchange.STATUS_COMPLETED, status);


        httpExchange.reset();
        httpExchange.setURL(_scheme+"localhost:"+_port+"/");
        httpExchange.setMethod(HttpMethods.POST);
        httpExchange.setRequestContentType("application/data");
        httpExchange.setRequestContent(niobuf);
        _httpClient.send(httpExchange);
        status = httpExchange.waitForDone();
        result=httpExchange.getResponseContent();
        assertEquals(niobuf.length(),result.length());
        assertEquals(HttpExchange.STATUS_COMPLETED, status);
    }

View Full Code Here

Examples of org.mortbay.io.nio.DirectNIOBuffer

        {
            Buffer buf=null;
            if (size==getHeaderBufferSize())
                buf=new IndirectNIOBuffer(size);
            else if (_useDirectBuffers)
                buf=new DirectNIOBuffer(size);
            else
                buf=new IndirectNIOBuffer(size);
            return buf;
        }
        else

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.