mirror of
https://github.com/VCMP-SqMod/SqMod.git
synced 2025-07-29 20:21:48 +02:00
bin
module
vendor
CPR
ConcurrentQueue
Fmt
POCO
ApacheConnector
CppParser
CppUnit
Crypto
Data
Encodings
Foundation
cmake
include
Poco
Dynamic
ASCIIEncoding.h
AbstractCache.h
AbstractDelegate.h
AbstractEvent.h
AbstractObserver.h
AbstractPriorityDelegate.h
AbstractStrategy.h
AccessExpirationDecorator.h
AccessExpireCache.h
AccessExpireLRUCache.h
AccessExpireStrategy.h
ActiveDispatcher.h
ActiveMethod.h
ActiveResult.h
ActiveRunnable.h
ActiveStarter.h
Activity.h
Alignment.h
Any.h
ArchiveStrategy.h
Array.h
Ascii.h
AsyncChannel.h
AtomicCounter.h
AtomicFlag.h
AutoPtr.h
AutoReleasePool.h
Base32Decoder.h
Base32Encoder.h
Base64Decoder.h
Base64Encoder.h
BasicEvent.h
BinaryReader.h
BinaryWriter.h
Buffer.h
BufferAllocator.h
BufferedBidirectionalStreamBuf.h
BufferedStreamBuf.h
Bugcheck.h
ByteOrder.h
Channel.h
Checksum.h
ClassLibrary.h
ClassLoader.h
Clock.h
Condition.h
Config.h
Configurable.h
ConsoleChannel.h
CountingStream.h
DataURIStream.h
DataURIStreamFactory.h
DateTime.h
DateTimeFormat.h
DateTimeFormatter.h
DateTimeParser.h
Debugger.h
DefaultStrategy.h
DeflatingStream.h
Delegate.h
DigestEngine.h
DigestStream.h
DirectoryIterator.h
DirectoryIteratorStrategy.h
DirectoryIterator_UNIX.h
DirectoryIterator_WIN32U.h
DirectoryWatcher.h
DynamicAny.h
DynamicAnyHolder.h
DynamicFactory.h
DynamicStruct.h
Environment.h
Environment_UNIX.h
Environment_VX.h
Environment_WIN32U.h
Environment_WINCE.h
Error.h
ErrorHandler.h
Event.h
EventArgs.h
EventChannel.h
EventLogChannel.h
Event_POSIX.h
Event_VX.h
Event_WIN32.h
Exception.h
ExpirationDecorator.h
Expire.h
ExpireCache.h
ExpireLRUCache.h
ExpireStrategy.h
FIFOBuffer.h
FIFOBufferStream.h
FIFOEvent.h
FIFOStrategy.h
FPEnvironment.h
FPEnvironment_C99.h
FPEnvironment_DEC.h
FPEnvironment_DUMMY.h
FPEnvironment_QNX.h
FPEnvironment_SUN.h
FPEnvironment_WIN32.h
File.h
FileChannel.h
FileStream.h
FileStreamFactory.h
FileStream_POSIX.h
FileStream_WIN32.h
File_UNIX.h
File_VX.h
File_WIN32U.h
File_WINCE.h
Format.h
Formatter.h
FormattingChannel.h
Foundation.h
FunctionDelegate.h
FunctionPriorityDelegate.h
Glob.h
HMACEngine.h
Hash.h
HashFunction.h
HashMap.h
HashSet.h
HashStatistic.h
HashTable.h
HexBinaryDecoder.h
HexBinaryEncoder.h
InflatingStream.h
Instantiator.h
JSONString.h
KeyValueArgs.h
LRUCache.h
LRUStrategy.h
Latin1Encoding.h
Latin2Encoding.h
Latin9Encoding.h
LineEndingConverter.h
LinearHashTable.h
ListMap.h
LocalDateTime.h
LogFile.h
LogFile_STD.h
LogFile_WIN32U.h
LogStream.h
Logger.h
LoggingFactory.h
LoggingRegistry.h
MD4Engine.h
MD5Engine.h
Manifest.h
MemoryPool.h
MemoryStream.h
Message.h
MetaObject.h
MetaProgramming.h
Mutex.h
Mutex_POSIX.h
Mutex_VX.h
Mutex_WIN32.h
Mutex_WINCE.h
NObserver.h
NamedEvent.h
NamedEvent_Android.h
NamedEvent_UNIX.h
NamedEvent_WIN32U.h
NamedMutex.h
NamedMutex_Android.h
NamedMutex_UNIX.h
NamedMutex_WIN32U.h
NamedTuple.h
NestedDiagnosticContext.h
Notification.h
NotificationCenter.h
NotificationQueue.h
NotificationStrategy.h
NullChannel.h
NullStream.h
Nullable.h
NumberFormatter.h
NumberParser.h
NumericString.h
ObjectPool.h
Observer.h
Optional.h
OrderedMap.h
OrderedSet.h
PBKDF2Engine.h
Path.h
Path_UNIX.h
Path_WIN32U.h
Path_WINCE.h
PatternFormatter.h
Pipe.h
PipeImpl.h
PipeImpl_DUMMY.h
PipeImpl_POSIX.h
PipeImpl_WIN32.h
PipeStream.h
Platform.h
Platform_POSIX.h
Platform_VX.h
Platform_WIN32.h
Poco.h
PriorityDelegate.h
PriorityEvent.h
PriorityExpire.h
PriorityNotificationQueue.h
PriorityStrategy.h
Process.h
Process_UNIX.h
Process_VX.h
Process_WIN32U.h
Process_WINCE.h
PurgeStrategy.h
RWLock.h
RWLock_Android.h
RWLock_POSIX.h
RWLock_VX.h
RWLock_WIN32.h
RWLock_WINCE.h
Random.h
RandomStream.h
RecursiveDirectoryIterator.h
RecursiveDirectoryIteratorImpl.h
RefCountedObject.h
RegularExpression.h
RotateStrategy.h
Runnable.h
RunnableAdapter.h
SHA1Engine.h
SHA2Engine.h
ScopedLock.h
ScopedUnlock.h
Semaphore.h
Semaphore_POSIX.h
Semaphore_VX.h
Semaphore_WIN32.h
SharedLibrary.h
SharedLibrary_HPUX.h
SharedLibrary_UNIX.h
SharedLibrary_VX.h
SharedLibrary_WIN32U.h
SharedMemory.h
SharedMemory_DUMMY.h
SharedMemory_POSIX.h
SharedMemory_WIN32.h
SharedPtr.h
SignalHandler.h
SimpleFileChannel.h
SimpleHashTable.h
SingletonHolder.h
SortedDirectoryIterator.h
SplitterChannel.h
Stopwatch.h
StrategyCollection.h
StreamChannel.h
StreamConverter.h
StreamCopier.h
StreamTokenizer.h
StreamUtil.h
String.h
StringTokenizer.h
SynchronizedObject.h
SyslogChannel.h
Task.h
TaskManager.h
TaskNotification.h
TeeStream.h
TemporaryFile.h
TextBufferIterator.h
TextConverter.h
TextEncoding.h
TextIterator.h
Thread.h
ThreadLocal.h
ThreadPool.h
ThreadTarget.h
Thread_POSIX.h
Thread_VX.h
Thread_WIN32.h
Thread_WINCE.h
TimedNotificationQueue.h
Timer.h
Timespan.h
Timestamp.h
Timezone.h
Token.h
Tuple.h
TypeList.h
Types.h
URI.h
URIStreamFactory.h
URIStreamOpener.h
UTF16Encoding.h
UTF32Encoding.h
UTF8Encoding.h
UTF8String.h
UTFString.h
UUID.h
UUIDGenerator.h
UnWindows.h
UnbufferedStreamBuf.h
Unicode.h
UnicodeConverter.h
UniqueAccessExpireCache.h
UniqueAccessExpireLRUCache.h
UniqueAccessExpireStrategy.h
UniqueExpireCache.h
UniqueExpireLRUCache.h
UniqueExpireStrategy.h
ValidArgs.h
Version.h
Void.h
Windows1250Encoding.h
Windows1251Encoding.h
Windows1252Encoding.h
WindowsConsoleChannel.h
ordered_hash.h
ordered_map.h
ordered_set.h
zconf.h
zlib.h
samples
src
testsuite
wcelibcex-1.0
CMakeLists.txt
Foundation_vs140.sln
Foundation_vs140.vcxproj
Foundation_vs140.vcxproj.filters
Foundation_vs150.sln
Foundation_vs150.vcxproj
Foundation_vs150.vcxproj.filters
Foundation_vs160.sln
Foundation_vs160.vcxproj
Foundation_vs160.vcxproj.filters
Makefile
extradirs
JSON
JWT
MongoDB
Net
NetSSL_OpenSSL
NetSSL_Win
PDF
PageCompiler
PocoDoc
ProGen
Redis
SevenZip
Util
XML
Zip
appveyor
build
cmake
contrib
doc
packaging
patches
release
travis
CHANGELOG
CMakeLists.txt
CODE_OF_CONDUCT.md
CONTRIBUTING.md
CONTRIBUTORS
LICENSE
Makefile
NEWS
README
README.md
VERSION
appveyor.yml
build_cmake.cmd
build_cmake.sh
build_vs140.cmd
build_vs150.cmd
build_vs160.cmd
buildwin.cmd
buildwin.ps1
components
configure
cppignore.lnx
cppignore.win
env.bat
env.sh
libversion
SimpleIni
Squirrel
TinyDir
CMakeLists.txt
.gitignore
.gitmodules
CMakeLists.txt
LICENSE
README.md
Switched to POCO library for unified platform/library interface. Deprecated the external module API. It was creating more problems than solving. Removed most built-in libraries in favor of system libraries for easier maintenance. Cleaned and secured code with help from static analyzers.
231 lines
4.3 KiB
C++
231 lines
4.3 KiB
C++
//
|
|
// PriorityStrategy.h
|
|
//
|
|
// Library: Foundation
|
|
// Package: Events
|
|
// Module: PrioritytStrategy
|
|
//
|
|
// Implementation of the DefaultStrategy template.
|
|
//
|
|
// Copyright (c) 2006-2011, Applied Informatics Software Engineering GmbH.
|
|
// and Contributors.
|
|
//
|
|
// SPDX-License-Identifier: BSL-1.0
|
|
//
|
|
|
|
|
|
#ifndef Foundation_PriorityStrategy_INCLUDED
|
|
#define Foundation_PriorityStrategy_INCLUDED
|
|
|
|
|
|
#include "Poco/NotificationStrategy.h"
|
|
#include "Poco/SharedPtr.h"
|
|
#include <vector>
|
|
|
|
|
|
namespace Poco {
|
|
|
|
|
|
template <class TArgs, class TDelegate>
|
|
class PriorityStrategy: public NotificationStrategy<TArgs, TDelegate>
|
|
/// NotificationStrategy for PriorityEvent.
|
|
///
|
|
/// Delegates are kept in a std::vector<>, ordered
|
|
/// by their priority.
|
|
{
|
|
public:
|
|
using DelegateHandle = TDelegate*;
|
|
using DelegatePtr = SharedPtr<TDelegate>;
|
|
using Delegates = std::vector<DelegatePtr>;
|
|
using Iterator = typename Delegates::iterator;
|
|
|
|
public:
|
|
PriorityStrategy()
|
|
{
|
|
}
|
|
|
|
PriorityStrategy(const PriorityStrategy& s):
|
|
_delegates(s._delegates)
|
|
{
|
|
}
|
|
|
|
~PriorityStrategy()
|
|
{
|
|
}
|
|
|
|
void notify(const void* sender, TArgs& arguments)
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
(*it)->notify(sender, arguments);
|
|
}
|
|
}
|
|
|
|
DelegateHandle add(const TDelegate& delegate)
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
if ((*it)->priority() > delegate.priority())
|
|
{
|
|
DelegatePtr pDelegate(static_cast<TDelegate*>(delegate.clone()));
|
|
_delegates.insert(it, pDelegate);
|
|
return pDelegate.get();
|
|
}
|
|
}
|
|
DelegatePtr pDelegate(static_cast<TDelegate*>(delegate.clone()));
|
|
_delegates.push_back(pDelegate);
|
|
return pDelegate.get();
|
|
}
|
|
|
|
void remove(const TDelegate& delegate)
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
if (delegate.equals(**it))
|
|
{
|
|
(*it)->disable();
|
|
_delegates.erase(it);
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
|
|
void remove(DelegateHandle delegateHandle)
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
if (*it == delegateHandle)
|
|
{
|
|
(*it)->disable();
|
|
_delegates.erase(it);
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
|
|
PriorityStrategy& operator = (const PriorityStrategy& s)
|
|
{
|
|
if (this != &s)
|
|
{
|
|
_delegates = s._delegates;
|
|
}
|
|
return *this;
|
|
}
|
|
|
|
void clear()
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
(*it)->disable();
|
|
}
|
|
_delegates.clear();
|
|
}
|
|
|
|
bool empty() const
|
|
{
|
|
return _delegates.empty();
|
|
}
|
|
|
|
protected:
|
|
Delegates _delegates;
|
|
};
|
|
|
|
|
|
template <class TDelegate>
|
|
class PriorityStrategy<void, TDelegate>
|
|
/// NotificationStrategy for PriorityEvent.
|
|
///
|
|
/// Delegates are kept in a std::vector<>, ordered
|
|
/// by their priority.
|
|
{
|
|
public:
|
|
using DelegateHandle = TDelegate*;
|
|
using DelegatePtr = SharedPtr<TDelegate>;
|
|
using Delegates = std::vector<DelegatePtr>;
|
|
using Iterator = typename Delegates::iterator;
|
|
|
|
public:
|
|
|
|
void notify(const void* sender)
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
(*it)->notify(sender);
|
|
}
|
|
}
|
|
|
|
DelegateHandle add(const TDelegate& delegate)
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
if ((*it)->priority() > delegate.priority())
|
|
{
|
|
DelegatePtr pDelegate(static_cast<TDelegate*>(delegate.clone()));
|
|
_delegates.insert(it, pDelegate);
|
|
return pDelegate.get();
|
|
}
|
|
}
|
|
DelegatePtr pDelegate(static_cast<TDelegate*>(delegate.clone()));
|
|
_delegates.push_back(pDelegate);
|
|
return pDelegate.get();
|
|
}
|
|
|
|
void remove(const TDelegate& delegate)
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
if (delegate.equals(**it))
|
|
{
|
|
(*it)->disable();
|
|
_delegates.erase(it);
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
|
|
void remove(DelegateHandle delegateHandle)
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
if (*it == delegateHandle)
|
|
{
|
|
(*it)->disable();
|
|
_delegates.erase(it);
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
|
|
PriorityStrategy& operator = (const PriorityStrategy& s)
|
|
{
|
|
if (this != &s)
|
|
{
|
|
_delegates = s._delegates;
|
|
}
|
|
return *this;
|
|
}
|
|
|
|
void clear()
|
|
{
|
|
for (Iterator it = _delegates.begin(); it != _delegates.end(); ++it)
|
|
{
|
|
(*it)->disable();
|
|
}
|
|
_delegates.clear();
|
|
}
|
|
|
|
bool empty() const
|
|
{
|
|
return _delegates.empty();
|
|
}
|
|
|
|
protected:
|
|
Delegates _delegates;
|
|
};
|
|
|
|
|
|
} // namespace Poco
|
|
|
|
|
|
#endif // Foundation_PriorityStrategy_INCLUDED
|