blob: a08211ba15c074c2538d61f02a4a141842adab04 (
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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*-*/
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
* You can obtain one at http://mozilla.org/MPL/2.0/. */
#ifndef MOZILLA_AUDIO_RING_BUFFER_H_
#define MOZILLA_AUDIO_RING_BUFFER_H_
#include "AudioSampleFormat.h"
#include "mozilla/Span.h"
#include <functional>
namespace mozilla {
/**
* AudioRingBuffer works with audio sample format float or short. The
* implementation wrap around the RingBuffer thus it is not thread-safe. Reads
* and writes must happen in the same thread which may be different than the
* construction thread. The memory is pre-allocated in the constructor, but may
* also be re-allocated on the fly should a larger length be needed. The sample
* format has to be specified in order to be used.
*/
class AudioRingBuffer final {
public:
explicit AudioRingBuffer(uint32_t aSizeInBytes);
~AudioRingBuffer();
/**
* Set the sample format to either short or float. The sample format must be
* set before the using any other method.
*/
void SetSampleFormat(AudioSampleFormat aFormat);
/**
* Write `aBuffer.Length()` number of samples when the format is float.
*/
uint32_t Write(const Span<const float>& aBuffer);
/**
* Write `aBuffer.Length()` number of samples when the format is short.
*/
uint32_t Write(const Span<const int16_t>& aBuffer);
/**
* Write `aSamples` number of samples from `aBuffer`. Note the `aBuffer` does
* not change.
*/
uint32_t Write(const AudioRingBuffer& aBuffer, uint32_t aSamples);
/**
* Write `aSamples` number of zeros before the beginning of the existing data.
*/
uint32_t PrependSilence(uint32_t aSamples);
/**
* Write `aSamples` number of zeros.
*/
uint32_t WriteSilence(uint32_t aSamples);
/**
* Read `aBuffer.Length()` number of samples when the format is float.
*/
uint32_t Read(const Span<float>& aBuffer);
/**
* Read `aBuffer.Length()` number of samples when the format is short.
*/
uint32_t Read(const Span<int16_t>& aBuffer);
/**
* Read the internal buffer without extra copies when sample format is float.
* Check also the RingBuffer::ReadNoCopy() for more details.
*/
uint32_t ReadNoCopy(
std::function<uint32_t(const Span<const float>&)>&& aCallable);
/**
* Read the internal buffer without extra copies when sample format is short.
* Check also the RingBuffer::ReadNoCopy() for more details.
*/
uint32_t ReadNoCopy(
std::function<uint32_t(const Span<const int16_t>&)>&& aCallable);
/**
* Remove `aSamples` number of samples.
*/
uint32_t Discard(uint32_t aSamples);
/**
* Remove all available samples.
*/
uint32_t Clear();
/**
* Increase the ring buffer size if necessary to at least the specified length
* in bytes. Must be divisible by the sample size.
* Will not deallocate memory if the underlying buffer is large enough.
* Returns false if memory allocation is required and fails.
*/
bool EnsureLengthBytes(uint32_t aLengthBytes);
/**
* Return the number of samples this buffer can hold.
*/
uint32_t Capacity() const;
/**
* Return true if the buffer is full.
*/
bool IsFull() const;
/**
* Return true if the buffer is empty.
*/
bool IsEmpty() const;
/**
* Return the number of samples available for writing.
*/
uint32_t AvailableWrite() const;
/**
* Return the number of samples available for reading.
*/
uint32_t AvailableRead() const;
private:
class AudioRingBufferPrivate;
UniquePtr<AudioRingBufferPrivate> mPtr;
};
} // namespace mozilla
#endif // MOZILLA_AUDIO_RING_BUFFER_H_
|
