src/mojo/public/bindings/sync_dispatcher.h

   1 // Copyright 2014 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.
   4
   5 #ifndef MOJO_PUBLIC_BINDINGS_SYNC_DISPATCHER_H_
   6 #define MOJO_PUBLIC_BINDINGS_SYNC_DISPATCHER_H_
   7
   8 #include "mojo/public/system/core_cpp.h"
   9
  10 namespace mojo {
  11
  12 class MessageReceiver;
  13
  14 // Waits for one message to arrive on the message pipe, and dispatch it to the
  15 // receiver. Returns true on success, false on failure.
  16 bool WaitForMessageAndDispatch(MessagePipeHandle handle,
  17                                mojo::MessageReceiver* receiver);
  18
  19 template<typename S> class SyncDispatcher {
  20  public:
  21   SyncDispatcher(ScopedMessagePipeHandle message_pipe, S* sink)
  22       : message_pipe_(message_pipe.Pass()),
  23         stub_(sink) {
  24   }
  25
  26   bool WaitAndDispatchOneMessage() {
  27     return WaitForMessageAndDispatch(message_pipe_.get(), &stub_);
  28   }
  29
  30  private:
  31   ScopedMessagePipeHandle message_pipe_;
  32   typename S::_Stub stub_;
  33 };
  34
  35 }  // namespace mojo
  36
  37 #endif  // MOJO_PUBLIC_BINDINGS_SYNC_DISPATCHER_H_