Add Mojo IPC for seeding new Renderer with Browser's cached blob state.

blimp/engine/renderer/blob_channel_sender_proxy.cc

 // 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/engine/renderer/blob_channel_sender_proxy.h"
 
 #include "content/public/renderer/render_thread.h"
 #include "services/shell/public/cpp/interface_provider.h"
 
 namespace blimp {
 namespace engine {
 namespace {
 
 mojom::BlobChannelPtr GetConnectedBlobChannel() {
   mojom::BlobChannelPtr blob_channel_ptr;
   content::RenderThread::Get()->GetRemoteInterfaces()->GetInterface(
       &blob_channel_ptr);
   CHECK(blob_channel_ptr) << "Could not connect to BlobChannel Mojo interface.";
   return blob_channel_ptr;
 }
 
 }  // namespace
 
 BlobChannelSenderProxy::BlobChannelSenderProxy()
-    : blob_channel_(GetConnectedBlobChannel()) {}
+    : blob_channel_(GetConnectedBlobChannel()), weak_factory_(this) {
+  // TODO(kmarshall): Switch to observer push model (vs. the current pull model)
+  // once cache invalidations are introduced.
+  blob_channel_->GetCachedBlobIds(
+      base::Bind(&BlobChannelSenderProxy::OnGetCacheStateComplete,
+                 weak_factory_.GetWeakPtr()));
+}
 
 BlobChannelSenderProxy::~BlobChannelSenderProxy() {}
 
 bool BlobChannelSenderProxy::IsInEngineCache(const std::string& id) const {
   return replication_state_.find(id) != replication_state_.end();
 }
 
 bool BlobChannelSenderProxy::IsInClientCache(const std::string& id) const {
   return replication_state_.find(id)->second;
 }
 
 void BlobChannelSenderProxy::PutBlob(const BlobId& id, BlobDataPtr data) {
   DCHECK(!IsInEngineCache(id));
 
   replication_state_[id] = false;
   blob_channel_->PutBlob(id, data->data);
 }
 
 void BlobChannelSenderProxy::DeliverBlob(const std::string& id) {
   DCHECK(!IsInClientCache(id));
 
   // We assume that the client will have the blob if we push it.
   // TODO(kmarshall): Revisit this assumption when asynchronous blob transport
   // is supported.
   replication_state_[id] = true;
 
   blob_channel_->DeliverBlob(id);
 }
 
+std::vector<BlobChannelSender::CacheStateEntry>
+BlobChannelSenderProxy::GetCachedBlobIds() const {
+  NOTREACHED();
+  return std::vector<BlobChannelSender::CacheStateEntry>();
+}
+
+void BlobChannelSenderProxy::OnGetCacheStateComplete(
+    mojo::Array<mojom::CacheStateEntryPtr> cache_state) {
+  VLOG(1) << "Received cache state from browser (" << cache_state.size()
+          << " items)";
+  replication_state_.clear();

[dcheng, 2016/06/28 21:34:52]

Are there callbacks to update this state later? I'm just wondering if this will
collide with mutations in DeliverBlob() above.

[Kevin M, 2016/06/29 21:01:22]

For now, this is called only once at the beginning of the renderer process'
lifetime, so we don't need to worry about collisions.

As the (temporary, in-memory) cache doesn't yet support evictions, we don't have
to add any listeners for cache invalidation events. When we do implement an
actual cache, we'll have to do it - probably by passing a delegate Interface
that allows the browser to push the cache state delta to the renderer.

+  for (const auto& next_item : cache_state) {
+    replication_state_[next_item->id] = next_item->was_delivered;
+  }
+}
+
 }  // namespace engine
 }  // namespace blimp