Examples of ChannelBufferInputStream

com.alibaba.dubbo.remoting.buffer.ChannelBufferInputStream
@author kimi
com.facebook.presto.jdbc.internal.netty.buffer.ChannelBufferInputStream
An {@link InputStream} which reads data from a {@link ChannelBuffer}.
A read operation against this stream will occur at the {@code readerIndex}of its underlying buffer and the {@code readerIndex} will increase duringthe read operation.
This stream implements {@link DataInput} for your convenience.The endianness of the stream is not always big endian but depends on the endianness of the underlying buffer. @see ChannelBufferOutputStream @apiviz.uses com.facebook.presto.jdbc.internal.netty.buffer.ChannelBuffer
io.netty.buffer.ChannelBufferInputStream
net.gleamynode.netty.buffer.ChannelBufferInputStream
@author The Netty Project (netty@googlegroups.com) @author Trustin Lee (trustin@gmail.com) @version $Rev: 552 $, $Date: 2008-07-14 15:55:31 +0900 (Mon, 14 Jul 2008) $ @see ChannelBufferOutputStream @apiviz.uses net.gleamynode.netty.buffer.ChannelBuffer
org.jboss.netty.buffer.ChannelBufferInputStream
{@link InputStream} which reads data from a {@link ChannelBuffer}.
A read operation against this stream will occur at the {@code readerIndex}of its underlying buffer and the {@code readerIndex} will increase duringthe read operation.
This stream implements {@link DataInput} for your convenience.The endianness of the stream is not always big endian but depends on the endianness of the underlying buffer. @author The Netty Project (netty-dev@lists.jboss.org) @author Trustin Lee (tlee@redhat.com) @version $Rev: 145 $, $Date: 2008-08-27 16:17:41 +0900 (Wed, 27 Aug 2008) $ @see ChannelBufferOutputStream @apiviz.uses org.jboss.netty.buffer.ChannelBuffer

Examples of org.jboss.netty.buffer.ChannelBufferInputStream

     */
    ChannelBufferInputStream verifyDigestAndReturnData(long entryId, ChannelBuffer dataReceived)
            throws BKDigestMatchException {
        verifyDigest(entryId, dataReceived);
        dataReceived.readerIndex(METADATA_LENGTH + macCodeLength);
        return new ChannelBufferInputStream(dataReceived);
    }

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream

        if (rc != BKException.Code.OK) {
            logErrorAndReattemptRead(entry, "Error: " + BKException.getMessage(rc), rc);
            return;
        }


        ChannelBufferInputStream is;
        try {
            is = lh.macManager.verifyDigestAndReturnData(entryId, buffer);
        } catch (BKDigestMatchException e) {
            logErrorAndReattemptRead(entry, "Mac mismatch", BKException.Code.DigestMatchException);
            return;

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream

    }


    @Override
    protected Object decode(
            ChannelHandlerContext ctx, Channel channel, ChannelBuffer buffer, CompatibleObjectDecoderState state) throws Exception {
        bin.switchStream(new ChannelBufferInputStream(buffer));


        switch (state) {
        case READ_HEADER:
            oin = newObjectInputStream(bin);
            checkpoint(CompatibleObjectDecoderState.READ_OBJECT);

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream

            return null;
        }


        buffer.skipBytes(4);
        return new CompactObjectInputStream(
                new ChannelBufferInputStream(buffer, dataLen), classLoader).readObject();
    }

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream


    ChannelBufferInputStream verifyDigestAndReturnData(long entryId, ChannelBuffer dataReceived)
            throws BKDigestMatchException {
        verifyDigest(entryId, dataReceived);
        dataReceived.readerIndex(24 + macCodeLength);
        return new ChannelBufferInputStream(dataReceived);
    }

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream

            }


        }


        private void copyContentToTmpFile(ChannelBuffer content) throws IOException, FileNotFoundException {
            ChannelBufferInputStream cbis = new ChannelBufferInputStream(content);
            ByteStreams.copy(cbis, fos);
        }

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream

            logErrorAndReattemptRead(entry, "Error: " + BKException.getMessage(rc), rc);
            return;
        }
        
        numPendingReads--;
        ChannelBufferInputStream is;
        try {
            is = lh.macManager.verifyDigestAndReturnData(entryId, buffer);
        } catch (BKDigestMatchException e) {
            logErrorAndReattemptRead(entry, "Mac mismatch", BKException.Code.DigestMatchException);
            return;

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream

    }


    @Override
    protected Object decode(
            ChannelHandlerContext ctx, Channel channel, ChannelBuffer buffer, CompatibleObjectDecoderState state) throws Exception {
        bin.switchStream(new ChannelBufferInputStream(buffer));


        switch (state) {
        case READ_HEADER:
            oin = newObjectInputStream(bin);
            checkpoint(CompatibleObjectDecoderState.READ_OBJECT);

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream


                        Nabaztag nabaztag = checkNotNull(nabaztagDAO.findOne("macAddress", mac));


                        ChannelBuffer content = request.request.getContent();
                        logger.debug("record orig size: {}", content.readableBytes());
                        ChannelBufferInputStream inputStream = new ChannelBufferInputStream(content);


                        TmpData sound = new TmpData();
                        sound.setData(ByteStreams.toByteArray(inputStream));
                        tmpDataDAO.save(sound, WriteConcern.SAFE);

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream

 * Date: 12/7/11
 */
public class DataUtil {
    
    public static ChannelBuffer compress(ChannelBuffer in) throws IOException {
        ChannelBufferInputStream channelBufferInputStream = new ChannelBufferInputStream(in);
        ChannelBuffer out = ChannelBuffers.dynamicBuffer(in.readableBytes());
        ChannelBufferOutputStream channelBufferOutputStream = new ChannelBufferOutputStream(out);


        compress(ByteStreams.toByteArray(channelBufferInputStream), channelBufferOutputStream);
        return out;

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.