aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/libs/poco/Foundation/src/Event_POSIX.cpp
diff options
context:
space:
mode:
authororivej <orivej@yandex-team.ru>2022-02-10 16:45:01 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:01 +0300
commit2d37894b1b037cf24231090eda8589bbb44fb6fc (patch)
treebe835aa92c6248212e705f25388ebafcf84bc7a1 /contrib/libs/poco/Foundation/src/Event_POSIX.cpp
parent718c552901d703c502ccbefdfc3c9028d608b947 (diff)
downloadydb-2d37894b1b037cf24231090eda8589bbb44fb6fc.tar.gz
Restoring authorship annotation for <orivej@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'contrib/libs/poco/Foundation/src/Event_POSIX.cpp')
-rw-r--r--contrib/libs/poco/Foundation/src/Event_POSIX.cpp340
1 files changed, 170 insertions, 170 deletions
diff --git a/contrib/libs/poco/Foundation/src/Event_POSIX.cpp b/contrib/libs/poco/Foundation/src/Event_POSIX.cpp
index de726f6db8..50fb6f78a8 100644
--- a/contrib/libs/poco/Foundation/src/Event_POSIX.cpp
+++ b/contrib/libs/poco/Foundation/src/Event_POSIX.cpp
@@ -1,170 +1,170 @@
-//
-// Event_POSIX.cpp
-//
-// Library: Foundation
-// Package: Threading
-// Module: Event
-//
-// Copyright (c) 2004-2006, Applied Informatics Software Engineering GmbH.
-// and Contributors.
-//
-// SPDX-License-Identifier: BSL-1.0
-//
-
-
-#include "Poco/Event_POSIX.h"
-#if defined(POCO_VXWORKS)
-#include <timers.h>
-#include <cstring>
-#else
-#include <time.h>
-#include <sys/time.h>
-#endif
-
-
-//
-// Note: pthread_cond_timedwait() with CLOCK_MONOTONIC is supported
-// on Linux and QNX, as well as on Android >= 5.0 (API level 21).
-// On Android < 5.0, HAVE_PTHREAD_COND_TIMEDWAIT_MONOTONIC is defined
-// to indicate availability of non-standard pthread_cond_timedwait_monotonic().
-//
-#ifndef POCO_HAVE_MONOTONIC_PTHREAD_COND_TIMEDWAIT
- #if (defined(__linux__) || defined(__QNX__)) && !(defined(__ANDROID__) && (defined(HAVE_PTHREAD_COND_TIMEDWAIT_MONOTONIC) || __ANDROID_API__ <= 21))
- #define POCO_HAVE_MONOTONIC_PTHREAD_COND_TIMEDWAIT 1
- #endif
-#endif
-
-
-#ifndef POCO_HAVE_CLOCK_GETTIME
- #if (defined(_POSIX_TIMERS) && defined(CLOCK_REALTIME)) || defined(POCO_VXWORKS) || defined(__QNX__)
- #ifndef __APPLE__ // See GitHub issue #1453 - not available before Mac OS 10.12/iOS 10
- #define POCO_HAVE_CLOCK_GETTIME
- #endif
- #endif
-#endif
-
-
-namespace Poco {
-
-
-EventImpl::EventImpl(bool autoReset): _auto(autoReset), _state(false)
-{
-#if defined(POCO_VXWORKS)
- // This workaround is for VxWorks 5.x where
- // pthread_mutex_init() won't properly initialize the mutex
- // resulting in a subsequent freeze in pthread_mutex_destroy()
- // if the mutex has never been used.
- std::memset(&_mutex, 0, sizeof(_mutex));
-#endif
-
- if (pthread_mutex_init(&_mutex, NULL))
- throw SystemException("cannot create event (mutex)");
-
-#if defined(POCO_HAVE_MONOTONIC_PTHREAD_COND_TIMEDWAIT)
- pthread_condattr_t attr;
- if (pthread_condattr_init(&attr))
- {
- pthread_mutex_destroy(&_mutex);
- throw SystemException("cannot create event (condition attribute)");
- }
- if (pthread_condattr_setclock(&attr, CLOCK_MONOTONIC))
- {
- pthread_condattr_destroy(&attr);
- pthread_mutex_destroy(&_mutex);
- throw SystemException("cannot create event (condition attribute clock)");
- }
- if (pthread_cond_init(&_cond, &attr))
- {
- pthread_condattr_destroy(&attr);
- pthread_mutex_destroy(&_mutex);
- throw SystemException("cannot create event (condition)");
- }
- pthread_condattr_destroy(&attr);
-#else
- if (pthread_cond_init(&_cond, NULL))
- {
- pthread_mutex_destroy(&_mutex);
- throw SystemException("cannot create event (condition)");
- }
-#endif
-}
-
-
-EventImpl::~EventImpl()
-{
- pthread_cond_destroy(&_cond);
- pthread_mutex_destroy(&_mutex);
-}
-
-
-void EventImpl::waitImpl()
-{
- if (pthread_mutex_lock(&_mutex))
- throw SystemException("wait for event failed (lock)");
- while (!_state)
- {
- if (pthread_cond_wait(&_cond, &_mutex))
- {
- pthread_mutex_unlock(&_mutex);
- throw SystemException("wait for event failed");
- }
- }
- if (_auto)
- _state = false;
- pthread_mutex_unlock(&_mutex);
-}
-
-
-bool EventImpl::waitImpl(long milliseconds)
-{
- int rc = 0;
- struct timespec abstime;
-
-#if defined(POCO_HAVE_MONOTONIC_PTHREAD_COND_TIMEDWAIT)
- clock_gettime(CLOCK_MONOTONIC, &abstime);
- abstime.tv_sec += milliseconds / 1000;
- abstime.tv_nsec += (milliseconds % 1000)*1000000;
- if (abstime.tv_nsec >= 1000000000)
- {
- abstime.tv_nsec -= 1000000000;
- abstime.tv_sec++;
- }
-#elif defined(POCO_HAVE_CLOCK_GETTIME)
- clock_gettime(CLOCK_REALTIME, &abstime);
- abstime.tv_sec += milliseconds / 1000;
- abstime.tv_nsec += (milliseconds % 1000)*1000000;
- if (abstime.tv_nsec >= 1000000000)
- {
- abstime.tv_nsec -= 1000000000;
- abstime.tv_sec++;
- }
-#else
- struct timeval tv;
- gettimeofday(&tv, NULL);
- abstime.tv_sec = tv.tv_sec + milliseconds / 1000;
- abstime.tv_nsec = tv.tv_usec*1000 + (milliseconds % 1000)*1000000;
- if (abstime.tv_nsec >= 1000000000)
- {
- abstime.tv_nsec -= 1000000000;
- abstime.tv_sec++;
- }
-#endif
-
- if (pthread_mutex_lock(&_mutex) != 0)
- throw SystemException("wait for event failed (lock)");
- while (!_state)
- {
- if ((rc = pthread_cond_timedwait(&_cond, &_mutex, &abstime)))
- {
- if (rc == ETIMEDOUT) break;
- pthread_mutex_unlock(&_mutex);
- throw SystemException("cannot wait for event");
- }
- }
- if (rc == 0 && _auto) _state = false;
- pthread_mutex_unlock(&_mutex);
- return rc == 0;
-}
-
-
-} // namespace Poco
+//
+// Event_POSIX.cpp
+//
+// Library: Foundation
+// Package: Threading
+// Module: Event
+//
+// Copyright (c) 2004-2006, Applied Informatics Software Engineering GmbH.
+// and Contributors.
+//
+// SPDX-License-Identifier: BSL-1.0
+//
+
+
+#include "Poco/Event_POSIX.h"
+#if defined(POCO_VXWORKS)
+#include <timers.h>
+#include <cstring>
+#else
+#include <time.h>
+#include <sys/time.h>
+#endif
+
+
+//
+// Note: pthread_cond_timedwait() with CLOCK_MONOTONIC is supported
+// on Linux and QNX, as well as on Android >= 5.0 (API level 21).
+// On Android < 5.0, HAVE_PTHREAD_COND_TIMEDWAIT_MONOTONIC is defined
+// to indicate availability of non-standard pthread_cond_timedwait_monotonic().
+//
+#ifndef POCO_HAVE_MONOTONIC_PTHREAD_COND_TIMEDWAIT
+ #if (defined(__linux__) || defined(__QNX__)) && !(defined(__ANDROID__) && (defined(HAVE_PTHREAD_COND_TIMEDWAIT_MONOTONIC) || __ANDROID_API__ <= 21))
+ #define POCO_HAVE_MONOTONIC_PTHREAD_COND_TIMEDWAIT 1
+ #endif
+#endif
+
+
+#ifndef POCO_HAVE_CLOCK_GETTIME
+ #if (defined(_POSIX_TIMERS) && defined(CLOCK_REALTIME)) || defined(POCO_VXWORKS) || defined(__QNX__)
+ #ifndef __APPLE__ // See GitHub issue #1453 - not available before Mac OS 10.12/iOS 10
+ #define POCO_HAVE_CLOCK_GETTIME
+ #endif
+ #endif
+#endif
+
+
+namespace Poco {
+
+
+EventImpl::EventImpl(bool autoReset): _auto(autoReset), _state(false)
+{
+#if defined(POCO_VXWORKS)
+ // This workaround is for VxWorks 5.x where
+ // pthread_mutex_init() won't properly initialize the mutex
+ // resulting in a subsequent freeze in pthread_mutex_destroy()
+ // if the mutex has never been used.
+ std::memset(&_mutex, 0, sizeof(_mutex));
+#endif
+
+ if (pthread_mutex_init(&_mutex, NULL))
+ throw SystemException("cannot create event (mutex)");
+
+#if defined(POCO_HAVE_MONOTONIC_PTHREAD_COND_TIMEDWAIT)
+ pthread_condattr_t attr;
+ if (pthread_condattr_init(&attr))
+ {
+ pthread_mutex_destroy(&_mutex);
+ throw SystemException("cannot create event (condition attribute)");
+ }
+ if (pthread_condattr_setclock(&attr, CLOCK_MONOTONIC))
+ {
+ pthread_condattr_destroy(&attr);
+ pthread_mutex_destroy(&_mutex);
+ throw SystemException("cannot create event (condition attribute clock)");
+ }
+ if (pthread_cond_init(&_cond, &attr))
+ {
+ pthread_condattr_destroy(&attr);
+ pthread_mutex_destroy(&_mutex);
+ throw SystemException("cannot create event (condition)");
+ }
+ pthread_condattr_destroy(&attr);
+#else
+ if (pthread_cond_init(&_cond, NULL))
+ {
+ pthread_mutex_destroy(&_mutex);
+ throw SystemException("cannot create event (condition)");
+ }
+#endif
+}
+
+
+EventImpl::~EventImpl()
+{
+ pthread_cond_destroy(&_cond);
+ pthread_mutex_destroy(&_mutex);
+}
+
+
+void EventImpl::waitImpl()
+{
+ if (pthread_mutex_lock(&_mutex))
+ throw SystemException("wait for event failed (lock)");
+ while (!_state)
+ {
+ if (pthread_cond_wait(&_cond, &_mutex))
+ {
+ pthread_mutex_unlock(&_mutex);
+ throw SystemException("wait for event failed");
+ }
+ }
+ if (_auto)
+ _state = false;
+ pthread_mutex_unlock(&_mutex);
+}
+
+
+bool EventImpl::waitImpl(long milliseconds)
+{
+ int rc = 0;
+ struct timespec abstime;
+
+#if defined(POCO_HAVE_MONOTONIC_PTHREAD_COND_TIMEDWAIT)
+ clock_gettime(CLOCK_MONOTONIC, &abstime);
+ abstime.tv_sec += milliseconds / 1000;
+ abstime.tv_nsec += (milliseconds % 1000)*1000000;
+ if (abstime.tv_nsec >= 1000000000)
+ {
+ abstime.tv_nsec -= 1000000000;
+ abstime.tv_sec++;
+ }
+#elif defined(POCO_HAVE_CLOCK_GETTIME)
+ clock_gettime(CLOCK_REALTIME, &abstime);
+ abstime.tv_sec += milliseconds / 1000;
+ abstime.tv_nsec += (milliseconds % 1000)*1000000;
+ if (abstime.tv_nsec >= 1000000000)
+ {
+ abstime.tv_nsec -= 1000000000;
+ abstime.tv_sec++;
+ }
+#else
+ struct timeval tv;
+ gettimeofday(&tv, NULL);
+ abstime.tv_sec = tv.tv_sec + milliseconds / 1000;
+ abstime.tv_nsec = tv.tv_usec*1000 + (milliseconds % 1000)*1000000;
+ if (abstime.tv_nsec >= 1000000000)
+ {
+ abstime.tv_nsec -= 1000000000;
+ abstime.tv_sec++;
+ }
+#endif
+
+ if (pthread_mutex_lock(&_mutex) != 0)
+ throw SystemException("wait for event failed (lock)");
+ while (!_state)
+ {
+ if ((rc = pthread_cond_timedwait(&_cond, &_mutex, &abstime)))
+ {
+ if (rc == ETIMEDOUT) break;
+ pthread_mutex_unlock(&_mutex);
+ throw SystemException("cannot wait for event");
+ }
+ }
+ if (rc == 0 && _auto) _state = false;
+ pthread_mutex_unlock(&_mutex);
+ return rc == 0;
+}
+
+
+} // namespace Poco