Used oneof in blimp_message.proto

blimp/net/blimp_message_multiplexer.cc

 // Copyright 2015 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/net/blimp_message_multiplexer.h"
 
 #include "base/logging.h"
 #include "base/memory/ptr_util.h"
+#include "blimp/common/create_blimp_message.h"
 #include "blimp/common/proto/blimp_message.pb.h"
 #include "blimp/net/blimp_message_processor.h"
 
 namespace blimp {
 namespace {
 
 class MultiplexedSender : public BlimpMessageProcessor {
  public:
   MultiplexedSender(base::WeakPtr<BlimpMessageProcessor> output_processor,
-                    BlimpMessage::Type type);
+                    BlimpMessage::FeatureCase type);

[Kevin M, 2016/05/20 18:28:16]

update name

[shaktisahu, 2016/05/20 22:29:41]

Done.

   ~MultiplexedSender() override;
 
   // BlimpMessageProcessor implementation.
   // |message.type|, if set, must match the sender's type.

[Kevin M, 2016/05/20 18:28:16]

update comment

[shaktisahu, 2016/05/20 22:29:42]

Done.

   void ProcessMessage(std::unique_ptr<BlimpMessage> message,
                       const net::CompletionCallback& callback) override;
 
  private:
   base::WeakPtr<BlimpMessageProcessor> output_processor_;
-  BlimpMessage::Type type_;
+  BlimpMessage::FeatureCase type_;

[Kevin M, 2016/05/20 18:28:16]

update name

[shaktisahu, 2016/05/20 22:29:42]

Done.

 
   DISALLOW_COPY_AND_ASSIGN(MultiplexedSender);
 };
 
 MultiplexedSender::MultiplexedSender(
     base::WeakPtr<BlimpMessageProcessor> output_processor,
-    BlimpMessage::Type type)
+    BlimpMessage::FeatureCase type)

[Kevin M, 2016/05/20 18:28:16]

update param name

[shaktisahu, 2016/05/20 22:29:42]

Done.

     : output_processor_(output_processor), type_(type) {}
 
 MultiplexedSender::~MultiplexedSender() {}
 
 void MultiplexedSender::ProcessMessage(
     std::unique_ptr<BlimpMessage> message,
     const net::CompletionCallback& callback) {
-  if (message->has_type()) {
-    DCHECK_EQ(type_, message->type());
-  } else {
-    message->set_type(type_);
-  }
+  DCHECK_EQ(type_, message->feature_case());
   output_processor_->ProcessMessage(std::move(message), callback);
 }
 
 }  // namespace
 
 BlimpMessageMultiplexer::BlimpMessageMultiplexer(
     BlimpMessageProcessor* output_processor)
     : output_weak_factory_(output_processor) {}
 
 BlimpMessageMultiplexer::~BlimpMessageMultiplexer() {}
 
 std::unique_ptr<BlimpMessageProcessor>
-BlimpMessageMultiplexer::CreateSenderForType(BlimpMessage::Type type) {
+BlimpMessageMultiplexer::CreateSenderForType(
+    BlimpMessage::FeatureCase feature_case) {
   return base::WrapUnique(
-      new MultiplexedSender(output_weak_factory_.GetWeakPtr(), type));
+      new MultiplexedSender(output_weak_factory_.GetWeakPtr(), feature_case));
 }
 }  // namespace blimp