sysio::resource_monitor::file_space_handler< SpaceProvider > Class Template Reference

#include <file_space_handler.hpp>

Public Member Functions
	file_space_handler (SpaceProvider &&space_provider, boost::asio::io_context &ctx)
void	set_sleep_time (uint32_t sleep_time)
void	set_threshold (uint32_t new_threshold, uint32_t new_warning_threshold)
void	set_shutdown_on_exceeded (bool new_shutdown_on_exceeded)
void	set_warning_interval (uint32_t new_warning_interval)
bool	is_threshold_exceeded ()
void	add_file_system (const bfs::path &path_name)
void	space_monitor_loop ()

Detailed Description

template<typename SpaceProvider>
class sysio::resource_monitor::file_space_handler< SpaceProvider >

Definition at line 13 of file file_space_handler.hpp.

Constructor & Destructor Documentation

file_space_handler()

template<typename SpaceProvider >

sysio::resource_monitor::file_space_handler< SpaceProvider >::file_space_handler ( SpaceProvider && space_provider, boost::asio::io_context & ctx )

inline

Definition at line 15 of file file_space_handler.hpp.

      :space_provider(std::move(space_provider)),
      timer{ctx}
      {
      }

Member Function Documentation

add_file_system()

template<typename SpaceProvider >

void sysio::resource_monitor::file_space_handler< SpaceProvider >::add_file_system ( const bfs::path & path_name )

inline

Definition at line 77 of file file_space_handler.hpp.

                                                     {
         // Get detailed information of the path
         struct stat statbuf;
         auto status = space_provider.get_stat(path_name.string().c_str(), &statbuf);
         SYS_ASSERT(status == 0, chain::plugin_config_exception,
                    "Failed to run stat on ${path} with status ${status}", ("path", path_name.string())("status", status));
 
         dlog("${path_name}'s file system to be monitored", ("path_name", path_name.string()));
 
         // If the file system containing the path is already
         // in the filesystem list, do not add it again
         for (auto& fs: filesystems) {
            if (statbuf.st_dev == fs.st_dev) { // Two files belong to the same file system if their device IDs are the same.
               dlog("${path_name}'s file system already monitored", ("path_name", path_name.string()));
 
               return;
            }
         }
 
         // For efficiency, precalculate threshold values to avoid calculating it
         // everytime we check space usage. Since bfs::space returns
         // available amount, we use minimum available amount as threshold. 
         boost::system::error_code ec;
         auto info = space_provider.get_space(path_name, ec);
         SYS_ASSERT(!ec, chain::plugin_config_exception,
            "Unable to get space info for ${path_name}: [code: ${ec}] ${message}",
            ("path_name", path_name.string())
            ("ec", ec.value())
            ("message", ec.message()));
 
         auto shutdown_available = (100 - shutdown_threshold) * (info.capacity / 100); // (100 - shutdown_threshold)/100 is the percentage of minimum number of available bytes the file system must maintain  
         auto warning_available = (100 - warning_threshold) * (info.capacity / 100);
 
         // Add to the list
         filesystems.emplace_back(statbuf.st_dev, shutdown_available, path_name, warning_available);
         
         ilog("${path_name}'s file system monitored. shutdown_available: ${shutdown_available}, capacity: ${capacity}, threshold: ${threshold}", ("path_name", path_name.string()) ("shutdown_available", shutdown_available) ("capacity", info.capacity) ("threshold", shutdown_threshold) );
      }

Here is the caller graph for this function:

is_threshold_exceeded()

template<typename SpaceProvider >

bool sysio::resource_monitor::file_space_handler< SpaceProvider >::is_threshold_exceeded ( )

inline

Definition at line 43 of file file_space_handler.hpp.

                                   {
         // Go over each monitored file system
         for (auto& fs: filesystems) {
            boost::system::error_code ec;
            auto info = space_provider.get_space(fs.path_name, ec);
            if ( ec ) {
               // As the system is running and this plugin is not a critical
               // part of the system, we should not exit.
               // Just report the failure and continue;
               wlog( "Unable to get space info for ${path_name}: [code: ${ec}] ${message}. Ignore this failure.",
                  ("path_name", fs.path_name.string())
                  ("ec", ec.value())
                  ("message", ec.message()));
 
               continue;
            }
 
            if ( info.available < fs.shutdown_available ) {
               if (output_threshold_warning) {
                  elog("Space usage warning: ${path}'s file system exceeded threshold ${threshold}%, available: ${available}, Capacity: ${capacity}, shutdown_available: ${shutdown_available}",
                       ("path", fs.path_name.string())("threshold", shutdown_threshold)("available", info.available)("capacity", info.capacity)("shutdown_available", fs.shutdown_available));
               }
               return true;
            } else if ( info.available < fs.warning_available && output_threshold_warning ) {
               wlog("Space usage warning: ${path}'s file system approaching threshold. available: ${available}, warning_available: ${warning_available}", ("path", fs.path_name.string()) ("available", info.available) ("warning_available", fs.warning_available));
               if ( shutdown_on_exceeded) {
                  wlog("nodeop will shutdown when space usage exceeds threshold ${threshold}%", ("threshold", shutdown_threshold));
               }
            }
         }
 
         return false;
      }

Here is the caller graph for this function:

set_shutdown_on_exceeded()

template<typename SpaceProvider >

void sysio::resource_monitor::file_space_handler< SpaceProvider >::set_shutdown_on_exceeded ( bool new_shutdown_on_exceeded )

inline

Definition at line 35 of file file_space_handler.hpp.

                                                                   {
         shutdown_on_exceeded = new_shutdown_on_exceeded;
      }

Here is the caller graph for this function:

set_sleep_time()

template<typename SpaceProvider >

void sysio::resource_monitor::file_space_handler< SpaceProvider >::set_sleep_time ( uint32_t sleep_time )

inline

Definition at line 21 of file file_space_handler.hpp.

                                               {
         sleep_time_in_secs = sleep_time;
      }

Here is the caller graph for this function:

set_threshold()

template<typename SpaceProvider >

void sysio::resource_monitor::file_space_handler< SpaceProvider >::set_threshold ( uint32_t new_threshold, uint32_t new_warning_threshold )

inline

Definition at line 27 of file file_space_handler.hpp.

                                                                                 {
         SYS_ASSERT(new_warning_threshold < new_threshold, chain::plugin_config_exception,
                    "warning_threshold ${new_warning_threshold} must be less than threshold ${new_threshold}", ("new_warning_threshold", new_warning_threshold) ("new_threshold", new_threshold));
 
         shutdown_threshold = new_threshold;
         warning_threshold = new_warning_threshold;
      }

Here is the caller graph for this function:

set_warning_interval()

template<typename SpaceProvider >

void sysio::resource_monitor::file_space_handler< SpaceProvider >::set_warning_interval ( uint32_t new_warning_interval )

inline

Definition at line 39 of file file_space_handler.hpp.

                                                               {
         warning_interval = new_warning_interval;
      }

Here is the caller graph for this function:

space_monitor_loop()

template<typename SpaceProvider >

void sysio::resource_monitor::file_space_handler< SpaceProvider >::space_monitor_loop ( )

inline

Definition at line 116 of file file_space_handler.hpp.

                             {
      if ( is_threshold_exceeded() && shutdown_on_exceeded ) {
         elog("Shutting down, file system exceeded threshold");
         appbase::app().quit(); // This will gracefully stop Nodeop
         return;
      }
      update_warning_interval_counter();
 
      timer.expires_from_now( boost::posix_time::seconds( sleep_time_in_secs ));
 
      timer.async_wait([this](auto& ec) {
         if ( ec ) {
            wlog("Exit due to error: ${ec}, message: ${message}",
                 ("ec", ec.value())
                 ("message", ec.message()));
            return;
         } else {
            // Loop over
            space_monitor_loop();
         }
      });
   }

Here is the call graph for this function:

Here is the caller graph for this function:

---

The documentation for this class was generated from the following file:

• plugins/resource_monitor_plugin/include/sysio/resource_monitor_plugin/file_space_handler.hpp