Gather trace data by waiting on handles with a fixed timeout

mojo/public/cpp/bindings/lib/connector.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_PUBLIC_CPP_BINDINGS_LIB_CONNECTOR_H_
 #define MOJO_PUBLIC_CPP_BINDINGS_LIB_CONNECTOR_H_
 
 #include "mojo/public/c/environment/async_waiter.h"
 #include "mojo/public/cpp/bindings/lib/message_queue.h"
 #include "mojo/public/cpp/bindings/message.h"
@@ skipping 48 matching lines @@
   // quiescent state.
   void CloseMessagePipe();
 
   // Releases the pipe, not triggering the error state. Connector is put into
   // a quiescent state.
   ScopedMessagePipeHandle PassMessagePipe();
 
   // Is the connector bound to a MessagePipe handle?
   bool is_valid() const { return message_pipe_.is_valid(); }
 
-  // Waits for the next message on the pipe, blocking until one arrives or an
-  // error happens. Returns |true| if a message has been delivered, |false|
-  // otherwise.
-  bool WaitForIncomingMessage();
+  // Waits for the next message on the pipe, blocking until one arrives,
+  // |deadline| elapses, or an error happens. Returns |true| if a message has
+  // been delivered, |false| otherwise.
+  bool WaitForIncomingMessage(MojoDeadline deadline);
 
   // MessageReceiver implementation:
   bool Accept(Message* message) override;
 
+  MessagePipeHandle handle() const { return message_pipe_.get(); }
+
  private:
   static void CallOnHandleReady(void* closure, MojoResult result);
   void OnHandleReady(MojoResult result);
 
   void WaitToReadMore();
 
   // Returns false if |this| was destroyed during message dispatch.
   MOJO_WARN_UNUSED_RESULT bool ReadSingleMessage(MojoResult* read_result);
 
   // |this| can be destroyed during message dispatch.
@@ skipping 20 matching lines @@
   // of dispatching an incoming message.
   bool* destroyed_flag_;
 
   MOJO_DISALLOW_COPY_AND_ASSIGN(Connector);
 };
 
 }  // namespace internal
 }  // namespace mojo
 
 #endif  // MOJO_PUBLIC_CPP_BINDINGS_LIB_CONNECTOR_H_