| Index: blimp/net/blob_channel/blob_channel_receiver.cc
|
| diff --git a/blimp/net/blob_channel/blob_channel_receiver.cc b/blimp/net/blob_channel/blob_channel_receiver.cc
|
| deleted file mode 100644
|
| index 37e8961c7e260130e9aa3aa273c96b432e4a36d3..0000000000000000000000000000000000000000
|
| --- a/blimp/net/blob_channel/blob_channel_receiver.cc
|
| +++ /dev/null
|
| @@ -1,75 +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 "blimp/net/blob_channel/blob_channel_receiver.h"
|
| -
|
| -#include "base/logging.h"
|
| -#include "base/macros.h"
|
| -#include "base/memory/ptr_util.h"
|
| -#include "blimp/common/blob_cache/blob_cache.h"
|
| -#include "blimp/common/blob_cache/id_util.h"
|
| -
|
| -namespace blimp {
|
| -namespace {
|
| -
|
| -// Takes incoming blobs from |delegate_| stores them in |cache_|, and provides
|
| -// callers a getter interface for accessing blobs from |cache_|.
|
| -class BLIMP_NET_EXPORT BlobChannelReceiverImpl : public BlobChannelReceiver {
|
| - public:
|
| - BlobChannelReceiverImpl(std::unique_ptr<BlobCache> cache,
|
| - std::unique_ptr<Delegate> delegate);
|
| - ~BlobChannelReceiverImpl() override;
|
| -
|
| - // BlobChannelReceiver implementation.
|
| - BlobDataPtr Get(const BlobId& id) override;
|
| - void OnBlobReceived(const BlobId& id, BlobDataPtr data) override;
|
| -
|
| - private:
|
| - std::unique_ptr<BlobCache> cache_;
|
| - std::unique_ptr<Delegate> delegate_;
|
| -
|
| - // Guards against concurrent access to |cache_|.
|
| - base::Lock cache_lock_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(BlobChannelReceiverImpl);
|
| -};
|
| -
|
| -} // namespace
|
| -
|
| -// static
|
| -std::unique_ptr<BlobChannelReceiver> BlobChannelReceiver::Create(
|
| - std::unique_ptr<BlobCache> cache,
|
| - std::unique_ptr<Delegate> delegate) {
|
| - return base::WrapUnique(
|
| - new BlobChannelReceiverImpl(std::move(cache), std::move(delegate)));
|
| -}
|
| -
|
| -BlobChannelReceiverImpl::BlobChannelReceiverImpl(
|
| - std::unique_ptr<BlobCache> cache,
|
| - std::unique_ptr<Delegate> delegate)
|
| - : cache_(std::move(cache)), delegate_(std::move(delegate)) {
|
| - DCHECK(cache_);
|
| -
|
| - delegate_->SetReceiver(this);
|
| -}
|
| -
|
| -BlobChannelReceiverImpl::~BlobChannelReceiverImpl() {}
|
| -
|
| -BlobDataPtr BlobChannelReceiverImpl::Get(const BlobId& id) {
|
| - DVLOG(2) << "Get blob: " << BlobIdToString(id);
|
| -
|
| - base::AutoLock lock(cache_lock_);
|
| - return cache_->Get(id);
|
| -}
|
| -
|
| -void BlobChannelReceiverImpl::OnBlobReceived(const BlobId& id,
|
| - BlobDataPtr data) {
|
| - DVLOG(2) << "Blob received: " << BlobIdToString(id)
|
| - << ", size: " << data->data.size();
|
| -
|
| - base::AutoLock lock(cache_lock_);
|
| - cache_->Put(id, data);
|
| -}
|
| -
|
| -} // namespace blimp
|
|
|