Examples of readInt()

Examples of org.jboss.netty.buffer.BigEndianHeapChannelBuffer.readInt()

60
61
62
63
64
65
66
67
68
69
70
        ChannelBuffer buf = (ChannelBuffer) encoder.encode(null, null, query);
        ChannelBuffer buf2 = new BigEndianHeapChannelBuffer(buf.readableBytes() + 8);
        buf2.writeInt(123);
        buf2.writeBytes(buf);

        buf2.readInt();
        ProtobufDecoder decoder = new ProtobufDecoder();
        decoder.addMessageType(Query.getDefaultInstance());
        Message message = (Message) decoder.decode(null, null, buf2);
        assertEquals(query, message);
    }
View Full Code Here

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

33
34
35
36
37
38
39
40
41
42
43
      if(Events.NETWORK_MESSAGE == event.getType())
      {
        ChannelBuffer apocalypse = (ChannelBuffer) event.getSource();
        if(apocalypse.readableBytes()>=4)
        {
          int cmd = apocalypse.readInt();
          ZombieCommands command = ZombieCommands.CommandsEnum.fromInt(cmd);
          if(command == ZombieCommands.APOCALYPSE)
          {
            System.out.println("Cancelling " + type +  " timer due to apocalypse");
            service.shutdown();
View Full Code Here

Examples of org.jboss.netty.buffer.ChannelBufferInputStream.readInt()

75
76
77
78
79
80
81
82
83
84
85
    ChannelBufferInputStream inputStream = new ChannelBufferInputStream(buffer);
    int senderId = -1;
    long requestId = -1;
    int response = -1;
    try {
      senderId = inputStream.readInt();
      requestId = inputStream.readLong();
      response = inputStream.readByte();
      inputStream.close();
    } catch (IOException e) {
      throw new IllegalStateException(
View Full Code Here

Examples of org.jboss.netty.buffer.DynamicChannelBuffer.readInt()

24
25
26
27
28
29
30
31
32
33
34
    int count = 5000000;
    for (int i = 0; i < count; i++) {

      buf.markReaderIndex();
      // read the size of the message
      buf.readInt();
      DefaultMessageTree result = (DefaultMessageTree) codec.decode(buf);
      buf.resetReaderIndex();
      result.setBuffer(buf);
    }
  }
View Full Code Here

Examples of org.jboss.soa.esb.message.body.content.BytesBody.readInt()

128
129
130
131
132
133
134
135
136
137
138
    mapMessage.flush();
   
    mapMessage.readMode();

    assertEquals(mapMessage.readInt(), 12345);
    assertEquals(mapMessage.readUTFString(), "hello world");
    assertEquals(mapMessage.readShort(), (short) 10);
    assertEquals(mapMessage.readBoolean(), true);
  }
}
View Full Code Here

Examples of org.jf.dexlib2.dexbacked.BaseDexBuffer.readInt()

253
254
255
256
257
258
259
260
    }


    public static int getEndian(byte[] buf, int offset) {
        BaseDexBuffer bdb = new BaseDexBuffer(buf);
        return bdb.readInt(offset + ENDIAN_TAG_OFFSET);
    }
}
View Full Code Here

Examples of org.jgroups.util.ByteArrayDataInputStream.readInt()

257
258
259
260
261
262
263
264
265
266
267
        int[] numbers={Integer.MIN_VALUE, -322649, -500, 0, 1, 100, 322649, Integer.MAX_VALUE};
        for(int i: numbers)
            out.writeInt(i);
        ByteArrayDataInputStream in=new ByteArrayDataInputStream(out.buffer());
        for(int i: numbers) {
            int num=in.readInt();
            assert num == i;
        }
    }

    public void testLong() throws IOException {
View Full Code Here

Examples of org.lealone.store.Data.readInt()

216
217
218
219
220
221
222
223
224
225
226
                listIndex = 0;
                Data buff = rowBuff;
                buff.reset();
                int min = Constants.FILE_BLOCK_SIZE;
                file.readFully(buff.getBytes(), 0, min);
                int len = buff.readInt() * Constants.FILE_BLOCK_SIZE;
                buff.checkCapacity(len);
                if (len - min > 0) {
                    file.readFully(buff.getBytes(), min, len - min);
                }
                while (true) {
View Full Code Here

Examples of org.lealone.value.Transfer.readInt()

90
91
92
93
94
95
96
97
98
99
100
                    for (int j = 0; j < size; j++)
                        transfer.writeString(batchCommands.get(j));
                    session.done(transfer);

                    for (int j = 0; j < size; j++)
                        result[j] = transfer.readInt();
                } else {
                    session.traceOperation("COMMAND_EXECUTE_BATCH_UPDATE_PREPAREDSTATEMENT", id);
                    transfer.writeInt(SessionRemote.COMMAND_EXECUTE_BATCH_UPDATE_PREPAREDSTATEMENT).writeInt(id);
                    int size = batchParameters.size();
                    result = new int[size];
View Full Code Here

Examples of org.lilyproject.bytes.api.DataInput.readInt()

186
187
188
189
190
191
192
193
194
195
196
        Assert.assertEquals(b, dataInput.readBoolean());
        Assert.assertEquals(bytes[0], dataInput.readByte());
        Assert.assertArrayEquals(bytes, dataInput.readBytes(10));
        Assert.assertEquals(d, dataInput.readDouble(), 0.0001);
        Assert.assertEquals(f, dataInput.readFloat(), 0.0001);
        Assert.assertEquals(i, dataInput.readInt());
        Assert.assertEquals(l, dataInput.readLong());
        Assert.assertEquals(s, dataInput.readShort());
        Assert.assertEquals(string, dataInput.readUTF());
        Assert.assertEquals(Math.abs(i), dataInput.readVInt());
        Assert.assertEquals(Math.abs(l), dataInput.readVLong());
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.