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

services/media/framework/graph.cc

 // Copyright 2016 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/media/framework/graph.h"
 
 namespace mojo {
 namespace media {
 
 Graph::Graph() {
@@ skipping 181 matching lines @@
   DCHECK(input.valid());
   engine_.PrepareInput(input);
 }
 
 void Graph::PrimeSinks() {
   for (Stage* sink : sinks_) {
     sink->Prime();
   }
 }
 
+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);
 
   if (stage->input_count() == 0) {
     sources_.push_back(stage);
   }
 
   if (stage->output_count() == 0) {
     sinks_.push_back(stage);
   }
 
   stage->SetUpdateCallback(update_function_);
 
   return PartRef(stage);
 }
 
 }  // namespace media
 }  // namespace mojo