space_handler_fixture Struct Reference

Collaboration diagram for space_handler_fixture:

Classes
struct	mock_space_provider

Public Types
using	file_space_handler_t = file_space_handler<mock_space_provider>

Public Member Functions
	space_handler_fixture ()
void	add_file_system (const bfs::path &path_name)
void	set_threshold (uint32_t threshold, uint32_t warning_threshold)
void	set_sleep_time (uint32_t sleep_time)
void	set_shutdown_on_exceeded (bool shutdown_on_exceeded)
bool	is_threshold_exceeded ()
void	space_monitor_loop ()
bool	test_loop_common (int num_loops, int interval)

Public Attributes
boost::asio::io_context	ctx
std::function< bfs::space_info(const bfs::path &p, boost::system::error_code &ec)>	mock_get_space
std::function< int(const char *path, struct stat *buf)>	mock_get_stat
file_space_handler_t	space_handler

Detailed Description

Definition at line 12 of file test_monitor_loop.cpp.

Member Typedef Documentation

file_space_handler_t

using space_handler_fixture::file_space_handler_t = file_space_handler<mock_space_provider>

Definition at line 31 of file test_monitor_loop.cpp.

Constructor & Destructor Documentation

space_handler_fixture()

space_handler_fixture::space_handler_fixture ( )

inline

Definition at line 32 of file test_monitor_loop.cpp.

   : space_handler(mock_space_provider( *this ), ctx)
   {
   }

Member Function Documentation

add_file_system()

void space_handler_fixture::add_file_system ( const bfs::path & path_name )

inline

Definition at line 37 of file test_monitor_loop.cpp.

                                                  {
      space_handler.add_file_system( path_name );
   }

Here is the call graph for this function:

Here is the caller graph for this function:

is_threshold_exceeded()

bool space_handler_fixture::is_threshold_exceeded ( )

inline

Definition at line 53 of file test_monitor_loop.cpp.

                                {
      return space_handler.is_threshold_exceeded();
   }

Here is the call graph for this function:

set_shutdown_on_exceeded()

void space_handler_fixture::set_shutdown_on_exceeded ( bool shutdown_on_exceeded )

inline

Definition at line 49 of file test_monitor_loop.cpp.

                                                            {
      space_handler.set_shutdown_on_exceeded(shutdown_on_exceeded);
   }

Here is the call graph for this function:

Here is the caller graph for this function:

set_sleep_time()

void space_handler_fixture::set_sleep_time ( uint32_t sleep_time )

inline

Definition at line 45 of file test_monitor_loop.cpp.

                                            {
      space_handler.set_sleep_time( sleep_time );
   }

Here is the call graph for this function:

Here is the caller graph for this function:

set_threshold()

void space_handler_fixture::set_threshold ( uint32_t threshold, uint32_t warning_threshold )

inline

Definition at line 41 of file test_monitor_loop.cpp.

                                                                      {
      space_handler.set_threshold( threshold, warning_threshold );
   }

Here is the call graph for this function:

Here is the caller graph for this function:

space_monitor_loop()

void space_handler_fixture::space_monitor_loop ( )

inline

Definition at line 57 of file test_monitor_loop.cpp.

                             {
      return space_handler.space_monitor_loop();
   }

Here is the call graph for this function:

Here is the caller graph for this function:

test_loop_common()

bool space_handler_fixture::test_loop_common ( int num_loops, int interval )

inline

Definition at line 61 of file test_monitor_loop.cpp.

   {
      mock_get_space = [ i = 0, num_loops ]( const bfs::path& p, boost::system::error_code& ec) mutable -> bfs::space_info {
         ec = boost::system::errc::make_error_code(errc::success);
 
         bfs::space_info rc;
         rc.capacity  = 1000000;
 
         if ( i < num_loops + 1 ) {  // "+ 1" for the get_space in add_file_system
            rc.available = 300000;
         } else {
            rc.available = 100000;
         }
 
         i++;
 
         return rc;
      };
 
      mock_get_stat = []( const char *path, struct stat *buf ) -> int {
         buf->st_dev = 0;
         return 0;
      };
 
      set_threshold(80, 75);
      set_shutdown_on_exceeded(true);
      set_sleep_time(interval);
      add_file_system("/test");
 
      auto start = std::chrono::system_clock::now();
 
      auto monitor_thread = std::thread( [this] {
         space_monitor_loop();
         ctx.run();
      });
 
      monitor_thread.join();
 
      auto end = std::chrono::system_clock::now();
      std::chrono::duration<double> test_duration = end - start;
 
      // For tests to be repeatable on any platforms under any loads,
      // particularly for longer runs,
      // we just make sure the test duration is longer than a margin
      // of theroretical duration. 
      bool finished_in_time = (test_duration >= std::chrono::duration<double>((num_loops - 1) * interval));
 
      return finished_in_time;
   }

Here is the call graph for this function:

Member Data Documentation

ctx

boost::asio::io_context space_handler_fixture::ctx

Definition at line 29 of file test_monitor_loop.cpp.

mock_get_space

std::function<bfs::space_info(const bfs::path& p, boost::system::error_code& ec)> space_handler_fixture::mock_get_space

Definition at line 112 of file test_monitor_loop.cpp.

mock_get_stat

std::function<int(const char *path, struct stat *buf)> space_handler_fixture::mock_get_stat

Definition at line 113 of file test_monitor_loop.cpp.

space_handler

file_space_handler_t space_handler_fixture::space_handler

Definition at line 115 of file test_monitor_loop.cpp.

---

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

• plugins/resource_monitor_plugin/test/test_monitor_loop.cpp