1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
|
package org.apache.qpid.framing;
import org.apache.qpid.codec.MarkableDataInput;
public class ByteArrayDataInput implements ExtendedDataInput, MarkableDataInput
{
private byte[] _data;
private int _offset;
private int _length;
private int _origin;
private int _mark;
public ByteArrayDataInput(byte[] data)
{
this(data,0, data.length);
}
public ByteArrayDataInput(byte[] data, int offset, int length)
{
_data = data;
_offset = offset;
_length = length;
_origin = offset;
_mark = 0;
}
public void readFully(byte[] b)
{
System.arraycopy(_data,_offset,b,0,b.length);
_offset+=b.length;
}
public void readFully(byte[] b, int off, int len)
{
System.arraycopy(_data,_offset,b,off,len);
_offset+=len;
}
public int skipBytes(int n)
{
return _offset+=n;
}
public boolean readBoolean()
{
return _data[_offset++] != 0;
}
public byte readByte()
{
return _data[_offset++];
}
public int readUnsignedByte()
{
return ((int)_data[_offset++]) & 0xFF;
}
public short readShort()
{
return (short) (((((int)_data[_offset++]) << 8) & 0xFF00) | (((int)_data[_offset++]) & 0xFF));
}
public int readUnsignedShort()
{
return (((((int)_data[_offset++]) << 8) & 0xFF00) | (((int)_data[_offset++]) & 0xFF));
}
public char readChar()
{
return (char) (((((int)_data[_offset++]) << 8) & 0xFF00) | (((int)_data[_offset++]) & 0xFF));
}
public int readInt()
{
return ((((int)_data[_offset++]) << 24) & 0xFF000000)
| ((((int)_data[_offset++]) << 16) & 0xFF0000)
| ((((int)_data[_offset++]) << 8) & 0xFF00)
| (((int)_data[_offset++]) & 0xFF);
}
public long readLong()
{
return ((((long)_data[_offset++]) << 56) & 0xFF00000000000000L)
| ((((long)_data[_offset++]) << 48) & 0xFF000000000000L)
| ((((long)_data[_offset++]) << 40) & 0xFF0000000000L)
| ((((long)_data[_offset++]) << 32) & 0xFF00000000L)
| ((((long)_data[_offset++]) << 24) & 0xFF000000L)
| ((((long)_data[_offset++]) << 16) & 0xFF0000L)
| ((((long)_data[_offset++]) << 8) & 0xFF00L)
| (((long)_data[_offset++]) & 0xFFL);
}
public float readFloat()
{
return Float.intBitsToFloat(readInt());
}
public double readDouble()
{
return Double.longBitsToDouble(readLong());
}
public AMQShortString readAMQShortString()
{
int length = _data[_offset++] & 0xff;
if(length == 0)
{
return null;
}
else
{
final AMQShortString amqShortString = new AMQShortString(_data, _offset, length);
_offset+=length;
return amqShortString;
}
}
public String readLine()
{
throw new UnsupportedOperationException();
}
public String readUTF()
{
throw new UnsupportedOperationException();
}
public int available()
{
return (_origin+_length)-_offset;
}
public long skip(long i)
{
_offset+=i;
return i;
}
public int read(byte[] b)
{
readFully(b);
return b.length;
}
public int position()
{
return _offset - _origin;
}
public void position(int position)
{
_offset = position + _origin;
}
public int length()
{
return _length;
}
public void mark(int readAhead)
{
_mark = _offset-_origin;
}
public void reset()
{
_offset = _origin + _mark;
}
}
|
