Package org.apache.mina.core.buffer

Examples of org.apache.mina.core.buffer.IoBuffer.rewind()

130
131
132
133
134
135
136
137
138
139
140
    }

    private static boolean checkRequest(IoBuffer message) {
        IoBuffer buff = message;
        boolean check = buff.get() == 1;
        buff.rewind();
        return check;
    }

    private static boolean checkResponse(IoBuffer message) {
        IoBuffer buff = message;
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
    }

    private static boolean checkResponse(IoBuffer message) {
        IoBuffer buff = message;
        boolean check = buff.get() == 2;
        buff.rewind();
        return check;
    }

    // Inner classes -------------------------------------------------
View Full Code Here
224
225
226
227
228
229
230
231
232
233
234
        @Override
        public void messageSent(IoSession session, Object message)
                throws Exception {
            IoBuffer buffer = (IoBuffer) message;
            buffer.rewind();
            byte[] data = new byte[buffer.remaining()];
            buffer.get(data);
            StringBuffer sb = (StringBuffer) session.getAttribute("sent");
            sb.append(new String(data, "ASCII"));
        }
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
        // length is the data minus 4 bytes for the pre-pended length
        int recordLength = buf.position() - 4;

        // write the length
        buf.rewind();
        buf.putInt( recordLength );

        // set the position back before flipping the buffer
        buf.position( pos );
        buf.flip();
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
        // length is the data minus 4 bytes for the pre-pended length
        int recordLength = buf.position() - 4;

        // write the length
        buf.rewind();
        buf.putInt( recordLength );

        // set the position back before flipping the buffer
        buf.position( pos );
        buf.flip();
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
        // length is the data minus 2 bytes for the pre-pended length
        short recordLength = ( short ) ( end - 2 );

        // write the length
        buf.rewind();
        buf.putShort( recordLength );

        // set the position back before flipping the buffer
        buf.position( end );
        buf.flip();
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
    }

    private static boolean checkRequest(IoBuffer message) {
        IoBuffer buff = message;
        boolean check = buff.get() == 1;
        buff.rewind();
        return check;
    }

    private static boolean checkResponse(IoBuffer message) {
        IoBuffer buff = message;
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
    }

    private static boolean checkResponse(IoBuffer message) {
        IoBuffer buff = message;
        boolean check = buff.get() == 2;
        buff.rewind();
        return check;
    }

    // Inner classes -------------------------------------------------
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
    }

    static boolean checkRequest(IoBuffer message) {
        IoBuffer buff = message;
        boolean check = buff.get() == 1;
        buff.rewind();
        return check;
    }

    static boolean checkResponse(IoBuffer message) {
        IoBuffer buff = message;
View Full Code Here
135
136
137
138
139
140
141
142
143
144
145
    }

    static boolean checkResponse(IoBuffer message) {
        IoBuffer buff = message;
        boolean check = buff.get() == 2;
        buff.rewind();
        return check;
    }

    // Inner classes -------------------------------------------------
    private final class ServerFactory implements KeepAliveMessageFactory {
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.