Examples of readVarLong()

Examples of com.peterhi.obsolete.Stream.readVarLong()

1752
1753
1754
1755
1756
1757
1758
1759
1760
1761
1762
    try {
      Stream stream = new Stream();
      stream.writeBit(1);
      stream.writeBit(1);
      stream.write(1);
      stream.readVarLong();
      fail();
    } catch (InsufficientBufferException ex) {
    } finally {
    }
  }
View Full Code Here

Examples of com.peterhi.obsolete.Stream.readVarLong()

1698
1699
1700
1701
1702
1703
1704
1705
1706
1707
1708
            continue;
          }
        }
       
        if (nwi.isNormal()) {
          assertEquals(nwi.getNumber().longValue(), stream.readVarLong());
        } else {
          BigInteger flow = BigInteger.valueOf(2).pow(nwi.getBits());
          BigInteger left = nwi.getNumber();
          BigInteger right = BigInteger.valueOf(stream.readVarLong());
         
View Full Code Here

Examples of com.peterhi.obsolete.Stream.readVarLong()

1702
1703
1704
1705
1706
1707
1708
1709
1710
1711
1712
        if (nwi.isNormal()) {
          assertEquals(nwi.getNumber().longValue(), stream.readVarLong());
        } else {
          BigInteger flow = BigInteger.valueOf(2).pow(nwi.getBits());
          BigInteger left = nwi.getNumber();
          BigInteger right = BigInteger.valueOf(stream.readVarLong());
         
          if (nwi.isOverflow()) {
            left = left.subtract(flow);
          } else {
            left = left.add(flow);
View Full Code Here

Examples of com.peterhi.obsolete.Stream.readVarLong()

1723
1724
1725
1726
1727
1728
1729
1730
1731
1732
1733
 
  @Test
  public void fReadVarLong_void() throws Exception {
    try {
      Stream stream = new Stream();
      stream.readVarLong();
      fail();
    } catch (EOFException ex) {
    } finally {
    }
   
View Full Code Here

Examples of com.peterhi.obsolete.Stream.readVarLong()

1732
1733
1734
1735
1736
1737
1738
1739
1740
1741
1742
    }
   
    try {
      Stream stream = new Stream();
      stream.writeBit(1);
      stream.readVarLong();
      fail();
    } catch (InsufficientBufferException ex) {
    } finally {
    }
   
View Full Code Here

Examples of com.peterhi.obsolete.Stream.readVarLong()

1741
1742
1743
1744
1745
1746
1747
1748
1749
1750
1751
    }
   
    try {
      Stream stream = new Stream();
      stream.writeBit(2);
      stream.readVarLong();
      fail();
    } catch (InsufficientBufferException ex) {
    } finally {
    }
   
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayInputStream.readVarLong()

130
131
132
133
134
135
136
137
138
139
140
    protected void onCommand(TransportPool pool, Object data) {
        try {
            DataByteArrayInputStream bais = new DataByteArrayInputStream( (Buffer) data);
            int size = bais.readInt();
            long correlation = bais.readVarLong();
            pool.onDone(correlation);
            ResponseFuture response = requests.remove(correlation);
            if( response!=null ) {
                response.set(bais);
            }
View Full Code Here

Examples of org.h2.store.DataReader.readVarLong()

686
687
688
689
690
691
692
693
694
695
696
                    }
                }
            } else if (x == PageLog.REMOVE) {
                int sessionId = in.readVarInt();
                setStorage(in.readVarInt());
                long key = in.readVarLong();
                writer.println("-- session " + sessionId +
                        " table " + storageId +
                        " - " + key);
                if (transactionLog) {
                    if (storageId == 0) {
View Full Code Here

Examples of org.h2.store.DataReader.readVarLong()

687
688
689
690
691
692
693
694
695
696
697
                    }
                }
            } else if (x == PageLog.REMOVE) {
                int sessionId = in.readVarInt();
                setStorage(in.readVarInt());
                long key = in.readVarLong();
                writer.println("-- session " + sessionId +
                        " table " + storageId +
                        " - " + key);
                if (transactionLog) {
                    if (storageId == 0) {
View Full Code Here

Examples of org.h2.store.DataReader.readVarLong()

627
628
629
630
631
632
633
634
635
636
637
                        " table " + storageId +
                        " add " + row.toString());
            } else if (x == PageLog.REMOVE) {
                int sessionId = in.readVarInt();
                setStorage(in.readVarInt());
                long key = in.readVarLong();
                writer.println("-- session " + sessionId +
                        " table " + storageId +
                        " remove " + key);
            } else if (x == PageLog.TRUNCATE) {
                int sessionId = in.readVarInt();
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.