Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "blimp/net/blob_channel/helium_blob_receiver_delegate.h" | |
| 6 | |
| 7 #include "blimp/common/blob_cache/blob_cache.h" | |
| 8 #include "blimp/common/proto/blimp_message.pb.h" | |
| 9 #include "blimp/common/proto/blob_channel.pb.h" | |
| 10 #include "net/base/net_errors.h" | |
| 11 | |
| 12 namespace blimp { | |
| 13 | |
| 14 HeliumBlobReceiverDelegate::HeliumBlobReceiverDelegate() {} | |
| 15 | |
| 16 HeliumBlobReceiverDelegate::~HeliumBlobReceiverDelegate() {} | |
| 17 | |
| 18 void HeliumBlobReceiverDelegate::ProcessMessage( | |
| 19 std::unique_ptr<BlimpMessage> message, | |
| 20 const net::CompletionCallback& callback) { | |
| 21 if (!message->has_blob_channel()) { | |
| 22 DLOG(WARNING) << "BlobChannel message has no |blob_channel| submessage."; | |
| 23 callback.Run(net::ERR_INVALID_ARGUMENT); | |
| 24 return; | |
| 25 } | |
| 26 | |
| 27 BlobChannelMessage* blob_msg = message->mutable_blob_channel(); | |
|
Wez
2016/05/20 21:46:18
nit: Comment here to explain why you take a mutabl
Kevin M
2016/05/23 20:48:07
Done.
| |
| 28 if (blob_msg->type() != BlobChannelMessage::TRANSFER_BLOB) { | |
| 29 callback.Run(net::ERR_NOT_IMPLEMENTED); | |
| 30 return; | |
| 31 } | |
| 32 | |
| 33 if (blob_msg->blob_id().empty()) { | |
| 34 callback.Run(net::ERR_INVALID_ARGUMENT); | |
| 35 return; | |
| 36 } | |
| 37 | |
| 38 // Create a temporarily non-const BlobData so that we may efficiently reuse | |
| 39 // the allocated payload string via string::swap(). | |
| 40 // | |
| 41 // BlobData becomes const once it is implicitly cast to a BlobDataPtr | |
| 42 // during the call to OnBlobReceived(). | |
|
Wez
2016/05/20 21:46:18
I think the point here is that we don't store it t
Kevin M
2016/05/23 20:48:07
Done.
| |
| 43 scoped_refptr<BlobData> blob_data(new BlobData); | |
| 44 blob_data->data.swap(*blob_msg->mutable_payload()); | |
| 45 OnBlobReceived(blob_msg->blob_id(), blob_data); | |
| 46 | |
| 47 callback.Run(net::OK); | |
| 48 } | |
| 49 | |
| 50 } // namespace blimp | |
| OLD | NEW |