/*
* Copyright (c) 2008 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:  TimerServer
*
*/


#include <time.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <limits.h>
#include <signal.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>

#include "logger.h"

#include "tickerprovider.h"

namespace java
{
namespace captain
{

TickerProvider::TickerProvider(TickerProviderEventsInterface* aEvents)
        :TickerProviderInterface(aEvents), mTimerId(0), mNextTickAt(0LL)
{
    JELOG2(EJavaCaptain);
    int rc = timer_create(CLOCK_REALTIME, NULL, &mTimerId);
    if (rc != 0)
    {
        ELOG2(EJavaCaptain, "tickerProvider timer_create failed(%d) errono=%d", rc, errno);
        mTimerId = 0;
    }
}

TickerProvider::~TickerProvider()
{
    JELOG2(EJavaCaptain);
    if (mTimerId)
    {
        timer_delete(mTimerId);
    }
}

void TickerProvider::nextTickAt(const long long& aJavaTime)
{
    JELOG2(EJavaCaptain);

    long long periodmS = (aJavaTime - getCurrentJavaTime());
    LOG1(EJavaCaptain, EInfo, "request %d ms from now", periodmS);

    // Already or about to expire (within next 100ms)
    if (periodmS < 100)
    {
        cancel();
        kill(getpid(), SIGALRM);
        mNextTickAt = 0LL;
    }
    else
    {
        long long periodS = periodmS/1000LL;
        //19 Jan 2038 is maximum timer value(equal with INT_MAX) which can be set to the
        //to the timer_settime. It is ok to set INT_MAX as value of timer in this situation.
        //Ultimate solution would be set first INT_MAX to the timer and after expiration of that timer
        //set rest of the timer value of the orig. timer.
        int periodnS = 0;
        if ((long long) INT_MAX < periodS)
        {
            periodS = INT_MAX;
        }
        else
        {
            periodnS = periodmS - (periodS * 1000);
            periodnS *= 1000L; // ms -> us
            periodnS *= 1000L; // us -> ns
        }

        LOG1(EJavaCaptain, EInfo, "nextTickAt (%ld seconds)", periodS);
        LOG1(EJavaCaptain, EInfo, "nextTickAt (%d nanoseconds)", periodnS);

        struct itimerspec value;
        memset(&value, 0, sizeof(value));
        int rc = timer_gettime(mTimerId, &value);

        if (!rc)
        {
            // Start timer if it wasn't already started or was started but set too late
            if ((!value.it_value.tv_sec && !value.it_value.tv_nsec) ||
                    (value.it_value.tv_sec > periodS) ||
                    (value.it_value.tv_sec == periodS && value.it_value.tv_nsec > periodnS))
            {
                memset(&value, 0, sizeof(value));
                value.it_value.tv_sec = periodS;
                value.it_value.tv_nsec = periodnS;
                rc = timer_settime(mTimerId, 0, &value, NULL);
                if (rc != 0)
                {
                    ELOG2(EJavaCaptain, "tickerProvider timer_settime failed(%d) errono=%d", rc, errno);
                }
                mNextTickAt = aJavaTime;
            }
        }
        else
        {
            ELOG2(EJavaCaptain, "tickerProvider timer_gettime failed(%d) errno=%d", rc, errno);
        }
    }
}

long long TickerProvider::getNextTickAt()
{
    JELOG2(EJavaCaptain);

    struct itimerspec value;
    memset(&value, 0, sizeof(value));
    int rc = timer_gettime(mTimerId, &value);

    if (!rc)
    {
        // Timer was not started
        if (!value.it_value.tv_sec && !value.it_value.tv_nsec)
        {
            mNextTickAt = 0LL;
        }
    }
    else
    {
        ELOG2(EJavaCaptain, "tickerProvider timer_gettime failed(%d) errno=%d", rc, errno);
    }

    return mNextTickAt;
}

void TickerProvider::cancel()
{
    JELOG2(EJavaCaptain);

    struct itimerspec value;
    memset(&value, 0, sizeof(value));
    int rc = timer_gettime(mTimerId, &value);

    if (!rc)
    {
        // Stop timer only if it was started
        if (value.it_value.tv_sec || value.it_value.tv_nsec)
        {
            memset(&value, 0, sizeof(value));
            rc = timer_settime(mTimerId, 0, &value, NULL);
            if (rc != 0)
            {
                ELOG2(EJavaCaptain, "tickerProvider timer_settime failed(%d) errono=%d", rc, errno);
            }
        }
    }
    else
    {
        ELOG2(EJavaCaptain, "tickerProvider timer_gettime failed(%d) errno=%d", rc, errno);
    }
}

} // namespace captain
} // namespace java