Klagarge/XF
Archived
1
0
Fork 0
Code Issues Pull Requests Releases 1 Activity

start to implement timeoutmanager

Browse Source
This commit is contained in:
Rémi Heredero 2023-09-26 14:26:07 +02:00
parent b7403dc872
commit 422f5d7448
2 changed files with 26 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/simplified/xf/include/xf/interface/timeoutmanager.h
View File

@ -22,8 +22,7 @@ namespace interface {
* - Implements the Singleton pattern * - Implements the Singleton pattern
* - Handle timeouts (hold, decrement, re-inject) * - Handle timeouts (hold, decrement, re-inject)
*/ */
class XFTimeoutManager class XFTimeoutManager {
{
public: public:
virtual ~XFTimeoutManager() = default; virtual ~XFTimeoutManager() = default;

27
src/simplified/xf/port/common/timeoutmanager.cpp
View File

@ -15,12 +15,35 @@ using Mutex = interface::XFMutex; // Rename XFMutex interface class to Mut
// Note: The implementation is done here because only in this file the real XFTimeoutManager // Note: The implementation is done here because only in this file the real XFTimeoutManager
// class is known (port specific class). An instance of the XFTimeoutManager class is // class is known (port specific class). An instance of the XFTimeoutManager class is
// returned by the 'interface::XFTimeoutManager' class. // returned by the 'interface::XFTimeoutManager' class.
interface::XFTimeoutManager * interface::XFTimeoutManager::getInstance() interface::XFTimeoutManager * interface::XFTimeoutManager::getInstance() {
{
static ::XFTimeoutManager timeoutManager; static ::XFTimeoutManager timeoutManager;
return &timeoutManager; return &timeoutManager;
} }
// TODO: Implement code for XFTimeoutManager class // TODO: Implement code for XFTimeoutManager class
XFTimeoutManager::XFTimeoutManager() {
}
XFTimeoutManager::~XFTimeoutManager() {
}
void XFTimeoutManager::start(std::function<void (uint32_t)> startTimeoutManagerTimer) {
startTimeoutManagerTimer(tickInterval_);
}
void XFTimeoutManager::scheduleTimeout(int32_t timeoutId, int32_t interval, interface::XFBehavior *pBehavior) {
::XFTimeout* timeout = new XFTimeout(timeoutId, interval, pBehavior);
timeouts_.push_front(timeout);
}
int32_t timeoutIdComparison;
bool myPredicate(XFTimeout* timeout) {return (timeout->getId()==timeoutIdComparison);}
void XFTimeoutManager::unscheduleTimeout(int32_t timeoutId, interface::XFBehavior *pBehavior) {
timeoutIdComparison = timeoutId;
timeouts_.remove_if(myPredicate);
}
#endif // USE_XF_COMMON_TIMEOUTMANAGER_CLASS #endif // USE_XF_COMMON_TIMEOUTMANAGER_CLASS