List of bufferOffset() Examples

Examples of bufferOffset()

com.linkedin.databus.core.util.BufferPosition.bufferOffset()
@return the offset encoded in the contained position
com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()
Gets the index in the position. @param position encoded position @return the offset encoded in the position

Examples of com.linkedin.databus.core.util.BufferPosition.bufferOffset()

    Assert.assertEquals(0, headPos.bufferGenId());
    Assert.assertEquals(0, headPos.bufferIndex());
    Assert.assertEquals(9629, headPos.bufferOffset());
    Assert.assertEquals(1, tailPos.bufferGenId());
    Assert.assertEquals(0, tailPos.bufferIndex());
    Assert.assertEquals(9416, tailPos.bufferOffset());
    Assert.assertEquals(9984, dbusBuf.getBuffer()[0].limit());
    dbusBuf.getScnIndex().assertHeadPosition(dbusBuf.getHead());


    final BufferPosition lastWinStart = new BufferPosition(61 + 22 * 416,
                                                           dbusBuf.getBufferPositionParser(),

View Full Code Here

Examples of com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()


    headPos = dbusBuf.getHead();
    tailPos = dbusBuf.getTail();
    headGenId = parser.bufferGenId(headPos);
    headIndexId = parser.bufferIndex(headPos);
    headOffset = parser.bufferOffset(headPos);
    tailGenId = parser.bufferGenId(tailPos);
    tailIndexId = parser.bufferIndex(tailPos);
    tailOffset = parser.bufferOffset(tailPos);


    assertEquals(0, headGenId);

View Full Code Here

Examples of com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()

    headGenId = parser.bufferGenId(headPos);
    headIndexId = parser.bufferIndex(headPos);
    headOffset = parser.bufferOffset(headPos);
    tailGenId = parser.bufferGenId(tailPos);
    tailIndexId = parser.bufferIndex(tailPos);
    tailOffset = parser.bufferOffset(tailPos);


    assertEquals(0, headGenId);
    assertEquals(2, headIndexId);
    assertEquals(61, headOffset);
    assertEquals(1, tailIndexId);

View Full Code Here

Examples of com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()


    long headPos = dbusBuf.getHead();
    long tailPos = dbusBuf.getTail();
    long headGenId = parser.bufferGenId(headPos);
    long headIndexId = parser.bufferIndex(headPos);
    long headOffset = parser.bufferOffset(headPos);
    long tailGenId = parser.bufferGenId(tailPos);
    long tailIndexId = parser.bufferIndex(tailPos);
    long tailOffset = parser.bufferOffset(tailPos);


    // current writing position should be 222 (id=1)

View Full Code Here

Examples of com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()

    long headGenId = parser.bufferGenId(headPos);
    long headIndexId = parser.bufferIndex(headPos);
    long headOffset = parser.bufferOffset(headPos);
    long tailGenId = parser.bufferGenId(tailPos);
    long tailIndexId = parser.bufferIndex(tailPos);
    long tailOffset = parser.bufferOffset(tailPos);


    // current writing position should be 222 (id=1)
    assertEquals(0, headGenId);
    assertEquals(1, headIndexId);
    assertEquals(383, headOffset);

View Full Code Here

Examples of com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()


    headPos = dbusBuf.getHead();
    tailPos = dbusBuf.getTail();
    headGenId = parser.bufferGenId(headPos);
    headIndexId = parser.bufferIndex(headPos);
    headOffset = parser.bufferOffset(headPos);
    tailGenId = parser.bufferGenId(tailPos);
    tailIndexId = parser.bufferIndex(tailPos);
    tailOffset = parser.bufferOffset(tailPos);


    assertEquals(1, headGenId);

View Full Code Here

Examples of com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()

    headGenId = parser.bufferGenId(headPos);
    headIndexId = parser.bufferIndex(headPos);
    headOffset = parser.bufferOffset(headPos);
    tailGenId = parser.bufferGenId(tailPos);
    tailIndexId = parser.bufferIndex(tailPos);
    tailOffset = parser.bufferOffset(tailPos);


    assertEquals(1, headGenId);
    assertEquals(0, headIndexId);
    assertEquals(61, headOffset);
    assertEquals(2, tailIndexId);

View Full Code Here

Examples of com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()

      LOG.info("Buffer :" + Arrays.toString(dbusBuf.getBuffer()));
      headPos = dbusBuf.getHead();
      tailPos = dbusBuf.getTail();
      headGenId = parser.bufferGenId(headPos);
      headIndexId = parser.bufferIndex(headPos);
      headOffset = parser.bufferOffset(headPos);
      tailGenId = parser.bufferGenId(tailPos);
      tailIndexId = parser.bufferIndex(tailPos);
      tailOffset = parser.bufferOffset(tailPos);


      assertEquals("Head GenId", 1, headGenId);

View Full Code Here

Examples of com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()

      headGenId = parser.bufferGenId(headPos);
      headIndexId = parser.bufferIndex(headPos);
      headOffset = parser.bufferOffset(headPos);
      tailGenId = parser.bufferGenId(tailPos);
      tailIndexId = parser.bufferIndex(tailPos);
      tailOffset = parser.bufferOffset(tailPos);


      assertEquals("Head GenId", 1, headGenId);
      assertEquals("Head Index", 0, headIndexId);
      assertEquals("Head Offset", 583, headOffset);
      assertEquals("Tail GenId", 2, tailGenId);

View Full Code Here

Examples of com.linkedin.databus.core.util.BufferPositionParser.bufferOffset()

    long tailPos = dbusBuf.getTail();
    long scnIndexHead = dbusBuf.getScnIndex().getHead();
    long scnIndexTail = dbusBuf.getScnIndex().getTail();
    long headGenId = parser.bufferGenId(headPos);
    long headIndexId = parser.bufferIndex(headPos);
    long headOffset = parser.bufferOffset(headPos);
    long tailGenId = parser.bufferGenId(tailPos);
    long tailIndexId = parser.bufferIndex(tailPos);
    long tailOffset = parser.bufferOffset(tailPos);


    assertEquals("Head GenId", 0, headGenId);

View Full Code Here

0 1 2 3

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.