The Windows portion of Native Messagaing

chrome/browser/extensions/api/messaging/native_message_process_host_posix.cc

 // Copyright (c) 2012 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 "chrome/browser/extensions/api/messaging/native_message_process_host.h"
 
 #include <unistd.h>
 
 #include "base/logging.h"
 #include "base/process_util.h"
 #include "content/public/browser/browser_thread.h"
 
 namespace extensions {
 
 void NativeMessageProcessHost::ReadNowForTesting() {
   OnFileCanReadWithoutBlocking(read_file_);
 }
 
 void NativeMessageProcessHost::InitIO() {
   // Always watch the read end.
   MessageLoopForIO::current()->WatchFileDescriptor(read_file_,
                                                    true, /* persistent */
                                                    MessageLoopForIO::WATCH_READ,
                                                    &read_watcher_,
                                                    this);
 }
 
+void NativeMessageProcessHost::StopIO() {
+  read_watcher_.StopWatchingFileDescriptor();
+}
+
+bool NativeMessageProcessHost::ReadMessage(MessageType* type,
+                                           std::string* message) {
+  // Read the type (uint32) and length (uint32).
+  char message_meta_data[8];
+  if (!file_util::ReadFromFD(read_file_, message_meta_data, 8)) {
+    LOG(ERROR) << "Error reading the message type and length.";
+    return false;
+  }
+
+  uint32 message_length;
+  if (!VerifyMessageMetaData(message_meta_data, type, &message_length))
+    return false;
+
+  message->resize(message_length, '\0');
+  if (!file_util::ReadFromFD(read_file_, &(*message)[0], message_length)) {
+    LOG(ERROR) << "Error reading the json data.";
+    return false;
+  }
+
+  return true;
+}
+
 void NativeMessageProcessHost::OnFileCanReadWithoutBlocking(int fd) {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::FILE));
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
 
   // Make sure that the fd given to us is the same one we started with.
   CHECK_EQ(fd, read_file_);
 
   // If this is a sendMessage request, stop trying to read after the first
   // message.
   if (is_send_message_)
     read_watcher_.StopWatchingFileDescriptor();
 
   MessageType type;
@@ skipping 15 matching lines @@
       base::Bind(&Client::PostMessageFromNativeProcess, weak_client_ui_,
                  destination_port_, message));
 }
 
 bool NativeMessageProcessHost::WriteData(FileHandle file,
                                          const char* data,
                                          size_t bytes_to_write) {
   return file_util::WriteFileDescriptor(file, data, bytes_to_write);
 }
 
-bool NativeMessageProcessHost::ReadData(FileHandle file,
-                                        char* data,
-                                        size_t bytes_to_read) {
-  return file_util::ReadFromFD(file, data, bytes_to_read);
-}
-
 }  // namespace extensions