XRootD
Loading...
Searching...
No Matches
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/XrdXrootdTpcMon.hh"
#include "XrdOuc/XrdOucTUtils.hh"
#include "XrdHttpTpc/XrdHttpTpcUtils.hh"
#include <curl/curl.h>
#include <dlfcn.h>
#include <fcntl.h>
#include <algorithm>
#include <memory>
#include <sstream>
#include <stdexcept>
#include <thread>
#include <iostream>
#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 std::string PrepareURL (const std::string &input)
XrdHttpExtHandlerXrdHttpGetExtHandler (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 175 of file XrdHttpTpcTPC.cc.

176{
177 std::stringstream parser(opaque);
178 std::string sequence;
179 std::stringstream output;
180 bool first = true;
181 while (getline(parser, sequence, '&')) {
182 if (sequence.empty()) {continue;}
183 size_t equal_pos = sequence.find('=');
184 char *val = NULL;
185 if (equal_pos != std::string::npos)
186 val = curl_easy_escape(curl, sequence.c_str() + equal_pos + 1, sequence.size() - equal_pos - 1);
187 // Do not emit parameter if value exists and escaping failed.
188 if (!val && equal_pos != std::string::npos) {continue;}
189
190 if (!first) output << "&";
191 first = false;
192 output << sequence.substr(0, equal_pos);
193 if (val) {
194 output << "=" << val;
195 curl_free(val);
196 }
197 }
198 return output.str();
199}
void getline(uchar *buff, int blen)

References getline().

Here is the call graph for this function:

◆ PrepareURL()

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

Definition at line 241 of file XrdHttpTpcTPC.cc.

241 {
242 if (!strncmp(input.c_str(), "davs://", 7)) {
243 return "https://" + input.substr(7);
244 }
245 return input;
246}

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 1057 of file XrdHttpTpcTPC.cc.

1057 {
1058 if (curl_global_init(CURL_GLOBAL_DEFAULT)) {
1059 log->Emsg("TPCInitialize", "libcurl failed to initialize");
1060 return NULL;
1061 }
1062
1063 TPCHandler *retval{NULL};
1064 if (!config) {
1065 log->Emsg("TPCInitialize", "TPC handler requires a config filename in order to load");
1066 return NULL;
1067 }
1068 try {
1069 log->Emsg("TPCInitialize", "Will load configuration for the TPC handler from", config);
1070 retval = new TPCHandler(log, config, myEnv);
1071 } catch (std::runtime_error &re) {
1072 log->Emsg("TPCInitialize", "Encountered a runtime failure when loading ", re.what());
1073 //printf("Provided env vars: %p, XrdInet*: %p\n", myEnv, myEnv->GetPtr("XrdInet*"));
1074 }
1075 return retval;
1076}
int Emsg(const char *esfx, int ecode, const char *text1, const char *text2=0)

References XrdSysError::Emsg().

Here is the call graph for this function:

◆ XrdVERSIONINFO()

XrdVERSIONINFO ( XrdHttpGetExtHandler ,
HttpTPC  )

References TPC::Pull, and XrdHttpGetExtHandler().

Here is the call graph for this function: