foreign_storage::RefreshTimeCalculator Class Reference

#include <RefreshTimeCalculator.h>

Static Public Member Functions
static int64_t	getNextRefreshTime (const std::map< std::string, std::string, std::less<>> &foreign_table_options)
static int64_t	getCurrentTime ()
static void	setMockCurrentTime (int64_t mock_current_time)
static void	resetMockCurrentTime ()

Static Private Attributes
static std::atomic< bool >	should_use_mock_current_time_ {false}
static std::atomic< int64_t >	mock_current_time_ {0}

Detailed Description

Definition at line 25 of file RefreshTimeCalculator.h.

Member Function Documentation

int64_t foreign_storage::RefreshTimeCalculator::getCurrentTime ( )

static

Definition at line 76 of file RefreshTimeCalculator.cpp.

References CHECK_GT, mock_current_time_, and should_use_mock_current_time_.

Referenced by Catalog_Namespace::Catalog::getAllForeignTablesForRefresh(), getNextRefreshTime(), Catalog_Namespace::anonymous_namespace{Catalog.cpp}::set_common_log_system_table_options(), and Catalog_Namespace::Catalog::updateForeignTableRefreshTimes().

                                              {
  if (should_use_mock_current_time_) {
    CHECK_GT(mock_current_time_, 0);
    return mock_current_time_;
  } else {
    return std::chrono::duration_cast<std::chrono::seconds>(
               std::chrono::system_clock::now().time_since_epoch())
        .count();
  }
}

Here is the caller graph for this function:

int64_t foreign_storage::RefreshTimeCalculator::getNextRefreshTime ( const std::map< std::string, std::string, std::less<>> &  foreign_table_options )

static

Definition at line 51 of file RefreshTimeCalculator.cpp.

References CHECK, foreign_storage::anonymous_namespace{RefreshTimeCalculator.cpp}::get_interval_duration(), getCurrentTime(), foreign_storage::ForeignTable::NULL_REFRESH_TIME, foreign_storage::ForeignTable::REFRESH_INTERVAL_KEY, and foreign_storage::ForeignTable::REFRESH_START_DATE_TIME_KEY.

Referenced by Catalog_Namespace::anonymous_namespace{Catalog.cpp}::get_next_refresh_time().

                                                                          {
  int64_t current_time = getCurrentTime();
  auto start_date_entry = foreign_table_options.find(
      foreign_storage::ForeignTable::REFRESH_START_DATE_TIME_KEY);
  CHECK(start_date_entry != foreign_table_options.end());
  auto start_date_time = dateTimeParse<kTIMESTAMP>(start_date_entry->second, 0);

  // If start date time is current or in the future, then that is the next refresh time
  if (start_date_time >= current_time) {
    return start_date_time;
  }
  auto interval_entry =
      foreign_table_options.find(foreign_storage::ForeignTable::REFRESH_INTERVAL_KEY);
  if (interval_entry != foreign_table_options.end()) {
    auto interval_duration = get_interval_duration(interval_entry->second);
    auto num_intervals =
        (current_time - start_date_time + interval_duration - 1) / interval_duration;
    return start_date_time + (num_intervals * interval_duration);
  } else {
    // If this was a one time refresh, then there is no next refresh time
    return foreign_storage::ForeignTable::NULL_REFRESH_TIME;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void foreign_storage::RefreshTimeCalculator::resetMockCurrentTime ( )

static

Definition at line 92 of file RefreshTimeCalculator.cpp.

References mock_current_time_, and should_use_mock_current_time_.

                                                 {
  should_use_mock_current_time_ = false;
  mock_current_time_ = 0;
}

void foreign_storage::RefreshTimeCalculator::setMockCurrentTime ( int64_t  mock_current_time )

static

Definition at line 87 of file RefreshTimeCalculator.cpp.

References mock_current_time_, and should_use_mock_current_time_.

                                                                        {
  mock_current_time_ = mock_current_time;
  should_use_mock_current_time_ = true;
}

Member Data Documentation

std::atomic<int64_t> foreign_storage::RefreshTimeCalculator::mock_current_time_ {0}

inlinestaticprivate

Definition at line 37 of file RefreshTimeCalculator.h.

Referenced by getCurrentTime(), resetMockCurrentTime(), and setMockCurrentTime().

std::atomic<bool> foreign_storage::RefreshTimeCalculator::should_use_mock_current_time_ {false}

inlinestaticprivate

Definition at line 36 of file RefreshTimeCalculator.h.

Referenced by getCurrentTime(), resetMockCurrentTime(), and setMockCurrentTime().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/Catalog/RefreshTimeCalculator.h
• /home/jenkins-slave/workspace/core-os-doxygen/Catalog/RefreshTimeCalculator.cpp