1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #ifndef MOJO_SYSTEM_MESSAGE_PIPE_DISPATCHER_H_
6 #define MOJO_SYSTEM_MESSAGE_PIPE_DISPATCHER_H_
8 #include "base/basictypes.h"
9 #include "base/compiler_specific.h"
10 #include "base/memory/ref_counted.h"
11 #include "mojo/public/system/system_export.h"
12 #include "mojo/system/dispatcher.h"
19 // This is the |Dispatcher| implementation for message pipes (created by the
20 // Mojo primitive |MojoCreateMessagePipe()|). This class is thread-safe.
21 class MOJO_SYSTEM_EXPORT MessagePipeDispatcher : public Dispatcher {
23 MessagePipeDispatcher();
25 // Must be called before any other methods. (This method is not thread-safe.)
26 void Init(scoped_refptr<MessagePipe> message_pipe, unsigned port);
29 friend class base::RefCountedThreadSafe<MessagePipeDispatcher>;
30 virtual ~MessagePipeDispatcher();
32 // |Dispatcher| implementation/overrides:
33 virtual void CancelAllWaitersNoLock() OVERRIDE;
34 virtual MojoResult CloseImplNoLock() OVERRIDE;
35 virtual MojoResult WriteMessageImplNoLock(
38 const MojoHandle* handles,
40 MojoWriteMessageFlags flags) OVERRIDE;
41 virtual MojoResult ReadMessageImplNoLock(
45 uint32_t* num_handles,
46 MojoReadMessageFlags flags) OVERRIDE;
47 virtual MojoResult AddWaiterImplNoLock(Waiter* waiter,
49 MojoResult wake_result) OVERRIDE;
50 virtual void RemoveWaiterImplNoLock(Waiter* waiter) OVERRIDE;
52 // Protected by |lock()|:
53 scoped_refptr<MessagePipe> message_pipe_; // This will be null if closed.
56 DISALLOW_COPY_AND_ASSIGN(MessagePipeDispatcher);
62 #endif // MOJO_SYSTEM_MESSAGE_PIPE_DISPATCHER_H_