-
Notifications
You must be signed in to change notification settings - Fork 8
/
oscilloscope.cpp
206 lines (182 loc) · 6.15 KB
/
oscilloscope.cpp
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
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
#include "oscilloscope.h"
#if QT_VERSION >= QT_VERSION_CHECK(6, 0, 0)
#include "QAudioSink"
#endif
Oscilloscope::Oscilloscope(QObject *parent) : QThread(parent)
{
//设置边框数据
//bufferFrame.resize(32 * this->channelCount);
//for(int i = 0; i < 8; i++)
//{
// bufferFrame[i * channelCount + channelX] = char(i * 32);
// bufferFrame[i * channelCount + channelY] = char(0);
// bufferFrame[(8 + i) * channelCount + channelX] = char(255);
// bufferFrame[(8 + i) * channelCount + channelY] = char(i * 32);
// bufferFrame[(16 + i) * channelCount + channelX] = char((7 - i) * 32);
// bufferFrame[(16 + i) * channelCount + channelY] = char(255);
// bufferFrame[(24 + i) * channelCount + channelX] = char(0);
// bufferFrame[(24 + i) * channelCount + channelY] = char((7 - i) * 32);
//}
//bufferFrame.resize(256 * 4 * this->channelCount);
//for(int i = 0; i < 256; i++)
//{
// bufferFrame[i * channelCount + channelX] = char(i);
// bufferFrame[i * channelCount + channelY] = char(0);
// bufferFrame[(256 + i) * channelCount + channelX] = char(255);
// bufferFrame[(256 + i) * channelCount + channelY] = char(i);
// bufferFrame[(256 * 2 + i) * channelCount + channelX] = char(255 - i);
// bufferFrame[(256 * 2 + i) * channelCount + channelY] = char(255);
// bufferFrame[(256 * 3 + i) * channelCount + channelX] = char(0);
// bufferFrame[(256 * 3 + i) * channelCount + channelY] = char(255 - i);
//}
//设置输出格式
#if QT_VERSION >= QT_VERSION_CHECK(6, 0, 0)
format.setSampleFormat(QAudioFormat::UInt8);
#else
format.setCodec("audio/pcm");
format.setSampleSize(8);
format.setSampleType(QAudioFormat::UnSignedInt);
format.setByteOrder(QAudioFormat::LittleEndian);
#endif
}
Oscilloscope::~Oscilloscope()
{
stop();
}
int Oscilloscope::set(QAudioDevice audioDevice, int sampleRate, int channelCount, int channelX, int channelY, int fps)
{
this->audioDevice = audioDevice;
this->sampleRate = sampleRate;
format.setSampleRate(sampleRate);
this->channelCount = channelCount;
format.setChannelCount(channelCount);
this->channelX = channelX;
this->channelY = channelY;
if(fps == 0)
this->fps = 1;
else
this->fps = fps;
setBuffer();
return isFormatSupported();
}
int Oscilloscope::setAudioDevice(const QAudioDevice audioDevice)
{
this->audioDevice = audioDevice;
return isFormatSupported();
}
int Oscilloscope::setSampleRate(int sampleRate)
{
this->sampleRate = sampleRate;
format.setSampleRate(sampleRate);
setBuffer();
return isFormatSupported();
}
int Oscilloscope::setChannelCount(int channelCount)
{
this->channelCount = channelCount;
format.setChannelCount(channelCount);
setBuffer();
return isFormatSupported();
}
void Oscilloscope::setChannelX(int channelX)
{
this->channelX = channelX;
}
void Oscilloscope::setChannelY(int channelY)
{
this->channelY = channelY;
}
void Oscilloscope::setFPS(int fps)
{
if(fps == 0)
this->fps = 1;
else
this->fps = fps;
setBuffer();
}
void Oscilloscope::setBuffer() //根据参数重新分配buffer内存
{
bufferMaxSize = this->sampleRate / this->fps * this->channelCount; //最大值等于一个帧的时间的按照采样率的数据量
if(buffer)
delete buffer;
buffer = new char[bufferMaxSize];
if(bufferRefresh)
delete buffer;
bufferRefresh = new char[bufferMaxSize];
}
void Oscilloscope::setPoints(const QVector<Point> points) //根据点数据计算buffer,暂存在bufferRefresh等另一个线程下一次刷新时候将会复制走
{
for(int i = 0; i < points.length() && i * channelCount < bufferMaxSize; i++)
{
bufferRefresh[i * channelCount + channelX] = char(points.at(i).x);
bufferRefresh[i * channelCount + channelY] = char(-1 - points.at(i).y);
}
bufferRefreshLen = points.length() * channelCount;
if(bufferRefreshLen > bufferMaxSize) bufferRefreshLen = bufferMaxSize;
refresh = true; //设置需要刷新标记,等待线程刷新
}
int Oscilloscope::isFormatSupported()
{
return audioDevice.isFormatSupported(format);
}
void Oscilloscope::run()
{
#if QT_VERSION >= QT_VERSION_CHECK(6, 0, 0)
auto output = new QAudioSink(this->audioDevice, format);
#else
auto output = new QAudioOutput(this->audioDevice, format);
#endif
if(output->bufferSize() < bufferMaxSize * 2) output->setBufferSize(bufferMaxSize * 2); //如果音频缓冲区小于最大buffer的两倍则扩大之。
auto device = output->start();
stateStart = true;
while(1)
{
//退出检测
if(stopMe)
{
output->stop();
delete output;
stopMe = false;
stateStart = false;
return;
}
//如果需要刷新,先刷新
if(refresh)
{
refresh = false;
memcpy(buffer, bufferRefresh, size_t(bufferRefreshLen));
bufferLen = bufferRefreshLen;
}
//输出
if(device && output && bufferLen)
{
if((output->bufferSize() - output->bytesFree()) * 10 / channelCount * fps / sampleRate < 10 && //如果剩余数据可播放的时间小于fps的倒数(*10是为了不想用浮点数)
output->bytesFree() > bufferLen) //且剩余缓冲大于即将写入的数据大小 (一般情况下不会出现这个情况,这里只是以防万一)
{
//device->write(bufferFrame, bufferFrame.length()); //输出边框
device->write(buffer, bufferLen);
}
else //否则说明缓冲区时间一定大于fps的倒数,所以可以休息一会
QThread::msleep(1000 / fps / 10); //休息十分之一的帧的时间
}
}
}
int Oscilloscope::stop(int time)
{
if(stateStart)
{
stopMe = true;
int i = 0;
while(stateStart)
{
QCoreApplication::processEvents();
i++;
if(time && (i > time)) return 1;
}
}
return 0;
}
bool Oscilloscope::state()
{
return stateStart;
}