List of resetWriterIndex() Examples

Examples of resetWriterIndex()

org.hornetq.api.core.HornetQBuffer.resetWriterIndex()
Repositions the current {@code writerIndex} to the marked{@code writerIndex} in this buffer. @throws IndexOutOfBoundsException if the current {@code readerIndex} is greater than the marked{@code writerIndex}
org.jboss.netty.buffer.ChannelBuffer.resetWriterIndex()
Repositions the current {@code writerIndex} to the marked{@code writerIndex} in this buffer. @throws IndexOutOfBoundsException if the current {@code readerIndex} is greater than the marked{@code writerIndex}

Examples of org.hornetq.api.core.HornetQBuffer.resetWriterIndex()


            byte[] data = new byte[(int)sizeBody];
            inflater.inflate(data);
            inflater.end();
            qbuff.resetReaderIndex();
            qbuff.resetWriterIndex();
            qbuff.writeBytes(data);
         }


         frame = connection.createStompMessage(newServerMessage, subscription, deliveryCount);

View Full Code Here

Examples of org.hornetq.api.core.HornetQBuffer.resetWriterIndex()


            byte[] data = new byte[(int) sizeBody];
            inflater.inflate(data);
            inflater.end();
            qbuff.resetReaderIndex();
            qbuff.resetWriterIndex();
            qbuff.writeBytes(data);
         }


         frame = connection.createStompMessage(newServerMessage, subscription, deliveryCount);

View Full Code Here

Examples of org.hornetq.api.core.HornetQBuffer.resetWriterIndex()


            byte[] data = new byte[(int)sizeBody];
            inflater.inflate(data);
            inflater.end();
            qbuff.resetReaderIndex();
            qbuff.resetWriterIndex();
            qbuff.writeBytes(data);
         }


         frame = connection.createStompMessage(newServerMessage, subscription, deliveryCount);

View Full Code Here

Examples of org.hornetq.api.core.HornetQBuffer.resetWriterIndex()


            byte[] data = new byte[(int)sizeBody];
            inflater.inflate(data);
            inflater.end();
            qbuff.resetReaderIndex();
            qbuff.resetWriterIndex();
            qbuff.writeBytes(data);
         }


         frame = connection.createStompMessage(newServerMessage, subscription, deliveryCount);

View Full Code Here

Examples of org.hornetq.api.core.HornetQBuffer.resetWriterIndex()


            byte[] data = new byte[(int)sizeBody];
            inflater.inflate(data);
            inflater.end();
            qbuff.resetReaderIndex();
            qbuff.resetWriterIndex();
            qbuff.writeBytes(data);
         }


         frame = connection.createStompMessage(newServerMessage, subscription, deliveryCount);

View Full Code Here

Examples of org.hornetq.api.core.HornetQBuffer.resetWriterIndex()


            byte[] data = new byte[(int)sizeBody];
            inflater.inflate(data);
            inflater.end();
            qbuff.resetReaderIndex();
            qbuff.resetWriterIndex();
            qbuff.writeBytes(data);
         }


         frame = connection.createStompMessage(newServerMessage, subscription, deliveryCount);

View Full Code Here

Examples of org.hornetq.api.core.HornetQBuffer.resetWriterIndex()


            byte[] data = new byte[(int) sizeBody];
            inflater.inflate(data);
            inflater.end();
            qbuff.resetReaderIndex();
            qbuff.resetWriterIndex();
            qbuff.writeBytes(data);
         }


         frame = connection.createStompMessage(newServerMessage, subscription, deliveryCount);

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBuffer.resetWriterIndex()


        long ledger = getValidLedgerId(servers);
        for(long entry = 0; entry < warmUpCount; entry++) {
            ChannelBuffer toSend = ChannelBuffers.buffer(size);
            toSend.resetReaderIndex();
            toSend.resetWriterIndex();
            toSend.writeLong(ledger);
            toSend.writeLong(entry);
            toSend.writerIndex(toSend.capacity());
            bc.addEntry(new InetSocketAddress(addr, port), ledger, new byte[20],
                        entry, toSend, tc, null, BookieProtocol.FLAG_NONE);

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBuffer.resetWriterIndex()

        int entryCount = 5000;
        long startTime = System.nanoTime();
        for(long entry = 0; entry < entryCount; entry++) {
            ChannelBuffer toSend = ChannelBuffers.buffer(size);
            toSend.resetReaderIndex();
            toSend.resetWriterIndex();
            toSend.writeLong(ledger);
            toSend.writeLong(entry);
            toSend.writerIndex(toSend.capacity());
            lc.resetComplete();
            bc.addEntry(new InetSocketAddress(addr, port), ledger, new byte[20],

View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBuffer.resetWriterIndex()

        startTime = System.currentTimeMillis();
        tc = new ThroughputCallback();
        for(long entry = 0; entry < entryCount; entry++) {
            ChannelBuffer toSend = ChannelBuffers.buffer(size);
            toSend.resetReaderIndex();
            toSend.resetWriterIndex();
            toSend.writeLong(ledger);
            toSend.writeLong(entry);
            toSend.writerIndex(toSend.capacity());
            bc.addEntry(new InetSocketAddress(addr, port), ledger, new byte[20],
                        entry, toSend, tc, null, BookieProtocol.FLAG_NONE);

View Full Code Here

0 1

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.