Index: blimp/engine/mojo/blob_channel_service.cc |
diff --git a/blimp/engine/mojo/blob_channel_service.cc b/blimp/engine/mojo/blob_channel_service.cc |
index 0234df60698b3a2c2628537b7e66cfd9ae44bfd9..7e0d740007bf9b0c4af82f8e96bb70f84a799c43 100644 |
--- a/blimp/engine/mojo/blob_channel_service.cc |
+++ b/blimp/engine/mojo/blob_channel_service.cc |
@@ -4,6 +4,8 @@ |
#include "blimp/engine/mojo/blob_channel_service.h" |
+#include <vector> |
+ |
#include "blimp/net/blob_channel/blob_channel_sender.h" |
namespace blimp { |
@@ -18,6 +20,24 @@ BlobChannelService::BlobChannelService(BlobChannelSender* blob_channel_sender, |
BlobChannelService::~BlobChannelService() {} |
+void BlobChannelService::GetCacheState( |
+ const BlobChannelService::GetCacheStateCallback& callback) { |
+ VLOG(1) << "BlobChannel::GetCacheState called."; |
+ |
+ // Get the cache state & marshal the contents to the Mojo response. |
Wez
2016/06/21 00:33:33
"marshal the contents to ... response" sounds odd
Kevin M
2016/06/21 21:23:51
Done.
|
+ std::vector<BlobChannelSender::CacheState> cache_state = |
+ blob_channel_sender_->GetCacheState(); |
+ auto output = mojo::Array<mojom::CacheStateEntryPtr>::New(cache_state.size()); |
+ for (size_t i = 0; i < cache_state.size(); ++i) { |
+ mojom::CacheStateEntryPtr converted(mojom::CacheStateEntry::New()); |
+ converted->id = cache_state[i].id; |
+ converted->is_replicated = cache_state[i].is_replicated; |
+ output[i] = std::move(converted); |
+ } |
+ |
+ callback.Run(std::move(output)); |
+} |
+ |
void BlobChannelService::PutBlob(const mojo::String& id, |
const mojo::String& data) { |
blob_channel_sender_->PutBlob(id, new BlobData(data)); |