ECF

EpsiFileCompressor.cpp

void EpsiFileCompressor::compress(const QString &folder, const QString &ecfFilename)
{
    QWaitCondition      waitCondition;

    FilePool            filepool(folder);
    ZippedBufferPool    zippedBufferPool(&waitCondition);
    Zipper              zipper1(&filepool, &zippedBufferPool);
    Zipper              zipper2(&filepool, &zippedBufferPool);
    Writter             writter(ecfFilename, &zippedBufferPool, &waitCondition);

    zipper1.start();
    zipper2.start();
    writter.start();

    zipper1.wait();
    zipper2.wait();

    zippedBufferPool.done(true);

    writter.wait();
}

Writter.cpp

void Writter::run()
{
    m_waitCondition->wait(&m_mutex);

    ZippedBuffer    zippedBuffer = m_zippedBufferPool->tryGet();

    while ( ! m_zippedBufferPool->done())
    {
        if (zippedBuffer.valid())
        {
            m_stream << zippedBuffer;
        }

        zippedBuffer = m_zippedBufferPool->tryGet();
    }

    m_mutex.unlock();
}

ZippedBufferPool.cpp

ZippedBuffer ZippedBufferPool::tryGet()
{
    QMutexLocker    locker(&m_mutex);
    ZippedBuffer    zippedBuffer;

    if ( ! m_zippedBuffers.empty())
    {
        zippedBuffer = m_zippedBuffers.front();
        m_zippedBuffers.pop_front();
    }

    return zippedBuffer;
}