TPC::TPCRequestManager::TPCRequest Class Reference

#include <XrdHttpTpcPool.hh>

Collaboration diagram for TPC::TPCRequestManager::TPCRequest:

Public Member Functions
	TPCRequest (const std::string &label, const int scitag, CURL *handle)
void	Cancel ()
CURL *	GetHandle () const
std::string	GetLabel () const
std::string	GetRemoteConnDesc ()
int	GetScitag () const
bool	IsActive () const
void	SetActive ()
void	SetDone (int status, const std::string &msg)
void	UpdateRemoteConnDesc ()
int	WaitFor (std::chrono::steady_clock::duration)

Static Public Member Functions
static std::string	GenerateIdentifier (const std::string &label, const char *vorg, const int scitag)

Detailed Description

Definition at line 40 of file XrdHttpTpcPool.hh.

Constructor & Destructor Documentation

TPCRequest()

TPC::TPCRequestManager::TPCRequest::TPCRequest ( const std::string &  label, const int  scitag, CURL *  handle  )

inline

Definition at line 42 of file XrdHttpTpcPool.hh.

: m_label(label), m_scitag(scitag), m_curl(handle) {}

Member Function Documentation

Cancel()

void TPCRequestManager::TPCRequest::Cancel

(

)

Definition at line 318 of file XrdHttpTpcPool.cc.

{ m_active.store(false, std::memory_order_relaxed); }

GenerateIdentifier()

std::string TPCRequestManager::TPCRequest::GenerateIdentifier ( const std::string &  label, const char *  vorg, const int  scitag  )

static

Definition at line 328 of file XrdHttpTpcPool.cc.

                                                                                                                    {
    std::stringstream ss;
    ss << label;  // always present
 
    if (vorg && *vorg) {
        ss << "_" << vorg;
    }
 
    if (scitag != -1) {
        ss << "_" << scitag;
    }
    return ss.str();
}

GetHandle()

CURL * TPCRequestManager::TPCRequest::GetHandle

(

)

const

Definition at line 320 of file XrdHttpTpcPool.cc.

{ return m_curl; }

GetLabel()

std::string TPCRequestManager::TPCRequest::GetLabel

(

)

const

Definition at line 326 of file XrdHttpTpcPool.cc.

{ return m_label; }

Referenced by TPC::TPCRequestManager::Produce().

Here is the caller graph for this function:

GetRemoteConnDesc()

std::string TPCRequestManager::TPCRequest::GetRemoteConnDesc

(

)

Definition at line 377 of file XrdHttpTpcPool.cc.

                                                         {
    std::unique_lock<std::mutex> lock(m_conn_mutex);
    return m_conn_list;
}

GetScitag()

int TPCRequestManager::TPCRequest::GetScitag

(

)

const

Definition at line 322 of file XrdHttpTpcPool.cc.

{ return m_scitag; }

IsActive()

bool TPCRequestManager::TPCRequest::IsActive

(

)

const

Definition at line 324 of file XrdHttpTpcPool.cc.

{ return m_active.load(std::memory_order_relaxed); }

SetActive()

void TPCRequestManager::TPCRequest::SetActive

(

)

Definition at line 316 of file XrdHttpTpcPool.cc.

{ m_active.store(true, std::memory_order_relaxed); }

SetDone()

void TPCRequestManager::TPCRequest::SetDone	(	int	status,
		const std::string &	msg
	)

Definition at line 382 of file XrdHttpTpcPool.cc.

                                                                          {
    std::unique_lock<std::mutex> lock(m_mutex);
    m_status = status;
    m_message = msg;
    m_cv.notify_one();
}

UpdateRemoteConnDesc()

void TPCRequestManager::TPCRequest::UpdateRemoteConnDesc

(

)

Definition at line 343 of file XrdHttpTpcPool.cc.

                                                       {
#if LIBCURL_VERSION_NUM >= 0x071500
    // Retrieve IP address and port from the curl handle
    const char *curl_ip = nullptr;
    CURLcode rc = curl_easy_getinfo(m_curl, CURLINFO_PRIMARY_IP, &curl_ip);
    if (rc != CURLE_OK || !curl_ip) {
        return;  // Failed to get IP, cannot update connection descriptor
    }
 
    long curl_port = 0;
    rc = curl_easy_getinfo(m_curl, CURLINFO_PRIMARY_PORT, &curl_port);
    if (rc != CURLE_OK || curl_port == 0) {
        return;  // Failed to get port, cannot update connection descriptor
    }
 
    // Format the connection string according to HTTP-TPC spec
    // IPv6 addresses must be enclosed in square brackets
    std::stringstream ss;
    if (strchr(curl_ip, ':') == nullptr) {
        ss << "tcp:" << curl_ip << ":" << curl_port;
    } else {
        ss << "tcp:[" << curl_ip << "]:" << curl_port;
    }
 
    {
        std::unique_lock<std::mutex> lock(m_conn_mutex);
        m_conn_list = ss.str();
    }
#else
    // For older libcurl versions, do nothing
    return;
#endif
}

WaitFor()

int TPCRequestManager::TPCRequest::WaitFor

(

std::chrono::steady_clock::duration

dur

)

Definition at line 389 of file XrdHttpTpcPool.cc.

                                                                          {
    std::unique_lock<std::mutex> lock(m_mutex);
    m_cv.wait_for(lock, dur, [&] { return m_status >= 0; });
 
    return m_status;
}

---

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

• XrdHttpTpcPool.hh
• XrdHttpTpcPool.cc