Ensure that in-flight message pipes are always closed and the other end is notified.

mojo/edk/system/raw_channel.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 "mojo/edk/system/raw_channel.h"
 
 #include <stddef.h>
 #include <stdint.h>
 #include <string.h>
 #include <algorithm>
@@ skipping 631 matching lines @@
     const char* error_message = nullptr;
     if (!message_view.IsValid(GetSerializedPlatformHandleSize(),
                               &error_message)) {
       DCHECK(error_message);
       LOG(ERROR) << "Received invalid message: " << error_message;
       CallOnError(Delegate::ERROR_READ_BAD_MESSAGE);
       *stop_dispatching = true;
       return;  // |this| may have been destroyed in |CallOnError()|.
     }
 
-    if (message_view.type() != MessageInTransit::Type::MESSAGE) {
+    if (message_view.type() != MessageInTransit::Type::MESSAGE &&
+        message_view.type() != MessageInTransit::Type::QUIT_MESSAGE) {
       if (!OnReadMessageForRawChannel(message_view)) {
         CallOnError(Delegate::ERROR_READ_BAD_MESSAGE);
         *stop_dispatching = true;
         return;  // |this| may have been destroyed in |CallOnError()|.
       }
     } else {
       ScopedPlatformHandleVectorPtr platform_handles;
       if (message_view.transport_data_buffer()) {
         size_t num_platform_handles;
         const void* platform_handle_table;
@@ skipping 61 matching lines @@
   OnReadCompletedNoLock(io_result, bytes_read);
 }
 
 void RawChannel::WillDestroyCurrentMessageLoop() {
   base::AutoLock locker(read_lock_);
   OnReadCompletedNoLock(IO_FAILED_SHUTDOWN, 0);
 }
 
 }  // namespace edk
 }  // namespace mojo