Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(176)

Unified Diff: runtime/bin/buffer_list.dart

Issue 8506005: Merge the two buffer list implementations (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 9 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « runtime/bin/bin.gypi ('k') | runtime/bin/socket_stream.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: runtime/bin/buffer_list.dart
diff --git a/runtime/bin/buffer_list.dart b/runtime/bin/buffer_list.dart
new file mode 100644
index 0000000000000000000000000000000000000000..a8c225cb400007e0251c462c25d971c005ffdbc7
--- /dev/null
+++ b/runtime/bin/buffer_list.dart
@@ -0,0 +1,99 @@
+// Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file
+// for details. All rights reserved. Use of this source code is governed by a
+// BSD-style license that can be found in the LICENSE file.
+
+/*
Mads Ager (google) 2011/11/09 09:46:15 These are nice comments. Maybe use the dart doc fo
Søren Gjesse 2011/11/09 09:58:38 Done.
+ * Utility class that holds a number of byte buffers and can deliver
+ * the bytes either one by one or in chunks.
+ */
+class _BufferList {
+ _BufferList() {
+ clear();
+ }
+
+ /*
+ * Adds a new buffer to the list possibly with an offset of the
+ * first byte of interest. The offset can only be specified if the
+ * buffer list is empty.
+ */
+ void add(List<int> buffer, [int offset = 0]) {
+ assert(offset == 0 || _buffers.isEmpty());
+ _buffers.addLast(buffer);
+ _length += buffer.length;
+ if (offset != 0) _index = offset;
+ }
+
+ /*
+ * Returns the first buffer from the list. This returns the whole
+ * buffer and does not remove the buffer from the list. Use
+ * [index()] to determine the index of the first byte in the buffer.
Mads Ager (google) 2011/11/09 09:46:15 remove the () from [index()] or use code comments
Søren Gjesse 2011/11/09 09:58:38 Removed () (it is a getter)
+ */
+ List<int> get first() => _buffers.first();
+
+ /* Returns the current index of the next byte. This will always be
+ * an index into the first buffer as when the index is advanced past
+ * the end of a buffer it is removed from the list.
+ */
+ int get index() => _index;
+
+ /*
+ * Peek at the next available byte.
+ */
+ int peek() {
Mads Ager (google) 2011/11/09 09:46:15 use '=>' syntax?
Søren Gjesse 2011/11/09 09:58:38 Done.
+ return _buffers.first()[_index];
+ }
+
+ /*
+ * Returns the next available byte removing it from the buffers.
+ */
+ int next() {
+ int value = _buffers.first()[_index++];
+ _length--;
+ if (_index == _buffers.first().length) {
+ _buffers.removeFirst();
+ _index = 0;
+ }
+ return value;
+ }
+
+ /*
+ * Removed a number of bytes from the buffer list. Currently the
Mads Ager (google) 2011/11/09 09:46:15 Removed -> Remove
Søren Gjesse 2011/11/09 09:58:38 Done.
+ * number of bytes to remove must be confined to the first buffer.
+ */
+ void removeBytes(int count) {
+ int firstRemaining = first.length - _index;
+ assert(count <= firstRemaining);
+ if (count == firstRemaining) {
+ _buffers.removeFirst();
+ _index = 0;
+ } else {
+ _index += count;
+ }
+ _length -= count;
+ }
+
+
+ /*
+ * Returns the total number of bytes remaining in the buffers.
+ */
+ int get length() => _length;
+
+ /*
+ * Returns whether the buffer list is empty that is has no bytes
+ * available.
+ */
+ bool isEmpty() => _buffers.isEmpty();
+
+ /*
+ * Clears the content of the buffer list.
+ */
+ void clear() {
+ _index = 0;
+ _length = 0;
+ _buffers = new Queue();
+ }
+
+ int _length; // Total number of bytes remaining in the buffers.
+ Queue<List<int>> _buffers; // List of data buffers.
+ int _index; // Index of the next byte in the first buffer.
+}
« no previous file with comments | « runtime/bin/bin.gypi ('k') | runtime/bin/socket_stream.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698