Examples of SessionInputBuffer

org.apache.http.impl.nio.reactor.SessionInputBuffer
org.apache.http.io.SessionInputBuffer
Session input buffer for blocking connections. @author Oleg Kalnichevski @version $Revision: 560528 $ @since 4.0
org.apache.http.nio.impl.reactor.SessionInputBuffer
org.apache.http.nio.reactor.SessionInputBuffer
Session input buffer for non-blocking connections. @author Oleg Kalnichevski @since 4.0

Examples of org.apache.http.io.SessionInputBuffer

        assertNotNull(entity.getContentType());
        assertEquals("stuff", entity.getContentType().getValue());
    }


    public void testEntityContentEncoding() throws Exception {
        SessionInputBuffer datareceiver = new SessionInputBufferMockup(new byte[] {'0'});
        HttpMessage message = new HttpMessageMockup();


        message.addHeader("Content-Encoding", "what not");
        EntityDeserializer entitygen = new EntityDeserializer(
                new LaxContentLengthStrategy());

View Full Code Here

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

        int linebuffersize = buffersize;
        if (linebuffersize > 512) {
            linebuffersize = 512;
        }
        
        this.inbuf = new SessionInputBuffer(buffersize, linebuffersize); 
        this.inbuf.reset(params);
        this.outbuf = new SessionOutputBuffer(buffersize, linebuffersize); 
        this.outbuf.reset(params);
        this.lineBuffer = new CharArrayBuffer(64);

View Full Code Here

Examples of org.apache.http.nio.reactor.SessionInputBuffer

    }


    public void testReadLineChunks() throws Exception {
        
        HttpParams params = new BasicHttpParams();
        SessionInputBuffer inbuf = new SessionInputBufferImpl(16, 16, params);
        
        ReadableByteChannel channel = newChannel("One\r\nTwo\r\nThree");
        
        inbuf.fill(channel);
        
        CharArrayBuffer line = new CharArrayBuffer(64);
        
        line.clear();
        assertTrue(inbuf.readLine(line, false));
        assertEquals("One", line.toString());
        
        line.clear();
        assertTrue(inbuf.readLine(line, false));
        assertEquals("Two", line.toString());


        line.clear();
        assertFalse(inbuf.readLine(line, false));


        channel = newChannel("\r\nFour");
        inbuf.fill(channel);
        
        line.clear();
        assertTrue(inbuf.readLine(line, false));
        assertEquals("Three", line.toString());


        inbuf.fill(channel);
        
        line.clear();
        assertTrue(inbuf.readLine(line, true));
        assertEquals("Four", line.toString());


        line.clear();
        assertFalse(inbuf.readLine(line, true));
    }

View Full Code Here

Examples of org.apache.http.nio.reactor.SessionInputBuffer

    
    public void testWriteLineChunks() throws Exception {
        
        HttpParams params = new BasicHttpParams();
        SessionOutputBuffer outbuf = new SessionOutputBufferImpl(16, 16, params);
        SessionInputBuffer inbuf = new SessionInputBufferImpl(16, 16, params);
        
        ReadableByteChannel inChannel = newChannel("One\r\nTwo\r\nThree");
        
        inbuf.fill(inChannel);
        
        CharArrayBuffer line = new CharArrayBuffer(64);
        
        line.clear();
        assertTrue(inbuf.readLine(line, false));
        assertEquals("One", line.toString());
        
        outbuf.writeLine(line);
        
        line.clear();
        assertTrue(inbuf.readLine(line, false));
        assertEquals("Two", line.toString());


        outbuf.writeLine(line);
        
        line.clear();
        assertFalse(inbuf.readLine(line, false));


        inChannel = newChannel("\r\nFour");
        inbuf.fill(inChannel);


        line.clear();
        assertTrue(inbuf.readLine(line, false));
        assertEquals("Three", line.toString());


        outbuf.writeLine(line);
        
        inbuf.fill(inChannel);
        
        line.clear();
        assertTrue(inbuf.readLine(line, true));
        assertEquals("Four", line.toString());


        outbuf.writeLine(line);
        
        line.clear();
        assertFalse(inbuf.readLine(line, true));


        ByteArrayOutputStream outstream = new ByteArrayOutputStream(); 
        WritableByteChannel outChannel = newChannel(outstream);
        outbuf.flush(outChannel);

View Full Code Here

Examples of org.apache.http.nio.reactor.SessionInputBuffer

        WritableByteChannel outChannel = newChannel(outstream);
        outbuf.flush(outChannel);


        ReadableByteChannel channel = newChannel(outstream.toByteArray());
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 16, params);
        inbuf.fill(channel);
        
        for (int i = 0; i < teststrs.length; i++) {
            assertEquals(teststrs[i], inbuf.readLine(true));
        }
        assertNull(inbuf.readLine(true));
        assertNull(inbuf.readLine(true));
    }

View Full Code Here

Examples of org.apache.http.nio.reactor.SessionInputBuffer

        WritableByteChannel outChannel = newChannel(outstream);
        outbuf.flush(outChannel);


        ReadableByteChannel channel = newChannel(outstream.toByteArray());


        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 16, params);
        inbuf.fill(channel);
        
        assertEquals("a", inbuf.readLine(true));
        assertEquals("", inbuf.readLine(true));
        assertEquals("\r", inbuf.readLine(true));
        assertEquals("", inbuf.readLine(true));
        assertEquals(s1, inbuf.readLine(true));
        assertEquals(s2, inbuf.readLine(true));
        assertEquals(s3, inbuf.readLine(true));
        assertEquals("a", inbuf.readLine(true));
        assertNull(inbuf.readLine(true));
        assertNull(inbuf.readLine(true));
    }

View Full Code Here

Examples of org.apache.http.nio.reactor.SessionInputBuffer

        for (int i = 0; i < out.length; i++) {
            out[i] = (byte)('0' + i);
        }
        ReadableByteChannel channel = newChannel(out);        
        HttpParams params = new BasicHttpParams();
        SessionInputBuffer inbuf = new SessionInputBufferImpl(16, 16, params);
        while (inbuf.fill(channel) > 0) {
        }


        byte[] in = new byte[40];
        for (int i = 0; i < in.length; i++) {
            in[i] = (byte)inbuf.read();
        }
        for (int i = 0; i < out.length; i++) {
            assertEquals(out[i], in[i]);
        }
    }

View Full Code Here

Examples of org.apache.http.nio.reactor.SessionInputBuffer

        outbuf.flush(outChannel);


        byte[] tmp = outstream.toByteArray();
        
        ReadableByteChannel channel = newChannel(tmp);        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(16, 16, params);
        
        while (inbuf.fill(channel) > 0) {
        }
        
        for (int i = 0; i < 10; i++) {
            assertEquals(s1, inbuf.readLine(true));
            assertEquals(s2, inbuf.readLine(true));
            assertEquals(s3, inbuf.readLine(true));
        }
    }

View Full Code Here

Examples of org.apache.http.nio.reactor.SessionInputBuffer

        } catch (CharacterCodingException expected) {
        }
        
        byte[] tmp = s1.getBytes("ISO-8859-1");        
        ReadableByteChannel channel = newChannel(tmp);        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(16, 16, params);
        while (inbuf.fill(channel) > 0) {
        }
        
        try {
            String s = inbuf.readLine(true);
            fail("Expected CharacterCodingException, got '" + s + "'");
        } catch (CharacterCodingException expected) {
        }            
    }

View Full Code Here

Examples of org.apache.http.nio.reactor.SessionInputBuffer

        String s = "5\r\n01234\r\n5\r\n56789\r\n6\r\nabcdef\r\n0\r\n\r\n";
        ReadableByteChannel channel = new ReadableByteChannelMockup(
                new String[] {s}, "US-ASCII"); 
        HttpParams params = new BasicHttpParams();
        
        SessionInputBuffer inbuf = new SessionInputBufferImpl(1024, 256, params);
        HttpTransportMetricsImpl metrics = new HttpTransportMetricsImpl();
        ChunkDecoder decoder = new ChunkDecoder(channel, inbuf, metrics);
        
        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.