mojo_audio_output_stream_provider.h 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
  1. // Copyright 2017 The Chromium Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style license that can be
  3. // found in the LICENSE file.
  4. #ifndef MEDIA_MOJO_SERVICES_MOJO_AUDIO_OUTPUT_STREAM_PROVIDER_H_
  5. #define MEDIA_MOJO_SERVICES_MOJO_AUDIO_OUTPUT_STREAM_PROVIDER_H_
  6. #include <memory>
  7. #include <string>
  8. #include "base/sequence_checker.h"
  9. #include "media/audio/audio_output_delegate.h"
  10. #include "media/mojo/mojom/audio_output_stream.mojom.h"
  11. #include "media/mojo/services/media_mojo_export.h"
  12. #include "media/mojo/services/mojo_audio_output_stream.h"
  13. #include "mojo/public/cpp/bindings/pending_receiver.h"
  14. #include "mojo/public/cpp/bindings/pending_remote.h"
  15. #include "mojo/public/cpp/bindings/receiver.h"
  16. #include "mojo/public/cpp/bindings/remote.h"
  17. namespace media {
  18. // Provides a single AudioOutput, given the audio parameters to use.
  19. class MEDIA_MOJO_EXPORT MojoAudioOutputStreamProvider
  20. : public mojom::AudioOutputStreamProvider {
  21. public:
  22. using CreateDelegateCallback =
  23. base::OnceCallback<std::unique_ptr<AudioOutputDelegate>(
  24. const AudioParameters& params,
  25. mojo::PendingRemote<mojom::AudioOutputStreamObserver>,
  26. AudioOutputDelegate::EventHandler*)>;
  27. using DeleterCallback = base::OnceCallback<void(AudioOutputStreamProvider*)>;
  28. // |create_delegate_callback| is used to obtain an AudioOutputDelegate for the
  29. // AudioOutput when it's initialized and |deleter_callback| is called when
  30. // this class should be removed (stream ended/error). |deleter_callback| is
  31. // required to destroy |this| synchronously.
  32. MojoAudioOutputStreamProvider(
  33. mojo::PendingReceiver<mojom::AudioOutputStreamProvider> pending_receiver,
  34. CreateDelegateCallback create_delegate_callback,
  35. DeleterCallback deleter_callback,
  36. std::unique_ptr<mojom::AudioOutputStreamObserver> observer);
  37. MojoAudioOutputStreamProvider(const MojoAudioOutputStreamProvider&) = delete;
  38. MojoAudioOutputStreamProvider& operator=(
  39. const MojoAudioOutputStreamProvider&) = delete;
  40. ~MojoAudioOutputStreamProvider() override;
  41. private:
  42. // mojom::AudioOutputStreamProvider implementation.
  43. void Acquire(const AudioParameters& params,
  44. mojo::PendingRemote<mojom::AudioOutputStreamProviderClient>
  45. provider_client) override;
  46. // Called when |audio_output_| had an error.
  47. void CleanUp(bool had_error);
  48. // Closes mojo connections, reports a bad message, and self-destructs.
  49. void BadMessage(const std::string& error);
  50. SEQUENCE_CHECKER(sequence_checker_);
  51. mojo::Receiver<AudioOutputStreamProvider> receiver_;
  52. CreateDelegateCallback create_delegate_callback_;
  53. DeleterCallback deleter_callback_;
  54. std::unique_ptr<mojom::AudioOutputStreamObserver> observer_;
  55. mojo::Receiver<mojom::AudioOutputStreamObserver> observer_receiver_;
  56. absl::optional<MojoAudioOutputStream> audio_output_;
  57. mojo::Remote<mojom::AudioOutputStreamProviderClient> provider_client_;
  58. };
  59. } // namespace media
  60. #endif // MEDIA_MOJO_SERVICES_MOJO_AUDIO_OUTPUT_STREAM_PROVIDER_H_