Create DispatchSourceMach to run a MACH_RECV dispatch source.

sandbox/mac/mach_message_server.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 SANDBOX_MAC_MACH_MESSAGE_SERVER_H_
 #define SANDBOX_MAC_MACH_MESSAGE_SERVER_H_
 
-#include <dispatch/dispatch.h>
 #include <mach/mach.h>
 
 #include "base/mac/scoped_mach_port.h"
 #include "base/mac/scoped_mach_vm.h"
+#include "base/memory/scoped_ptr.h"
 #include "sandbox/mac/message_server.h"
 
 namespace sandbox {
 
+class DispatchSourceMach;
+
 // A Mach message server that operates a receive port. Messages are received
 // and then passed to the MessageDemuxer for handling. The Demuxer
 // can use the server class to send a reply, forward the message to a
 // different port, or reply to the message with a MIG error.
 class MachMessageServer : public MessageServer {
  public:
   // Creates a new Mach message server that will send messages to |demuxer|
   // for handling. If the |server_receive_right| is non-NULL, this class will
   // take ownership of the port and it will be used to receive messages.
   // Otherwise the server will create a new receive right.
@@ skipping 19 matching lines @@
   // Event handler for the |server_source_| that reads a message from the queue
   // and processes it.
   void ReceiveMessage();
 
   // The demuxer delegate. Weak.
   MessageDemuxer* demuxer_;
 
   // The Mach port on which the server is receiving requests.
   base::mac::ScopedMachReceiveRight server_port_;
 
-  // The dispatch queue used to service the server_source_.
-  dispatch_queue_t server_queue_;
-
-  // A MACH_RECV dispatch source for the server_port_.
-  dispatch_source_t server_source_;
-
-  // Semaphore used to wait on the |server_source_|'s cancellation in the
-  // destructor.
-  dispatch_semaphore_t source_canceled_;
-
   // The size of the two message buffers below.
   const mach_msg_size_t buffer_size_;
 
   // Request and reply buffers used in ReceiveMessage.
   base::mac::ScopedMachVM request_buffer_;
   base::mac::ScopedMachVM reply_buffer_;
 
+  // MACH_RECV dispatch source that handles the |server_port_|.
+  scoped_ptr<DispatchSourceMach> dispatch_source_;
+
   // Whether or not ForwardMessage() was called during ReceiveMessage().
   bool did_forward_message_;
 };
 
 }  // namespace sandbox
 
 #endif  // SANDBOX_MAC_MACH_MESSAGE_SERVER_H_