blob: 6a85b2647f35bb42c888f51f818bf44e4e16952c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
// Copyright (c) 2012 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.
//
// Creates an audio output stream based on the PulseAudio asynchronous API;
// specifically using the pa_threaded_mainloop model.
//
// If the stream is successfully opened, Close() must be called before the
// stream is deleted as Close() is responsible for ensuring resource cleanup
// occurs.
//
// This object is designed so that all AudioOutputStream methods will be called
// on the same thread that created the object.
//
// WARNING: This object blocks on internal PulseAudio calls in Open() while
// waiting for PulseAudio's context structure to be ready. It also blocks in
// inside PulseAudio in Start() and repeated during playback, waiting for
// PulseAudio write callbacks to occur.
#ifndef MEDIA_AUDIO_PULSE_PULSE_OUTPUT_H_
#define MEDIA_AUDIO_PULSE_PULSE_OUTPUT_H_
#include <stddef.h>
#include <memory>
#include <string>
#include "base/macros.h"
#include "base/threading/thread_checker.h"
#include "media/audio/audio_io.h"
#include "media/audio/audio_manager.h"
#include "media/base/audio_parameters.h"
struct pa_context;
struct pa_stream;
struct pa_threaded_mainloop;
namespace media {
class AudioManagerBase;
class PulseAudioOutputStream : public AudioOutputStream {
public:
PulseAudioOutputStream(const AudioParameters& params,
const std::string& device_id,
AudioManagerBase* manager,
AudioManager::LogCallback log_callback);
~PulseAudioOutputStream() override;
// Implementation of AudioOutputStream.
bool Open() override;
void Close() override;
void Flush() override;
void Start(AudioSourceCallback* callback) override;
void Stop() override;
void SetVolume(double volume) override;
void GetVolume(double* volume) override;
private:
// Helper method used for sending native logs to the registered client.
void SendLogMessage(const char* format, ...) PRINTF_FORMAT(2, 3);
// Called by PulseAudio when |pa_stream_| change state. If an unexpected
// failure state change happens and |source_callback_| is set
// this method will forward the error via OnError().
static void StreamNotifyCallback(pa_stream* s, void* p_this);
// Called by PulseAudio when it needs more audio data.
static void StreamRequestCallback(pa_stream* s, size_t len, void* p_this);
// Fulfill a write request from the write request callback. Outputs silence
// if the request could not be fulfilled.
void FulfillWriteRequest(size_t requested_bytes);
// Close() helper function to free internal structs.
void Reset();
// AudioParameters from the constructor.
const AudioParameters params_;
// The device ID for the device to open.
const std::string device_id_;
// Audio manager that created us. Used to report that we've closed.
AudioManagerBase* manager_;
// Callback to send log messages to registered clients.
AudioManager::LogCallback log_callback_;
// PulseAudio API structs.
pa_context* pa_context_;
pa_threaded_mainloop* pa_mainloop_;
pa_stream* pa_stream_;
// Float representation of volume from 0.0 to 1.0.
float volume_;
// Callback to audio data source. Must only be modified while holding a lock
// on |pa_mainloop_| via pa_threaded_mainloop_lock().
AudioSourceCallback* source_callback_;
// Container for retrieving data from AudioSourceCallback::OnMoreData().
std::unique_ptr<AudioBus> audio_bus_;
const size_t buffer_size_;
base::ThreadChecker thread_checker_;
DISALLOW_COPY_AND_ASSIGN(PulseAudioOutputStream);
};
} // namespace media
#endif // MEDIA_AUDIO_PULSE_PULSE_OUTPUT_H_
|
