Examples of rewind()

Examples of java.nio.ByteBuffer.rewind()

402
403
404
405
406
407
408
409
410
411
412
      ByteBuffer buf = getByteBuffer(nio_segment_size);

      int index = 0;
      while (index < src.length)
      {
        buf.rewind();
        int remaining = src.length - index;
        int size = Math.min(nio_segment_size, remaining);
        if (size != buf.capacity())
        {
          // System.out.println("reallocating segment_size: " +
View Full Code Here

Examples of java.nio.ByteBuffer.rewind()

408
409
410
411
412
413
414
415
416
417
418
              actualBuffer.position(2);
              actualBuffer = actualBuffer.slice();
            }

            ByteBuffer expectedBuffer = encodedBlocks.get(blockId);
            expectedBuffer.rewind();

            // test if content matches, produce nice message
            assertBuffersEqual(expectedBuffer, actualBuffer, algo, encoding,
                pread);
          }
View Full Code Here

Examples of java.nio.ByteBuffer.rewind()

432
433
434
435
436
437
438
439
440
441
442
    final int rawBlockSize = writeTestKeyValues(doubleOutputStream,
        blockId, includesMemstoreTS);

    ByteBuffer rawBuf = ByteBuffer.wrap(baos.toByteArray());
    rawBuf.rewind();

    final int encodedSize;
    final ByteBuffer encodedBuf;
    if (encoding == DataBlockEncoding.NONE) {
      encodedSize = rawBlockSize;
View Full Code Here

Examples of java.nio.ByteBuffer.rewind()

313
314
315
316
317
318
319
320
321
322
323
              actualBuffer.position(2);
              actualBuffer = actualBuffer.slice();
            }

            ByteBuffer expectedBuffer = encodedBlocks.get(blockId);
            expectedBuffer.rewind();

            // test if content matches, produce nice message
            TestHFileBlock.assertBuffersEqual(expectedBuffer, actualBuffer, algo, encoding,
                pread);
          }
View Full Code Here

Examples of java.nio.ByteBuffer.rewind()

99
100
101
102
103
104
105
106
107
108
109
        this.delimiter = delimiter;

        // Convert delimiter to ByteBuffer if not done yet.
        if (delimBuf == null) {
            ByteBuffer tmp = charset.encode(CharBuffer.wrap(delimiter.getValue()));
            tmp.rewind();
            delimBuf = tmp;
        }
    }

    /**
 
View Full Code Here

Examples of java.nio.ByteBuffer.rewind()

58
59
60
61
62
63
64
65
66
67
        for (T object : getObjects()) {
            int size = encoder.getEncodedSize(object);
            ByteBuffer out = ByteBuffer.allocate(size);
            encoder.writeTo(object, out);           
            assertEquals(size, out.position());
            out.rewind();
            assertEquals(object, decoder.decode(IoBuffer.wrap(out)));
        }
    }
}
View Full Code Here

Examples of java.nio.ByteBuffer.rewind()

39
40
41
42
43
44
45
46
47
48
49
    public void verifyThatHeaderWithoutLeadingSpaceIsSupported() throws UnsupportedEncodingException,
            ProtocolDecoderException {
        String reqStr = "GET / HTTP/1.0\r\nHost:localhost\r\n\r\n";
        ByteBuffer buffer = ByteBuffer.allocate(reqStr.length());
        buffer.put(reqStr.getBytes("US-ASCII"));
        buffer.rewind();
        HttpServerDecoder decoder = new HttpServerDecoder();
        HttpDecoderState state = decoder.createDecoderState();
        HttpPdu pdus = decoder.decode(buffer, state);
        assertNotNull(pdus);
View Full Code Here

Examples of java.nio.ByteBuffer.rewind()

54
55
56
57
58
59
60
61
62
63
64
    public void verifyThatLeadingSpacesAreRemovedFromHeader() throws UnsupportedEncodingException,
            ProtocolDecoderException {
        String reqStr = "GET / HTTP/1.0\r\nHost:  localhost\r\n\r\n";
        ByteBuffer buffer = ByteBuffer.allocate(reqStr.length());
        buffer.put(reqStr.getBytes("US-ASCII"));
        buffer.rewind();
        HttpServerDecoder decoder = new HttpServerDecoder();
        HttpDecoderState state = decoder.createDecoderState();
        HttpPdu pdus = decoder.decode(buffer, state);
        assertNotNull(pdus);
        assertEquals("localhost", ((HttpRequestImpl) pdus).getHeader("host"));
View Full Code Here

Examples of java.nio.ByteBuffer.rewind()

68
69
70
71
72
73
74
75
76
77
78
    public void verifyThatTrailingSpacesAreRemovedFromHeader() throws UnsupportedEncodingException,
            ProtocolDecoderException {
        String reqStr = "GET / HTTP/1.0\r\nHost:localhost  \r\n\r\n";
        ByteBuffer buffer = ByteBuffer.allocate(reqStr.length());
        buffer.put(reqStr.getBytes("US-ASCII"));
        buffer.rewind();
        HttpServerDecoder decoder = new HttpServerDecoder();
        HttpDecoderState state = decoder.createDecoderState();
        HttpPdu pdus = decoder.decode(buffer, state);
        assertNotNull(pdus);
        assertEquals("localhost", ((HttpRequestImpl) pdus).getHeader("host"));
View Full Code Here

Examples of java.nio.ByteBuffer.rewind()

1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
          inMemory);
      bucketEntry.setDeserialiserReference(data.getDeserializer(), deserialiserMap);
      try {
        if (data instanceof HFileBlock) {
          ByteBuffer sliceBuf = ((HFileBlock) data).getBufferReadOnlyWithHeader();
          sliceBuf.rewind();
          assert len == sliceBuf.limit() + HFileBlock.EXTRA_SERIALIZATION_SPACE;
          ByteBuffer extraInfoBuffer = ByteBuffer.allocate(HFileBlock.EXTRA_SERIALIZATION_SPACE);
          ((HFileBlock) data).serializeExtraInfo(extraInfoBuffer);
          ioEngine.write(sliceBuf, offset);
          ioEngine.write(extraInfoBuffer, offset + len - HFileBlock.EXTRA_SERIALIZATION_SPACE);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.