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 {
    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();
+  BlobChannelReceiver();

[Wez, 2016/05/20 21:46:17]

This is a pure interface, so no need for ctor to be declared.

[Kevin M, 2016/05/23 20:48:07]

Done.

+  virtual ~BlobChannelReceiver();

[Wez, 2016/05/20 21:46:17]

Pure interface, so no-op virtual dtor can be declared in-line.

[Kevin M, 2016/05/23 20:48:07]

Done.

 
   // 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);
+  virtual BlobDataPtr Get(const BlobId& id) = 0;
+
+  // Called by Delegate::OnBlobReceived() when a blob arrives over the channel.
+  virtual void OnBlobReceived(const BlobId& id, BlobDataPtr data) = 0;
+};
+
+// Receives blobs from a remote sender.

[Wez, 2016/05/20 21:46:17]

And does what with them? :)

[Kevin M, 2016/05/23 20:48:07]

Done.

+class BLIMP_NET_EXPORT BlobChannelReceiverImpl : public BlobChannelReceiver {

[Wez, 2016/05/20 21:46:17]

Rather than declare this implementation in the header, why not add a static
Create() method to the Receiver interface, and move this into the cc?

[Kevin M, 2016/05/23 20:48:07]

Done.

+ 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:
-  friend class Delegate;
-
-  // 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);
+  DISALLOW_COPY_AND_ASSIGN(BlobChannelReceiverImpl);
 };
 
 }  // namespace blimp
 
 #endif  // BLIMP_NET_BLOB_CHANNEL_BLOB_CHANNEL_RECEIVER_H_