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

Unified Diff: third_party/WebKit/Source/platform/image-decoders/SegmentStreamTest.cpp

Issue 2565323003: Move gif image decoder to SkCodec (Closed)
Patch Set: Explicitly specify move ctor / assignment until required patch lands. Created 3 years, 4 months 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
Index: third_party/WebKit/Source/platform/image-decoders/SegmentStreamTest.cpp
diff --git a/third_party/WebKit/Source/platform/image-decoders/SegmentStreamTest.cpp b/third_party/WebKit/Source/platform/image-decoders/SegmentStreamTest.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..180a728e6a0599b46f44f97712eb22a6c202bdfd
--- /dev/null
+++ b/third_party/WebKit/Source/platform/image-decoders/SegmentStreamTest.cpp
@@ -0,0 +1,702 @@
+// Copyright (c) 2017 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#include "platform/image-decoders/SegmentStream.h"
+
+#include <array>
+#include <memory>
+#include "platform/SharedBuffer.h"
+#include "platform/image-decoders/SegmentReader.h"
+#include "platform/wtf/PtrUtil.h"
+#include "testing/gtest/include/gtest/gtest.h"
+
+// SegmentStream has 4 accessors which do not alter state:
+// - isCleared()
+// - isAtEnd()
+// - getPosition()
+// - getLength()
+//
+// For every operation which changes state we can test:
+// - the operation completed as expected,
+// - the accessors did not change, and/or
+// - the accessors changed in the way we expected.
+//
+// There are actually 2 more accessors:
+// - hasPosition()
+// - hasLength()
+// but these should always return true to indicate that we can call getLength()
+// for example. So let's not add them to every state changing operation and add
+// needless complexity.
+
+namespace {
+
+constexpr size_t kBufferAllocationSize = 20;
+constexpr size_t kInsideBufferPosition = 10;
+constexpr size_t kPastEndOfBufferPosition = 30;
+
+testing::AssertionResult IsCleared(const blink::SegmentStream&);
+testing::AssertionResult IsAtEnd(const blink::SegmentStream&);
+testing::AssertionResult PositionIsZero(const blink::SegmentStream&);
+testing::AssertionResult PositionIsInsideBuffer(const blink::SegmentStream&);
+testing::AssertionResult PositionIsAtEndOfBuffer(const blink::SegmentStream&);
+testing::AssertionResult LengthIsZero(const blink::SegmentStream&);
+testing::AssertionResult LengthIsAllocationSize(const blink::SegmentStream&);
+
+// Many of these tests require a SegmentStream with populated data.
+//
+// This function creates a buffer of size |kBufferAllocationSize| and prepares
+// a SegmentStream with that buffer.
+// This also populates other properties such as the length, cleared state, etc.
+blink::SegmentStream CreatePopulatedSegmentStream();
+
+// This function creates a buffer of size |kBufferAllocationSize| to be used
+// when populating a SegmentStream.
+WTF::RefPtr<blink::SegmentReader> CreateSegmentReader();
+
+size_t ReadFromSegmentStream(blink::SegmentStream&,
+ size_t amount_to_read = kInsideBufferPosition);
+size_t PeekIntoSegmentStream(blink::SegmentStream&,
+ size_t amount_to_peek = kInsideBufferPosition);
+
+} // namespace
+
+namespace blink {
+
+TEST(SegmentStreamTest, DefaultConstructorShouldSetIsCleared) {
+ SegmentStream segment_stream;
+
+ ASSERT_TRUE(IsCleared(segment_stream));
+}
+
+TEST(SegmentStreamTest, DefaultConstructorShouldSetIsAtEnd) {
+ SegmentStream segment_stream;
+
+ ASSERT_TRUE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, DefaultContructorShouldClearPosition) {
+ SegmentStream segment_stream;
+
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+}
+
+TEST(SegmentStreamTest, DefaultConstructorShouldHaveZeroLength) {
+ SegmentStream segment_stream;
+
+ ASSERT_TRUE(LengthIsZero(segment_stream));
+}
+
+TEST(SegmentStreamTest, MoveConstructorShouldSetIsClearedWhenRhsIsCleared) {
+ SegmentStream cleared_segment_stream;
+ ASSERT_TRUE(IsCleared(cleared_segment_stream));
+
+ SegmentStream move_constructed_segment_stream =
+ std::move(cleared_segment_stream);
+
+ ASSERT_TRUE(IsCleared(move_constructed_segment_stream));
+}
+
+TEST(SegmentStreamTest,
+ MoveConstructorShouldUnsetIsClearedWhenRhsIsNotCleared) {
+ SegmentStream uncleared_segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsCleared(uncleared_segment_stream));
+
+ SegmentStream move_constructed_segment_stream =
+ std::move(uncleared_segment_stream);
+
+ ASSERT_FALSE(IsCleared(move_constructed_segment_stream));
+}
+
+TEST(SegmentStreamTest, MoveConstructorShouldSetIsAtEndWhenRhsIsAtEnd) {
+ SegmentStream at_end_segment_stream;
+ ASSERT_TRUE(IsAtEnd(at_end_segment_stream));
+
+ SegmentStream move_constructed_segment_stream =
+ std::move(at_end_segment_stream);
+
+ ASSERT_TRUE(IsAtEnd(move_constructed_segment_stream));
+}
+
+TEST(SegmentStreamTest, MoveConstructorShouldUnsetIsAtEndWhenRhsIsNotAtEnd) {
+ SegmentStream not_at_end_segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsAtEnd(not_at_end_segment_stream));
+
+ SegmentStream move_constructed_segment_stream =
+ std::move(not_at_end_segment_stream);
+
+ ASSERT_FALSE(IsAtEnd(move_constructed_segment_stream));
+}
+
+TEST(SegmentStreamTest, MoveContructorShouldCopyRhsPosition) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ segment_stream.seek(kInsideBufferPosition);
+ ASSERT_EQ(kInsideBufferPosition, segment_stream.getPosition());
+
+ SegmentStream move_constructed_segment_stream = std::move(segment_stream);
+
+ ASSERT_EQ(kInsideBufferPosition,
+ move_constructed_segment_stream.getPosition());
+}
+
+TEST(SegmentStreamTest, MoveConstructorShouldCopyRhsLength) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_EQ(kBufferAllocationSize, segment_stream.getLength());
+
+ SegmentStream move_constructed_segment_stream = std::move(segment_stream);
+
+ ASSERT_EQ(kBufferAllocationSize, move_constructed_segment_stream.getLength());
+}
+
+TEST(SegmentStreamTest,
+ MoveAssignmentOperatorShouldSetIsClearedWhenRhsIsCleared) {
+ SegmentStream cleared_segment_stream;
+ ASSERT_TRUE(IsCleared(cleared_segment_stream));
+
+ SegmentStream move_assigned_segment_stream;
+ move_assigned_segment_stream = std::move(cleared_segment_stream);
+
+ ASSERT_TRUE(IsCleared(move_assigned_segment_stream));
+}
+
+TEST(SegmentStreamTest,
+ MoveAssignmentOperatorShouldUnsetIsClearedWhenRhsIsNotCleared) {
+ SegmentStream uncleared_segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsCleared(uncleared_segment_stream));
+
+ SegmentStream move_assigned_segment_stream;
+ move_assigned_segment_stream = std::move(uncleared_segment_stream);
+
+ ASSERT_FALSE(IsCleared(move_assigned_segment_stream));
+}
+
+TEST(SegmentStreamTest, MoveAssignmentOperatorShouldSetIsAtEndWhenRhsIsAtEnd) {
+ SegmentStream at_end_segment_stream;
+ ASSERT_TRUE(IsAtEnd(at_end_segment_stream));
+
+ SegmentStream move_assigned_segment_stream;
+ move_assigned_segment_stream = std::move(at_end_segment_stream);
+
+ ASSERT_TRUE(IsAtEnd(move_assigned_segment_stream));
+}
+
+TEST(SegmentStreamTest,
+ MoveAssignmentOperatorShouldUnsetIsAtEndWhenRhsIsNotAtEnd) {
+ SegmentStream not_at_end_segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsAtEnd(not_at_end_segment_stream));
+
+ SegmentStream move_assigned_segment_stream;
+ move_assigned_segment_stream = std::move(not_at_end_segment_stream);
+
+ ASSERT_FALSE(IsAtEnd(move_assigned_segment_stream));
+}
+
+TEST(SegmentStreamTest, MoveAssignmentOperatorShouldCopyRhsPosition) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ segment_stream.seek(kInsideBufferPosition);
+ ASSERT_EQ(kInsideBufferPosition, segment_stream.getPosition());
+
+ SegmentStream move_assigned_segment_stream;
+ move_assigned_segment_stream = std::move(segment_stream);
+
+ ASSERT_EQ(kInsideBufferPosition, move_assigned_segment_stream.getPosition());
+}
+
+TEST(SegmentStreamTest, MoveAssignmentOperatorShouldCopyRhsLength) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_EQ(kBufferAllocationSize, segment_stream.getLength());
+
+ SegmentStream move_assigned_segment_stream;
+ move_assigned_segment_stream = std::move(segment_stream);
+
+ ASSERT_EQ(kBufferAllocationSize, move_assigned_segment_stream.getLength());
+}
+
+TEST(SegmentStreamTest, SetReaderShouldUnsetIsCleared) {
+ SegmentStream segment_stream;
+ WTF::RefPtr<SegmentReader> segment_reader = CreateSegmentReader();
+ ASSERT_TRUE(IsCleared(segment_stream));
+
+ segment_stream.SetReader(segment_reader);
+
+ ASSERT_FALSE(IsCleared(segment_stream));
+}
+
+TEST(SegmentStreamTest, SetReaderShouldUnsetIsAtEnd) {
+ SegmentStream segment_stream;
+ WTF::RefPtr<SegmentReader> segment_reader = CreateSegmentReader();
+ ASSERT_TRUE(IsAtEnd(segment_stream));
+
+ segment_stream.SetReader(segment_reader);
+
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, SetReaderShouldNotChangePosition) {
+ SegmentStream segment_stream;
+ WTF::RefPtr<SegmentReader> segment_reader = CreateSegmentReader();
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+
+ segment_stream.SetReader(segment_reader);
+
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+}
+
+TEST(SegmentStreamTest, SetReaderShouldUpdateLength) {
+ SegmentStream segment_stream;
+ WTF::RefPtr<SegmentReader> segment_reader = CreateSegmentReader();
+ ASSERT_FALSE(LengthIsAllocationSize(segment_stream));
+
+ segment_stream.SetReader(segment_reader);
+
+ ASSERT_TRUE(LengthIsAllocationSize(segment_stream));
+}
+
+TEST(SegmentStreamTest, SetReaderShouldSetIsClearedWhenSetToNull) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsCleared(segment_stream));
+
+ segment_stream.SetReader(nullptr);
+
+ ASSERT_TRUE(IsCleared(segment_stream));
+}
+
+TEST(SegmentStreamTest, SetReaderShouldSetIsClearedWhenReaderSizeNotBigEnough) {
+ SegmentStream segment_stream;
+ segment_stream.seek(kPastEndOfBufferPosition);
+ RefPtr<blink::SegmentReader> segment_reader = CreateSegmentReader();
+
+ segment_stream.SetReader(segment_reader);
+
+ ASSERT_TRUE(IsCleared(segment_stream));
+}
+
+TEST(SegmentStreamTest, SetReaderShouldSetIsAtEndWhenReaderSizeNotBigEnough) {
+ SegmentStream segment_stream;
+ segment_stream.seek(kPastEndOfBufferPosition);
+ RefPtr<blink::SegmentReader> segment_reader = CreateSegmentReader();
+
+ segment_stream.SetReader(segment_reader);
+
+ ASSERT_TRUE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest,
+ SetReaderShouldNotChangePositionWhenReaderSizeNotBigEnough) {
+ SegmentStream segment_stream;
+ segment_stream.seek(kPastEndOfBufferPosition);
+ RefPtr<blink::SegmentReader> segment_reader = CreateSegmentReader();
+
+ segment_stream.SetReader(segment_reader);
+
+ ASSERT_EQ(kPastEndOfBufferPosition, segment_stream.getPosition());
+}
+
+TEST(SegmentStreamTest, SetReaderShouldChangeLengthWhenReaderSizeNotBigEnough) {
+ SegmentStream segment_stream;
+ segment_stream.seek(kPastEndOfBufferPosition);
+ RefPtr<blink::SegmentReader> segment_reader = CreateSegmentReader();
+
+ segment_stream.SetReader(segment_reader);
+
+ ASSERT_TRUE(LengthIsAllocationSize(segment_stream));
+}
+
+TEST(SegmentStreamTest, SetReaderShouldSetIsAtEndWhenSetToNull) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+
+ segment_stream.SetReader(nullptr);
+ ASSERT_TRUE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, SetReaderShouldNotChangePositionWhenSetToNull) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ const size_t amount_read = ReadFromSegmentStream(segment_stream);
+ ASSERT_EQ(kInsideBufferPosition, amount_read);
+ const size_t pre_nulled_position = segment_stream.getPosition();
+ ASSERT_EQ(kInsideBufferPosition, pre_nulled_position);
+
+ segment_stream.SetReader(nullptr);
+
+ ASSERT_EQ(kInsideBufferPosition, segment_stream.getPosition());
+}
+
+TEST(SegmentStreamTest, SetReaderShouldClearLengthWhenSetToNull) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(LengthIsZero(segment_stream));
+
+ segment_stream.SetReader(nullptr);
+
+ ASSERT_TRUE(LengthIsZero(segment_stream));
+}
+
+TEST(SegmentStreamTest, ReadShouldConsumeBuffer) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+
+ const size_t amount_read = ReadFromSegmentStream(segment_stream);
+
+ ASSERT_EQ(kInsideBufferPosition, amount_read);
+}
+
+TEST(SegmentStreamTest, ReadShouldNotClear) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+
+ ReadFromSegmentStream(segment_stream);
+
+ ASSERT_FALSE(IsCleared(segment_stream));
+}
+
+TEST(SegmentStreamTest, ReadShouldUpdateIsAtEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+
+ ReadFromSegmentStream(segment_stream, kBufferAllocationSize);
+
+ ASSERT_TRUE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, ReadShouldUpdatePosition) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+
+ ReadFromSegmentStream(segment_stream);
+
+ ASSERT_TRUE(PositionIsInsideBuffer(segment_stream));
+}
+
+TEST(SegmentStreamTest, ReadShouldNotChangeLength) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_EQ(kBufferAllocationSize, segment_stream.getLength());
+
+ ReadFromSegmentStream(segment_stream);
+
+ ASSERT_EQ(kBufferAllocationSize, segment_stream.getLength());
+}
+
+TEST(SegmentStreamTest, ReadShouldConsumeBufferWithoutGoingPastTheEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+
+ const size_t amount_read =
+ ReadFromSegmentStream(segment_stream, kPastEndOfBufferPosition);
+
+ ASSERT_EQ(kBufferAllocationSize, amount_read);
+}
+
+TEST(SegmentStreamTest, ReadShouldSetIsAtEndWhenPastEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+
+ ReadFromSegmentStream(segment_stream, kPastEndOfBufferPosition);
+
+ ASSERT_TRUE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, ReadShouldTruncatePositionWhenPastEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+
+ ReadFromSegmentStream(segment_stream, kPastEndOfBufferPosition);
+
+ ASSERT_TRUE(PositionIsAtEndOfBuffer(segment_stream));
+}
+
+TEST(SegmentStreamTest, PeekShouldConsumeBuffer) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+
+ const size_t amount_peeked = PeekIntoSegmentStream(segment_stream);
+
+ ASSERT_EQ(kInsideBufferPosition, amount_peeked);
+}
+
+TEST(SegmentStreamTest, PeekShouldNotClear) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+
+ PeekIntoSegmentStream(segment_stream);
+
+ ASSERT_FALSE(IsCleared(segment_stream));
+}
+
+TEST(SegmentStreamTest, PeekShouldNotUpdateIsAtEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+
+ PeekIntoSegmentStream(segment_stream, kBufferAllocationSize);
+
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, PeekShouldNotUpdatePosition) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+
+ PeekIntoSegmentStream(segment_stream);
+
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+}
+
+TEST(SegmentStreamTest, PeekShouldNotChangeLength) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+
+ PeekIntoSegmentStream(segment_stream);
+
+ ASSERT_EQ(kBufferAllocationSize, segment_stream.getLength());
+}
+
+TEST(SegmentStreamTest, PeekShouldConsumeBufferWithoutGoingPastTheEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+
+ const size_t amount_peeked =
+ PeekIntoSegmentStream(segment_stream, kPastEndOfBufferPosition);
+
+ ASSERT_EQ(kBufferAllocationSize, amount_peeked);
+}
+
+TEST(SegmentStreamTest, PeekShouldNotSetIsAtEndWhenPastEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+
+ PeekIntoSegmentStream(segment_stream, kPastEndOfBufferPosition);
+
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, PeekShouldNotTruncatePositionWhenPastEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+
+ PeekIntoSegmentStream(segment_stream, kPastEndOfBufferPosition);
+
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+}
+
+TEST(SegmentStreamTest, RewindShouldNotClear) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ReadFromSegmentStream(segment_stream);
+ ASSERT_FALSE(IsCleared(segment_stream));
+
+ segment_stream.rewind();
+
+ ASSERT_FALSE(IsCleared(segment_stream));
+}
+
+TEST(SegmentStreamTest, RewindShouldNotSetAtEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ReadFromSegmentStream(segment_stream);
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+
+ segment_stream.rewind();
+
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, RewindShouldResetPosition) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ReadFromSegmentStream(segment_stream);
+ ASSERT_TRUE(PositionIsInsideBuffer(segment_stream));
+
+ segment_stream.rewind();
+
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+}
+
+TEST(SegmentStreamTest, RewindShouldNotChangeLength) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ReadFromSegmentStream(segment_stream);
+
+ segment_stream.rewind();
+
+ ASSERT_EQ(kBufferAllocationSize, segment_stream.getLength());
+}
+
+TEST(SegmentStreamTest, HasPositionShouldBeSupported) {
+ blink::SegmentStream segment_stream;
+
+ ASSERT_TRUE(segment_stream.hasPosition());
+}
+
+TEST(SegmentStreamTest, SeekShouldNotSetIsCleared) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsCleared(segment_stream));
+
+ segment_stream.seek(kInsideBufferPosition);
+
+ ASSERT_FALSE(IsCleared(segment_stream));
+}
+
+TEST(SegmentStreamTest, SeekShouldNotSetIsAtEndWhenSeekingInsideTheBuffer) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+
+ segment_stream.seek(kInsideBufferPosition);
+
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, SeekShouldSetIsAtEndWhenSeekingToTheEndOfTheBuffer) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_FALSE(IsAtEnd(segment_stream));
+
+ segment_stream.seek(kBufferAllocationSize);
+
+ ASSERT_TRUE(IsAtEnd(segment_stream));
+}
+
+TEST(SegmentStreamTest, SeekShouldUpdatePosition) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+
+ segment_stream.seek(kInsideBufferPosition);
+
+ ASSERT_EQ(kInsideBufferPosition, segment_stream.getPosition());
+}
+
+TEST(SegmentStreamTest, SeekShouldNotTruncatePositionWhenPastEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+
+ segment_stream.seek(kPastEndOfBufferPosition);
+
+ ASSERT_EQ(kPastEndOfBufferPosition, segment_stream.getPosition());
+}
+
+TEST(SegmentStreamTest, SeekShouldNotUpdateLength) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+
+ segment_stream.seek(kInsideBufferPosition);
+
+ ASSERT_EQ(kBufferAllocationSize, segment_stream.getLength());
+}
+
+TEST(SegmentStreamTest, MoveShouldNotSetCleared) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+
+ segment_stream.move(kInsideBufferPosition);
+
+ ASSERT_FALSE(IsCleared(segment_stream));
+}
+
+TEST(SegmentStreamTest, MoveShouldUpdatePosition) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+
+ segment_stream.move(kInsideBufferPosition);
+
+ ASSERT_TRUE(PositionIsInsideBuffer(segment_stream));
+}
+
+TEST(SegmentStreamTest, MoveShouldNotTruncatePositionWhenPastEnd) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_TRUE(PositionIsZero(segment_stream));
+
+ segment_stream.move(kPastEndOfBufferPosition);
+
+ ASSERT_EQ(kPastEndOfBufferPosition, segment_stream.getPosition());
+}
+
+TEST(SegmentStreamTest, MoveShouldNotChangeLength) {
+ SegmentStream segment_stream = CreatePopulatedSegmentStream();
+ ASSERT_TRUE(LengthIsAllocationSize(segment_stream));
+
+ segment_stream.move(kInsideBufferPosition);
+
+ ASSERT_TRUE(LengthIsAllocationSize(segment_stream));
+}
+
+TEST(SegmentStreamTest, HasLengthShouldBeSupported) {
+ blink::SegmentStream segment_stream;
+ ASSERT_TRUE(segment_stream.hasLength());
+}
+
+} // namespace blink
+
+namespace {
+
+testing::AssertionResult IsCleared(const blink::SegmentStream& segment_stream) {
+ if (segment_stream.IsCleared())
+ return testing::AssertionSuccess();
+
+ return testing::AssertionFailure() << "SegmentStream is not clear";
+}
+
+testing::AssertionResult IsAtEnd(const blink::SegmentStream& segment_stream) {
+ if (segment_stream.isAtEnd())
+ return testing::AssertionSuccess();
+
+ return testing::AssertionFailure() << "SegmentStream is not at the end";
+}
+
+testing::AssertionResult PositionIsZero(
+ const blink::SegmentStream& segment_stream) {
+ if (segment_stream.getPosition() == 0ul)
+ return testing::AssertionSuccess();
+
+ return testing::AssertionFailure() << "SegmentStream position is not 0";
+}
+
+testing::AssertionResult PositionIsInsideBuffer(
+ const blink::SegmentStream& segment_stream) {
+ if (segment_stream.getPosition() == kInsideBufferPosition)
+ return testing::AssertionSuccess();
+
+ return testing::AssertionFailure()
+ << "SegmentStream position is not inside the buffer";
+}
+
+testing::AssertionResult PositionIsAtEndOfBuffer(
+ const blink::SegmentStream& segment_stream) {
+ if (segment_stream.getPosition() == kBufferAllocationSize)
+ return testing::AssertionSuccess();
+
+ return testing::AssertionFailure()
+ << "SegmentStream position is not at the end of the buffer";
+}
+
+testing::AssertionResult LengthIsZero(
+ const blink::SegmentStream& segment_stream) {
+ if (segment_stream.getLength() == 0ul)
+ return testing::AssertionSuccess();
+
+ return testing::AssertionFailure() << "SegmentStream length is not 0";
+}
+
+testing::AssertionResult LengthIsAllocationSize(
+ const blink::SegmentStream& segment_stream) {
+ if (segment_stream.getLength() == kBufferAllocationSize)
+ return testing::AssertionSuccess();
+
+ return testing::AssertionFailure()
+ << "SegmentStream length is not the allocation size";
+}
+
+blink::SegmentStream CreatePopulatedSegmentStream() {
+ blink::SegmentStream segment_stream;
+ segment_stream.SetReader(CreateSegmentReader());
+ return segment_stream;
+}
+
+WTF::RefPtr<blink::SegmentReader> CreateSegmentReader() {
+ std::array<char, kBufferAllocationSize> raw_buffer;
+
+ WTF::RefPtr<blink::SharedBuffer> shared_buffer =
+ blink::SharedBuffer::Create(raw_buffer.data(), kBufferAllocationSize);
+
+ WTF::RefPtr<blink::SegmentReader> segment_reader =
+ blink::SegmentReader::CreateFromSharedBuffer(std::move(shared_buffer));
+
+ return segment_reader;
+}
+
+size_t ReadFromSegmentStream(blink::SegmentStream& segment_stream,
+ size_t amount_to_read) {
+ std::array<char, kBufferAllocationSize> read_buffer;
+ return segment_stream.read(read_buffer.data(), amount_to_read);
+}
+
+size_t PeekIntoSegmentStream(blink::SegmentStream& segment_stream,
+ size_t amount_to_peek) {
+ std::array<char, kBufferAllocationSize> peek_buffer;
+ return segment_stream.peek(peek_buffer.data(), amount_to_peek);
+}
+
+} // namespace

Powered by Google App Engine
This is Rietveld 408576698