From d072fcd763329e884a5e3fbe2c5aaa5218c25c06 Mon Sep 17 00:00:00 2001 From: Kevin Heifner Date: Thu, 16 Jan 2025 16:18:12 -0600 Subject: [PATCH] GH-1095 Make expire_now() private --- libraries/chain/include/eosio/chain/platform_timer.hpp | 4 ++-- libraries/chain/platform_timer_asio_fallback.cpp | 4 ++-- libraries/chain/platform_timer_kqueue.cpp | 4 ++-- libraries/chain/platform_timer_posix.cpp | 4 ++-- 4 files changed, 8 insertions(+), 8 deletions(-) diff --git a/libraries/chain/include/eosio/chain/platform_timer.hpp b/libraries/chain/include/eosio/chain/platform_timer.hpp index 88aed7fa97..253c35b13d 100644 --- a/libraries/chain/include/eosio/chain/platform_timer.hpp +++ b/libraries/chain/include/eosio/chain/platform_timer.hpp @@ -16,7 +16,6 @@ struct platform_timer { void start(fc::time_point tp); void stop(); void interrupt_timer(); - void _expire_now(); // called by internal timer /* Sets a callback for when timer expires. Be aware this could might fire from a signal handling context and/or on any particular thread. Only a single callback can be registered at once; trying to register more will @@ -43,8 +42,9 @@ struct platform_timer { state_t timer_state() const { return _state; } private: - std::atomic _state = state_t::stopped; + void expire_now(); + std::atomic _state = state_t::stopped; struct impl; constexpr static size_t fwd_size = 8; diff --git a/libraries/chain/platform_timer_asio_fallback.cpp b/libraries/chain/platform_timer_asio_fallback.cpp index d5c355e850..96ae98bfd4 100644 --- a/libraries/chain/platform_timer_asio_fallback.cpp +++ b/libraries/chain/platform_timer_asio_fallback.cpp @@ -69,12 +69,12 @@ void platform_timer::start(fc::time_point tp) { my->timer->async_wait([this](const boost::system::error_code& ec) { if(ec) return; - _expire_now(); + expire_now(); }); } } -void platform_timer::_expire_now() { +void platform_timer::expire_now() { state_t expected = state_t::running; if (_state.compare_exchange_strong(expected, state_t::timed_out)) { call_expiration_callback(); diff --git a/libraries/chain/platform_timer_kqueue.cpp b/libraries/chain/platform_timer_kqueue.cpp index ed64b4b352..53a2804d84 100644 --- a/libraries/chain/platform_timer_kqueue.cpp +++ b/libraries/chain/platform_timer_kqueue.cpp @@ -58,7 +58,7 @@ platform_timer::platform_timer() { if(c == 1 && anEvent.filter == EVFILT_TIMER) { platform_timer* self = (platform_timer*)anEvent.udata; - self->_expire_now(); + self->expire_now(); } else if(c == 1 && anEvent.filter == EVFILT_USER) return; @@ -105,7 +105,7 @@ void platform_timer::start(fc::time_point tp) { } } -void platform_timer::_expire_now() { +void platform_timer::expire_now() { state_t expected = state_t::running; if (_state.compare_exchange_strong(expected, state_t::timed_out)) { call_expiration_callback(); diff --git a/libraries/chain/platform_timer_posix.cpp b/libraries/chain/platform_timer_posix.cpp index 6ccbe46571..aac36a5cd7 100644 --- a/libraries/chain/platform_timer_posix.cpp +++ b/libraries/chain/platform_timer_posix.cpp @@ -21,7 +21,7 @@ struct platform_timer::impl { static void sig_handler(int, siginfo_t* si, void*) { platform_timer* self = (platform_timer*)si->si_value.sival_ptr; - self->_expire_now(); + self->expire_now(); } }; @@ -72,7 +72,7 @@ void platform_timer::start(fc::time_point tp) { } } -void platform_timer::_expire_now() { +void platform_timer::expire_now() { state_t expected = state_t::running; if (_state.compare_exchange_strong(expected, state_t::timed_out)) { call_expiration_callback();