Add a Mojo EDK for Chrome that uses one OS pipe per message pipe.

mojo/edk/system/message_in_transit.h

 // 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.
 
 #ifndef MOJO_EDK_SYSTEM_MESSAGE_IN_TRANSIT_H_
 #define MOJO_EDK_SYSTEM_MESSAGE_IN_TRANSIT_H_
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <ostream>
 #include <vector>
 
 #include "base/memory/aligned_memory.h"
 #include "base/memory/scoped_ptr.h"
-#include "mojo/edk/system/channel_endpoint_id.h"
 #include "mojo/edk/system/dispatcher.h"
 #include "mojo/edk/system/memory.h"
 #include "mojo/edk/system/system_impl_export.h"
 #include "mojo/public/cpp/system/macros.h"
 
 namespace mojo {
 namespace system {
 
-class Channel;
+class RawChannel;
 class TransportData;
 
 // This class is used to represent data in transit. It is thread-unsafe.
 //
 // |MessageInTransit| buffers:
 //
 // A |MessageInTransit| can be serialized by writing the main buffer and then,
 // if it has one, the transport data buffer. Both buffers are
 // |kMessageAlignment|-byte aligned and a multiple of |kMessageAlignment| bytes
 // in size.
 //
 // The main buffer consists of the header (of type |Header|, which is an
 // internal detail of this class) followed immediately by the message data
 // (accessed by |bytes()| and of size |num_bytes()|, and also
 // |kMessageAlignment|-byte aligned), and then any padding needed to make the
 // main buffer a multiple of |kMessageAlignment| bytes in size.
 //
 // See |TransportData| for a description of the (serialized) transport data
 // buffer.
 class MOJO_SYSTEM_IMPL_EXPORT MessageInTransit {
  public:
   enum class Type : uint16_t {
-    // Messages that are forwarded to endpoint clients.
-    ENDPOINT_CLIENT = 0,
-    // Messages that are consumed by the |ChannelEndpoint|.
-    ENDPOINT = 1,
-    // Messages that are consumed by the |Channel|.
-    CHANNEL = 2,
-    // Messages that are consumed by the |RawChannel| (implementation).
-    RAW_CHANNEL = 3,
-    // |ConnectionManager| implementations also use |RawChannel|s.
-    // Messages sent to a |MasterConnectionManager|.
-    CONNECTION_MANAGER = 4,
-    // Messages sent by a |MasterConnectionManager| (all responses).
-    CONNECTION_MANAGER_ACK = 5,
-  };
-
-  enum class Subtype : uint16_t {
-    // Subtypes for type |Type::ENDPOINT_CLIENT|:
-    // Message pipe or data pipe data (etc.).
-    ENDPOINT_CLIENT_DATA = 0,
-    // Data pipe: consumer -> producer message that data was consumed. Payload
-    // is |RemoteDataPipeAck|.
-    ENDPOINT_CLIENT_DATA_PIPE_ACK = 1,
-    // Subtypes for type |Type::ENDPOINT|:
-    // TODO(vtl): Nothing yet.
-    // Subtypes for type |Type::CHANNEL|:
-    CHANNEL_ATTACH_AND_RUN_ENDPOINT = 0,
-    CHANNEL_REMOVE_ENDPOINT = 1,
-    CHANNEL_REMOVE_ENDPOINT_ACK = 2,
-    // Subtypes for type |Type::RAW_CHANNEL|:
-    RAW_CHANNEL_POSIX_EXTRA_PLATFORM_HANDLES = 0,
-    // Subtypes for type |Type::CONNECTION_MANAGER| (the message data is always
-    // a buffer containing the connection ID):
-    CONNECTION_MANAGER_ALLOW_CONNECT = 0,
-    CONNECTION_MANAGER_CANCEL_CONNECT = 1,
-    CONNECTION_MANAGER_CONNECT = 2,
-    // Subtypes for type |Type::CONNECTION_MANAGER_ACK|, corresponding to
-    // |ConnectionManager::Result| values (failure and non-"connect" acks never
-    // have any message contents; success acks for "connect" always have a
-    // |ConnectionManagerAckSuccessConnectData| as data and also a platform
-    // handle attached for "new connection"):
-    CONNECTION_MANAGER_ACK_FAILURE = 0,
-    CONNECTION_MANAGER_ACK_SUCCESS = 1,
-    CONNECTION_MANAGER_ACK_SUCCESS_CONNECT_SAME_PROCESS = 2,
-    CONNECTION_MANAGER_ACK_SUCCESS_CONNECT_NEW_CONNECTION = 3,
-    CONNECTION_MANAGER_ACK_SUCCESS_CONNECT_REUSE_CONNECTION = 4,
+    MESSAGE = 0,
+    RAW_CHANNEL_POSIX_EXTRA_PLATFORM_HANDLES = 1,
+    RAW_CHANNEL_QUIT = 2,
   };
 
   // Messages (the header and data) must always be aligned to a multiple of this
   // quantity (which must be a power of 2).
   static const size_t kMessageAlignment = 8;
 
   // Forward-declare |Header| so that |View| can use it:
  private:
   struct Header;
 
@@ skipping 31 matching lines @@
     }
     size_t transport_data_buffer_size() const {
       return total_size() - main_buffer_size();
     }
     size_t total_size() const { return header()->total_size; }
     uint32_t num_bytes() const { return header()->num_bytes; }
     const void* bytes() const {
       return static_cast<const char*>(buffer_) + sizeof(Header);
     }
     Type type() const { return header()->type; }
-    Subtype subtype() const { return header()->subtype; }
-    ChannelEndpointId source_id() const { return header()->source_id; }
-    ChannelEndpointId destination_id() const {
-      return header()->destination_id;
-    }
 
    private:
     const Header* header() const { return static_cast<const Header*>(buffer_); }
 
     const void* const buffer_;
 
     // Though this struct is trivial, disallow copy and assign, since it doesn't
     // own its data. (If you're copying/assigning this, you're probably doing
     // something wrong.)
     MOJO_DISALLOW_COPY_AND_ASSIGN(View);
   };
 
   // |bytes| is optional; if null, the message data will be zero-initialized.
   MessageInTransit(Type type,
-                   Subtype subtype,
                    uint32_t num_bytes,
                    const void* bytes);
   // |bytes| should be valid (and non-null), unless |num_bytes| is zero.
   MessageInTransit(Type type,
-                   Subtype subtype,
                    uint32_t num_bytes,
                    UserPointer<const void> bytes);
   // Constructs a |MessageInTransit| from a |View|.
   explicit MessageInTransit(const View& message_view);
 
   ~MessageInTransit();
 
   // Gets the size of the next message from |buffer|, which has |buffer_size|
   // bytes currently available, returning true and setting |*next_message_size|
   // on success. |buffer| should be aligned on a |kMessageAlignment| boundary
@@ skipping 12 matching lines @@
   void SetDispatchers(scoped_ptr<DispatcherVector> dispatchers);
 
   // Sets the |TransportData| for this message. This should only be done when
   // there are no dispatchers and no existing |TransportData|.
   void SetTransportData(scoped_ptr<TransportData> transport_data);
 
   // Serializes any dispatchers to the secondary buffer. This message must not
   // already have a secondary buffer (so this must only be called once). The
   // caller must ensure (e.g., by holding on to a reference) that |channel|
   // stays alive through the call.
-  void SerializeAndCloseDispatchers(Channel* channel);
+  void SerializeAndCloseDispatchers();
 
   // Gets the main buffer and its size (in number of bytes), respectively.
   const void* main_buffer() const { return main_buffer_.get(); }
   size_t main_buffer_size() const { return main_buffer_size_; }
 
   // Gets the transport data buffer (if any).
   const TransportData* transport_data() const { return transport_data_.get(); }
   TransportData* transport_data() { return transport_data_.get(); }
 
   // Gets the total size of the message (see comment in |Header|, below).
   size_t total_size() const { return header()->total_size; }
 
   // Gets the size of the message data.
   uint32_t num_bytes() const { return header()->num_bytes; }
 
   // Gets the message data (of size |num_bytes()| bytes).
   const void* bytes() const { return main_buffer_.get() + sizeof(Header); }
   void* bytes() { return main_buffer_.get() + sizeof(Header); }
 
   Type type() const { return header()->type; }
-  Subtype subtype() const { return header()->subtype; }
-  ChannelEndpointId source_id() const { return header()->source_id; }
-  ChannelEndpointId destination_id() const { return header()->destination_id; }
-
-  void set_source_id(ChannelEndpointId source_id) {
-    header()->source_id = source_id;
-  }
-  void set_destination_id(ChannelEndpointId destination_id) {
-    header()->destination_id = destination_id;
-  }
 
   // Gets the dispatchers attached to this message; this may return null if
   // there are none. Note that the caller may mutate the set of dispatchers
   // (e.g., take ownership of all the dispatchers, leaving the vector empty).
   DispatcherVector* dispatchers() { return dispatchers_.get(); }
 
   // Returns true if this message has dispatchers attached.
   bool has_dispatchers() const {
     return dispatchers_ && !dispatchers_->empty();
   }
@@ skipping 10 matching lines @@
   // Header for the data (main buffer). Must be a multiple of
   // |kMessageAlignment| bytes in size. Must be POD.
   struct Header {
     // Total size of the message, including the header, the message data
     // ("bytes") including padding (to make it a multiple of |kMessageAlignment|
     // bytes), and serialized handle information. Note that this may not be the
     // correct value if dispatchers are attached but
     // |SerializeAndCloseDispatchers()| has not been called.
     uint32_t total_size;
     Type type;                         // 2 bytes.
-    Subtype subtype;                   // 2 bytes.
-    ChannelEndpointId source_id;       // 4 bytes.
-    ChannelEndpointId destination_id;  // 4 bytes.
-    // Size of actual message data.
+    Type blahblahforalignment;                         // 2 bytes.
     uint32_t num_bytes;
     uint32_t unused;
   };
 
   const Header* header() const {
     return reinterpret_cast<const Header*>(main_buffer_.get());
   }
   Header* header() { return reinterpret_cast<Header*>(main_buffer_.get()); }
 
-  void ConstructorHelper(Type type, Subtype subtype, uint32_t num_bytes);
+  void ConstructorHelper(Type type, uint32_t num_bytes);
   void UpdateTotalSize();
 
   const size_t main_buffer_size_;
   const scoped_ptr<char, base::AlignedFreeDeleter> main_buffer_;  // Never null.
 
   scoped_ptr<TransportData> transport_data_;  // May be null.
 
   // Any dispatchers that may be attached to this message. These dispatchers
   // should be "owned" by this message, i.e., have a ref count of exactly 1. (We
   // allow a dispatcher entry to be null, in case it couldn't be duplicated for
   // some reason.)
   scoped_ptr<DispatcherVector> dispatchers_;
 
   MOJO_DISALLOW_COPY_AND_ASSIGN(MessageInTransit);
 };
 
 // So logging macros and |DCHECK_EQ()|, etc. work.
 MOJO_SYSTEM_IMPL_EXPORT inline std::ostream& operator<<(
     std::ostream& out,
     MessageInTransit::Type type) {
   return out << static_cast<uint16_t>(type);
 }
 
-// So logging macros and |DCHECK_EQ()|, etc. work.
-MOJO_SYSTEM_IMPL_EXPORT inline std::ostream& operator<<(
-    std::ostream& out,
-    MessageInTransit::Subtype subtype) {
-  return out << static_cast<uint16_t>(subtype);
-}
-
 }  // namespace system
 }  // namespace mojo
 
 #endif  // MOJO_EDK_SYSTEM_MESSAGE_IN_TRANSIT_H_