| 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..f7e804ef8ab15bed2f3041c88ad7280c22a2f079
 | 
| --- /dev/null
 | 
| +++ b/third_party/WebKit/Source/platform/image-decoders/SegmentStreamTest.cpp
 | 
| @@ -0,0 +1,735 @@
 | 
| +// 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/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;
 | 
| +constexpr long kFarPastBeginningOfBufferOsset = -60;
 | 
| +
 | 
| +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, ReadShouldNotConsumeBufferWhenCleared) {
 | 
| +  SegmentStream segment_stream = CreatePopulatedSegmentStream();
 | 
| +  // Clear |segment_stream|
 | 
| +  segment_stream.SetReader(nullptr);
 | 
| +  ASSERT_TRUE(IsCleared(segment_stream));
 | 
| +
 | 
| +  const size_t amount_read = ReadFromSegmentStream(segment_stream);
 | 
| +
 | 
| +  ASSERT_EQ(0u, amount_read);
 | 
| +}
 | 
| +
 | 
| +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, PeekShouldNotConsumeBufferWhenCleared) {
 | 
| +  SegmentStream segment_stream = CreatePopulatedSegmentStream();
 | 
| +  // Clear |segment_stream|
 | 
| +  segment_stream.SetReader(nullptr);
 | 
| +  ASSERT_TRUE(IsCleared(segment_stream));
 | 
| +
 | 
| +  const size_t amount_peeked = PeekIntoSegmentStream(segment_stream);
 | 
| +
 | 
| +  ASSERT_EQ(0u, amount_peeked);
 | 
| +}
 | 
| +
 | 
| +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, MoveShouldClampPositionToZeroWhenGoingNegative) {
 | 
| +  SegmentStream segment_stream = CreatePopulatedSegmentStream();
 | 
| +  ReadFromSegmentStream(segment_stream);
 | 
| +  ASSERT_TRUE(PositionIsInsideBuffer);
 | 
| +
 | 
| +  // Move into the negative
 | 
| +  segment_stream.move(kFarPastBeginningOfBufferOsset);
 | 
| +
 | 
| +  ASSERT_TRUE(PositionIsZero(segment_stream));
 | 
| +}
 | 
| +
 | 
| +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
 | 
| 
 |