/*

* Copyright (c) 2007-2007 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 "logger.h"

#include "monitor.h"

#ifndef __SYMBIAN32__

#include <sys/time.h>

#include <errno.h>

#endif

using namespace java::util;

Monitor::Monitor() : mWaiting(false), mNotifyBeforeWait(false)

{

    JELOG2(EUtils);

}

Monitor::~Monitor()

{

    JELOG2(EUtils);

    pthread_mutex_destroy(&mMutex);

    pthread_cond_destroy(&mCondVar);

}

OS_EXPORT Monitor* Monitor::createMonitor()

{

    JELOG2(EUtils);

    int result = -1;

    Monitor* monitor = new Monitor();

    if (monitor)

    {

        result = pthread_mutex_init(&monitor->mMutex, 0);

        if (result == 0)

        {

            result = pthread_cond_init(&monitor->mCondVar, 0);

            if (result != 0)

            {

                ELOG(EUtils, "Monitor::createMonitor() "

                     "pthread_cond_init() failed");

            }

        }

        else

        {

            ELOG(EUtils, "Monitor::createMonitor() "

                 "pthread_mutex_init() failed");

        }

    }

    else

    {

        ELOG(EUtils, "Monitor::createMonitor() "

             "new Monitor() failed");

    }

    if (result != 0 && monitor)

    {

        delete monitor;

        monitor = 0;

    }

    return monitor;

}

OS_EXPORT int Monitor::wait(int timeOut)

{

    JELOG4(EUtils, EEntryLog & EInfoHeavyLoad);

    pthread_mutex_lock(&mMutex);

    if (!mNotifyBeforeWait)

    {

        mWaiting = true;

        if (timeOut == 0)

        {

            while (mWaiting)

            {

                pthread_cond_wait(&mCondVar, &mMutex);

            }

        }

        else

        {

            struct timeval currentTimeVal;

            struct timespec timeOutTime;

            gettimeofday(&currentTimeVal, 0);

            timeOutTime.tv_sec = currentTimeVal.tv_sec + timeOut / 1000;

            timeOutTime.tv_nsec =

                currentTimeVal.tv_usec * 1000 + (timeOut % 1000) * 1000 * 1000;

            int err = pthread_cond_timedwait(&mCondVar, &mMutex, &timeOutTime);

            if (err != 0 && err != ETIMEDOUT)

            {

                ELOG1(EUtils, "Monitor: Timed wait failed, err = %d", err);

            }

        }

    }

    else

    {

        mNotifyBeforeWait = false;

    }

    pthread_mutex_unlock(&mMutex);

    return 0;

}

OS_EXPORT int Monitor::notify()

{

    JELOG4(EUtils, EEntryLog & EInfoHeavyLoad);

    pthread_mutex_lock(&mMutex);

    if (mWaiting)

    {

        pthread_cond_signal(&mCondVar);

    }

    else

    {

        mNotifyBeforeWait = true;

    }

    mWaiting = false;

    pthread_mutex_unlock(&mMutex);

    return 0;

}