Method Process

common/baseclasses/pullpin.cpp:433–585

}

void CPullPin::Process(void)
{
    // is there anything to do?
    if (m_tStop <= m_tStart)
    {
        EndOfStream();
        return;
    }

    BOOL bDiscontinuity = TRUE;

    // if there is more than one sample at the allocator,
    // then try to queue 2 at once in order to overlap.
    // -- get buffer count and required alignment
    ALLOCATOR_PROPERTIES Actual;
    HRESULT hr = m_pAlloc->GetProperties(&Actual);

    // align the start position downwards
    REFERENCE_TIME tStart = AlignDown(m_tStart / UNITS, Actual.cbAlign) * UNITS;
    REFERENCE_TIME tCurrent = tStart;

    REFERENCE_TIME tStop = m_tStop;
    if (tStop > m_tDuration)
    {
        tStop = m_tDuration;
    }

    // align the stop position - may be past stop, but that
    // doesn't matter
    REFERENCE_TIME tAlignStop = AlignUp(tStop / UNITS, Actual.cbAlign) * UNITS;

    DWORD dwRequest;

    if (!m_bSync)
    {

        //  Break out of the loop either if we get to the end or we're asked
        //  to do something else
        while (tCurrent < tAlignStop)
        {

            // Break out without calling EndOfStream if we're asked to
            // do something different
            if (CheckRequest(&dwRequest))
            {
                return;
            }

            // queue a first sample
            if (Actual.cBuffers > 1)
            {

                hr = QueueSample(tCurrent, tAlignStop, TRUE);
                bDiscontinuity = FALSE;

                if (FAILED(hr))
                {
                    return;