blob: 4ab0e9ef624ec2080e717f13fa799bd2c5117c26 (
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
136
137
138
139
140
141
142
|
// Copyright (C) 2016 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
//
// W A R N I N G
// -------------
//
// This file is not part of the Qt API. It exists for the convenience
// of other Qt classes. This header file may change from version to
// version without notice, or even be removed.
//
// We mean it.
//
#ifndef QAUDIOINPUTALSA_H
#define QAUDIOINPUTALSA_H
#include <alsa/asoundlib.h>
#include <QtCore/qfile.h>
#include <QtCore/qdebug.h>
#include <QtCore/qtimer.h>
#include <QtCore/qstring.h>
#include <QtCore/qstringlist.h>
#include <QtCore/qelapsedtimer.h>
#include <QtCore/qiodevice.h>
#include <QtMultimedia/qaudio.h>
#include <QtMultimedia/qaudiodevice.h>
#include <private/qaudiosystem_p.h>
QT_BEGIN_NAMESPACE
class AlsaInputPrivate;
class RingBuffer
{
public:
RingBuffer();
void resize(int size);
int bytesOfDataInBuffer() const;
int freeBytes() const;
const char *availableData() const;
int availableDataBlockSize() const;
void readBytes(int bytes);
void write(char *data, int len);
private:
int m_head;
int m_tail;
QByteArray m_data;
};
class QAlsaAudioSource : public QPlatformAudioSource
{
Q_OBJECT
public:
QAlsaAudioSource(const QByteArray &device);
~QAlsaAudioSource();
qint64 read(char* data, qint64 len);
void start(QIODevice* device) override;
QIODevice* start() override;
void stop() override;
void reset() override;
void suspend() override;
void resume() override;
qsizetype bytesReady() const override;
void setBufferSize(qsizetype value) override;
qsizetype bufferSize() const override;
qint64 processedUSecs() const override;
QAudio::Error error() const override;
QAudio::State state() const override;
void setFormat(const QAudioFormat& fmt) override;
QAudioFormat format() const override;
void setVolume(qreal) override;
qreal volume() const override;
bool resuming;
snd_pcm_t* handle;
qint64 totalTimeValue;
QIODevice* audioSource;
QAudioFormat settings;
QAudio::Error errorState;
QAudio::State deviceState;
private slots:
void userFeed();
bool deviceReady();
private:
int checkBytesReady();
int xrun_recovery(int err);
int setFormat();
bool open();
void close();
void drain();
QTimer* timer;
qint64 elapsedTimeOffset;
RingBuffer ringBuffer;
qsizetype bytesAvailable;
QByteArray m_device;
bool pullMode;
qsizetype buffer_size;
int period_size;
unsigned int buffer_time;
unsigned int period_time;
snd_pcm_uframes_t buffer_frames;
snd_pcm_uframes_t period_frames;
snd_pcm_access_t access;
snd_pcm_format_t pcmformat;
snd_pcm_hw_params_t *hwparams;
qreal m_volume;
};
class AlsaInputPrivate : public QIODevice
{
Q_OBJECT
public:
AlsaInputPrivate(QAlsaAudioSource* audio);
~AlsaInputPrivate();
qint64 readData( char* data, qint64 len) override;
qint64 writeData(const char* data, qint64 len) override;
void trigger();
private:
QAlsaAudioSource *audioDevice;
};
QT_END_NAMESPACE
#endif
|
