TinyPlayer/XAudioPlay.cpp at master · pwjworks/TinyPlayer · GitHub

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
#include "XAudioPlay.h"
#include <QAudioFormat>
#include <QAudioOutput>
#include <mutex>
using namespace std;

class CXAudioPlay :public XAudioPlay {
public:
	virtual long long GetNoPlayMs() {
		std::lock_guard<std::mutex> lck(mux);
		if (!out) {
			return 0;
		}
		long long pts = 0;
		// 还未播放的字节数
		double size = out->bufferSize() - out->bytesFree();
		// 一秒字节大小
		double secSize = sampleRate * (sampleSize / 8) * channels;
		if (secSize <= 0)
			pts = 0;
		else
			pts = (size / secSize) * 1000;
		return pts;
	}
	virtual void Clear() {
		std::lock_guard<std::mutex> lck(mux);
		if (io) {
			io->reset();
		}
	}
	virtual void Close() {
		std::lock_guard<std::mutex> lck(mux);
		if (io) {
			io->close();
			io = nullptr;
		}
		if (out) {
			out->stop();
			delete out;
			out = nullptr;
		}

	}
	virtual void SetPause(bool isPause) {
		std::lock_guard<std::mutex> lck(mux);
		if (!out) {
			return;
		}
		if (isPause) {
			out->suspend();
		}
		else {
			out->resume();
		}
	}

	virtual bool Open() {
		Close();
		QAudioFormat fmt;
		fmt.setSampleRate(44100);
		fmt.setSampleSize(16);
		fmt.setChannelCount(2);
		fmt.setCodec("audio/pcm");
		fmt.setByteOrder(QAudioFormat::LittleEndian);
		fmt.setSampleType(QAudioFormat::UnSignedInt);
		{
			std::lock_guard<std::mutex> lck(mux);
			out = new QAudioOutput(fmt);
			io = out->start();
		}
		if (io)
			return true;
		return false;
	}
	virtual bool Write(const unsigned char* data, int datasize) {
		if (!data || datasize <= 0)return false;
		lock_guard<mutex> lck(mux);
		if (!out || !io)	return false;
		io->write((char*)data, datasize);

		return true;
	}
	virtual int GetFree() {
		lock_guard<mutex> lck(mux);
		if (!out) {
			return 0;
		}
		int free = out->bytesFree();
		return free;
	}
	QAudioOutput* out;
	QIODevice* io;
	mutex mux;
};


XAudioPlay* XAudioPlay::Get() {
	static CXAudioPlay play;
	return &play;
}

XAudioPlay::XAudioPlay() {

}

XAudioPlay::~XAudioPlay() {

}