| 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
 | 
| 
 |