Examples.cpp

Go to the documentation of this file.

#include "stdafx.h"
#include "Examples.h"

void CFilterNop::InFilter() {
    AxPipe::CSeg *pInSeg;
    size_t cbIn;
    Open();
    // End of this stream is signalled by NULL
    while (pInSeg = Read(), (pInSeg && (cbIn = pInSeg->Len()))) {
        // We're not guaranteed to get an output segment of the required
        // size, so we must loop here.
        while (cbIn) {
            AxPipe::CSeg *pOutSeg = GetSeg(cbIn);

            if (!pOutSeg) {
                return;         // Error of some kind
            }
            // This might be a good place to do something...
            memcpy(pOutSeg->PtrWr(), pInSeg->PtrRd(), pOutSeg->Len());

            cbIn -= pOutSeg->Len();
            Pump(pOutSeg);
        }
        // We're done with the inbuffer, let it go.
        pInSeg->Release();
    }
    Close();
    // This might be a good place to flush, if there's anything to flush. There's
    // no explicit Flush() method for pull-style filters. When returning, you should
    // be ready for a new call to InFilter().
}

AxPipe::CSeg *
CJoinInterleave::In() {
    static int nThisIx = 0;
    int nStartIx = nThisIx;
    do {
        if (!StreamEmpty(nThisIx)) {
            AxPipe::CSeg *pSeg = StreamSeg(nThisIx);
            if (pSeg && pSeg->Len()) {
                // This is where you would do something with the data before passing it on
                // by returning a segment. At this point you know which stream the data
                // came from.
                return pSeg;
            }
        }
        // Next stream
        nThisIx = StreamIx(nThisIx + 1);
    } while (nThisIx != nStartIx);

    // Only signal end of stream when all streams are empty.
    return new AxPipe::CSeg;
}

---