XrdHttpTpcTPC.cc File Reference

#include "XrdHttp/XrdHttpExtHandler.hh"
#include "XrdNet/XrdNetAddr.hh"
#include "XrdNet/XrdNetUtils.hh"
#include "XrdOuc/XrdOucEnv.hh"
#include "XrdSec/XrdSecEntity.hh"
#include "XrdSfs/XrdSfsInterface.hh"
#include "XrdSys/XrdSysAtomics.hh"
#include "XrdSys/XrdSysFD.hh"
#include "XrdVersion.hh"
#include "XrdXrootd/XrdXrootdRedirHelper.hh"
#include "XrdXrootd/XrdXrootdTpcMon.hh"
#include "XrdOuc/XrdOucPrivateUtils.hh"
#include "XrdOuc/XrdOucTUtils.hh"
#include "XrdHttpTpc/XrdHttpTpcUtils.hh"
#include "XrdHttp/XrdHttpUtils.hh"
#include <curl/curl.h>
#include <dlfcn.h>
#include <fcntl.h>
#include <algorithm>
#include <memory>
#include <sstream>
#include <stdexcept>
#include <thread>
#include "XrdHttpTpcState.hh"
#include "XrdHttpTpcStream.hh"
#include "XrdHttpTpcTPC.hh"
#include <fstream>

Include dependency graph for XrdHttpTpcTPC.cc:

Go to the source code of this file.

Functions
std::string	encode_xrootd_opaque_to_uri (CURL *curl, const std::string &opaque)
static bool	IsAllowedScheme (const std::string &url)
static std::string	PrepareURL (const std::string &url)
XrdHttpExtHandler *	XrdHttpGetExtHandler (XrdSysError *log, const char *config, const char *, XrdOucEnv *myEnv)
	XrdVERSIONINFO (XrdHttpGetExtHandler, HttpTPC)

Function Documentation

encode_xrootd_opaque_to_uri()

std::string encode_xrootd_opaque_to_uri	(	CURL *	curl,
		const std::string &	opaque
	)

Definition at line 264 of file XrdHttpTpcTPC.cc.

{
    std::stringstream parser(opaque);
    std::string sequence;
    std::stringstream output;
    bool first = true;
    while (getline(parser, sequence, '&')) {
        if (sequence.empty()) {continue;}
        size_t equal_pos = sequence.find('=');
        char *val = NULL;
        if (equal_pos != std::string::npos)
            val = curl_easy_escape(curl, sequence.c_str() + equal_pos + 1, sequence.size()  - equal_pos - 1);
        // Do not emit parameter if value exists and escaping failed.
        if (!val && equal_pos != std::string::npos) {continue;}
 
        if (!first) output << "&";
        first = false;
        output << sequence.substr(0, equal_pos);
        if (val) {
            output << "=" << val;
            curl_free(val);
        }
    }
    return output.str();
}

References getline().

Here is the call graph for this function:

IsAllowedScheme()

static bool IsAllowedScheme ( const std::string &  url )

static

Definition at line 383 of file XrdHttpTpcTPC.cc.

{
  const std::string allowed_schemes[] = { "https://", "http://" };
 
  for (const auto& s : allowed_schemes)
    if (url.compare(0, s.size(), s) == 0)
      return true;
 
  return false;
}

Referenced by TPC::TPCHandler::ProcessReq().

Here is the caller graph for this function:

PrepareURL()

static std::string PrepareURL ( const std::string &  url )

static

Definition at line 372 of file XrdHttpTpcTPC.cc.

{
  const std::string replace_schemes[] = { "davs://", "s3://", "s3s://" };
 
  for (const auto& s : replace_schemes)
    if (url.compare(0, s.size(), s) == 0)
      return "https://" + url.substr(s.size());
 
  return url;
}

Referenced by TPC::TPCHandler::ProcessReq().

Here is the caller graph for this function:

XrdHttpGetExtHandler()

XrdHttpExtHandler* XrdHttpGetExtHandler	(	XrdSysError *	log,
		const char *	config,
		const char *	,
		XrdOucEnv *	myEnv
	)

Definition at line 1348 of file XrdHttpTpcTPC.cc.

                                                                                                                 {
    if (curl_global_init(CURL_GLOBAL_DEFAULT)) {
        log->Emsg("TPCInitialize", "libcurl failed to initialize");
        return NULL;
    }
 
    TPCHandler *retval{NULL};
    if (!config) {
        log->Emsg("TPCInitialize", "TPC handler requires a config filename in order to load");
        return NULL;
    }
    try {
        log->Emsg("TPCInitialize", "Will load configuration for the TPC handler from", config);
        retval = new TPCHandler(log, config, myEnv);
    } catch (std::runtime_error &re) {
        log->Emsg("TPCInitialize", "Encountered a runtime failure when loading ", re.what());
        //printf("Provided env vars: %p, XrdInet*: %p\n", myEnv, myEnv->GetPtr("XrdInet*"));
    }
    return retval;
}

References XrdSysError::Emsg().

Here is the call graph for this function:

XrdVERSIONINFO()

XrdVERSIONINFO	(	XrdHttpGetExtHandler	,
		HttpTPC
	)