CSplit.cpp

Go to the documentation of this file.

#include "stdafx.h"

namespace AxPipe {
    void
    CSplit::DestructSink() {
        // Here we do a safety first, so we can be called even if it's not
        // properly constructed.
        if (m_pLeft) {
            m_pLeft->WorkExitWait();
            delete m_pLeft;
        }
        if (m_pRight) {
            m_pRight->WorkExitWait();
            delete m_pRight;
        }
        m_pLeft = m_pRight = NULL;
    }
    void
    CSplit::PumpSplit(CSeg *pSeg) {
        pSeg->AddRef();
        m_pLeft->OutPump(pSeg);
        m_pRight->OutPump(pSeg);
    }

    CSplit::CSplit() {
        m_pLeft = NULL;
        m_pRight = NULL;
    };

    void
    CSplit::AppendSink(CSink *pSink, bool fAutoDeleteSink) {
        SetError(ERROR_CODE_GENERIC, _T("Use Init() for CSplit"));
    }

    void
    CSplit::Sync() {
        WaitForIdle();
        m_pLeft->Sync();                    // Wait for the rest of the pipe too.
        m_pRight->Sync();                   // Wait for the rest of the pipe too.
    }

    CSplit *
    CSplit::Init(CPipe *pLeft, CPipe *pRight) {
        (m_pLeft = pLeft)->CError::Init(this);
        (m_pRight = pRight)->CError::Init(this);
        return this;
    }
    void
    CSplit::Out(CSeg *pSeg) {
        PumpSplit(pSeg);
    }

    void
    CSplit::OutSpecial(CSeg *pSeg) {
        PumpSplit(pSeg);
    }
    
    bool
    CSplit::OutFlush() {
        PumpSplit((new CSeg)->SetType(eSegTypeFlush));
        return false;
    }
    
    bool
    CSplit::OutClose() {
        PumpSplit((new CSeg)->SetType(eSegTypeClose));
        return false;
    }
    
    bool
    CSplit::OutOpen() {
        PumpSplit((new CSeg)->SetType(eSegTypeOpen));
        return false;
    }
};

---