aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/libs/poco/Foundation/include/Poco/Expire.h
diff options
context:
space:
mode:
authorDevtools Arcadia <arcadia-devtools@yandex-team.ru>2022-02-07 18:08:42 +0300
committerDevtools Arcadia <arcadia-devtools@mous.vla.yp-c.yandex.net>2022-02-07 18:08:42 +0300
commit1110808a9d39d4b808aef724c861a2e1a38d2a69 (patch)
treee26c9fed0de5d9873cce7e00bc214573dc2195b7 /contrib/libs/poco/Foundation/include/Poco/Expire.h
downloadydb-1110808a9d39d4b808aef724c861a2e1a38d2a69.tar.gz
intermediate changes
ref:cde9a383711a11544ce7e107a78147fb96cc4029
Diffstat (limited to 'contrib/libs/poco/Foundation/include/Poco/Expire.h')
-rw-r--r--contrib/libs/poco/Foundation/include/Poco/Expire.h194
1 files changed, 194 insertions, 0 deletions
diff --git a/contrib/libs/poco/Foundation/include/Poco/Expire.h b/contrib/libs/poco/Foundation/include/Poco/Expire.h
new file mode 100644
index 0000000000..73f82b4b0d
--- /dev/null
+++ b/contrib/libs/poco/Foundation/include/Poco/Expire.h
@@ -0,0 +1,194 @@
+//
+// Expire.h
+//
+// Library: Foundation
+// Package: Events
+// Module: Expire
+//
+// Implementation of the Expire template.
+//
+// Copyright (c) 2006-2011, Applied Informatics Software Engineering GmbH.
+// and Contributors.
+//
+// SPDX-License-Identifier: BSL-1.0
+//
+
+
+#ifndef Foundation_Expire_INCLUDED
+#define Foundation_Expire_INCLUDED
+
+
+#include "Poco/Foundation.h"
+#include "Poco/AbstractDelegate.h"
+#include "Poco/Timestamp.h"
+
+
+namespace Poco {
+
+
+template <class TArgs>
+class Expire: public AbstractDelegate<TArgs>
+ /// Decorator for AbstractDelegate adding automatic
+ /// expiration of registrations to AbstractDelegate's.
+{
+public:
+ Expire(const AbstractDelegate<TArgs>& p, Timestamp::TimeDiff expireMillisecs):
+ _pDelegate(p.clone()),
+ _expire(expireMillisecs*1000)
+ {
+ }
+
+ Expire(const Expire& expire):
+ AbstractDelegate<TArgs>(expire),
+ _pDelegate(expire._pDelegate->clone()),
+ _expire(expire._expire),
+ _creationTime(expire._creationTime)
+ {
+ }
+
+ ~Expire()
+ {
+ delete _pDelegate;
+ }
+
+ Expire& operator = (const Expire& expire)
+ {
+ if (&expire != this)
+ {
+ delete this->_pDelegate;
+ this->_pDelegate = expire._pDelegate->clone();
+ this->_expire = expire._expire;
+ this->_creationTime = expire._creationTime;
+ this->_pTarget = expire._pTarget;
+ }
+ return *this;
+ }
+
+ bool notify(const void* sender, TArgs& arguments)
+ {
+ if (!expired())
+ return this->_pDelegate->notify(sender, arguments);
+ else
+ return false;
+ }
+
+ bool equals(const AbstractDelegate<TArgs>& other) const
+ {
+ return other.equals(*_pDelegate);
+ }
+
+ AbstractDelegate<TArgs>* clone() const
+ {
+ return new Expire(*this);
+ }
+
+ void disable()
+ {
+ _pDelegate->disable();
+ }
+
+ const AbstractDelegate<TArgs>* unwrap() const
+ {
+ return this->_pDelegate;
+ }
+
+protected:
+ bool expired() const
+ {
+ return _creationTime.isElapsed(_expire);
+ }
+
+ AbstractDelegate<TArgs>* _pDelegate;
+ Timestamp::TimeDiff _expire;
+ Timestamp _creationTime;
+
+private:
+ Expire();
+};
+
+
+template <>
+class Expire<void>: public AbstractDelegate<void>
+ /// Decorator for AbstractDelegate adding automatic
+ /// expiration of registrations to AbstractDelegate's.
+{
+public:
+ Expire(const AbstractDelegate<void>& p, Timestamp::TimeDiff expireMillisecs):
+ _pDelegate(p.clone()),
+ _expire(expireMillisecs*1000)
+ {
+ }
+
+ Expire(const Expire& expire):
+ AbstractDelegate<void>(expire),
+ _pDelegate(expire._pDelegate->clone()),
+ _expire(expire._expire),
+ _creationTime(expire._creationTime)
+ {
+ }
+
+ ~Expire()
+ {
+ delete _pDelegate;
+ }
+
+ Expire& operator = (const Expire& expire)
+ {
+ if (&expire != this)
+ {
+ delete this->_pDelegate;
+ this->_pDelegate = expire._pDelegate->clone();
+ this->_expire = expire._expire;
+ this->_creationTime = expire._creationTime;
+ //this->_pTarget = expire._pTarget;
+ }
+ return *this;
+ }
+
+ bool notify(const void* sender)
+ {
+ if (!expired())
+ return this->_pDelegate->notify(sender);
+ else
+ return false;
+ }
+
+ bool equals(const AbstractDelegate<void>& other) const
+ {
+ return other.equals(*_pDelegate);
+ }
+
+ AbstractDelegate<void>* clone() const
+ {
+ return new Expire(*this);
+ }
+
+ void disable()
+ {
+ _pDelegate->disable();
+ }
+
+ const AbstractDelegate<void>* unwrap() const
+ {
+ return this->_pDelegate;
+ }
+
+protected:
+ bool expired() const
+ {
+ return _creationTime.isElapsed(_expire);
+ }
+
+ AbstractDelegate<void>* _pDelegate;
+ Timestamp::TimeDiff _expire;
+ Timestamp _creationTime;
+
+private:
+ Expire();
+};
+
+
+} // namespace Poco
+
+
+#endif // Foundation_Expire_INCLUDED