/*

* Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:

*

*/

#include "cxefilesavethreaddesktop.h"

#include "cxeimagedataitem.h"  // item

#include "cxutils.h" // debug

/*!

    \class CxeFileSaveThreadDesktop

    \brief Still image saving thread    

*/

// ======== MEMBER FUNCTIONS ========

CxeFileSaveThreadDesktop::CxeFileSaveThreadDesktop(QObject *parent)

    : CxeFileSaveThread(parent), mExitThread(false), mExit(false)

{

    start(IdlePriority);

}

CxeFileSaveThreadDesktop::~CxeFileSaveThreadDesktop()

{

    CX_DEBUG_ENTER_FUNCTION();

    mMutex.lock();

    mExitThread = true;

    mDataToSave.wakeOne();

    mMutex.unlock();

    wait(); // until the thread has finished execution.

    qDeleteAll(mDataList);  // Ensure destruction

    mDataList.clear();

    CX_DEBUG_EXIT_FUNCTION();

}

void CxeFileSaveThreadDesktop::save(CxeImageDataItem *data)

{

    CX_DEBUG_ENTER_FUNCTION();

    // Ensure safe data adding. 

    // Saving thread will wait if needed, in read method, until mutex is unlocked

    mMutex.lock();

    mDataList.append(data);

    // Wake up saving thread if it's sleeping

    mDataToSave.wakeOne(); 

    mMutex.unlock();

    CX_DEBUG_EXIT_FUNCTION();

}

void CxeFileSaveThreadDesktop::handleVideoSaved(CxeError::Id status, const QString &filename)

{

    Q_UNUSED(status);

    Q_UNUSED(filename);

}

void CxeFileSaveThreadDesktop::handleSnapshotReady(CxeError::Id status, const QImage &snapshot, const QString &filename)

{

    Q_UNUSED(status);

    Q_UNUSED(snapshot);

    Q_UNUSED(filename);

}

void CxeFileSaveThreadDesktop::handleSnapshotReady(CxeError::Id status, const QImage &snapshot, int id)

{

    Q_UNUSED(status);

    Q_UNUSED(snapshot);

    Q_UNUSED(id);

}

void CxeFileSaveThreadDesktop::read()

{

    mMutex.lock();

    mCount = mDataList.count();

    mExit = mExitThread;

    mMutex.unlock();

}

void CxeFileSaveThreadDesktop::run()

{

    CX_DEBUG_ENTER_FUNCTION();

    CxeImageDataItem *item = NULL;

    int i = 0;

    // Check if there is data to save.

    // There should not be any, because the thread is just contructed

    read();

    while (!mExit || i < mCount) { // Complete save before exit

        CX_DEBUG(("CxeFileSaveThreadDesktop: index %d", i));

        // Wait data

        if (!mExit && i >= mCount) {

            // If there isn't any data to save, put the thread sleeping

            CX_DEBUG(("CxeFileSaveThreadDesktop: set thread sleeping"));

            mMutex.lock();

            //! @todo: read datalist count here before clearing, because there is some machine cycles after previous read 

            // Clear the datalist, since all items are saved

            mDataList.clear();

            i = 0;

            mDataToSave.wait(&mMutex); // waiting "wakeOne"

            mMutex.unlock();

            CX_DEBUG(("CxeFileSaveThreadDesktop: woken up"));

        }

        // There should be data now, because the thread is woken up

        read();

        if (i < mCount) { 

            item = mDataList[i];

        } else {

            CX_DEBUG(("CxeFileSaveThreadDesktop: ERROR - woke up without data"));

            continue;

        }

        // Check that item is not saved already

        if (item && item->state() == CxeImageDataItem::SavePending) {

            item->save();// Error ignored since it is emitted from CxeImageDataItemSymbian

            // Delete item, since we own it

            delete item; 

            item = NULL;

        }

        // Saving takes some seconds, there might be new data available.

        read();

        ++i;

    }

    CX_DEBUG_EXIT_FUNCTION();

}