diff options
Diffstat (limited to 'lib/libUPnP/Neptune/Source/System/Posix/NptPosixSystem.cpp')
| -rw-r--r-- | lib/libUPnP/Neptune/Source/System/Posix/NptPosixSystem.cpp | 201 |
1 files changed, 201 insertions, 0 deletions
diff --git a/lib/libUPnP/Neptune/Source/System/Posix/NptPosixSystem.cpp b/lib/libUPnP/Neptune/Source/System/Posix/NptPosixSystem.cpp new file mode 100644 index 0000000..4fb31a0 --- /dev/null +++ b/lib/libUPnP/Neptune/Source/System/Posix/NptPosixSystem.cpp @@ -0,0 +1,201 @@ +/***************************************************************** +| +| Neptune - System :: Posix Implementation +| +| (c) 2001-2003 Gilles Boccon-Gibod +| Author: Gilles Boccon-Gibod (bok@bok.net) +| + ****************************************************************/ + +/*---------------------------------------------------------------------- +| includes ++---------------------------------------------------------------------*/ +#include <stdio.h> +#include <stdlib.h> +#include <errno.h> +#include <time.h> +#include <sys/time.h> +#include <pthread.h> +#include <unistd.h> + +#include "NptConfig.h" +#include "NptTypes.h" +#include "NptSystem.h" +#include "NptResults.h" +#include "NptDebug.h" +#include "NptUtils.h" + +/*---------------------------------------------------------------------- +| NPT_PosixSystem ++---------------------------------------------------------------------*/ +class NPT_PosixSystem +{ +public: + // class variables + static NPT_PosixSystem System; + + // methods + NPT_PosixSystem(); + ~NPT_PosixSystem(); + + // members + pthread_mutex_t m_SleepMutex; + pthread_cond_t m_SleepCondition; +}; +NPT_PosixSystem NPT_PosixSystem::System; + +/*---------------------------------------------------------------------- +| NPT_PosixSystem::NPT_PosixSystem ++---------------------------------------------------------------------*/ +NPT_PosixSystem::NPT_PosixSystem() +{ + pthread_mutex_init(&m_SleepMutex, NULL); + pthread_cond_init(&m_SleepCondition, NULL); +} + +/*---------------------------------------------------------------------- +| NPT_PosixSystem::~NPT_PosixSystem ++---------------------------------------------------------------------*/ +NPT_PosixSystem::~NPT_PosixSystem() +{ + pthread_cond_destroy(&m_SleepCondition); + pthread_mutex_destroy(&m_SleepMutex); +} + +/*---------------------------------------------------------------------- +| NPT_System::GetProcessId ++---------------------------------------------------------------------*/ +NPT_Result +NPT_System::GetProcessId(NPT_UInt32& id) +{ + id = getpid(); + return NPT_SUCCESS; +} + +/*---------------------------------------------------------------------- +| NPT_GetSystemMachineName ++---------------------------------------------------------------------*/ +#if !defined(NPT_CONFIG_HAVE_SYSTEM_MACHINE_NAME) +NPT_Result NPT_GetSystemMachineName(NPT_String& /*name*/) +{ + return NPT_ERROR_NOT_SUPPORTED; +} +#endif + +/*---------------------------------------------------------------------- +| NPT_System::GetMachineName ++---------------------------------------------------------------------*/ +NPT_Result +NPT_System::GetMachineName(NPT_String& name) +{ + return NPT_GetSystemMachineName(name); +} + +/*---------------------------------------------------------------------- +| NPT_System::GetCurrentTimeStamp ++---------------------------------------------------------------------*/ +NPT_Result +NPT_System::GetCurrentTimeStamp(NPT_TimeStamp& now) +{ + struct timeval now_tv; + + // get current time from system + if (gettimeofday(&now_tv, NULL)) { + now.SetNanos(0); + return NPT_FAILURE; + } + + // convert format + now.SetNanos((NPT_UInt64)now_tv.tv_sec * 1000000000 + + (NPT_UInt64)now_tv.tv_usec * 1000); + + return NPT_SUCCESS; +} + +/*---------------------------------------------------------------------- +| NPT_System::Sleep ++---------------------------------------------------------------------*/ +NPT_Result +NPT_System::Sleep(const NPT_TimeInterval& duration) +{ + struct timespec time_req; + struct timespec time_rem; + int result; + + // setup the time value + time_req.tv_sec = (time_t)duration.ToNanos()/1000000000; + time_req.tv_nsec = duration.ToNanos()%1000000000; + + // sleep + do { + result = nanosleep(&time_req, &time_rem); + time_req = time_rem; + } while (result == -1 && + errno == EINTR && + (long)time_req.tv_sec >= 0 && + (long)time_req.tv_nsec >= 0); + + return NPT_SUCCESS; +} + +/*---------------------------------------------------------------------- +| NPT_System::SleepUntil ++---------------------------------------------------------------------*/ +NPT_Result +NPT_System::SleepUntil(const NPT_TimeStamp& when) +{ + struct timespec timeout; + struct timeval now; + int result; + + // get current time from system + if (gettimeofday(&now, NULL)) { + return NPT_FAILURE; + } + + // setup timeout + NPT_UInt64 limit = (NPT_UInt64)now.tv_sec*1000000000 + + (NPT_UInt64)now.tv_usec*1000 + + when.ToNanos(); + timeout.tv_sec = (time_t)limit/1000000000; + timeout.tv_nsec = limit%1000000000; + + // sleep + do { + result = pthread_cond_timedwait(&NPT_PosixSystem::System.m_SleepCondition, + &NPT_PosixSystem::System.m_SleepMutex, + &timeout); + if (result == ETIMEDOUT) { + return NPT_SUCCESS; + } + } while (result == EINTR); + + return NPT_FAILURE; +} + +/*---------------------------------------------------------------------- +| NPT_System::SetRandomSeed ++---------------------------------------------------------------------*/ +NPT_Result +NPT_System::SetRandomSeed(unsigned int seed) +{ + srand(seed); + return NPT_SUCCESS; +} + +/*---------------------------------------------------------------------- +| NPT_System::GetRandomInteger ++---------------------------------------------------------------------*/ +NPT_UInt32 +NPT_System::GetRandomInteger() +{ + static bool seeded = false; + if (seeded == false) { + NPT_TimeStamp now; + GetCurrentTimeStamp(now); + SetRandomSeed((NPT_UInt32)now.ToNanos()); + seeded = true; + } + + return rand(); +} |