1 files changed, 128 insertions, 0 deletions
diff --git a/src/base/TimeSource.cpp b/src/base/TimeSource.cpp
new file mode 100644
index 0000000..e90575d
--- /dev/null
+++ b/src/base/TimeSource.cpp
@@ -0,0 +1,128 @@
+//
+//  libavg - Media Playback Engine.
+//  Copyright (C) 2003-2014 Ulrich von Zadow
+//
+//  This library is free software; you can redistribute it and/or
+//  modify it under the terms of the GNU Lesser General Public
+//  License as published by the Free Software Foundation; either
+//  version 2 of the License, or (at your option) any later version.
+//
+//  This library is distributed in the hope that it will be useful,
+//  but WITHOUT ANY WARRANTY; without even the implied warranty of
+//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+//  Lesser General Public License for more details.
+//
+//  You should have received a copy of the GNU Lesser General Public
+//  License along with this library; if not, write to the Free Software
+//  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+//
+//  Current versions can be found at www.libavg.de
+//
+
+#include "TimeSource.h"
+
+#include "Logger.h"
+#include "Exception.h"
+
+#ifdef _WIN32
+#include <time.h>
+#include <sys/timeb.h>
+#include <windows.h>
+#include <Mmsystem.h>
+#else
+#include <sys/time.h>
+#endif
+#include <sys/stat.h>
+#include <sys/types.h>
+
+#include <errno.h>
+#include <assert.h>
+#include <iostream>
+#include <sstream>
+#include <unistd.h>
+
+using namespace std;
+
+namespace avg {
+
+TimeSource* TimeSource::m_pTimeSource = 0;
+
+TimeSource * TimeSource::get()
+{
+    if (!m_pTimeSource) {
+#ifdef _WIN32
+        TIMECAPS tc;
+        UINT wTimerRes;
+        MMRESULT err = timeGetDevCaps(&tc, sizeof(TIMECAPS));
+        AVG_ASSERT(err == TIMERR_NOERROR);
+        wTimerRes = max(tc.wPeriodMin, 1);
+        timeBeginPeriod(wTimerRes);
+#endif
+        m_pTimeSource = new TimeSource;
+    }
+    return m_pTimeSource;
+}
+
+TimeSource::TimeSource()
+{
+#ifdef __APPLE__
+    mach_timebase_info(&m_TimebaseInfo);
+#endif
+}
+
+TimeSource::~TimeSource()
+{
+}
+
+long long TimeSource::getCurrentMillisecs()
+{
+    return getCurrentMicrosecs()/1000;
+}
+
+long long TimeSource::getCurrentMicrosecs()
+{
+#ifdef _WIN32
+    return (long long)(timeGetTime())*1000;
+#else
+#ifdef __APPLE__
+    long long systemTime = mach_absolute_time();
+    return (systemTime * m_TimebaseInfo.numer/m_TimebaseInfo.denom)/1000;
+#else
+    struct timespec now;
+    int rc = clock_gettime(CLOCK_MONOTONIC, &now);
+    assert(rc == 0);
+    return ((long long)now.tv_sec)*1000000+now.tv_nsec/1000;
+#endif
+#endif
+}
+
+void TimeSource::sleepUntil(long long targetTime)
+{
+    long long now = getCurrentMillisecs();
+#ifdef __APPLE__
+    if (targetTime > now) {
+        msleep(targetTime-now);
+    }
+#else
+    while (now<targetTime) {
+        if (targetTime-now<=2) {
+            msleep(0);
+         } else {
+            msleep(int(targetTime-now-2));
+        }
+        now = getCurrentMillisecs();
+    }
+#endif
+}
+
+void msleep(int millisecs)
+{
+#if _WIN32
+            Sleep(millisecs);
+#else
+            usleep((long long)(millisecs)*1000);
+#endif
+}
+
+}
+