// ----------------------------------------------------------------------
// File: CachedValue.hh
// Author: Steven Murray - CERN
// ----------------------------------------------------------------------
/************************************************************************
* EOS - the CERN Disk Storage System *
* Copyright (C) 2011 CERN/Switzerland *
* *
* This program is free software: you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation, either version 3 of the License, or *
* (at your option) any later version. *
* *
* This program is distributed in the hope that it will be useful, *
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
* GNU General Public License for more details. *
* *
* You should have received a copy of the GNU General Public License *
* along with this program. If not, see .*
************************************************************************/
#ifndef __EOSMGMTGC_CACHEDVALUE_HH__
#define __EOSMGMTGC_CACHEDVALUE_HH__
#include "mgm/Namespace.hh"
#include
#include
#include
/*----------------------------------------------------------------------------*/
/**
* @file CachedValue.hh
*
* @brief Templated class for creating a time based cache for a single
* variable.
*
*/
/*----------------------------------------------------------------------------*/
EOSTGCNAMESPACE_BEGIN
//----------------------------------------------------------------------------
//! Templated class for creating a time based cache for a single variable.
//!
//! @tparam ValueType The type of the value to be cached.
//----------------------------------------------------------------------------
template class CachedValue {
public:
//--------------------------------------------------------------------------
//! Constructor
//! @param valueGetter callable responsible for getting a new value
//! @param maxAgeSecs age at which a call to get() will renew the cache. A
//! value of zero means the a call to get() will always renew the cache.
//--------------------------------------------------------------------------
CachedValue(std::function valueGetter, const std::time_t maxAgeSecs):
m_valueHasNeverBeenSet(true),
m_valueGetter(valueGetter),
m_maxAgeSecs(maxAgeSecs),
m_timestamp(time(nullptr))
{
}
//--------------------------------------------------------------------------
//! @return the cached value
//--------------------------------------------------------------------------
ValueType
get()
{
std::lock_guard lock(m_mutex);
const std::time_t now = time(nullptr);
const std::time_t age = now - m_timestamp;
if(m_valueHasNeverBeenSet || age >= m_maxAgeSecs) {
m_valueHasNeverBeenSet = false;
m_timestamp = now;
m_value = m_valueGetter();
}
return m_value;
}
private:
/// Mutex used to protect the cached value
std::mutex m_mutex;
/// True if the cached value has never been set
bool m_valueHasNeverBeenSet;
/// The cached value
ValueType m_value;
/// Callable responsible for getting a new value
std::function m_valueGetter;
/// Age at which a call to get() will renew the cache
std::time_t m_maxAgeSecs;
/// The timestamp of when the value was last updated
std::time_t m_timestamp;
}; // class CachedValue
EOSTGCNAMESPACE_END
#endif