Package org.apache.mina.common

Examples of org.apache.mina.common.ByteBuffer.asReadOnlyBuffer()

111
112
113
114
115
116
117
118
119
120
121
        short len = 1000;
        byte[] expected = getByteSequence(len);
        ByteBuffer buf = ByteBuffer.allocate(len + 2 , false);
        buf.putShort(len);
        buf.put(expected);
        buf = buf.asReadOnlyBuffer();
        buf.flip();

        assertEquals(0, sentMessages.size());
        assertEquals(0, receivedMessages.size());
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
        short len = 1000;
        byte[] expected = getByteSequence(len);
        ByteBuffer buf = ByteBuffer.allocate(len + 2 , false);
        buf.putShort(len);
        buf.put(expected);
        buf = buf.asReadOnlyBuffer();
        buf.flip();

        assertEquals(0, sentMessages.size());
        assertEquals(0, receivedMessages.size());
View Full Code Here
247
248
249
250
251
252
253
254
255
256
257
        short len = 32;
        byte[] expected = getByteSequence(len);
        ByteBuffer buf = ByteBuffer.allocate(len + 2 , false);
        buf.putShort(len);
        buf.put(expected);
        buf = buf.asReadOnlyBuffer();
        buf.flip();

        for (; buf.hasRemaining(); buf.skip(1)) {
            assertEquals(0, sentMessages.size());
            assertEquals(0, receivedMessages.size());
View Full Code Here
293
294
295
296
297
298
299
300
301
302
303
        short len = 1000;
        byte[] expected = getByteSequence(len);
        ByteBuffer buf = ByteBuffer.allocate(len + 2 , false);
        buf.putShort(len);
        buf.put(expected);
        buf = buf.asReadOnlyBuffer();
        buf.flip();

        assertEquals(0, sentMessages.size());
        assertEquals(0, receivedMessages.size());
View Full Code Here
326
327
328
329
330
331
332
333
334
335
336
        short len = (short) (len1 + len2);
        byte[] expected = getByteSequence(len);
        ByteBuffer buf = ByteBuffer.allocate(len + 2 , false);
        buf.putShort(len);
        buf.put(expected);
        buf = buf.asReadOnlyBuffer();
        buf.flip();

        assertEquals(0, sentMessages.size());
        assertEquals(0, receivedMessages.size());
View Full Code Here
374
375
376
377
378
379
380
381
382
383
384
        short len = 1000;
        byte[] sendData = getByteSequence(len);
        ByteBuffer buf = ByteBuffer.allocate(len + 2 , false);
        buf.putShort(len);
        buf.put(sendData);
        buf = buf.asReadOnlyBuffer();
        buf.flip();

        byte[] expected = new byte[buf.remaining()];
        buf.get(expected);
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
    if(showInfo) log.info("Incomming: "+session.getRemoteAddress().toString());

    ByteBuffer data = (ByteBuffer) message;

    // IN HEX DUMP
    log.info(HexDump.prettyPrintHex(data.asReadOnlyBuffer().array()));

    final byte type = data.get();
    data.position(0);

    switch(type){
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.