Chris@59
|
1 /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*- vi:set ts=8 sts=4 sw=4: */
|
Chris@59
|
2
|
Chris@59
|
3 /*
|
Chris@59
|
4 Sonic Visualiser
|
Chris@59
|
5 An audio file viewer and annotation editor.
|
Chris@59
|
6 Centre for Digital Music, Queen Mary, University of London.
|
Chris@59
|
7 This file copyright 2006 Chris Cannam.
|
Chris@59
|
8
|
Chris@59
|
9 This program is free software; you can redistribute it and/or
|
Chris@59
|
10 modify it under the terms of the GNU General Public License as
|
Chris@59
|
11 published by the Free Software Foundation; either version 2 of the
|
Chris@59
|
12 License, or (at your option) any later version. See the file
|
Chris@59
|
13 COPYING included with this distribution for more information.
|
Chris@59
|
14 */
|
Chris@59
|
15
|
Chris@59
|
16 #ifdef HAVE_PORTAUDIO
|
Chris@59
|
17
|
Chris@59
|
18 #include "AudioPortAudioTarget.h"
|
Chris@59
|
19 #include "AudioCallbackPlaySource.h"
|
Chris@59
|
20
|
Chris@59
|
21 #include <iostream>
|
Chris@59
|
22 #include <cassert>
|
Chris@59
|
23 #include <cmath>
|
Chris@59
|
24
|
Chris@59
|
25 //#define DEBUG_AUDIO_PORT_AUDIO_TARGET 1
|
Chris@59
|
26
|
Chris@59
|
27 AudioPortAudioTarget::AudioPortAudioTarget(AudioCallbackPlaySource *source) :
|
Chris@59
|
28 AudioCallbackPlayTarget(source),
|
Chris@59
|
29 m_stream(0),
|
Chris@59
|
30 m_bufferSize(0),
|
Chris@59
|
31 m_sampleRate(0),
|
Chris@71
|
32 m_latency(0),
|
Chris@71
|
33 m_done(false)
|
Chris@59
|
34 {
|
Chris@59
|
35 PaError err;
|
Chris@59
|
36
|
Chris@59
|
37 #ifdef DEBUG_AUDIO_PORT_AUDIO_TARGET
|
Chris@59
|
38 #ifdef HAVE_PORTAUDIO_V18
|
Chris@59
|
39 std::cerr << "AudioPortAudioTarget: Initialising for PortAudio v18" << std::endl;
|
Chris@59
|
40 #else
|
Chris@59
|
41 std::cerr << "AudioPortAudioTarget: Initialising for PortAudio v19" << std::endl;
|
Chris@59
|
42 #endif
|
Chris@59
|
43 #endif
|
Chris@59
|
44
|
Chris@59
|
45 err = Pa_Initialize();
|
Chris@59
|
46 if (err != paNoError) {
|
Chris@59
|
47 std::cerr << "ERROR: AudioPortAudioTarget: Failed to initialize PortAudio: " << Pa_GetErrorText(err) << std::endl;
|
Chris@59
|
48 return;
|
Chris@59
|
49 }
|
Chris@59
|
50
|
Chris@59
|
51 m_bufferSize = 1024;
|
Chris@59
|
52 m_sampleRate = 44100;
|
Chris@59
|
53 if (m_source && (m_source->getSourceSampleRate() != 0)) {
|
Chris@59
|
54 m_sampleRate = m_source->getSourceSampleRate();
|
Chris@59
|
55 }
|
Chris@59
|
56
|
Chris@59
|
57 #ifdef HAVE_PORTAUDIO_V18
|
Chris@59
|
58 m_latency = Pa_GetMinNumBuffers(m_bufferSize, m_sampleRate) * m_bufferSize;
|
Chris@59
|
59 #endif
|
Chris@59
|
60
|
Chris@59
|
61 #ifdef HAVE_PORTAUDIO_V18
|
Chris@59
|
62 err = Pa_OpenDefaultStream(&m_stream, 0, 2, paFloat32,
|
Chris@59
|
63 m_sampleRate, m_bufferSize, 0,
|
Chris@59
|
64 processStatic, this);
|
Chris@59
|
65 #else
|
Chris@59
|
66 err = Pa_OpenDefaultStream(&m_stream, 0, 2, paFloat32,
|
Chris@59
|
67 m_sampleRate, m_bufferSize,
|
Chris@59
|
68 processStatic, this);
|
Chris@59
|
69 #endif
|
Chris@59
|
70
|
Chris@59
|
71 if (err != paNoError) {
|
Chris@59
|
72 std::cerr << "ERROR: AudioPortAudioTarget: Failed to open PortAudio stream: " << Pa_GetErrorText(err) << std::endl;
|
Chris@59
|
73 m_stream = 0;
|
Chris@59
|
74 Pa_Terminate();
|
Chris@59
|
75 return;
|
Chris@59
|
76 }
|
Chris@59
|
77
|
Chris@59
|
78 #ifndef HAVE_PORTAUDIO_V18
|
Chris@59
|
79 const PaStreamInfo *info = Pa_GetStreamInfo(m_stream);
|
Chris@59
|
80 m_latency = int(info->outputLatency * m_sampleRate + 0.001);
|
Chris@59
|
81 #endif
|
Chris@59
|
82
|
Chris@59
|
83 std::cerr << "PortAudio latency = " << m_latency << " frames" << std::endl;
|
Chris@59
|
84
|
Chris@59
|
85 err = Pa_StartStream(m_stream);
|
Chris@59
|
86
|
Chris@59
|
87 if (err != paNoError) {
|
Chris@59
|
88 std::cerr << "ERROR: AudioPortAudioTarget: Failed to start PortAudio stream: " << Pa_GetErrorText(err) << std::endl;
|
Chris@59
|
89 Pa_CloseStream(m_stream);
|
Chris@59
|
90 m_stream = 0;
|
Chris@59
|
91 Pa_Terminate();
|
Chris@59
|
92 return;
|
Chris@59
|
93 }
|
Chris@59
|
94
|
Chris@59
|
95 if (m_source) {
|
Chris@59
|
96 std::cerr << "AudioPortAudioTarget: block size " << m_bufferSize << std::endl;
|
Chris@59
|
97 m_source->setTargetBlockSize(m_bufferSize);
|
Chris@59
|
98 m_source->setTargetSampleRate(m_sampleRate);
|
Chris@59
|
99 m_source->setTargetPlayLatency(m_latency);
|
Chris@59
|
100 }
|
Chris@59
|
101
|
Chris@59
|
102 #ifdef DEBUG_PORT_AUDIO_TARGET
|
Chris@59
|
103 std::cerr << "AudioPortAudioTarget: initialised OK" << std::endl;
|
Chris@59
|
104 #endif
|
Chris@59
|
105 }
|
Chris@59
|
106
|
Chris@59
|
107 AudioPortAudioTarget::~AudioPortAudioTarget()
|
Chris@59
|
108 {
|
Chris@71
|
109 std::cerr << "AudioPortAudioTarget::~AudioPortAudioTarget()" << std::endl;
|
Chris@71
|
110
|
Chris@71
|
111 shutdown();
|
Chris@71
|
112
|
Chris@59
|
113 if (m_stream) {
|
Chris@71
|
114
|
Chris@71
|
115 std::cerr << "closing stream" << std::endl;
|
Chris@71
|
116
|
Chris@59
|
117 PaError err;
|
Chris@59
|
118 err = Pa_CloseStream(m_stream);
|
Chris@59
|
119 if (err != paNoError) {
|
Chris@59
|
120 std::cerr << "ERROR: AudioPortAudioTarget: Failed to close PortAudio stream: " << Pa_GetErrorText(err) << std::endl;
|
Chris@59
|
121 }
|
Chris@71
|
122
|
Chris@71
|
123 std::cerr << "terminating" << std::endl;
|
Chris@71
|
124
|
Chris@59
|
125 err = Pa_Terminate();
|
Chris@59
|
126 if (err != paNoError) {
|
Chris@59
|
127 std::cerr << "ERROR: AudioPortAudioTarget: Failed to terminate PortAudio: " << Pa_GetErrorText(err) << std::endl;
|
Chris@59
|
128 }
|
Chris@59
|
129 }
|
Chris@71
|
130
|
Chris@71
|
131 m_stream = 0;
|
Chris@71
|
132
|
Chris@71
|
133 std::cerr << "AudioPortAudioTarget::~AudioPortAudioTarget() done" << std::endl;
|
Chris@71
|
134 }
|
Chris@71
|
135
|
Chris@71
|
136 void
|
Chris@71
|
137 AudioPortAudioTarget::shutdown()
|
Chris@71
|
138 {
|
Chris@71
|
139 m_done = true;
|
Chris@59
|
140 }
|
Chris@59
|
141
|
Chris@59
|
142 bool
|
Chris@59
|
143 AudioPortAudioTarget::isOK() const
|
Chris@59
|
144 {
|
Chris@59
|
145 return (m_stream != 0);
|
Chris@59
|
146 }
|
Chris@59
|
147
|
Chris@59
|
148 #ifdef HAVE_PORTAUDIO_V18
|
Chris@59
|
149 int
|
Chris@59
|
150 AudioPortAudioTarget::processStatic(void *input, void *output,
|
Chris@59
|
151 unsigned long nframes,
|
Chris@59
|
152 PaTimestamp outTime, void *data)
|
Chris@59
|
153 {
|
Chris@59
|
154 return ((AudioPortAudioTarget *)data)->process(input, output,
|
Chris@59
|
155 nframes, outTime);
|
Chris@59
|
156 }
|
Chris@59
|
157 #else
|
Chris@59
|
158 int
|
Chris@59
|
159 AudioPortAudioTarget::processStatic(const void *input, void *output,
|
Chris@59
|
160 unsigned long nframes,
|
Chris@59
|
161 const PaStreamCallbackTimeInfo *timeInfo,
|
Chris@59
|
162 PaStreamCallbackFlags flags, void *data)
|
Chris@59
|
163 {
|
Chris@59
|
164 return ((AudioPortAudioTarget *)data)->process(input, output,
|
Chris@59
|
165 nframes, timeInfo,
|
Chris@59
|
166 flags);
|
Chris@59
|
167 }
|
Chris@59
|
168 #endif
|
Chris@59
|
169
|
Chris@59
|
170 void
|
Chris@59
|
171 AudioPortAudioTarget::sourceModelReplaced()
|
Chris@59
|
172 {
|
Chris@59
|
173 m_source->setTargetSampleRate(m_sampleRate);
|
Chris@59
|
174 }
|
Chris@59
|
175
|
Chris@59
|
176 #ifdef HAVE_PORTAUDIO_V18
|
Chris@59
|
177 int
|
Chris@59
|
178 AudioPortAudioTarget::process(void *inputBuffer, void *outputBuffer,
|
Chris@59
|
179 unsigned long nframes,
|
Chris@59
|
180 PaTimestamp)
|
Chris@59
|
181 #else
|
Chris@59
|
182 int
|
Chris@59
|
183 AudioPortAudioTarget::process(const void *, void *outputBuffer,
|
Chris@59
|
184 unsigned long nframes,
|
Chris@59
|
185 const PaStreamCallbackTimeInfo *,
|
Chris@59
|
186 PaStreamCallbackFlags)
|
Chris@59
|
187 #endif
|
Chris@59
|
188 {
|
Chris@59
|
189 #ifdef DEBUG_AUDIO_PORT_AUDIO_TARGET
|
Chris@59
|
190 std::cout << "AudioPortAudioTarget::process(" << nframes << ")" << std::endl;
|
Chris@59
|
191 #endif
|
Chris@59
|
192
|
Chris@71
|
193 if (!m_source || m_done) return 0;
|
Chris@59
|
194
|
Chris@59
|
195 float *output = (float *)outputBuffer;
|
Chris@59
|
196
|
Chris@59
|
197 assert(nframes <= m_bufferSize);
|
Chris@59
|
198
|
Chris@59
|
199 static float **tmpbuf = 0;
|
Chris@59
|
200 static size_t tmpbufch = 0;
|
Chris@59
|
201 static size_t tmpbufsz = 0;
|
Chris@59
|
202
|
Chris@59
|
203 size_t sourceChannels = m_source->getSourceChannelCount();
|
Chris@59
|
204
|
Chris@59
|
205 // Because we offer pan, we always want at least 2 channels
|
Chris@59
|
206 if (sourceChannels < 2) sourceChannels = 2;
|
Chris@59
|
207
|
Chris@59
|
208 if (!tmpbuf || tmpbufch != sourceChannels || int(tmpbufsz) < m_bufferSize) {
|
Chris@59
|
209
|
Chris@59
|
210 if (tmpbuf) {
|
Chris@59
|
211 for (size_t i = 0; i < tmpbufch; ++i) {
|
Chris@59
|
212 delete[] tmpbuf[i];
|
Chris@59
|
213 }
|
Chris@59
|
214 delete[] tmpbuf;
|
Chris@59
|
215 }
|
Chris@59
|
216
|
Chris@59
|
217 tmpbufch = sourceChannels;
|
Chris@59
|
218 tmpbufsz = m_bufferSize;
|
Chris@59
|
219 tmpbuf = new float *[tmpbufch];
|
Chris@59
|
220
|
Chris@59
|
221 for (size_t i = 0; i < tmpbufch; ++i) {
|
Chris@59
|
222 tmpbuf[i] = new float[tmpbufsz];
|
Chris@59
|
223 }
|
Chris@59
|
224 }
|
Chris@59
|
225
|
Chris@59
|
226 size_t received = m_source->getSourceSamples(nframes, tmpbuf);
|
Chris@59
|
227
|
Chris@59
|
228 float peakLeft = 0.0, peakRight = 0.0;
|
Chris@59
|
229
|
Chris@59
|
230 for (size_t ch = 0; ch < 2; ++ch) {
|
Chris@59
|
231
|
Chris@59
|
232 float peak = 0.0;
|
Chris@59
|
233
|
Chris@59
|
234 if (ch < sourceChannels) {
|
Chris@59
|
235
|
Chris@59
|
236 // PortAudio samples are interleaved
|
Chris@59
|
237 for (size_t i = 0; i < nframes; ++i) {
|
Chris@59
|
238 if (i < received) {
|
Chris@59
|
239 output[i * 2 + ch] = tmpbuf[ch][i] * m_outputGain;
|
Chris@59
|
240 float sample = fabsf(output[i * 2 + ch]);
|
Chris@59
|
241 if (sample > peak) peak = sample;
|
Chris@59
|
242 } else {
|
Chris@59
|
243 output[i * 2 + ch] = 0;
|
Chris@59
|
244 }
|
Chris@59
|
245 }
|
Chris@59
|
246
|
Chris@59
|
247 } else if (ch == 1 && sourceChannels == 1) {
|
Chris@59
|
248
|
Chris@59
|
249 for (size_t i = 0; i < nframes; ++i) {
|
Chris@59
|
250 if (i < received) {
|
Chris@59
|
251 output[i * 2 + ch] = tmpbuf[0][i] * m_outputGain;
|
Chris@59
|
252 float sample = fabsf(output[i * 2 + ch]);
|
Chris@59
|
253 if (sample > peak) peak = sample;
|
Chris@59
|
254 } else {
|
Chris@59
|
255 output[i * 2 + ch] = 0;
|
Chris@59
|
256 }
|
Chris@59
|
257 }
|
Chris@59
|
258
|
Chris@59
|
259 } else {
|
Chris@59
|
260 for (size_t i = 0; i < nframes; ++i) {
|
Chris@59
|
261 output[i * 2 + ch] = 0;
|
Chris@59
|
262 }
|
Chris@59
|
263 }
|
Chris@59
|
264
|
Chris@59
|
265 if (ch == 0) peakLeft = peak;
|
Chris@59
|
266 if (ch > 0 || sourceChannels == 1) peakRight = peak;
|
Chris@59
|
267 }
|
Chris@59
|
268
|
Chris@59
|
269 m_source->setOutputLevels(peakLeft, peakRight);
|
Chris@59
|
270
|
Chris@59
|
271 return 0;
|
Chris@59
|
272 }
|
Chris@59
|
273
|
Chris@59
|
274 #endif /* HAVE_PORTAUDIO */
|
Chris@59
|
275
|