[Chromecast] Complete PostProcessingPipeline changes

chromecast/media/cma/backend/alsa/post_processing_pipeline_parser.h

 // Copyright 2017 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 CHROMECAST_MEDIA_CMA_BACKEND_ALSA_POST_PROCESSING_PIPELINE_PARSER_H_
 #define CHROMECAST_MEDIA_CMA_BACKEND_ALSA_POST_PROCESSING_PIPELINE_PARSER_H_
 
 #include <memory>
 #include <string>
+#include <unordered_set>
+#include <vector>
 
 #include "base/macros.h"
 
 namespace base {
 class DictionaryValue;
 class ListValue;
 }  // namespace base
 
 namespace chromecast {
 namespace media {
 
+// Helper class to hold information about a stream pipeline.
+struct StreamPipelineDescriptor {
+  // The format for pipeline is:
+  // [ {"processor": "PATH_TO_SHARED_OBJECT",
+  //    "config": "CONFIGURATION_STRING"},
+  //   {"processor": "PATH_TO_SHARED_OBJECT",
+  //    "config": "CONFIGURATION_STRING"},
+  //    ... ]
+  base::ListValue* pipeline;
+  std::unordered_set<std::string> stream_types;
+
+  StreamPipelineDescriptor(
+      base::ListValue* pipeline_in,
+      const std::unordered_set<std::string>& stream_types_in);
+  ~StreamPipelineDescriptor();
+  StreamPipelineDescriptor(const StreamPipelineDescriptor& other);
+  StreamPipelineDescriptor operator=(const StreamPipelineDescriptor& other) =
+      delete;
+};
+
 // Helper class to parse post-processing pipeline descriptor file.
 class PostProcessingPipelineParser {
  public:
   PostProcessingPipelineParser();
+
+  // Use json string instead of reading from file. For test only.
+  explicit PostProcessingPipelineParser(const std::string& json);
   ~PostProcessingPipelineParser();
 
-  // Reads the pipeline descriptor file and does preliminary parsing.
-  // Crashes with fatal log if parsing fails.
-  void Initialize();
+  std::vector<StreamPipelineDescriptor> GetStreamPipelines();
 
-  // Gets the list of processors for a given stream type.
-  // The format will be:
-  // [
-  //   {"processor": "PATH_TO_SHARED_OBJECT",
-  //    "config": "CONFIGURATION_STRING"},
-  //   {"processor": "PATH_TO_SHARED_OBJECT",
-  //    "config": "CONFIGURATION_STRING"},
-  //    ...
-  // ]
-  base::ListValue* GetPipelineByDeviceId(const std::string& device_id);
+  // Gets the list of processors for the mix/linearize stages.
+  // Same format as StreamPipelineDescriptor.pipeline
+  base::ListValue* GetMixPipeline();
+  base::ListValue* GetLinearizePipeline();
+
+  static std::string file_path();

[kmackay, 2017/04/28 00:31:42]

GetFilePath()

[bshaya, 2017/04/28 01:37:37]

Done.

 
  private:
+  base::ListValue* GetPipelineByKey(const std::string& key);
+
   std::unique_ptr<base::DictionaryValue> config_dict_;
-  base::DictionaryValue* pipeline_dict_ = nullptr;
 
   DISALLOW_COPY_AND_ASSIGN(PostProcessingPipelineParser);
 };
 
 }  // namepsace media
 }  // namespace chromecast
 
 #endif  // CHROMECAST_MEDIA_CMA_BACKEND_ALSA_POST_PROCESSING_PIPELINE_PARSER_H_