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
|
// 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
#include "samplegrabber_p.h"
STDMETHODIMP SampleGrabberCallback::QueryInterface(REFIID riid, void** ppv)
{
if (!ppv)
return E_POINTER;
if (riid == IID_IMFSampleGrabberSinkCallback) {
*ppv = static_cast<IMFSampleGrabberSinkCallback*>(this);
} else if (riid == IID_IMFClockStateSink) {
*ppv = static_cast<IMFClockStateSink*>(this);
} else if (riid == IID_IUnknown) {
*ppv = static_cast<IUnknown*>(this);
} else {
*ppv = NULL;
return E_NOINTERFACE;
}
AddRef();
return S_OK;
}
STDMETHODIMP_(ULONG) SampleGrabberCallback::AddRef()
{
return InterlockedIncrement(&m_cRef);
}
STDMETHODIMP_(ULONG) SampleGrabberCallback::Release()
{
ULONG cRef = InterlockedDecrement(&m_cRef);
if (cRef == 0) {
delete this;
}
return cRef;
}
// IMFClockStateSink methods.
STDMETHODIMP SampleGrabberCallback::OnClockStart(MFTIME hnsSystemTime, LONGLONG llClockStartOffset)
{
Q_UNUSED(hnsSystemTime);
Q_UNUSED(llClockStartOffset);
return S_OK;
}
STDMETHODIMP SampleGrabberCallback::OnClockStop(MFTIME hnsSystemTime)
{
Q_UNUSED(hnsSystemTime);
return S_OK;
}
STDMETHODIMP SampleGrabberCallback::OnClockPause(MFTIME hnsSystemTime)
{
Q_UNUSED(hnsSystemTime);
return S_OK;
}
STDMETHODIMP SampleGrabberCallback::OnClockRestart(MFTIME hnsSystemTime)
{
Q_UNUSED(hnsSystemTime);
return S_OK;
}
STDMETHODIMP SampleGrabberCallback::OnClockSetRate(MFTIME hnsSystemTime, float flRate)
{
Q_UNUSED(hnsSystemTime);
Q_UNUSED(flRate);
return S_OK;
}
// IMFSampleGrabberSink methods.
STDMETHODIMP SampleGrabberCallback::OnSetPresentationClock(IMFPresentationClock* pClock)
{
Q_UNUSED(pClock);
return S_OK;
}
STDMETHODIMP SampleGrabberCallback::OnShutdown()
{
return S_OK;
}
//void AudioSampleGrabberCallback::addProbe(MFAudioProbeControl* probe)
//{
// QMutexLocker locker(&m_audioProbeMutex);
// if (m_audioProbes.contains(probe))
// return;
// m_audioProbes.append(probe);
//}
//void AudioSampleGrabberCallback::removeProbe(MFAudioProbeControl* probe)
//{
// QMutexLocker locker(&m_audioProbeMutex);
// m_audioProbes.removeOne(probe);
//}
void AudioSampleGrabberCallback::setFormat(const QAudioFormat& format)
{
m_format = format;
}
STDMETHODIMP AudioSampleGrabberCallback::OnProcessSample(REFGUID guidMajorMediaType, DWORD dwSampleFlags,
LONGLONG llSampleTime, LONGLONG llSampleDuration, const BYTE * pSampleBuffer,
DWORD dwSampleSize)
{
Q_UNUSED(dwSampleFlags);
Q_UNUSED(llSampleTime);
Q_UNUSED(llSampleDuration);
Q_UNUSED(pSampleBuffer);
Q_UNUSED(dwSampleSize);
if (guidMajorMediaType != GUID_NULL && guidMajorMediaType != MFMediaType_Audio)
return S_OK;
QMutexLocker locker(&m_audioProbeMutex);
// if (m_audioProbes.isEmpty())
return S_OK;
// Check if sample has a presentation time
if (llSampleTime == _I64_MAX) {
// Set default QAudioBuffer start time
llSampleTime = -1;
} else {
// WMF uses 100-nanosecond units, Qt uses microseconds
llSampleTime /= 10;
}
// for (MFAudioProbeControl* probe : qAsConst(m_audioProbes))
// probe->bufferProbed((const char*)pSampleBuffer, dwSampleSize, m_format, llSampleTime);
return S_OK;
}
|
