Blimp: Add BlobChannel Helium messages and delegate impls.

blimp/net/blob_channel/blob_channel_receiver.h

 // 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.
 
 #ifndef BLIMP_NET_BLOB_CHANNEL_BLOB_CHANNEL_RECEIVER_H_
 #define BLIMP_NET_BLOB_CHANNEL_BLOB_CHANNEL_RECEIVER_H_
 
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/synchronization/lock.h"
 #include "blimp/common/blob_cache/blob_cache.h"
 #include "blimp/net/blimp_message_processor.h"
 #include "blimp/net/blimp_net_export.h"
 
 namespace blimp {
 
 class BlobCache;
 
-// Receives blobs from a remote sender.
 class BLIMP_NET_EXPORT BlobChannelReceiver {
  public:
   class Delegate {

[Wez, 2016/05/24 01:18:40]

Re-reviewing the HeliumBlobReceiverDelegate I was finding this Delegate
arrangement very strange.

The Delegate as you have it here is really a base implementation of a delegate,
and all that it actually does is accept the BlobChannelReceiver and store it, so
the subclass can call OnBlobReceived.

It would be cleaner to have this be a pure interface and let
HeliumBlobReceiverDelegate store the receiver and call it, I think.

[Kevin M, 2016/05/25 00:06:33]

Done.

    public:
     Delegate();
     virtual ~Delegate();
 
+    // Sets the Receiver object which will take incoming blobs.
+    void SetReceiver(BlobChannelReceiver* receiver);
+
    protected:
     // Forwards incoming blob data to |receiver_|.
     void OnBlobReceived(const BlobId& id, BlobDataPtr data);
 
    private:
-    friend class BlobChannelReceiver;
-
-    // Sets the Receiver object which will take incoming blobs.
-    void SetReceiver(BlobChannelReceiver* receiver);
-
     BlobChannelReceiver* receiver_ = nullptr;
 
     DISALLOW_COPY_AND_ASSIGN(Delegate);
   };
 
-  BlobChannelReceiver(std::unique_ptr<BlobCache> cache,
-                      std::unique_ptr<Delegate> delegate);
-  ~BlobChannelReceiver();
+  virtual ~BlobChannelReceiver() {}
+
+  // Constructs a BlobChannelReceiverImpl object for use.
+  static std::unique_ptr<BlobChannelReceiver> Create(
+      std::unique_ptr<BlobCache> cache,
+      std::unique_ptr<Delegate> delegate);
 
   // Gets a blob from the BlobChannel.
   // Returns nullptr if the blob is not available in the channel.
   // Can be accessed concurrently from any thread. Calling code must ensure that
   // the object instance outlives all calls to Get().
-  BlobDataPtr Get(const BlobId& id);
-
- private:
-  friend class Delegate;
+  virtual BlobDataPtr Get(const BlobId& id) = 0;
 
   // Called by Delegate::OnBlobReceived() when a blob arrives over the channel.
-  void OnBlobReceived(const BlobId& id, BlobDataPtr data);
-
-  std::unique_ptr<BlobCache> cache_;
-  std::unique_ptr<Delegate> delegate_;
-
-  // Guards against concurrent access to |cache_|.
-  base::Lock cache_lock_;
-
-  DISALLOW_COPY_AND_ASSIGN(BlobChannelReceiver);
+  virtual void OnBlobReceived(const BlobId& id, BlobDataPtr data) = 0;
 };
 
 }  // namespace blimp
 
 #endif  // BLIMP_NET_BLOB_CHANNEL_BLOB_CHANNEL_RECEIVER_H_