Index: blimp/net/blob_channel/blob_channel_sender_unittest.cc |
diff --git a/blimp/net/blob_channel/blob_channel_sender_unittest.cc b/blimp/net/blob_channel/blob_channel_sender_unittest.cc |
deleted file mode 100644 |
index e949e2d1eb74920424e95944d2e2abc7c257b99b..0000000000000000000000000000000000000000 |
--- a/blimp/net/blob_channel/blob_channel_sender_unittest.cc |
+++ /dev/null |
@@ -1,117 +0,0 @@ |
-// Copyright 2016 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 <algorithm> |
-#include <memory> |
- |
-#include "base/memory/ptr_util.h" |
-#include "blimp/common/blob_cache/id_util.h" |
-#include "blimp/common/blob_cache/mock_blob_cache.h" |
-#include "blimp/net/blob_channel/blob_channel_sender_impl.h" |
-#include "testing/gmock/include/gmock/gmock.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-using testing::_; |
-using testing::Pointee; |
-using testing::Return; |
-using testing::UnorderedElementsAre; |
- |
-namespace blimp { |
-namespace { |
- |
-const char kBlobId[] = |
- "\x20\x1e\x33\xb2\x2a\xa4\xf5\x5a\x98\xfc\x6b\x5b\x14\xc6\xab\x2b" |
- "\x99\xbc\xcc\x1b\x1c\xa0\xa1\x8a\xf0\x45\x4a\x04\x7f\x6b\x06\x72"; |
-const char kBlobPayload[] = "blob-1-payload"; |
-const char kBlobId2[] = |
- "\x90\x11\x3f\xcf\x1f\xc0\xef\x0a\x72\x11\xe0\x8d\xe4\x74\xd6\xdf" |
- "\x04\x04\x8d\x61\xf0\xa1\xdf\xc2\xc6\xd3\x86\x9f\xfd\x92\x97\xf1"; |
- |
-// Helper function for creating a cache payload vector from a string. |
-BlobDataPtr CreatePayload(const std::string& input) { |
- BlobDataPtr output(new BlobData(input)); |
- return output; |
-} |
- |
-MATCHER_P(BlobDataEqual, expected, "") { |
- return expected->data == arg->data; |
-} |
- |
-class MockSenderDelegate : public BlobChannelSenderImpl::Delegate { |
- public: |
- MockSenderDelegate() {} |
- ~MockSenderDelegate() override {} |
- |
- MOCK_METHOD2(DeliverBlob, void(const BlobId&, BlobDataPtr)); |
-}; |
- |
-class BlobChannelSenderTest : public testing::Test { |
- public: |
- BlobChannelSenderTest() |
- : mock_delegate_(new testing::StrictMock<MockSenderDelegate>), |
- mock_cache_(new testing::StrictMock<MockBlobCache>), |
- blob_sender_( |
- new BlobChannelSenderImpl(base::WrapUnique(mock_cache_), |
- base::WrapUnique(mock_delegate_))) {} |
- ~BlobChannelSenderTest() override {} |
- |
- testing::StrictMock<MockSenderDelegate>* mock_delegate_; |
- testing::StrictMock<MockBlobCache>* mock_cache_; |
- std::unique_ptr<BlobChannelSender> blob_sender_; |
-}; |
- |
-TEST_F(BlobChannelSenderTest, PutBlob) { |
- EXPECT_CALL(*mock_cache_, |
- Put(kBlobId, BlobDataEqual(CreatePayload(kBlobPayload)))); |
- EXPECT_CALL(*mock_cache_, Contains(kBlobId)).WillOnce(Return(false)); |
- blob_sender_->PutBlob(kBlobId, CreatePayload(kBlobPayload)); |
-} |
- |
-TEST_F(BlobChannelSenderTest, PutBlobDuplicate) { |
- EXPECT_CALL(*mock_cache_, Contains(kBlobId)).WillOnce(Return(true)); |
- blob_sender_->PutBlob(kBlobId, CreatePayload(kBlobPayload)); |
-} |
- |
-TEST_F(BlobChannelSenderTest, Push) { |
- auto payload = CreatePayload(kBlobPayload); |
- EXPECT_CALL(*mock_delegate_, DeliverBlob(kBlobId, BlobDataEqual(payload))); |
- EXPECT_CALL(*mock_cache_, Contains(kBlobId)) |
- .WillOnce(Return(false)) |
- .WillOnce(Return(true)); |
- EXPECT_CALL(*mock_cache_, Put(kBlobId, BlobDataEqual(payload))); |
- EXPECT_CALL(*mock_cache_, Get(kBlobId)).WillOnce(Return(payload)); |
- blob_sender_->PutBlob(kBlobId, payload); |
- blob_sender_->DeliverBlob(kBlobId); |
-} |
- |
-TEST_F(BlobChannelSenderTest, GetCachedBlobIds) { |
- std::string blob_id1 = CalculateBlobId(kBlobId); |
- std::string blob_id2 = CalculateBlobId(kBlobId2); |
- BlobDataPtr blob_payload1 = CreatePayload(kBlobPayload); |
- |
- EXPECT_CALL(*mock_cache_, Contains(blob_id1)).WillOnce(Return(true)); |
- EXPECT_CALL(*mock_cache_, Get(blob_id1)).WillOnce(Return(blob_payload1)); |
- |
- std::vector<BlobId> cache_state; |
- cache_state.push_back(blob_id1); |
- cache_state.push_back(blob_id2); |
- |
- EXPECT_CALL(*mock_cache_, GetCachedBlobIds()).WillOnce(Return(cache_state)); |
- EXPECT_CALL(*mock_delegate_, |
- DeliverBlob(blob_id1, BlobDataEqual(blob_payload1))); |
- |
- // Mark one of the blobs as delivered. |
- blob_sender_->DeliverBlob(blob_id1); |
- |
- std::vector<BlobChannelSender::CacheStateEntry> actual = |
- blob_sender_->GetCachedBlobIds(); |
- EXPECT_EQ(2u, actual.size()); |
- EXPECT_EQ(blob_id1, actual[0].id); |
- EXPECT_TRUE(actual[0].was_delivered); |
- EXPECT_EQ(blob_id2, actual[1].id); |
- EXPECT_FALSE(actual[1].was_delivered); |
-} |
- |
-} // namespace |
-} // namespace blimp |