--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/javamanager/javacaptain/src.linux/tickerprovider.cpp	Tue Apr 27 16:30:29 2010 +0300
@@ -0,0 +1,176 @@
+/*
+* 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
+