ChannelMojo: Handle errors in pending message processing.

ipc/mojo/ipc_message_pipe_reader.h

 // 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.
 
 #ifndef IPC_IPC_MESSAGE_PIPE_READER_H_
 #define IPC_IPC_MESSAGE_PIPE_READER_H_
 
 #include <vector>
 
 #include "base/memory/scoped_ptr.h"
+#include "ipc/ipc_export.h"
 #include "mojo/public/c/environment/async_waiter.h"
 #include "mojo/public/cpp/system/core.h"
 
 namespace IPC {
 namespace internal {
 
 // A helper class to handle bytestream directly over mojo::MessagePipe
 // in template-method pattern. MessagePipeReader manages the lifetime
 // of given MessagePipe and participates the event loop, and
 // read the stream and call the client when it is ready.
 //
 // Each client has to:
 //
 //  * Provide a subclass implemenation of a specific use of a MessagePipe
 //    and implement callbacks.
 //  * Create the subclass instance with a MessagePipeHandle.
 //    The constructor automatically start listening on the pipe.
 //
 // MessageReader has to be used in IO thread. It isn't thread-safe.
 //
-class MessagePipeReader {
+class IPC_MOJO_EXPORT MessagePipeReader {
  public:
   // Delay the object deletion using the current message loop.
   // This is intended to used by MessagePipeReader owners.
   class DelayedDeleter {
    public:
     typedef base::DefaultDeleter<MessagePipeReader> DefaultType;
 
     static void DeleteNow(MessagePipeReader* ptr) { delete ptr; }
 
     DelayedDeleter() {}
@@ skipping 47 matching lines @@
   MojoAsyncWaitID pipe_wait_id_;
   mojo::ScopedMessagePipeHandle pipe_;
 
   DISALLOW_COPY_AND_ASSIGN(MessagePipeReader);
 };
 
 }  // namespace internal
 }  // namespace IPC
 
 #endif  // IPC_IPC_MESSAGE_PIPE_READER_H_