TPC::TPCRequestManager Class Reference

#include <XrdHttpTpcPool.hh>

Collaboration diagram for TPC::TPCRequestManager:

Classes
class	TPCRequest

Public Member Functions
	TPCRequestManager (XrdOucEnv &xrdEnv, XrdSysError &eDest)
bool	Produce (TPCRequest &handler)
void	SetMaxIdleRequests (unsigned max_pending_ops)
void	SetMaxWorkers (unsigned max_workers)
void	SetWorkerIdleTimeout (std::chrono::steady_clock::duration dur)

Detailed Description

Definition at line 38 of file XrdHttpTpcPool.hh.

Constructor & Destructor Documentation

TPCRequestManager()

TPCRequestManager::TPCRequestManager	(	XrdOucEnv &	xrdEnv,
		XrdSysError &	eDest
	)

Definition at line 396 of file XrdHttpTpcPool.cc.

: m_log(eDest), m_xrdEnv(xrdEnv) {}

Member Function Documentation

Produce()

bool TPCRequestManager::Produce

(

TPCRequestManager::TPCRequest &

handler

)

Definition at line 403 of file XrdHttpTpcPool.cc.

                                                                    {
    std::shared_ptr<TPCQueue> queue;
    // Get the queue from our per-label map.  To avoid a race condition,
    // if the queue we get has already been shut down, we release the lock
    // and try again (with the expectation that the queue will eventually
    // get the lock and remove itself from the map).
    while (true) {
        m_mutex.lock_shared();
        std::lock_guard<std::shared_mutex> guard{m_mutex, std::adopt_lock};
        auto iter = m_pool_map.find(handler.GetLabel());
        if (iter != m_pool_map.end()) {
            if (!iter->second->IsDone()) {
                queue = iter->second;
                break;
            }
        } else {
            break;
        }
    }
    if (!queue) {
        auto created_queue = false;
        std::string queue_name = "";
        {
            std::lock_guard<std::shared_mutex> guard(m_mutex);
            auto iter = m_pool_map.find(handler.GetLabel());
            if (iter == m_pool_map.end()) {
                queue = std::make_shared<TPCQueue>(handler.GetLabel(), *this);
                m_pool_map.insert(iter, {handler.GetLabel(), queue});
                created_queue = true;
                queue_name = handler.GetLabel();
            } else {
                queue = iter->second;
            }
        }
        if (created_queue) {
            m_log.Log(LogMask::Info, "RequestManager", "Created new TPC request queue for", queue_name.c_str());
        }
    }
 
    return queue->Produce(handler);
}

References TPC::TPCRequestManager::TPCRequest::GetLabel(), TPC::Info, and XrdSysError::Log().

Here is the call graph for this function:

SetMaxIdleRequests()

void TPC::TPCRequestManager::SetMaxIdleRequests ( unsigned  max_pending_ops )

inline

Definition at line 78 of file XrdHttpTpcPool.hh.

{ m_max_pending_ops = max_pending_ops; }

SetMaxWorkers()

void TPC::TPCRequestManager::SetMaxWorkers ( unsigned  max_workers )

inline

Definition at line 77 of file XrdHttpTpcPool.hh.

{ m_max_workers = max_workers; }

SetWorkerIdleTimeout()

void TPCRequestManager::SetWorkerIdleTimeout

(

std::chrono::steady_clock::duration

dur

)

Definition at line 398 of file XrdHttpTpcPool.cc.

{ m_idle_timeout = dur; }

---

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

• XrdHttpTpcPool.hh
• XrdHttpTpcPool.cc