Restoring authorship annotation for <orivej@yandex-team.ru>. Commit 2 of 2.

1 files changed, 170 insertions, 170 deletions

diff --git a/contrib/libs/poco/Foundation/src/Semaphore_POSIX.cpp b/contrib/libs/poco/Foundation/src/Semaphore_POSIX.cpp
index 6a79a0c0d3..f4818af200 100644
--- a/contrib/libs/poco/Foundation/src/Semaphore_POSIX.cpp
+++ b/contrib/libs/poco/Foundation/src/Semaphore_POSIX.cpp
@@ -1,170 +1,170 @@
-// 
-// Semaphore_POSIX.cpp 
-// 
-// Library: Foundation 
-// Package: Threading 
-// Module:  Semaphore 
-// 
-// Copyright (c) 2004-2006, Applied Informatics Software Engineering GmbH. 
-// and Contributors. 
-// 
-// SPDX-License-Identifier:	BSL-1.0 
-// 
- 
- 
-#include "Poco/Semaphore_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 { 
- 
- 
-SemaphoreImpl::SemaphoreImpl(int n, int max): _n(n), _max(max) 
-{ 
-	poco_assert (n >= 0 && max > 0 && n <= max); 
- 
-#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 semaphore (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 semaphore (condition attribute)"); 
-	} 
-	if (pthread_condattr_setclock(&attr, CLOCK_MONOTONIC)) 
-    { 
-		pthread_condattr_destroy(&attr); 
-		pthread_mutex_destroy(&_mutex); 
-		throw SystemException("cannot create semaphore (condition attribute clock)"); 
-    } 
-	if (pthread_cond_init(&_cond, &attr)) 
-	{ 
-		pthread_condattr_destroy(&attr); 
-		pthread_mutex_destroy(&_mutex); 
-		throw SystemException("cannot create semaphore (condition)"); 
-	} 
-	pthread_condattr_destroy(&attr); 
-#else 
-	if (pthread_cond_init(&_cond, NULL)) 
-	{ 
-		pthread_mutex_destroy(&_mutex); 
-		throw SystemException("cannot create semaphore (condition)"); 
-	} 
-#endif 
-} 
- 
- 
-SemaphoreImpl::~SemaphoreImpl() 
-{ 
-	pthread_cond_destroy(&_cond); 
-	pthread_mutex_destroy(&_mutex); 
-} 
- 
- 
-void SemaphoreImpl::waitImpl() 
-{ 
-	if (pthread_mutex_lock(&_mutex)) 
-		throw SystemException("wait for semaphore failed (lock)"); 
-	while (_n < 1) 
-	{ 
-		if (pthread_cond_wait(&_cond, &_mutex)) 
-		{ 
-			pthread_mutex_unlock(&_mutex); 
-			throw SystemException("wait for semaphore failed"); 
-		} 
-	} 
-	--_n; 
-	pthread_mutex_unlock(&_mutex); 
-} 
- 
- 
-bool SemaphoreImpl::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 semaphore failed (lock)"); 
-	while (_n < 1) 
-	{ 
-		if ((rc = pthread_cond_timedwait(&_cond, &_mutex, &abstime))) 
-		{ 
-			if (rc == ETIMEDOUT) break; 
-			pthread_mutex_unlock(&_mutex); 
-			throw SystemException("cannot wait for semaphore"); 
-		} 
-	} 
-	if (rc == 0) --_n; 
-	pthread_mutex_unlock(&_mutex); 
-	return rc == 0; 
-} 
- 
- 
-} // namespace Poco 
+//
+// Semaphore_POSIX.cpp
+//
+// Library: Foundation
+// Package: Threading
+// Module:  Semaphore
+//
+// Copyright (c) 2004-2006, Applied Informatics Software Engineering GmbH.
+// and Contributors.
+//
+// SPDX-License-Identifier:	BSL-1.0
+//
+
+
+#include "Poco/Semaphore_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 {
+
+
+SemaphoreImpl::SemaphoreImpl(int n, int max): _n(n), _max(max)
+{
+	poco_assert (n >= 0 && max > 0 && n <= max);
+
+#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 semaphore (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 semaphore (condition attribute)");
+	}
+	if (pthread_condattr_setclock(&attr, CLOCK_MONOTONIC))
+    {
+		pthread_condattr_destroy(&attr);
+		pthread_mutex_destroy(&_mutex);
+		throw SystemException("cannot create semaphore (condition attribute clock)");
+    }
+	if (pthread_cond_init(&_cond, &attr))
+	{
+		pthread_condattr_destroy(&attr);
+		pthread_mutex_destroy(&_mutex);
+		throw SystemException("cannot create semaphore (condition)");
+	}
+	pthread_condattr_destroy(&attr);
+#else
+	if (pthread_cond_init(&_cond, NULL))
+	{
+		pthread_mutex_destroy(&_mutex);
+		throw SystemException("cannot create semaphore (condition)");
+	}
+#endif
+}
+
+
+SemaphoreImpl::~SemaphoreImpl()
+{
+	pthread_cond_destroy(&_cond);
+	pthread_mutex_destroy(&_mutex);
+}
+
+
+void SemaphoreImpl::waitImpl()
+{
+	if (pthread_mutex_lock(&_mutex))
+		throw SystemException("wait for semaphore failed (lock)");
+	while (_n < 1)
+	{
+		if (pthread_cond_wait(&_cond, &_mutex))
+		{
+			pthread_mutex_unlock(&_mutex);
+			throw SystemException("wait for semaphore failed");
+		}
+	}
+	--_n;
+	pthread_mutex_unlock(&_mutex);
+}
+
+
+bool SemaphoreImpl::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 semaphore failed (lock)");
+	while (_n < 1)
+	{
+		if ((rc = pthread_cond_timedwait(&_cond, &_mutex, &abstime)))
+		{
+			if (rc == ETIMEDOUT) break;
+			pthread_mutex_unlock(&_mutex);
+			throw SystemException("cannot wait for semaphore");
+		}
+	}
+	if (rc == 0) --_n;
+	pthread_mutex_unlock(&_mutex);
+	return rc == 0;
+}
+
+
+} // namespace Poco