XrdClHttpOptionsCache.cc

Go to the documentation of this file.

/******************************************************************************/
/* Copyright (C) 2025, Pelican Project, Morgridge Institute for Research      */
/*                                                                            */
/* This file is part of the XrdClHttp client plugin for XRootD.               */
/*                                                                            */
/* XRootD is free software: you can redistribute it and/or modify it under    */
/* the terms of the GNU Lesser General Public License as published by the     */
/* Free Software Foundation, either version 3 of the License, or (at your     */
/* option) any later version.                                                 */
/*                                                                            */
/* XRootD 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 Lesser General Public       */
/* License for more details.                                                  */
/*                                                                            */
/* The copyright holder's institutional names and contributor's names may not */
/* be used to endorse or promote products derived from this software without  */
/* specific prior written permission of the institution or contributor.       */
/******************************************************************************/
 
#include "XrdClHttpOptionsCache.hh"
 
#include <curl/curl.h>
 
#include <thread>
 
XrdClHttp::VerbsCache XrdClHttp::VerbsCache::g_cache;
std::once_flag XrdClHttp::VerbsCache::m_expiry_launch;
std::mutex XrdClHttp::VerbsCache::m_shutdown_lock;
std::condition_variable XrdClHttp::VerbsCache::m_shutdown_requested_cv;
bool XrdClHttp::VerbsCache::m_shutdown_requested = false;
std::thread XrdClHttp::VerbsCache::m_expire_tid;
 
// shutdown trigger, must be last of the static members
XrdClHttp::VerbsCache::shutdown_s XrdClHttp::VerbsCache::m_shutdowns;
 
XrdClHttp::VerbsCache & XrdClHttp::VerbsCache::Instance() {
    std::unique_lock lk(m_shutdown_lock);
    if (!m_shutdown_requested) {
        std::call_once(m_expiry_launch, [] {
            std::thread t(VerbsCache::ExpireThread);
            m_expire_tid = std::move(t);
        });
    }
    return g_cache;
}
 
void XrdClHttp::VerbsCache::ExpireThread()
{
    while (true) {
        {
            std::unique_lock lock(m_shutdown_lock);
            m_shutdown_requested_cv.wait_for(
                lock,
                std::chrono::seconds(30),
                []{return m_shutdown_requested;}
            );
            if (m_shutdown_requested) {
                break;
            }
        }
        auto now = std::chrono::steady_clock::now();
        g_cache.Expire(now);
    }
}
 
void XrdClHttp::VerbsCache::Expire(std::chrono::steady_clock::time_point now)
{
    std::unique_lock lock(m_mutex);
    for (auto iter = m_verbs_map.begin(); iter != m_verbs_map.end();) {
        if (iter->second.m_expiry < now) {
            iter = m_verbs_map.erase(iter);
        } else {
            ++iter;
        }
    }
}
 
void
XrdClHttp::VerbsCache::Shutdown()
{
    {
       std::unique_lock lock(m_shutdown_lock);
       m_shutdown_requested = true;
       m_shutdown_requested_cv.notify_one();
    }
 
    if (m_expire_tid.joinable()) {
      m_expire_tid.join();
    }
}