mojo::RawChannelWin: Use GetOverlappedResult() to retrive read bytes.

mojo/system/raw_channel_win.cc

 // Copyright 2013 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 "mojo/system/raw_channel.h"
 
 #include <windows.h>
 
 #include "base/auto_reset.h"
 #include "base/bind.h"
@@ skipping 353 matching lines @@
 
 RawChannel::IOResult RawChannelWin::Read(size_t* bytes_read) {
   DCHECK_EQ(base::MessageLoop::current(), message_loop_for_io());
   DCHECK(io_handler_);
   DCHECK(!io_handler_->pending_read());
 
   char* buffer = nullptr;
   size_t bytes_to_read = 0;
   read_buffer()->GetBuffer(&buffer, &bytes_to_read);
 
-  DWORD bytes_read_dword = 0;
   BOOL result = ReadFile(io_handler_->handle(),
                          buffer,
                          static_cast<DWORD>(bytes_to_read),
-                         &bytes_read_dword,
+                         NULL,

[viettrungluu, 2014/09/30 19:07:40]

nullptr

                          &io_handler_->read_context()->overlapped);
   if (!result) {
-    DCHECK_EQ(bytes_read_dword, 0u);
     DWORD error = GetLastError();
     if (error == ERROR_BROKEN_PIPE)
       return IO_FAILED_SHUTDOWN;
     if (error != ERROR_IO_PENDING) {
       LOG(WARNING) << "ReadFile: " << logging::SystemErrorCodeToString(error);
       return IO_FAILED_UNKNOWN;
     }
   }
 
   if (result && skip_completion_port_on_success_) {
+    DWORD bytes_read_dword = 0;
+    BOOL get_size_result =
+        GetOverlappedResult(io_handler_->handle(),
+                            &io_handler_->read_context()->overlapped,
+                            &bytes_read_dword,
+                            FALSE);
+    DPCHECK(get_size_result);
     *bytes_read = bytes_read_dword;
     return IO_SUCCEEDED;
   }
 
   // If the read is pending or the read has succeeded but we don't skip
   // completion port on success, instruct |io_handler_| to wait for the
   // completion packet.
   //
   // TODO(yzshen): It seems there isn't document saying that all error cases
   // (other than ERROR_IO_PENDING) are guaranteed to *not* queue a completion
@@ skipping 169 matching lines @@
 
 // Static factory method declared in raw_channel.h.
 // static
 scoped_ptr<RawChannel> RawChannel::Create(
     embedder::ScopedPlatformHandle handle) {
   return make_scoped_ptr(new RawChannelWin(handle.Pass()));
 }
 
 }  // namespace system
 }  // namespace mojo