chromecast/media/cma/backend/mixer/mixer_service_receiver.h

// Copyright 2019 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_MIXER_MIXER_SERVICE_RECEIVER_H_
#define CHROMECAST_MEDIA_CMA_BACKEND_MIXER_MIXER_SERVICE_RECEIVER_H_

#include <memory>

#include "base/containers/flat_map.h"
#include "base/macros.h"
#include "chromecast/media/audio/mixer_service/receiver/receiver.h"

namespace chromecast {
namespace media {
class StreamMixer;

namespace mixer_service {
class Generic;
class MixerSocket;
}  // namespace mixer_service

class MixerServiceReceiver : public mixer_service::Receiver {
 public:
  explicit MixerServiceReceiver(StreamMixer* mixer);
  ~MixerServiceReceiver() override;

  // Called by the mixer when the active stream count changes.
  void OnStreamCountChanged(int primary, int sfx);

 private:
  class ControlConnection;

  // mixer_service::Receiver implementation:
  void CreateOutputStream(std::unique_ptr<mixer_service::MixerSocket> socket,
                          const mixer_service::Generic& message) override;
  void CreateLoopbackConnection(
      std::unique_ptr<mixer_service::MixerSocket> socket,
      const mixer_service::Generic& message) override;
  void CreateAudioRedirection(
      std::unique_ptr<mixer_service::MixerSocket> socket,
      const mixer_service::Generic& message) override;
  void CreateControlConnection(
      std::unique_ptr<mixer_service::MixerSocket> socket,
      const mixer_service::Generic& message) override;

  void RemoveControlConnection(ControlConnection* ptr);

  StreamMixer* const mixer_;

  base::flat_map<ControlConnection*, std::unique_ptr<ControlConnection>>
      control_connections_;
  int primary_stream_count_ = 0;
  int sfx_stream_count_ = 0;

  DISALLOW_COPY_AND_ASSIGN(MixerServiceReceiver);
};

}  // namespace media
}  // namespace chromecast

#endif  // CHROMECAST_MEDIA_CMA_BACKEND_MIXER_MIXER_SERVICE_RECEIVER_H_