Add a simple, safe gain PostProcessor.

chromecast/media/cma/backend/alsa/stream_mixer_alsa.cc

 // 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 "chromecast/media/cma/backend/alsa/stream_mixer_alsa.h"
 
 #include <algorithm>
 #include <cmath>
 #include <limits>
 #include <unordered_set>
 #include <utility>
 
 #include "base/bind_helpers.h"
 #include "base/command_line.h"
 #include "base/lazy_instance.h"
 #include "base/memory/ptr_util.h"
 #include "base/memory/weak_ptr.h"
 #include "base/numerics/saturated_arithmetic.h"
 #include "base/single_thread_task_runner.h"
 #include "base/stl_util.h"
 #include "base/threading/platform_thread.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "base/time/time.h"
 #include "chromecast/base/chromecast_switches.h"
 #include "chromecast/media/base/audio_device_ids.h"
 #include "chromecast/media/cma/backend/alsa/alsa_wrapper.h"
+#include "chromecast/media/cma/backend/alsa/cast_audio_json.h"
 #include "chromecast/media/cma/backend/alsa/filter_group.h"
 #include "chromecast/media/cma/backend/alsa/post_processing_pipeline_parser.h"
 #include "chromecast/media/cma/backend/alsa/stream_mixer_alsa_input_impl.h"
 #include "chromecast/public/media/audio_post_processor_shlib.h"
 #include "media/audio/audio_device_description.h"
 #include "media/base/audio_bus.h"
 #include "media/base/audio_sample_types.h"
 #include "media/base/media_switches.h"
 
 #define RETURN_REPORT_ERROR(snd_func, ...)                        \
@@ skipping 233 matching lines @@
   std::unordered_set<std::string> used_streams;
   for (auto& stream_pipeline : pipeline_parser->GetStreamPipelines()) {
     const auto& device_ids = stream_pipeline.stream_types;
     for (const std::string& stream_type : device_ids) {
       CHECK(IsOutputDeviceId(stream_type))
           << stream_type << " is not a stream type. Stream types are listed "
           << "in chromecast/media/base/audio_device_ids.cc and "
           << "media/audio/audio_device_description.cc";
       CHECK(used_streams.insert(stream_type).second)
           << "Multiple instances of stream type '" << stream_type << "' in "
-          << pipeline_parser->GetFilePath() << ".";
+          << kCastAudioJsonFilePath << ".";
     }
     filter_groups_.push_back(base::MakeUnique<FilterGroup>(
         kNumInputChannels, false /* mono_mixer */,
         *device_ids.begin() /* name */, stream_pipeline.pipeline, device_ids,
         std::vector<FilterGroup*>() /* mixed_inputs */));
     if (device_ids.find(::media::AudioDeviceDescription::kDefaultDeviceId) !=
         device_ids.end()) {
       default_filter_ = filter_groups_.back().get();
     }
   }
@@ skipping 788 matching lines @@
   }
   for (auto&& input : inputs_) {
     // Volume limits don't apply to effects streams.
     if (input->primary() && input->content_type() == type) {
       input->SetContentTypeVolume(effective_volume, fade_ms);
     }
   }
 }
 
 void StreamMixerAlsa::SetPostProcessorConfig(const std::string& name,
-                                             const std::string& message) {
-  RUN_ON_MIXER_THREAD(&StreamMixerAlsa::SetPostProcessorConfig, name, message);
+                                             const std::string& config) {
+  RUN_ON_MIXER_THREAD(&StreamMixerAlsa::SetPostProcessorConfig, name, config);
   for (auto&& filter_group : filter_groups_) {
-    filter_group->SetPostProcessorConfig(name, message);
+    filter_group->SetPostProcessorConfig(name, config);
   }
 }
 
 }  // namespace media
 }  // namespace chromecast