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

1 files changed, 207 insertions, 207 deletions

diff --git a/contrib/libs/poco/Foundation/src/RWLock_WIN32.cpp b/contrib/libs/poco/Foundation/src/RWLock_WIN32.cpp
index 95383804cd..973b0ae3c5 100644
--- a/contrib/libs/poco/Foundation/src/RWLock_WIN32.cpp
+++ b/contrib/libs/poco/Foundation/src/RWLock_WIN32.cpp
@@ -1,207 +1,207 @@
-// 
-// RWLock_WIN32.cpp 
-// 
-// Library: Foundation 
-// Package: Threading 
-// Module:  RWLock 
-// 
-// Copyright (c) 2004-2006, Applied Informatics Software Engineering GmbH. 
-// and Contributors. 
-// 
-// SPDX-License-Identifier:	BSL-1.0 
-// 
- 
- 
-#include "Poco/RWLock_WIN32.h" 
- 
- 
-namespace Poco { 
- 
- 
-RWLockImpl::RWLockImpl(): _readers(0), _writersWaiting(0), _writers(0) 
-{ 
-	_mutex = CreateMutexW(NULL, FALSE, NULL); 
-	if (_mutex == NULL) 
-		throw SystemException("cannot create reader/writer lock"); 
- 
-	_readEvent = CreateEventW(NULL, TRUE, TRUE, NULL); 
-	if (_readEvent == NULL) 
-		throw SystemException("cannot create reader/writer lock"); 
- 
-	_writeEvent = CreateEventW(NULL, TRUE, TRUE, NULL); 
-	if (_writeEvent == NULL) 
-		throw SystemException("cannot create reader/writer lock"); 
-} 
- 
- 
-RWLockImpl::~RWLockImpl() 
-{ 
-	CloseHandle(_mutex); 
-	CloseHandle(_readEvent); 
-	CloseHandle(_writeEvent); 
-} 
- 
- 
-inline void RWLockImpl::addWriter() 
-{ 
-	switch (WaitForSingleObject(_mutex, INFINITE)) 
-	{ 
-	case WAIT_OBJECT_0: 
-		if (++_writersWaiting == 1) ResetEvent(_readEvent); 
-		ReleaseMutex(_mutex); 
-		break; 
-	default: 
-		throw SystemException("cannot lock reader/writer lock"); 
-	} 
-} 
- 
- 
-inline void RWLockImpl::removeWriter() 
-{ 
-	switch (WaitForSingleObject(_mutex, INFINITE)) 
-	{ 
-	case WAIT_OBJECT_0: 
-		if (--_writersWaiting == 0 && _writers == 0) SetEvent(_readEvent); 
-		ReleaseMutex(_mutex); 
-		break; 
-	default: 
-		throw SystemException("cannot lock reader/writer lock"); 
-	} 
-} 
- 
- 
-void RWLockImpl::readLockImpl() 
-{ 
-	HANDLE h[2]; 
-	h[0] = _mutex; 
-	h[1] = _readEvent; 
-	switch (WaitForMultipleObjects(2, h, TRUE, INFINITE)) 
-	{ 
-	case WAIT_OBJECT_0: 
-	case WAIT_OBJECT_0 + 1: 
-		++_readers; 
-		ResetEvent(_writeEvent); 
-		ReleaseMutex(_mutex); 
-		poco_assert_dbg(_writers == 0); 
-		break; 
-	default: 
-		throw SystemException("cannot lock reader/writer lock"); 
-	} 
-} 
- 
- 
-bool RWLockImpl::tryReadLockImpl() 
-{ 
-	for (;;) 
-	{ 
-		if (_writers != 0 || _writersWaiting != 0) 
-			return false; 
- 
-		DWORD result = tryReadLockOnce(); 
-		switch (result) 
-		{ 
-		case WAIT_OBJECT_0: 
-		case WAIT_OBJECT_0 + 1: 
-			return true; 
-		case WAIT_TIMEOUT: 
-			continue; // try again 
-		default: 
-			throw SystemException("cannot lock reader/writer lock"); 
-		} 
-	} 
-} 
- 
- 
-void RWLockImpl::writeLockImpl() 
-{ 
-	addWriter(); 
-	HANDLE h[2]; 
-	h[0] = _mutex; 
-	h[1] = _writeEvent; 
-	switch (WaitForMultipleObjects(2, h, TRUE, INFINITE)) 
-	{ 
-	case WAIT_OBJECT_0: 
-	case WAIT_OBJECT_0 + 1: 
-		--_writersWaiting; 
-		++_readers; 
-		++_writers; 
-		ResetEvent(_readEvent); 
-		ResetEvent(_writeEvent); 
-		ReleaseMutex(_mutex); 
-		poco_assert_dbg(_writers == 1); 
-		break; 
-	default: 
-		removeWriter(); 
-		throw SystemException("cannot lock reader/writer lock"); 
-	} 
-} 
- 
- 
-bool RWLockImpl::tryWriteLockImpl() 
-{ 
-	addWriter(); 
-	HANDLE h[2]; 
-	h[0] = _mutex; 
-	h[1] = _writeEvent; 
-	switch (WaitForMultipleObjects(2, h, TRUE, 1)) 
-	{ 
-	case WAIT_OBJECT_0: 
-	case WAIT_OBJECT_0 + 1: 
-		--_writersWaiting; 
-		++_readers; 
-		++_writers; 
-		ResetEvent(_readEvent); 
-		ResetEvent(_writeEvent); 
-		ReleaseMutex(_mutex); 
-		poco_assert_dbg(_writers == 1); 
-		return true; 
-	case WAIT_TIMEOUT: 
-		removeWriter(); 
-		return false; 
-	default: 
-		removeWriter(); 
-		throw SystemException("cannot lock reader/writer lock"); 
-	} 
-} 
- 
- 
-void RWLockImpl::unlockImpl() 
-{ 
-	switch (WaitForSingleObject(_mutex, INFINITE)) 
-	{ 
-	case WAIT_OBJECT_0: 
-		_writers = 0; 
-		if (_writersWaiting == 0) SetEvent(_readEvent); 
-		if (--_readers == 0) SetEvent(_writeEvent); 
-		ReleaseMutex(_mutex); 
-		break; 
-	default: 
-		throw SystemException("cannot unlock reader/writer lock"); 
-	} 
-} 
- 
- 
-DWORD RWLockImpl::tryReadLockOnce() 
-{ 
-	HANDLE h[2]; 
-	h[0] = _mutex; 
-	h[1] = _readEvent; 
-	DWORD result = WaitForMultipleObjects(2, h, TRUE, 1);  
-	switch (result) 
-	{ 
-	case WAIT_OBJECT_0: 
-	case WAIT_OBJECT_0 + 1: 
-		++_readers; 
-		ResetEvent(_writeEvent); 
-		ReleaseMutex(_mutex); 
-		poco_assert_dbg(_writers == 0); 
-		return result; 
-	case WAIT_TIMEOUT: 
-		return result; 
-	default: 
-		throw SystemException("cannot lock reader/writer lock"); 
-	} 
-} 
- 
- 
-} // namespace Poco 
+//
+// RWLock_WIN32.cpp
+//
+// Library: Foundation
+// Package: Threading
+// Module:  RWLock
+//
+// Copyright (c) 2004-2006, Applied Informatics Software Engineering GmbH.
+// and Contributors.
+//
+// SPDX-License-Identifier:	BSL-1.0
+//
+
+
+#include "Poco/RWLock_WIN32.h"
+
+
+namespace Poco {
+
+
+RWLockImpl::RWLockImpl(): _readers(0), _writersWaiting(0), _writers(0)
+{
+	_mutex = CreateMutexW(NULL, FALSE, NULL);
+	if (_mutex == NULL)
+		throw SystemException("cannot create reader/writer lock");
+
+	_readEvent = CreateEventW(NULL, TRUE, TRUE, NULL);
+	if (_readEvent == NULL)
+		throw SystemException("cannot create reader/writer lock");
+
+	_writeEvent = CreateEventW(NULL, TRUE, TRUE, NULL);
+	if (_writeEvent == NULL)
+		throw SystemException("cannot create reader/writer lock");
+}
+
+
+RWLockImpl::~RWLockImpl()
+{
+	CloseHandle(_mutex);
+	CloseHandle(_readEvent);
+	CloseHandle(_writeEvent);
+}
+
+
+inline void RWLockImpl::addWriter()
+{
+	switch (WaitForSingleObject(_mutex, INFINITE))
+	{
+	case WAIT_OBJECT_0:
+		if (++_writersWaiting == 1) ResetEvent(_readEvent);
+		ReleaseMutex(_mutex);
+		break;
+	default:
+		throw SystemException("cannot lock reader/writer lock");
+	}
+}
+
+
+inline void RWLockImpl::removeWriter()
+{
+	switch (WaitForSingleObject(_mutex, INFINITE))
+	{
+	case WAIT_OBJECT_0:
+		if (--_writersWaiting == 0 && _writers == 0) SetEvent(_readEvent);
+		ReleaseMutex(_mutex);
+		break;
+	default:
+		throw SystemException("cannot lock reader/writer lock");
+	}
+}
+
+
+void RWLockImpl::readLockImpl()
+{
+	HANDLE h[2];
+	h[0] = _mutex;
+	h[1] = _readEvent;
+	switch (WaitForMultipleObjects(2, h, TRUE, INFINITE))
+	{
+	case WAIT_OBJECT_0:
+	case WAIT_OBJECT_0 + 1:
+		++_readers;
+		ResetEvent(_writeEvent);
+		ReleaseMutex(_mutex);
+		poco_assert_dbg(_writers == 0);
+		break;
+	default:
+		throw SystemException("cannot lock reader/writer lock");
+	}
+}
+
+
+bool RWLockImpl::tryReadLockImpl()
+{
+	for (;;)
+	{
+		if (_writers != 0 || _writersWaiting != 0)
+			return false;
+
+		DWORD result = tryReadLockOnce();
+		switch (result)
+		{
+		case WAIT_OBJECT_0:
+		case WAIT_OBJECT_0 + 1:
+			return true;
+		case WAIT_TIMEOUT:
+			continue; // try again
+		default:
+			throw SystemException("cannot lock reader/writer lock");
+		}
+	}
+}
+
+
+void RWLockImpl::writeLockImpl()
+{
+	addWriter();
+	HANDLE h[2];
+	h[0] = _mutex;
+	h[1] = _writeEvent;
+	switch (WaitForMultipleObjects(2, h, TRUE, INFINITE))
+	{
+	case WAIT_OBJECT_0:
+	case WAIT_OBJECT_0 + 1:
+		--_writersWaiting;
+		++_readers;
+		++_writers;
+		ResetEvent(_readEvent);
+		ResetEvent(_writeEvent);
+		ReleaseMutex(_mutex);
+		poco_assert_dbg(_writers == 1);
+		break;
+	default:
+		removeWriter();
+		throw SystemException("cannot lock reader/writer lock");
+	}
+}
+
+
+bool RWLockImpl::tryWriteLockImpl()
+{
+	addWriter();
+	HANDLE h[2];
+	h[0] = _mutex;
+	h[1] = _writeEvent;
+	switch (WaitForMultipleObjects(2, h, TRUE, 1))
+	{
+	case WAIT_OBJECT_0:
+	case WAIT_OBJECT_0 + 1:
+		--_writersWaiting;
+		++_readers;
+		++_writers;
+		ResetEvent(_readEvent);
+		ResetEvent(_writeEvent);
+		ReleaseMutex(_mutex);
+		poco_assert_dbg(_writers == 1);
+		return true;
+	case WAIT_TIMEOUT:
+		removeWriter();
+		return false;
+	default:
+		removeWriter();
+		throw SystemException("cannot lock reader/writer lock");
+	}
+}
+
+
+void RWLockImpl::unlockImpl()
+{
+	switch (WaitForSingleObject(_mutex, INFINITE))
+	{
+	case WAIT_OBJECT_0:
+		_writers = 0;
+		if (_writersWaiting == 0) SetEvent(_readEvent);
+		if (--_readers == 0) SetEvent(_writeEvent);
+		ReleaseMutex(_mutex);
+		break;
+	default:
+		throw SystemException("cannot unlock reader/writer lock");
+	}
+}
+
+
+DWORD RWLockImpl::tryReadLockOnce()
+{
+	HANDLE h[2];
+	h[0] = _mutex;
+	h[1] = _readEvent;
+	DWORD result = WaitForMultipleObjects(2, h, TRUE, 1); 
+	switch (result)
+	{
+	case WAIT_OBJECT_0:
+	case WAIT_OBJECT_0 + 1:
+		++_readers;
+		ResetEvent(_writeEvent);
+		ReleaseMutex(_mutex);
+		poco_assert_dbg(_writers == 0);
+		return result;
+	case WAIT_TIMEOUT:
+		return result;
+	default:
+		throw SystemException("cannot lock reader/writer lock");
+	}
+}
+
+
+} // namespace Poco