Gather trace data by waiting on handles with a fixed timeout

services/tracing/collector_impl.cc

Index: services/tracing/collector_impl.cc
diff --git a/services/tracing/collector_impl.cc b/services/tracing/collector_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..3f32f88d27f3c3042a50deca4e2c952cd77899e3
--- /dev/null
+++ b/services/tracing/collector_impl.cc
@@ -0,0 +1,29 @@
+// Copyright 2015 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.
+
+#include "services/tracing/collector_impl.h"
+
+namespace tracing {
+
+CollectorImpl::CollectorImpl(mojo::InterfaceRequest<TraceDataCollector> request,
+                             TraceDataSink* sink)
+    : sink_(sink), binding_(this, request.Pass()) {
+}
+
+CollectorImpl::~CollectorImpl() {
+}
+
+void CollectorImpl::TryRead() {
+  binding_.WaitForIncomingMethodCall(MojoDeadline(0));
+}
+
+mojo::Handle CollectorImpl::TraceDataCollectorHandle() const {
+  return binding_.handle();
+}
+
+void CollectorImpl::DataCollected(const mojo::String& json) {
+  sink_->AddChunk(json.To<std::string>());
+}
+
+}  // namespace tracing