[EasyUnlock] Port PermitMessage class to native code.

components/proximity_auth/connection.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/proximity_auth/connection.h"
 
 #include "base/logging.h"
 #include "components/proximity_auth/connection_observer.h"
 #include "components/proximity_auth/wire_message.h"
 
@@ skipping 59 matching lines @@
       ConnectionObserver, observers_, OnSendCompleted(*this, message, success));
 }
 
 void Connection::OnBytesReceived(const std::string& bytes) {
   if (!IsConnected()) {
     VLOG(1) << "Received bytes, but not connected.";
     return;
   }
 
   received_bytes_ += bytes;
-  if (HasReceivedCompleteMessage()) {
-    scoped_ptr<WireMessage> message = DeserializeWireMessage();
-    if (message) {
-      FOR_EACH_OBSERVER(
-          ConnectionObserver, observers_, OnMessageReceived(*this, *message));
-    }
 
-    // Whether the message was parsed successfully or not, clear the
-    // |received_bytes_| buffer.
-    received_bytes_.clear();
+  bool is_incomplete_message;
+  scoped_ptr<WireMessage> message =
+      DeserializeWireMessage(&is_incomplete_message);
+  if (is_incomplete_message)
+    return;
+
+  if (message) {
+    FOR_EACH_OBSERVER(
+        ConnectionObserver, observers_, OnMessageReceived(*this, *message));
   }
+
+  // Whether the message was parsed successfully or not, clear the
+  // |received_bytes_| buffer.
+  received_bytes_.clear();
 }
 
-bool Connection::HasReceivedCompleteMessage() {
-  return WireMessage::IsCompleteMessage(received_bytes_);
-}
-
-scoped_ptr<WireMessage> Connection::DeserializeWireMessage() {
-  return WireMessage::Deserialize(received_bytes_);
+scoped_ptr<WireMessage> Connection::DeserializeWireMessage(
+    bool* is_incomplete_message) {
+  return WireMessage::Deserialize(received_bytes_, is_incomplete_message);
 }
 
 }  // namespace proximity_auth