Bootstrapping: Reboot on enrollment failure

components/pairing/proto_decoder.cc

 // Copyright 2014 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 "components/pairing/proto_decoder.h"
 
 #include "components/pairing/pairing_api.pb.h"
 #include "net/base/io_buffer.h"
 
 namespace {
 enum {
   MESSAGE_NONE,
   MESSAGE_HOST_STATUS,
   MESSAGE_CONFIGURE_HOST,
   MESSAGE_PAIR_DEVICES,
   MESSAGE_COMPLETE_SETUP,
   MESSAGE_ERROR,
   MESSAGE_ADD_NETWORK,
+  MESSAGE_REBOOT,
   NUM_MESSAGES,
 };
 }
 
 namespace pairing_chromeos {
 
 ProtoDecoder::ProtoDecoder(Observer* observer)
     : observer_(observer),
       next_message_type_(MESSAGE_NONE),
       next_message_size_(0) {
@@ skipping 76 matching lines @@
         message.ParseFromArray(&buffer[0], buffer.size());
         observer_->OnErrorMessage(message);
       }
       break;
     case MESSAGE_ADD_NETWORK: {
         pairing_api::AddNetwork message;
         message.ParseFromArray(&buffer[0], buffer.size());
         observer_->OnAddNetworkMessage(message);
       }
       break;
+      case MESSAGE_REBOOT: {

[xdai1, 2017/05/23 00:07:50]

the indent is off

+        pairing_api::Reboot message;
+        message.ParseFromArray(&buffer[0], buffer.size());
+        observer_->OnRebootMessage(message);
+      } break;
 
-    default:
-      LOG(WARNING) << "Skipping unknown message type: " << next_message_type_;
-      break;
+      default:
+        LOG(WARNING) << "Skipping unknown message type: " << next_message_type_;
+        break;
   }
 
   // Reset the message data.
   next_message_type_ = MESSAGE_NONE;
   next_message_size_ = 0;
 
   return true;
 }
 
 ProtoDecoder::IOBufferRefPtr ProtoDecoder::SendHostStatus(
@@ skipping 44 matching lines @@
 
 ProtoDecoder::IOBufferRefPtr ProtoDecoder::SendError(
     const pairing_api::Error& message, int* size) {
   std::string serialized_proto;
   if (!message.SerializeToString(&serialized_proto))
     NOTREACHED();
 
   return SendMessage(MESSAGE_ERROR, serialized_proto, size);
 }
 
+ProtoDecoder::IOBufferRefPtr ProtoDecoder::SendRebootHost(
+    const pairing_api::Reboot& message,
+    int* size) {
+  std::string serialized_proto;
+  if (!message.SerializeToString(&serialized_proto))
+    NOTREACHED();
+
+  return SendMessage(MESSAGE_REBOOT, serialized_proto, size);
+}
+
 ProtoDecoder::IOBufferRefPtr ProtoDecoder::SendMessage(
     uint8_t message_type,
     const std::string& message,
     int* size) {
   uint16_t message_size = message.size();
 
   *size = sizeof(message_type) + sizeof(message_size) + message.size();
   IOBufferRefPtr io_buffer(new net::IOBuffer(*size));
 
   // Write the message type.
@@ skipping 11 matching lines @@
   memcpy(&io_buffer->data()[offset], &data, sizeof(data));
   offset += sizeof(data);
 
   // Write the actual message.
   memcpy(&io_buffer->data()[offset], message.data(), message.size());
 
   return io_buffer;
 }
 
 }  // namespace pairing_chromeos