Examples of SessionInputBufferImpl

org.apache.http.impl.io.SessionInputBufferImpl
Abstract base class for session input buffers that stream data from an arbitrary {@link InputStream}. This class buffers input data in an internal byte array for optimal input performance.
{@link #readLine(CharArrayBuffer)} and {@link #readLine()} methods of thisclass treat a lone LF as valid line delimiters in addition to CR-LF required by the HTTP specification. @since 4.3
org.apache.http.impl.nio.reactor.SessionInputBufferImpl

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

    public void testDecodingFromSessionBuffer1() throws Exception {
        ReadableByteChannel channel = new ReadableByteChannelMockup(
                new String[] {"stuff;", "more stuff"}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params);
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();


        inbuf.fill(channel);
        
        assertEquals(6, inbuf.length());
        
        LengthDelimitedDecoder decoder = new LengthDelimitedDecoder(
                channel, inbuf, metrics, 16); 
        
        ByteBuffer dst = ByteBuffer.allocate(1024);

View Full Code Here

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

                new String[] {
                        "stuff;", 
                        "more stuff; and a lot more stuff"}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params);
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();


        inbuf.fill(channel);
        inbuf.fill(channel);
        
        assertEquals(38, inbuf.length());
        
        LengthDelimitedDecoder decoder = new LengthDelimitedDecoder(
                channel, inbuf, metrics, 16); 
        
        ByteBuffer dst = ByteBuffer.allocate(1024);

View Full Code Here

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

    public void testBasicDecodingFile() throws Exception {
        ReadableByteChannel channel = new ReadableByteChannelMockup(
                new String[] {"stuff; ", "more stuff; ", "a lot more stuff!!!"}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params); 
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();
        LengthDelimitedDecoder decoder = new LengthDelimitedDecoder(
                channel, inbuf, metrics, 36); 
        
        File fileHandle = File.createTempFile("testFile", ".txt");

View Full Code Here

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

    public void testDecodingFileWithBufferedSessionData() throws Exception {
        ReadableByteChannel channel = new ReadableByteChannelMockup(
                new String[] {"stuff; ", "more stuff; ", "a lot more stuff!!!"}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params); 
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();
        LengthDelimitedDecoder decoder = new LengthDelimitedDecoder(
                channel, inbuf, metrics, 36); 
        
        int i = inbuf.fill(channel);
        assertEquals(7, i);
        
        File fileHandle = File.createTempFile("testFile", ".txt");


        RandomAccessFile testfile = new RandomAccessFile(fileHandle, "rw");

View Full Code Here

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

                new String[] {
                        "stuff;", 
                        "more stuff; and a lot more stuff"}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params); 
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();
        LengthDelimitedDecoder decoder = new LengthDelimitedDecoder(
                channel, inbuf, metrics, 16); 
        
        File fileHandle = File.createTempFile("testFile", ".txt");

View Full Code Here

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

    public void testInvalidConstructor() {
        ReadableByteChannel channel = new ReadableByteChannelMockup(
                new String[] {"stuff;", "more stuff"}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params); 
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();
        try {
            new LengthDelimitedDecoder(null, null, null, 10);
            fail("IllegalArgumentException should have been thrown");
        } catch (IllegalArgumentException ex) {

View Full Code Here

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

        String s = "stuff";
        ReadableByteChannel channel = new ReadableByteChannelMockup(
                new String[] {s}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
    
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params); 
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();
        LengthDelimitedDecoder decoder = new LengthDelimitedDecoder(
                channel, inbuf, metrics, 3);
        
        try {

View Full Code Here

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

        int linebuffersize = buffersize;
        if (linebuffersize > 512) {
            linebuffersize = 512;
        }


        this.inbuf = new SessionInputBufferImpl(buffersize, linebuffersize, allocator, params);
        this.outbuf = new SessionOutputBufferImpl(buffersize, linebuffersize, allocator, params);


        this.incomingContentStrategy = new LaxContentLengthStrategy();
        this.outgoingContentStrategy = new StrictContentLengthStrategy();

View Full Code Here

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

    public void testBasicDecoding() throws Exception {
        ReadableByteChannel channel = new ReadableByteChannelMockup(
                new String[] {"stuff;", "more stuff"}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params); 
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();
        LengthDelimitedDecoder decoder = new LengthDelimitedDecoder(
                channel, inbuf, metrics, 16); 
        
        ByteBuffer dst = ByteBuffer.allocate(1024);

View Full Code Here

Examples of org.apache.http.impl.nio.reactor.SessionInputBufferImpl

                new String[] {
                        "stuff;", 
                        "more stuff; and a lot more stuff"}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params); 
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();
        LengthDelimitedDecoder decoder = new LengthDelimitedDecoder(
                channel, inbuf, metrics, 16); 
        
        ByteBuffer dst = ByteBuffer.allocate(1024);

View Full Code Here

0 1 2 3 4 5

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.