#include <WinAudioStream.h>

Inheritance diagram for CWinAudioStream:

Collaboration diagram for CWinAudioStream:

[legend]

Public Member Functions
	CWinAudioStream (IMediaObject *pObj)

virtual	~CWinAudioStream (void)

BOOL	startCapture (WAVEFORMATEX *format=NULL)

void	stopCapture (void)

Buffer	input (void)

BOOL	openOutput (ULONG bufcount=100, WAVEFORMATEX *format=NULL)

void	closeOutput (void)

void	output (Buffer buf)

	STDMETHODIMP_ (ULONG) AddRef(void)

	STDMETHODIMP_ (ULONG) Release(void)

STDMETHODIMP	QueryInterface (REFIID riid, void **ppv)

STDMETHODIMP	Read (void , ULONG, ULONG )

STDMETHODIMP	Seek (LARGE_INTEGER, DWORD, ULARGE_INTEGER *)

STDMETHODIMP	Write (const void , ULONG, ULONG )

STDMETHODIMP	SetSize (ULARGE_INTEGER)

STDMETHODIMP	CopyTo (IStream , ULARGE_INTEGER, ULARGE_INTEGER , ULARGE_INTEGER *)

STDMETHODIMP	Commit (DWORD)

STDMETHODIMP	Revert (void)

STDMETHODIMP	LockRegion (ULARGE_INTEGER, ULARGE_INTEGER, DWORD)

STDMETHODIMP	UnlockRegion (ULARGE_INTEGER, ULARGE_INTEGER, DWORD)

STDMETHODIMP	Stat (STATSTG *, DWORD)

STDMETHODIMP	Clone (IStream **)

Private Member Functions
void	freeOutputHeaders (void)

CWinMediaBuffer *	GetWriteBuffer (void)

void	Back2BufferStack (CWinMediaBuffer *pMediaBuf)

void	Back2BufferStackAll (void)

void	QueueCapturedData (BYTE *pData, UINT cbData)

void	QueueCapturedBuffer (CWinMediaBuffer *pMediaBuf)

void	ReadOneBuffer (BYTE *ppbData, ULONG pcbData)

UINT	CaptureThread (void)

BOOL	IsCapturing (void)

Static Private Member Functions
static UINT	CaptureThread (LPVOID pParam)

Private Attributes
CRITICAL_SECTION	m_lock

UINT	m_cRef

IMediaObject *	m_pMediaObj

HANDLE	m_hStopEvent

HANDLE	m_hDataReady

CWinThread *	m_captureThread

MediaBufferStack	m_bufferStack

MediaBufferQueue	m_bufferQueue

CWinMediaBuffer *	m_writeBuffer

CWinMediaBuffer *	m_readBuffer

ULONG	m_readBufferSize

ULONG	m_readBufferCount

ULONG	m_readBufferIndex

HWAVEOUT	m_hWave

WAVEHDR *	m_waveHeaders

ULONG	m_outputBufferNum

ULONG	m_outputBufferIndex

Buffer	m_streamData

Static Private Attributes
static const UINT	MaxReadBuffers = 20

static const UINT	MaxOutputBuffers = 210241024

Detailed Description

Definition at line 30 of file WinAudioStream.h.

Constructor & Destructor Documentation

◆ CWinAudioStream()

CWinAudioStream ( IMediaObject * pObj )

Definition at line 29 of file WinAudioStream.cpp.

{
    m_cRef              = 1;
    m_pMediaObj         = pObj;
 
    m_writeBuffer       = NULL;
    m_readBuffer        = NULL;
    m_readBufferSize    = 0;
    m_readBufferCount   = 0;
    m_readBufferIndex   = 0;
    //
    m_hStopEvent        = NULL;
    m_hDataReady        = NULL;
    //
    m_captureThread     = NULL;
 
    m_hWave             = NULL;
    m_waveHeaders       = NULL;
    m_outputBufferNum   = 0;
    m_outputBufferIndex = 0;
 
    m_streamData        = init_Buffer();
 
    if (m_pMediaObj!=NULL) m_pMediaObj->AddRef();
 
    InitializeCriticalSection(&m_lock);
}

◆ ~CWinAudioStream()

~CWinAudioStream ( void )

virtual

Definition at line 59 of file WinAudioStream.cpp.

{
    DEBUG_INFO("DESTRUCTOR: CWinAudioStream: START\n");
    //
    closeOutput();
    stopCapture();
 
    DeleteCriticalSection(&m_lock);
 
    DEBUG_INFO("DESTRUCTOR: CWinAudioStream: END\n");
}

References CWinAudioStream::closeOutput(), CWinAudioStream::m_lock, and CWinAudioStream::stopCapture().

Here is the call graph for this function:

Member Function Documentation

◆ Back2BufferStack()

void Back2BufferStack ( CWinMediaBuffer * pMediaBuf )

private

Definition at line 333 of file WinAudioStream.cpp.

{
    if (pMediaBuf!=NULL) {
        EnterCriticalSection(&m_lock);
        //
        pMediaBuf->SetLength(0);
        m_bufferStack.push(pMediaBuf);
        //
        LeaveCriticalSection(&m_lock);
    }
}

References CWinAudioStream::m_bufferStack, CWinAudioStream::m_lock, and CWinMediaBuffer::SetLength().

Referenced by CWinAudioStream::Back2BufferStackAll(), and CWinAudioStream::ReadOneBuffer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Back2BufferStackAll()

void Back2BufferStackAll ( void )

private

Definition at line 347 of file WinAudioStream.cpp.

{
    EnterCriticalSection(&m_lock);
 
    while (m_bufferQueue.size()>0) {
        CWinMediaBuffer* pMediaBuf = m_bufferQueue.front();
        m_bufferQueue.pop();
        Back2BufferStack(pMediaBuf);
    }
 
    if (m_readBuffer!=NULL) Back2BufferStack(m_readBuffer);
 
    m_readBufferIndex = 0;
    m_readBuffer = NULL;
    //
    LeaveCriticalSection(&m_lock);
}

References CWinAudioStream::Back2BufferStack(), CWinAudioStream::m_bufferQueue, CWinAudioStream::m_lock, CWinAudioStream::m_readBuffer, and CWinAudioStream::m_readBufferIndex.

Referenced by CWinAudioStream::stopCapture().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CaptureThread() [1/2]

UINT CaptureThread ( LPVOID pParam )

staticprivate

Definition at line 455 of file WinAudioStream.cpp.

{
    CWinAudioStream* pthis = (CWinAudioStream*)pParam;
    return pthis->CaptureThread();
}

References CWinAudioStream::CaptureThread().

Referenced by CWinAudioStream::CaptureThread().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CaptureThread() [2/2]

UINT CaptureThread ( void )

private

Definition at line 463 of file WinAudioStream.cpp.

{
    HANDLE mmHandle = NULL;
    DWORD  mmTaskIndex = 0;
 
    HRESULT hr = S_OK;
    bool bContinue = true;
    
    BYTE* pbOutputBuffer = NULL;
    CWinMediaBuffer outputBuffer(m_readBufferSize);
    
    DMO_OUTPUT_DATA_BUFFER OutputBufferStruct = {0};
    OutputBufferStruct.pBuffer = (IMediaBuffer*)&outputBuffer;
    
    DWORD dwStatus   = 0;
    ULONG cbProduced = 0;
 
    //
    mmHandle = AvSetMmThreadCharacteristics(_T("Audio"), &mmTaskIndex);
 
    while(bContinue) {
        //
        if (WaitForSingleObject(m_hStopEvent, 0)==WAIT_OBJECT_0) {
            bContinue = false;
            continue;
        }
 
        do {
            outputBuffer.clear();
            OutputBufferStruct.dwStatus = 0;
 
            hr = m_pMediaObj->ProcessOutput(0, 1, &OutputBufferStruct, &dwStatus);
            if (FAILED(hr)) {
                bContinue = false;
                break;
            }
            else if (hr==S_FALSE) {
                cbProduced = 0;
            }
            else {
                outputBuffer.GetBufferAndLength(&pbOutputBuffer, &cbProduced);
            }
 
            // Queue にデータを保存
            if (cbProduced>0) {
                QueueCapturedData(pbOutputBuffer, cbProduced);
                //Write(pbOutputBuffer, cbProduced, NULL);  // for TEST
            }
 
        } while (OutputBufferStruct.dwStatus & DMO_OUTPUT_DATA_BUFFERF_INCOMPLETE);
 
        //
        Sleep(10);
    }
 
    //
    SetEvent(m_hDataReady);
    AvRevertMmThreadCharacteristics(mmHandle);
 
    //
    if (FAILED(hr)) return FALSE;
    return TRUE;
}

References CWinMediaBuffer::clear(), CWinMediaBuffer::GetBufferAndLength(), CWinAudioStream::m_hDataReady, CWinAudioStream::m_hStopEvent, CWinAudioStream::m_pMediaObj, CWinAudioStream::m_readBufferSize, and CWinAudioStream::QueueCapturedData().

Referenced by CWinAudioStream::startCapture().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Clone()

STDMETHODIMP Clone ( IStream ** )

inline

Definition at line 94 of file WinAudioStream.h.

94{ return E_NOTIMPL;}

◆ closeOutput()

void closeOutput ( void )

Definition at line 188 of file WinAudioStream.cpp.

{
    freeOutputHeaders();
 
    if (m_hWave!=NULL) {
        ::waveOutPause(m_hWave);
        ::waveOutClose(m_hWave);
        m_hWave = NULL;
    }
}

References CWinAudioStream::freeOutputHeaders(), and CWinAudioStream::m_hWave.

Referenced by CWinAudioTool::closeOutput(), and CWinAudioStream::~CWinAudioStream().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Commit()

STDMETHODIMP Commit ( DWORD )

inline

Definition at line 89 of file WinAudioStream.h.

89{ return E_NOTIMPL;}

◆ CopyTo()

STDMETHODIMP CopyTo	(	IStream *	,
		ULARGE_INTEGER	,
		ULARGE_INTEGER *	,
		ULARGE_INTEGER *	)

inline

Definition at line 88 of file WinAudioStream.h.

88{ return E_NOTIMPL;}

◆ freeOutputHeaders()

void freeOutputHeaders ( void )

private

Definition at line 223 of file WinAudioStream.cpp.

{
    if (m_waveHeaders==NULL) return;
 
    for (ULONG i=0; i<m_outputBufferNum; i++) {
        if (m_waveHeaders[i].lpData!=NULL) {
            ::free(m_waveHeaders[i].lpData);
            m_waveHeaders[i].lpData = NULL;
        }
    }
    freeNull(m_waveHeaders);
}

References CWinAudioStream::m_outputBufferNum, and CWinAudioStream::m_waveHeaders.

Referenced by CWinAudioStream::closeOutput().

Here is the caller graph for this function:

◆ GetWriteBuffer()

CWinMediaBuffer * GetWriteBuffer ( void )

private

Definition at line 309 of file WinAudioStream.cpp.

{
    CWinMediaBuffer* pMediaBuf = NULL;
 
    EnterCriticalSection(&m_lock);
 
    if (m_bufferStack.size()>0) {   
        pMediaBuf = m_bufferStack.top();
        m_bufferStack.pop();
        pMediaBuf->SetLength(0);
    }                           
    else if (m_bufferQueue.size()>0) {
        pMediaBuf = m_bufferQueue.front();
        m_bufferQueue.pop();
        pMediaBuf->SetLength(0);
    }
 
    LeaveCriticalSection(&m_lock);
 
    return pMediaBuf;
}

References CWinAudioStream::m_bufferQueue, CWinAudioStream::m_bufferStack, CWinAudioStream::m_lock, and CWinMediaBuffer::SetLength().

Referenced by CWinAudioStream::QueueCapturedData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ input()

Buffer input ( void )

Definition at line 201 of file WinAudioStream.cpp.

{ 
    if (m_streamData.buf!=NULL) {
        ULONG len = 0;
        Read((void*)m_streamData.buf, (ULONG)m_streamData.bufsz, &len);
        m_streamData.vldsz = (int)len;
    }
    return m_streamData;
}

References CWinAudioStream::m_streamData, and CWinAudioStream::Read().

Referenced by CWinAudioTool::getAudioData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ IsCapturing()

BOOL IsCapturing ( void )

inlineprivate

Definition at line 145 of file WinAudioStream.h.

    {
        return (m_hStopEvent!=NULL) && (WaitForSingleObject(m_hStopEvent,0)!=WAIT_OBJECT_0);
    }

References CWinAudioStream::m_hStopEvent.

Referenced by CWinAudioStream::Read().

Here is the caller graph for this function:

◆ LockRegion()

STDMETHODIMP LockRegion	(	ULARGE_INTEGER	,
		ULARGE_INTEGER	,
		DWORD	)

inline

Definition at line 91 of file WinAudioStream.h.

91{ return E_NOTIMPL;}

◆ openOutput()

BOOL openOutput	(	ULONG	bufcount = 100,
		WAVEFORMATEX *	format = NULL )

Definition at line 153 of file WinAudioStream.cpp.

{
    if (m_pMediaObj==NULL && fmt==NULL) return FALSE;
 
    //
    WAVEFORMATEX format;
    if (fmt!=NULL) {
        format = *fmt;
    }
    else {
        DMO_MEDIA_TYPE media;
        m_pMediaObj->GetOutputCurrentType(0, &media);
        format = *(WAVEFORMATEX*)media.pbFormat;
    }
 
    //
    MMRESULT ret = ::waveOutOpen(&m_hWave, WAVE_MAPPER, &format, NULL, NULL, 0);
    if (ret!=MMSYSERR_NOERROR) return FALSE;
 
    m_outputBufferNum = bufcount;
    ULONG bufsz = sizeof(WAVEHDR)*m_outputBufferNum;
    m_waveHeaders = (WAVEHDR*)malloc(bufsz);
    memset(m_waveHeaders, 0, bufsz);
 
    for (ULONG i=0; i<m_outputBufferNum; i++) {
        m_waveHeaders[i].lpData  = (LPSTR)malloc(MaxOutputBuffers);
        m_waveHeaders[i].dwUser  = i;
        m_waveHeaders[i].dwFlags = WHDR_DONE;
    }
 
    return TRUE;
}

References CWinAudioStream::m_hWave, CWinAudioStream::m_outputBufferNum, CWinAudioStream::m_pMediaObj, CWinAudioStream::m_waveHeaders, and CWinAudioStream::MaxOutputBuffers.

Referenced by CWinAudioTool::openOutput().

Here is the caller graph for this function:

◆ output()

void output ( Buffer buf )

Definition at line 213 of file WinAudioStream.cpp.

{
    if (buf.buf==NULL || buf.vldsz<=0) return;
        
    Write((const void*)buf.buf, (ULONG)buf.vldsz, NULL);
    return;
}

References CWinAudioStream::Write().

Here is the call graph for this function:

◆ QueryInterface()

STDMETHODIMP QueryInterface	(	REFIID	riid,
		void **	ppv )

inline

Definition at line 63 of file WinAudioStream.h.

    {
        if (riid==IID_IUnknown) {
            AddRef();
            *ppv = (IUnknown*)this;
            return S_OK;
        }
        else if (riid==IID_IStream) {
            AddRef();
            *ppv = (IStream*)this;
            return S_OK;
        }
        else return E_NOINTERFACE;
    }

Referenced by CWinAudioTool::init(), and CWinAudioTool::setMediaType().

Here is the caller graph for this function:

◆ QueueCapturedBuffer()

void QueueCapturedBuffer ( CWinMediaBuffer * pMediaBuf )

private

Definition at line 400 of file WinAudioStream.cpp.

{
    EnterCriticalSection(&m_lock);
 
    m_bufferQueue.push(pMediaBuf);
    SetEvent(m_hDataReady);
 
    LeaveCriticalSection(&m_lock);
}

References CWinAudioStream::m_bufferQueue, CWinAudioStream::m_hDataReady, and CWinAudioStream::m_lock.

Referenced by CWinAudioStream::QueueCapturedData().

Here is the caller graph for this function:

◆ QueueCapturedData()

void QueueCapturedData	(	BYTE *	pData,
		UINT	cbData )

private

Definition at line 367 of file WinAudioStream.cpp.

{
    if (cbData<=0) return;
 
    if (m_writeBuffer==NULL) m_writeBuffer = GetWriteBuffer();
    if (m_writeBuffer==NULL) return;
 
    //
    BYTE* pWriteData  = NULL;
    DWORD cbWriteData = 0;
    DWORD cbMaxLength = 0;
 
    //
    m_writeBuffer->GetBufferAndLength(&pWriteData, &cbWriteData);
    m_writeBuffer->GetMaxLength(&cbMaxLength);
 
    if (cbWriteData+cbData<cbMaxLength) {
        memcpy(pWriteData+cbWriteData, pData, cbData);
        m_writeBuffer->SetLength(cbWriteData + cbData);
    }
    else {
        QueueCapturedBuffer(m_writeBuffer);
        //
        m_writeBuffer = GetWriteBuffer();
        m_writeBuffer->GetBufferAndLength(&pWriteData, &cbWriteData);
        //
        memcpy(pWriteData, pData, cbData);
        m_writeBuffer->SetLength(cbData);
    }
}

References CWinMediaBuffer::GetBufferAndLength(), CWinMediaBuffer::GetMaxLength(), CWinAudioStream::GetWriteBuffer(), CWinAudioStream::m_writeBuffer, CWinAudioStream::QueueCapturedBuffer(), and CWinMediaBuffer::SetLength().

Referenced by CWinAudioStream::CaptureThread().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Read()

STDMETHODIMP Read	(	void *	pData,
		ULONG	cbBuffer,
		ULONG *	pcbRead )

Definition at line 242 of file WinAudioStream.cpp.

{
   if (pcbRead==NULL) return E_INVALIDARG;
 
    ULONG bytesPendingToRead = cbBuffer;                // バッファの残り
 
    while (bytesPendingToRead>0 && IsCapturing()) {
        ReadOneBuffer((BYTE**)&pData, &bytesPendingToRead);
        if (m_readBuffer==NULL) WaitForSingleObject(m_hDataReady, INFINITE);
    }
 
    ULONG bytesRead = cbBuffer - bytesPendingToRead;    // 読み込んだデータ長
    m_readBufferCount += bytesRead;
 
    *pcbRead = bytesRead;
 
    return S_OK;
}

References CWinAudioStream::IsCapturing(), CWinAudioStream::m_hDataReady, CWinAudioStream::m_readBuffer, CWinAudioStream::m_readBufferCount, and CWinAudioStream::ReadOneBuffer().

Referenced by CWinAudioStream::input().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ReadOneBuffer()

void ReadOneBuffer	(	BYTE **	ppbData,
		ULONG *	pcbData )

private

Definition at line 412 of file WinAudioStream.cpp.

{
    EnterCriticalSection(&m_lock);
 
    //
    if (m_readBuffer==NULL) {
        if(m_bufferQueue.size()!=0) {
            m_readBuffer = m_bufferQueue.front();
            m_bufferQueue.pop();
        }
    }
 
    //
    if (m_readBuffer!=NULL) {
        //Copy as much data as we can or need
        BYTE* pData = NULL;
        DWORD dwDataLength = 0;
        m_readBuffer->GetBufferAndLength(&pData, &dwDataLength);
 
        ULONG cbToCopy = min(dwDataLength-m_readBufferIndex, *pcbData);
        memcpy(*ppbData, pData+m_readBufferIndex, cbToCopy);
        *ppbData = (*ppbData) + cbToCopy;
        *pcbData = (*pcbData) - cbToCopy;
        m_readBufferIndex    += cbToCopy;
 
        //
        if (m_readBufferIndex>=dwDataLength) {
            Back2BufferStack(m_readBuffer);
            m_readBuffer = NULL;
            m_readBufferIndex = 0;
 
            if (m_bufferQueue.size()!=0) {
                m_readBuffer = m_bufferQueue.front();
                m_bufferQueue.pop();
            }
        }
    }
 
    LeaveCriticalSection(&m_lock);
}

References CWinAudioStream::Back2BufferStack(), CWinMediaBuffer::GetBufferAndLength(), CWinAudioStream::m_bufferQueue, CWinAudioStream::m_lock, CWinAudioStream::m_readBuffer, and CWinAudioStream::m_readBufferIndex.

Referenced by CWinAudioStream::Read().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Revert()

STDMETHODIMP Revert ( void )

inline

Definition at line 90 of file WinAudioStream.h.

90{ return E_NOTIMPL;}

◆ Seek()

STDMETHODIMP Seek	(	LARGE_INTEGER	dlibMove,
		DWORD	dwOrigin,
		ULARGE_INTEGER *	plibNewPosition )

Definition at line 263 of file WinAudioStream.cpp.

{
    if (plibNewPosition!=NULL) plibNewPosition->QuadPart = m_readBufferCount + dlibMove.QuadPart;
 
    return S_OK;
}

References CWinAudioStream::m_readBufferCount.

◆ SetSize()

STDMETHODIMP SetSize ( ULARGE_INTEGER )

inline

Definition at line 87 of file WinAudioStream.h.

87{ return E_NOTIMPL;}

◆ startCapture()

BOOL startCapture ( WAVEFORMATEX * format = NULL )

Definition at line 73 of file WinAudioStream.cpp.

{
    if (m_pMediaObj==NULL && fmt==NULL) return FALSE;
 
    m_hStopEvent  = CreateEvent(NULL, FALSE, FALSE, NULL);
    m_hDataReady  = CreateEvent(NULL, FALSE, FALSE, NULL);
    m_writeBuffer = NULL;
    m_readBufferCount = 0;
 
    //
    WAVEFORMATEX format;
    if (fmt!=NULL) {
        format = *fmt;
    }
    else {
        DMO_MEDIA_TYPE media;
        m_pMediaObj->GetOutputCurrentType(0, &media);
        format = *(WAVEFORMATEX*)media.pbFormat;
    }
 
    // make Stack
    m_readBufferSize = format.nSamplesPerSec*format.nBlockAlign;
    for (UINT i=0; i<MaxReadBuffers; i++) {
        CWinMediaBuffer* pMediaBuf = new CWinMediaBuffer(m_readBufferSize);
        m_bufferStack.push(pMediaBuf);
    }
    m_streamData = make_Buffer(m_readBufferSize);
 
    // スレッドの起動
    m_captureThread = AfxBeginThread(CaptureThread, (LPVOID)this, THREAD_PRIORITY_NORMAL, 0, CREATE_SUSPENDED);
    m_captureThread->m_bAutoDelete = FALSE;
    m_captureThread->ResumeThread();
    ::Sleep(10);
 
    return TRUE;
}

References CWinAudioStream::CaptureThread(), CWinAudioStream::m_bufferStack, CWinAudioStream::m_captureThread, CWinAudioStream::m_hDataReady, CWinAudioStream::m_hStopEvent, CWinAudioStream::m_pMediaObj, CWinAudioStream::m_readBufferCount, CWinAudioStream::m_readBufferSize, CWinAudioStream::m_streamData, CWinAudioStream::m_writeBuffer, and CWinAudioStream::MaxReadBuffers.

Referenced by CWinAudioTool::startCapture().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Stat()

STDMETHODIMP Stat	(	STATSTG *	,
		DWORD	)

inline

Definition at line 93 of file WinAudioStream.h.

93{ return E_NOTIMPL;}

◆ STDMETHODIMP_() [1/2]

STDMETHODIMP_ ( ULONG )

inline

Definition at line 54 of file WinAudioStream.h.

54{ return InterlockedIncrement(&m_cRef);}

References CWinAudioStream::m_cRef.

◆ STDMETHODIMP_() [2/2]

STDMETHODIMP_ ( ULONG )

inline

Definition at line 56 of file WinAudioStream.h.

    {
        UINT ref = InterlockedDecrement(&m_cRef);
        if (ref==0) delete this;
        return ref;
    }

References CWinAudioStream::m_cRef.

◆ stopCapture()

void stopCapture ( void )

Definition at line 112 of file WinAudioStream.cpp.

{
    if (m_hStopEvent!=NULL) {
        SetEvent(m_hStopEvent);
        //
        if (m_captureThread!=NULL) {
            // スレッドが終了するまで待つ
            WaitForSingleObject(m_captureThread->m_hThread, INFINITE);
            CloseHandle(m_captureThread->m_hThread);
            delete m_captureThread;
            m_captureThread = NULL;
        }
        CloseHandle(m_hStopEvent);
        m_hStopEvent = NULL;
    }
 
    //
    if (m_hDataReady!=NULL) {
        SetEvent(m_hDataReady);
        CloseHandle(m_hDataReady);
        m_hDataReady = NULL;
    }
 
    //
    Back2BufferStackAll();
 
    // delete Stack
    while(!m_bufferStack.empty()) {
        CWinMediaBuffer* pMediaBuf = m_bufferStack.top();
        delete pMediaBuf;
        m_bufferStack.pop();
    }
 
    //
    free_Buffer(&m_streamData);
 
    return;
}

References CWinAudioStream::Back2BufferStackAll(), CWinAudioStream::m_bufferStack, CWinAudioStream::m_captureThread, CWinAudioStream::m_hDataReady, CWinAudioStream::m_hStopEvent, and CWinAudioStream::m_streamData.

Referenced by CWinAudioTool::stopCapture(), and CWinAudioStream::~CWinAudioStream().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ UnlockRegion()

STDMETHODIMP UnlockRegion	(	ULARGE_INTEGER	,
		ULARGE_INTEGER	,
		DWORD	)

inline

Definition at line 92 of file WinAudioStream.h.

92{ return E_NOTIMPL;}

◆ Write()

STDMETHODIMP Write	(	const void *	pbuf,
		ULONG	bufsz,
		ULONG *	dummy )

Definition at line 272 of file WinAudioStream.cpp.

{
    if (pbuf==NULL || bufsz==0 || bufsz>MaxOutputBuffers) return E_INVALIDARG;
 
    WAVEHDR* header = &m_waveHeaders[m_outputBufferIndex];
    if (!(header->dwFlags & WHDR_DONE)) return E_FAIL ;
 
    MMRESULT ret = ::waveOutUnprepareHeader(m_hWave, header, sizeof(WAVEHDR));
    if (ret!=MMSYSERR_NOERROR) return E_FAIL;
 
    header->dwBufferLength = (DWORD)bufsz;
    header->dwFlags = 0;
    memcpy(header->lpData, pbuf, bufsz);
 
    ret = ::waveOutPrepareHeader(m_hWave, header, sizeof(WAVEHDR));
    if (ret!=MMSYSERR_NOERROR) {
        header->dwFlags = WHDR_DONE;
        return E_FAIL;
    }
 
    ret = ::waveOutWrite(m_hWave, header, sizeof(WAVEHDR));
    if (ret!=MMSYSERR_NOERROR) {
        header->dwFlags = WHDR_DONE;
        return E_FAIL;
    }
 
    m_outputBufferIndex = (m_outputBufferIndex + 1) % m_outputBufferNum;
 
    return S_OK;
}