Lines Matching defs:pThisStrmIn

645     PPULSEAUDIOSTREAM pThisStrmIn = (PPULSEAUDIOSTREAM)pHstStrmIn;
649 pThisStrmIn->SampleSpec.format = drvHostPulseAudioFmtToPulse(pCfg->enmFormat);
650 pThisStrmIn->SampleSpec.rate = pCfg->uHz;
651 pThisStrmIn->SampleSpec.channels = pCfg->cChannels;
654 pThisStrmIn->BufAttr.fragsize = (pa_bytes_per_second(&pThisStrmIn->SampleSpec)
656 pThisStrmIn->BufAttr.maxlength = (pThisStrmIn->BufAttr.fragsize * 3) / 2;
659 int rc = drvHostPulseAudioOpen(true /* fIn */, "pa.in", &pThisStrmIn->SampleSpec, &pThisStrmIn->BufAttr,
660 &pThisStrmIn->pStream);
665 rc = drvHostPulseAudioPulseToFmt(pThisStrmIn->SampleSpec.format, &streamCfg.enmFormat,
669 LogRel(("PulseAudio: Cannot find audio capture format %ld\n", pThisStrmIn->SampleSpec.format));
673 streamCfg.uHz = pThisStrmIn->SampleSpec.rate;
674 streamCfg.cChannels = pThisStrmIn->SampleSpec.channels;
679 uint32_t cSamples = RT_MIN(pThisStrmIn->BufAttr.fragsize * 10, pThisStrmIn->BufAttr.maxlength)
686 pThisStrmIn->pu8PeekBuf = NULL;
700 PPULSEAUDIOSTREAM pThisStrmIn = (PPULSEAUDIOSTREAM)pHstStrmIn;
704 size_t cbAvail = pa_stream_readable_size(pThisStrmIn->pStream);
708 return drvHostPulseAudioError(pThisStrmIn->pDrv, "Failed to determine input data size");
711 if (pThisStrmIn->pu8PeekBuf)
713 Assert(pThisStrmIn->cbPeekBuf >= pThisStrmIn->offPeekBuf);
714 cbAvail += (pThisStrmIn->cbPeekBuf - pThisStrmIn->offPeekBuf);
728 cbToRead, cbAvail, pThisStrmIn->offPeekBuf, pThisStrmIn->cbPeekBuf));
736 if (!pThisStrmIn->pu8PeekBuf)
739 pa_stream_peek(pThisStrmIn->pStream,
740 (const void**)&pThisStrmIn->pu8PeekBuf, &pThisStrmIn->cbPeekBuf);
743 pThisStrmIn->offPeekBuf = 0;
748 if ( !pThisStrmIn->pu8PeekBuf
749 && !pThisStrmIn->cbPeekBuf)
755 Assert(pThisStrmIn->cbPeekBuf >= pThisStrmIn->offPeekBuf);
756 size_t cbToWrite = RT_MIN(pThisStrmIn->cbPeekBuf - pThisStrmIn->offPeekBuf, cbToRead);
760 pThisStrmIn->offPeekBuf, pThisStrmIn->cbPeekBuf, pThisStrmIn->pu8PeekBuf));
766 pThisStrmIn->pu8PeekBuf + pThisStrmIn->offPeekBuf,
776 pThisStrmIn->offPeekBuf += cbWritten;
782 || !pThisStrmIn->pu8PeekBuf
784 || pThisStrmIn->offPeekBuf == pThisStrmIn->cbPeekBuf)
787 pa_stream_drop(pThisStrmIn->pStream);
790 pThisStrmIn->pu8PeekBuf = NULL;
921 PPULSEAUDIOSTREAM pThisStrmIn = (PPULSEAUDIOSTREAM)pHstStrmIn;
922 if (pThisStrmIn->pStream)
925 pa_stream_disconnect(pThisStrmIn->pStream);
926 pa_stream_unref(pThisStrmIn->pStream);
929 pThisStrmIn->pStream = NULL;
1036 PPULSEAUDIOSTREAM pThisStrmIn = (PPULSEAUDIOSTREAM)pHstStrmIn;
1047 rc = drvHostPulseAudioWaitFor(pa_stream_cork(pThisStrmIn->pStream, 0 /* Play / resume */,
1048 drvHostPulseAudioCbSuccess, pThisStrmIn),
1057 if (pThisStrmIn->pu8PeekBuf) /* Do we need to drop the peek buffer?*/
1059 pa_stream_drop(pThisStrmIn->pStream);
1060 pThisStrmIn->pu8PeekBuf = NULL;
1063 rc = drvHostPulseAudioWaitFor(pa_stream_cork(pThisStrmIn->pStream, 1 /* Stop / pause */,
1064 drvHostPulseAudioCbSuccess, pThisStrmIn),