sysio::chain::platform_timer Struct Reference

#include <platform_timer.hpp>

Classes
struct	impl

Public Member Functions
	platform_timer ()
	~platform_timer ()
void	start (fc::time_point tp)
void	stop ()
void	set_expiration_callback (void(*func)(void *), void *user)

Public Attributes
std::atomic_bool	expired = true

Detailed Description

Definition at line 14 of file platform_timer.hpp.

Constructor & Destructor Documentation

platform_timer()

sysio::chain::platform_timer::platform_timer

(

)

Definition at line 24 of file platform_timer_asio_fallback.cpp.

                               {
   static_assert(sizeof(impl) <= fwd_size);
 
   std::lock_guard guard(timer_ref_mutex);
 
   if(refcount++ == 0) {
      std::promise<void> p;
      checktime_thread = std::thread([&p]() {
         fc::set_os_thread_name("checktime");
         checktime_ios = std::make_unique<boost::asio::io_service>();
         boost::asio::io_service::work work(*checktime_ios);
         p.set_value();
 
         checktime_ios->run();
      });
      p.get_future().get();
   }
 
   my->timer = std::make_unique<boost::asio::high_resolution_timer>(*checktime_ios);
 
   //compute_and_print_timer_accuracy(*this);
}

Here is the call graph for this function:

~platform_timer()

sysio::chain::platform_timer::~platform_timer

(

)

Definition at line 47 of file platform_timer_asio_fallback.cpp.

                                {
   stop();
   if(std::lock_guard guard(timer_ref_mutex); --refcount == 0) {
      checktime_ios->stop();
      checktime_thread.join();
      checktime_ios.reset();
   }
}

Here is the call graph for this function:

Member Function Documentation

set_expiration_callback()

void sysio::chain::platform_timer::set_expiration_callback ( void(* func )(void *), void * user )

inline

Definition at line 24 of file platform_timer.hpp.

                                                                {
      bool expect_false = false;
      while(!atomic_compare_exchange_strong(&_callback_variables_busy, &expect_false, true))
         expect_false = false;
      auto reset_busy = fc::make_scoped_exit([this]() {
         _callback_variables_busy.store(false, std::memory_order_release);
      });
      SYS_ASSERT(!(func && _expiration_callback), misc_exception, "Setting a platform_timer callback when one already exists");
 
      _expiration_callback = func;
      _expiration_callback_data = user;
   }

Here is the call graph for this function:

Here is the caller graph for this function:

start()

void sysio::chain::platform_timer::start

(

fc::time_point

tp

)

Definition at line 56 of file platform_timer_asio_fallback.cpp.

                                          {
   if(tp == fc::time_point::maximum()) {
      expired = 0;
      return;
   }
   fc::microseconds x = tp.time_since_epoch() - fc::time_point::now().time_since_epoch();
   if(x.count() <= 0)
      expired = 1;
   else {
#if 0
      std::promise<void> p;
      checktime_ios->post([&p,this]() {
         expired = 0;
         p.set_value();
      });
      p.get_future().get();
#endif
      expired = 0;
      my->timer->expires_after(std::chrono::microseconds(x.count()));
      my->timer->async_wait([this](const boost::system::error_code& ec) {
         if(ec)
            return;
         expired = 1;
         call_expiration_callback();
      });
   }
}

Here is the call graph for this function:

Here is the caller graph for this function:

stop()

void sysio::chain::platform_timer::stop

(

)

Definition at line 84 of file platform_timer_asio_fallback.cpp.

                          {
   if(expired)
      return;
 
   my->timer->cancel();
   expired = 1;
}

Here is the caller graph for this function:

Member Data Documentation

expired

std::atomic_bool sysio::chain::platform_timer::expired = true

Definition at line 37 of file platform_timer.hpp.

---

The documentation for this struct was generated from the following files:

• libraries/chain/include/sysio/chain/platform_timer.hpp
• libraries/chain/platform_timer_asio_fallback.cpp
• libraries/chain/platform_timer_macos.cpp
• libraries/chain/platform_timer_posix.cpp