mojo/public/cpp/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_CPP_BINDINGS_SYNC_DISPATCHER_H_
   6 #define MOJO_PUBLIC_CPP_BINDINGS_SYNC_DISPATCHER_H_
   7
   8 #include "mojo/public/cpp/system/core.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 Interface> class SyncDispatcher {
  20  public:
  21   SyncDispatcher(ScopedMessagePipeHandle message_pipe, Interface* sink)
  22       : message_pipe_(message_pipe.Pass()) {
  23     stub_.set_sink(sink);
  24   }
  25
  26   bool WaitAndDispatchOneMessage() {
  27     return WaitForMessageAndDispatch(message_pipe_.get(), &stub_);
  28   }
  29
  30  private:
  31   ScopedMessagePipeHandle message_pipe_;
  32   typename Interface::Stub_ stub_;
  33 };
  34
  35 }  // namespace mojo
  36
  37 #endif  // MOJO_PUBLIC_CPP_BINDINGS_SYNC_DISPATCHER_H_