Mercurial Hosting > luan
annotate src/org/eclipse/jetty/io/JBuffer.java @ 1064:a0abb16cf6e7
remove JBuffer.readFrom()
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Wed, 09 Nov 2016 03:09:37 -0700 |
parents | 0157e92670f5 |
children | 158d1e6ac17f |
rev | line source |
---|---|
1046 | 1 // tmp class to implement Buffer until I can get rid of it |
2 | |
3 package org.eclipse.jetty.io; | |
4 | |
5 import java.io.InputStream; | |
6 import java.io.IOException; | |
7 import java.nio.ByteBuffer; | |
8 import org.slf4j.Logger; | |
9 import org.slf4j.LoggerFactory; | |
10 import org.eclipse.jetty.util.TypeUtil; | |
11 | |
12 | |
1048 | 13 public final class JBuffer { |
1046 | 14 private static final Logger LOG = LoggerFactory.getLogger(JBuffer.class); |
15 | |
16 private final ByteBuffer bb; | |
17 | |
18 public JBuffer(ByteBuffer bb) { | |
19 this.bb = bb; | |
20 } | |
21 | |
1050
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
22 public int position() { |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
23 return bb.position(); |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
24 } |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
25 |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
26 public void position(int i) { |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
27 bb.position(i); |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
28 } |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
29 |
1062
4a50422596b6
fix JBuffer.getByteBuffer()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1061
diff
changeset
|
30 public int limit() { |
4a50422596b6
fix JBuffer.getByteBuffer()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1061
diff
changeset
|
31 return bb.limit(); |
4a50422596b6
fix JBuffer.getByteBuffer()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1061
diff
changeset
|
32 } |
4a50422596b6
fix JBuffer.getByteBuffer()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1061
diff
changeset
|
33 |
1050
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
34 public void limit(int i) { |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
35 bb.limit(i); |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
36 } |
5ef954fad97b
remove JBuffer.sliceFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1049
diff
changeset
|
37 |
1046 | 38 public byte[] array() { |
1053 | 39 return bb.array(); |
40 } | |
41 | |
42 public boolean hasArray() { | |
43 return bb.hasArray(); | |
1046 | 44 } |
45 | |
1048 | 46 public JBuffer duplicate() { |
1046 | 47 return new JBuffer(bb.duplicate()); |
48 } | |
49 | |
50 public int remaining() { | |
51 return bb.remaining(); | |
52 } | |
53 | |
54 public boolean isReadOnly() { | |
55 return bb.isReadOnly(); | |
56 } | |
57 | |
58 public boolean hasRemaining() { | |
59 return bb.hasRemaining(); | |
60 } | |
61 | |
62 public byte get() { | |
63 return bb.get(); | |
64 } | |
65 | |
1054
87275900646e
remove JBuffer.toString()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1053
diff
changeset
|
66 public void get(byte[] bytes) { |
87275900646e
remove JBuffer.toString()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1053
diff
changeset
|
67 bb.get(bytes); |
87275900646e
remove JBuffer.toString()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1053
diff
changeset
|
68 } |
87275900646e
remove JBuffer.toString()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1053
diff
changeset
|
69 |
1046 | 70 public void compact() { |
71 int n = bb.remaining(); | |
72 bb.compact(); | |
73 bb.position(0); | |
74 bb.limit(n); | |
75 } | |
76 | |
77 public int capacity() { | |
78 return bb.capacity(); | |
79 } | |
80 | |
81 | |
82 | |
83 public ByteBuffer getByteBuffer() { | |
1062
4a50422596b6
fix JBuffer.getByteBuffer()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1061
diff
changeset
|
84 return bb; |
1046 | 85 } |
86 | |
87 public void clear() { | |
88 bb.position(0); | |
89 bb.limit(0); | |
90 } | |
91 | |
92 public int space() { | |
93 return bb.capacity() - bb.limit(); | |
94 } | |
95 | |
96 | |
1060 | 97 public void get(byte[] b, int offset, int length) { |
1046 | 98 bb.get(b,offset,length); |
99 } | |
100 | |
101 | |
1048 | 102 public int put(JBuffer src) { |
1046 | 103 return put(src.asArray()); |
104 } | |
105 | |
106 public void put(byte b) | |
107 { | |
108 ByteBuffer dup = bb.duplicate(); | |
109 dup.position(bb.limit()); | |
110 dup.limit(bb.capacity()); | |
111 dup.put(b); | |
112 bb.limit(bb.limit()+1); | |
113 } | |
114 | |
1049
4afdf0f0c5bc
remove unused JBuffer methods
Franklin Schmidt <fschmidt@gmail.com>
parents:
1048
diff
changeset
|
115 private int put(byte[] b, int offset, int length) { |
1046 | 116 ByteBuffer dup = bb.duplicate(); |
117 int put = bb.limit(); | |
118 int capacity = bb.capacity(); | |
119 dup.position(put); | |
120 dup.limit(capacity); | |
121 if( length > capacity - put ) | |
122 length = capacity - put; | |
123 dup.put(b,offset,length); | |
124 bb.limit(put+length); | |
125 return length; | |
126 } | |
127 | |
128 public int put(byte[] b) { | |
129 return put(b,0,b.length); | |
130 } | |
131 | |
132 public final int putIndex() { | |
133 return bb.limit(); | |
134 } | |
135 | |
136 public void setPutIndex(int putIndex) { | |
137 bb.limit(putIndex); | |
138 } | |
139 | |
1051
1ab2dd0a7db5
remove JBuffer.get(int)
Franklin Schmidt <fschmidt@gmail.com>
parents:
1050
diff
changeset
|
140 public void skip(int n) { |
1046 | 141 if (remaining() < n) n = remaining(); |
142 bb.position(bb.position() + n); | |
143 } | |
144 | |
1060 | 145 private final byte[] asArray() { |
1046 | 146 byte[] bytes = new byte[remaining()]; |
147 bb.duplicate().get(bytes); | |
148 return bytes; | |
149 } | |
1064
a0abb16cf6e7
remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1063
diff
changeset
|
150 /* |
1046 | 151 @Override |
1054
87275900646e
remove JBuffer.toString()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1053
diff
changeset
|
152 public String toString() { |
87275900646e
remove JBuffer.toString()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1053
diff
changeset
|
153 // return toString("ISO-8859-1"); |
87275900646e
remove JBuffer.toString()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1053
diff
changeset
|
154 // Thread.dumpStack(); |
87275900646e
remove JBuffer.toString()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1053
diff
changeset
|
155 throw new RuntimeException("toString"); |
1046 | 156 } |
1064
a0abb16cf6e7
remove JBuffer.readFrom()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1063
diff
changeset
|
157 */ |
1046 | 158 |
1052
4a2489f1d5fe
remove JBuffer.peek()
Franklin Schmidt <fschmidt@gmail.com>
parents:
1051
diff
changeset
|
159 public byte get(int index) { |
1046 | 160 return bb.get(index); |
161 } | |
162 | |
163 } |