OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 part of dart.io; | 5 part of dart.io; |
6 | 6 |
7 /** | 7 /** |
8 * Builds a list of bytes, allowing bytes and lists of bytes to be added at the | 8 * Builds a list of bytes, allowing bytes and lists of bytes to be added at the |
9 * end. | 9 * end. |
10 * | 10 * |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
76 * Clear the contents of the builder. | 76 * Clear the contents of the builder. |
77 */ | 77 */ |
78 void clear(); | 78 void clear(); |
79 } | 79 } |
80 | 80 |
81 | 81 |
82 class _CopyingBytesBuilder implements BytesBuilder { | 82 class _CopyingBytesBuilder implements BytesBuilder { |
83 // Start with 1024 bytes. | 83 // Start with 1024 bytes. |
84 static const int _INIT_SIZE = 1024; | 84 static const int _INIT_SIZE = 1024; |
85 | 85 |
| 86 static final _emptyList = new Uint8List(0); |
| 87 |
86 int _length = 0; | 88 int _length = 0; |
87 Uint8List _buffer; | 89 Uint8List _buffer; |
88 | 90 |
| 91 _CopyingBytesBuilder([int initialCapacity = 0]) |
| 92 : _buffer = (initialCapacity <= 0) |
| 93 ? _emptyList |
| 94 : new Uint8List(_pow2roundup(initialCapacity)); |
| 95 |
89 void add(List<int> bytes) { | 96 void add(List<int> bytes) { |
90 int bytesLength = bytes.length; | 97 int bytesLength = bytes.length; |
91 if (bytesLength == 0) return; | 98 if (bytesLength == 0) return; |
92 int required = _length + bytesLength; | 99 int required = _length + bytesLength; |
93 if (_buffer == null) { | 100 if (_buffer.length < required) { |
94 int size = _pow2roundup(required); | 101 _grow(required); |
95 size = max(size, _INIT_SIZE); | |
96 _buffer = new Uint8List(size); | |
97 } else if (_buffer.length < required) { | |
98 // We will create a list in the range of 2-4 times larger than | |
99 // required. | |
100 int size = _pow2roundup(required) * 2; | |
101 var newBuffer = new Uint8List(size); | |
102 newBuffer.setRange(0, _buffer.length, _buffer); | |
103 _buffer = newBuffer; | |
104 } | 102 } |
105 assert(_buffer.length >= required); | 103 assert(_buffer.length >= required); |
106 if (bytes is Uint8List) { | 104 if (bytes is Uint8List) { |
107 _buffer.setRange(_length, required, bytes); | 105 _buffer.setRange(_length, required, bytes); |
108 } else { | 106 } else { |
109 for (int i = 0; i < bytesLength; i++) { | 107 for (int i = 0; i < bytesLength; i++) { |
110 _buffer[_length + i] = bytes[i]; | 108 _buffer[_length + i] = bytes[i]; |
111 } | 109 } |
112 } | 110 } |
113 _length = required; | 111 _length = required; |
114 } | 112 } |
115 | 113 |
116 void addByte(int byte) { add([byte]); } | 114 void addByte(int byte) { |
| 115 if (_buffer.length == _length) { |
| 116 // The grow algorithm always at least doubles. |
| 117 // If we added one to _length it would quadruple unnecessarily. |
| 118 _grow(_length); |
| 119 } |
| 120 assert(_buffer.length > _length); |
| 121 _buffer[_length] = byte; |
| 122 _length++; |
| 123 } |
| 124 |
| 125 void _grow(int required) { |
| 126 // We will create a list in the range of 2-4 times larger than |
| 127 // required. |
| 128 int newSize = required * 2; |
| 129 if (newSize < _INIT_SIZE) { |
| 130 newSize = _INIT_SIZE; |
| 131 } else { |
| 132 newSize = _pow2roundup(newSize); |
| 133 } |
| 134 var newBuffer = new Uint8List(newSize); |
| 135 newBuffer.setRange(0, _buffer.length, _buffer); |
| 136 _buffer = newBuffer; |
| 137 } |
117 | 138 |
118 List<int> takeBytes() { | 139 List<int> takeBytes() { |
119 if (_buffer == null) return new Uint8List(0); | 140 if (_length == 0) return _emptyList; |
120 var buffer = new Uint8List.view(_buffer.buffer, 0, _length); | 141 var buffer = new Uint8List.view(_buffer.buffer, 0, _length); |
121 clear(); | 142 clear(); |
122 return buffer; | 143 return buffer; |
123 } | 144 } |
124 | 145 |
125 List<int> toBytes() { | 146 List<int> toBytes() { |
126 if (_buffer == null) return new Uint8List(0); | 147 if (_length == 0) return _emptyList; |
127 return new Uint8List.fromList( | 148 return new Uint8List.fromList( |
128 new Uint8List.view(_buffer.buffer, 0, _length)); | 149 new Uint8List.view(_buffer.buffer, 0, _length)); |
129 } | 150 } |
130 | 151 |
131 int get length => _length; | 152 int get length => _length; |
132 | 153 |
133 bool get isEmpty => _length == 0; | 154 bool get isEmpty => _length == 0; |
134 | 155 |
135 bool get isNotEmpty => _length != 0; | 156 bool get isNotEmpty => _length != 0; |
136 | 157 |
137 void clear() { | 158 void clear() { |
138 _length = 0; | 159 _length = 0; |
139 _buffer = null; | 160 _buffer = _emptyList; |
140 } | 161 } |
141 | 162 |
142 int _pow2roundup(int x) { | 163 static int _pow2roundup(int x) { |
| 164 assert(x > 0); |
143 --x; | 165 --x; |
144 x |= x >> 1; | 166 x |= x >> 1; |
145 x |= x >> 2; | 167 x |= x >> 2; |
146 x |= x >> 4; | 168 x |= x >> 4; |
147 x |= x >> 8; | 169 x |= x >> 8; |
148 x |= x >> 16; | 170 x |= x >> 16; |
149 return x + 1; | 171 return x + 1; |
150 } | 172 } |
151 } | 173 } |
152 | 174 |
153 | 175 |
154 class _BytesBuilder implements BytesBuilder { | 176 class _BytesBuilder implements BytesBuilder { |
155 int _length = 0; | 177 int _length = 0; |
156 final List<Uint8List> _chunks = []; | 178 final List<Uint8List> _chunks = []; |
157 | 179 |
158 void add(List<int> bytes) { | 180 void add(List<int> bytes) { |
159 Uint8List typedBytes; | 181 Uint8List typedBytes; |
160 if (bytes is Uint8List) { | 182 if (bytes is Uint8List) { |
161 typedBytes = bytes; | 183 typedBytes = bytes; |
162 } else { | 184 } else { |
163 typedBytes = new Uint8List.fromList(bytes); | 185 typedBytes = new Uint8List.fromList(bytes); |
164 } | 186 } |
165 _chunks.add(typedBytes); | 187 _chunks.add(typedBytes); |
166 _length += typedBytes.length; | 188 _length += typedBytes.length; |
167 } | 189 } |
168 | 190 |
169 void addByte(int byte) { add([byte]); } | 191 void addByte(int byte) { |
| 192 _chunks.add(new Uint8List(1)..[0] = byte); |
| 193 _length++; |
| 194 } |
170 | 195 |
171 List<int> takeBytes() { | 196 List<int> takeBytes() { |
172 if (_chunks.length == 0) return new Uint8List(0); | 197 if (_length == 0) return _CopyingBytesBuilder._emptyList; |
173 if (_chunks.length == 1) { | 198 if (_chunks.length == 1) { |
174 var buffer = _chunks.single; | 199 var buffer = _chunks[0]; |
175 clear(); | 200 clear(); |
176 return buffer; | 201 return buffer; |
177 } | 202 } |
178 var buffer = new Uint8List(_length); | 203 var buffer = new Uint8List(_length); |
179 int offset = 0; | 204 int offset = 0; |
180 for (var chunk in _chunks) { | 205 for (var chunk in _chunks) { |
181 buffer.setRange(offset, offset + chunk.length, chunk); | 206 buffer.setRange(offset, offset + chunk.length, chunk); |
182 offset += chunk.length; | 207 offset += chunk.length; |
183 } | 208 } |
184 clear(); | 209 clear(); |
185 return buffer; | 210 return buffer; |
186 } | 211 } |
187 | 212 |
188 List<int> toBytes() { | 213 List<int> toBytes() { |
189 if (_chunks.length == 0) return new Uint8List(0); | 214 if (_length == 0) return _CopyingBytesBuilder._emptyList; |
190 var buffer = new Uint8List(_length); | 215 var buffer = new Uint8List(_length); |
191 int offset = 0; | 216 int offset = 0; |
192 for (var chunk in _chunks) { | 217 for (var chunk in _chunks) { |
193 buffer.setRange(offset, offset + chunk.length, chunk); | 218 buffer.setRange(offset, offset + chunk.length, chunk); |
194 offset += chunk.length; | 219 offset += chunk.length; |
195 } | 220 } |
196 return buffer; | 221 return buffer; |
197 } | 222 } |
198 | 223 |
199 int get length => _length; | 224 int get length => _length; |
200 | 225 |
201 bool get isEmpty => _length == 0; | 226 bool get isEmpty => _length == 0; |
202 | 227 |
203 bool get isNotEmpty => _length != 0; | 228 bool get isNotEmpty => _length != 0; |
204 | 229 |
205 void clear() { | 230 void clear() { |
206 _length = 0; | 231 _length = 0; |
207 _chunks.clear(); | 232 _chunks.clear(); |
208 } | 233 } |
209 } | 234 } |
OLD | NEW |