123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165 |
- #ifndef _FASTDDS_RTPS_RESOURCES_RESOURCEEVENT_H_
- #define _FASTDDS_RTPS_RESOURCES_RESOURCEEVENT_H_
- #ifndef DOXYGEN_SHOULD_SKIP_THIS_PUBLIC
- #include <fastrtps/utils/TimedMutex.hpp>
- #include <fastrtps/utils/TimedConditionVariable.hpp>
- #include <thread>
- #include <atomic>
- #include <vector>
- namespace eprosima {
- namespace fastrtps {
- namespace rtps {
- class TimedEventImpl;
- class ResourceEvent
- {
- public:
- ResourceEvent() = default;
- ~ResourceEvent();
-
- void init_thread();
-
- void register_timer(
- TimedEventImpl* event);
-
- void unregister_timer(
- TimedEventImpl* event);
-
- void notify(
- TimedEventImpl* event);
-
- void notify(
- TimedEventImpl* event,
- const std::chrono::steady_clock::time_point& timeout);
- private:
-
- std::atomic<bool> stop_{ false };
-
- TimedMutex mutex_;
-
- TimedConditionVariable cv_manipulation_;
-
- bool allow_vector_manipulation_ = true;
-
- TimedConditionVariable cv_;
-
- size_t timers_count_ = 0;
-
- std::vector<TimedEventImpl*> pending_timers_;
-
- std::vector<TimedEventImpl*> active_timers_;
-
- std::chrono::steady_clock::time_point current_time_;
-
- std::thread thread_;
-
- bool register_timer_nts(
- TimedEventImpl* event);
-
- void event_service();
-
- void sort_timers();
-
- void update_current_time();
-
- void do_timer_actions();
-
- void resize_collections()
- {
- pending_timers_.reserve(timers_count_);
- active_timers_.reserve(timers_count_);
- }
- };
- }
- }
- }
- #endif
- #endif
|