Index: net/spdy/lifo_write_scheduler_test.cc |
diff --git a/net/spdy/lifo_write_scheduler_test.cc b/net/spdy/lifo_write_scheduler_test.cc |
deleted file mode 100644 |
index 920238b51c675443b54775537393231bf9848de2..0000000000000000000000000000000000000000 |
--- a/net/spdy/lifo_write_scheduler_test.cc |
+++ /dev/null |
@@ -1,146 +0,0 @@ |
-// 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 "net/spdy/lifo_write_scheduler.h" |
- |
-#include "net/spdy/spdy_protocol.h" |
-#include "net/spdy/spdy_test_utils.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-namespace net { |
- |
-namespace test { |
- |
-template <typename StreamIdType> |
-class LifoWriteSchedulerPeer { |
- public: |
- explicit LifoWriteSchedulerPeer(LifoWriteScheduler<StreamIdType>* scheduler) |
- : scheduler_(scheduler) {} |
- |
- size_t NumRegisteredListStreams() const { |
- return scheduler_->registered_streams_.size(); |
- } |
- |
- std::set<StreamIdType>* GetReadyList() const { |
- return &scheduler_->ready_streams_; |
- } |
- |
- private: |
- LifoWriteScheduler<StreamIdType>* scheduler_; |
-}; |
- |
-// Test add and remove from ready list. |
-TEST(LifoWriteSchedulerTest, ReadyListTest) { |
- LifoWriteScheduler<SpdyStreamId> lifo; |
- LifoWriteSchedulerPeer<SpdyStreamId> peer(&lifo); |
- |
- EXPECT_SPDY_BUG( |
- EXPECT_EQ((uint32_t)0, |
- std::get<0>(lifo.PopNextReadyStreamAndPrecedence())), |
- "No ready streams available"); |
- EXPECT_SPDY_BUG(EXPECT_EQ((uint32_t)0, lifo.PopNextReadyStream()), |
- "No ready streams available"); |
- EXPECT_FALSE(lifo.HasReadyStreams()); |
- EXPECT_SPDY_BUG(lifo.MarkStreamReady(9, true), "Stream 9 is not registered"); |
- SpdyStreamPrecedence precedence(1); |
- lifo.RegisterStream(3, precedence); |
- lifo.RegisterStream(7, precedence); |
- lifo.RegisterStream(9, precedence); |
- lifo.RegisterStream(11, precedence); |
- lifo.RegisterStream(13, precedence); |
- lifo.RegisterStream(15, precedence); |
- lifo.RegisterStream(17, precedence); |
- lifo.MarkStreamReady(9, true); |
- lifo.MarkStreamReady(15, true); |
- lifo.MarkStreamReady(7, true); |
- lifo.MarkStreamReady(13, true); |
- lifo.MarkStreamReady(11, true); |
- lifo.MarkStreamReady(3, true); |
- lifo.MarkStreamReady(17, true); |
- EXPECT_TRUE(lifo.HasReadyStreams()); |
- EXPECT_EQ((uint32_t)7, lifo.NumReadyStreams()); |
- |
- EXPECT_SPDY_BUG(lifo.MarkStreamReady(11, true), |
- "Stream already exists in the list"); |
- EXPECT_SPDY_BUG(lifo.MarkStreamNotReady(5), |
- "Try to remove a stream that is not on list"); |
- EXPECT_SPDY_BUG(lifo.MarkStreamNotReady(21), |
- "Try to remove a stream that is not on list"); |
- |
- EXPECT_EQ((uint32_t)17, lifo.PopNextReadyStream()); |
- EXPECT_EQ((uint32_t)15, std::get<0>(lifo.PopNextReadyStreamAndPrecedence())); |
- EXPECT_TRUE(lifo.ShouldYield(9)); |
- EXPECT_FALSE(lifo.ShouldYield(13)); |
- EXPECT_FALSE(lifo.ShouldYield(15)); |
- |
- lifo.MarkStreamNotReady(3); |
- EXPECT_TRUE(peer.GetReadyList()->find(3) == peer.GetReadyList()->end()); |
- lifo.MarkStreamNotReady(13); |
- EXPECT_TRUE(peer.GetReadyList()->find(13) == peer.GetReadyList()->end()); |
- lifo.MarkStreamNotReady(7); |
- EXPECT_TRUE(peer.GetReadyList()->find(7) == peer.GetReadyList()->end()); |
- EXPECT_EQ((uint32_t)2, lifo.NumReadyStreams()); |
-} |
- |
-// Test add and remove from registered list. |
-TEST(LifoWriteSchedulerTest, RegisterListTest) { |
- LifoWriteScheduler<SpdyStreamId> lifo; |
- LifoWriteSchedulerPeer<SpdyStreamId> peer(&lifo); |
- SpdyStreamPrecedence precedence(1); |
- lifo.RegisterStream(3, precedence); |
- lifo.RegisterStream(5, precedence); |
- lifo.RegisterStream(7, precedence); |
- lifo.RegisterStream(9, precedence); |
- lifo.RegisterStream(11, precedence); |
- |
- EXPECT_TRUE(lifo.StreamRegistered(3)); |
- EXPECT_TRUE(lifo.StreamRegistered(5)); |
- EXPECT_TRUE(lifo.StreamRegistered(7)); |
- EXPECT_TRUE(lifo.StreamRegistered(9)); |
- EXPECT_TRUE(lifo.StreamRegistered(11)); |
- EXPECT_SPDY_BUG(lifo.RegisterStream(11, precedence), |
- "Stream 11 already registered"); |
- EXPECT_EQ((uint32_t)5, peer.NumRegisteredListStreams()); |
- |
- lifo.UnregisterStream(3); |
- EXPECT_FALSE(lifo.StreamRegistered(3)); |
- EXPECT_SPDY_BUG(lifo.UnregisterStream(3), "Stream 3 is not registered"); |
- EXPECT_SPDY_BUG(lifo.UnregisterStream(13), "Stream 13 is not registered"); |
- lifo.UnregisterStream(11); |
- EXPECT_FALSE(lifo.StreamRegistered(11)); |
- lifo.UnregisterStream(7); |
- EXPECT_FALSE(lifo.StreamRegistered(7)); |
- EXPECT_TRUE(lifo.StreamRegistered(5)); |
- EXPECT_TRUE(lifo.StreamRegistered(9)); |
-} |
- |
-// Test mark latest event time. |
-TEST(LifoWriteSchedulerTest, GetLatestEventTest) { |
- LifoWriteScheduler<SpdyStreamId> lifo; |
- LifoWriteSchedulerPeer<SpdyStreamId> peer(&lifo); |
- SpdyStreamPrecedence precedence(1); |
- lifo.RegisterStream(1, precedence); |
- lifo.RegisterStream(3, precedence); |
- lifo.RegisterStream(5, precedence); |
- lifo.RegisterStream(7, precedence); |
- lifo.RegisterStream(9, precedence); |
- lifo.RecordStreamEventTime(1, 1); |
- lifo.RecordStreamEventTime(3, 8); |
- lifo.RecordStreamEventTime(5, 4); |
- lifo.RecordStreamEventTime(7, 2); |
- lifo.RecordStreamEventTime(9, 3); |
- EXPECT_SPDY_BUG(lifo.RecordStreamEventTime(11, 1), |
- "Stream 11 is not registered"); |
- EXPECT_EQ(0, lifo.GetLatestEventWithPrecedence(9)); |
- EXPECT_EQ(3, lifo.GetLatestEventWithPrecedence(7)); |
- EXPECT_EQ(3, lifo.GetLatestEventWithPrecedence(5)); |
- EXPECT_EQ(4, lifo.GetLatestEventWithPrecedence(3)); |
- EXPECT_EQ(8, lifo.GetLatestEventWithPrecedence(1)); |
- EXPECT_SPDY_BUG(lifo.GetLatestEventWithPrecedence(11), |
- "Stream 11 is not registered"); |
-} |
- |
-} // namespace test |
- |
-} // namespace net |