Motown: Framework parts for mojo transport (producer/consumer/mediapipe) and control (audiotrack).

services/media/framework/graph.cc

Index: services/media/framework/graph.cc
diff --git a/services/media/framework/graph.cc b/services/media/framework/graph.cc
index 794985d2823bc0fea7e534dd5e2d34070237fa07..d5d0539eb31b59997bd7552bfc4ea4cdd9388571 100644
--- a/services/media/framework/graph.cc
+++ b/services/media/framework/graph.cc
@@ -199,6 +199,22 @@ void Graph::PrimeSinks() {
   }
 }
 
+void Graph::FlushOutput(const OutputRef& output) {
+  DCHECK(output);
+  engine_.FlushOutput(output);
+}
+
+void Graph::FlushAllOutputs(PartRef part) {
+  DCHECK(part.valid());
+  size_t output_count = part.output_count();
+  for (size_t output_index = 0; output_index < output_count; output_index++) {
+    const OutputRef& output = part.output(output_index);
+    if (output.connected()) {

[johngro, 2016/02/23 00:49:42]

if the output.connected() check is important, perhaps it would be good to move
this guard into Graph::FlushOutput so it is protected as well (or even bury it
all the way in Engine::FlushOutput).

Then, this code could become..

for (...) {
  FlushOutput(part.output(output_index));
}

[dalesat, 2016/02/23 20:34:34]

Done.

+      FlushOutput(output);
+    }
+  }
+}
+
 PartRef Graph::Add(Stage* stage) {
   stages_.push_back(stage);