#include <XrdTpcTPC.hh>
|
int | ProcessOptionsReq (XrdHttpExtReq &req) |
|
void | ConfigureCurlCA (CURL *curl) |
|
int | RedirectTransfer (CURL *curl, const std::string &redirect_resource, XrdHttpExtReq &req, XrdOucErrInfo &error, TPCLogRecord &) |
|
int | OpenWaitStall (XrdSfsFile &fh, const std::string &resource, int mode, int openMode, const XrdSecEntity &sec, const std::string &authz) |
|
int | RunCurlBasic (CURL *curl, XrdHttpExtReq &req, TPC::State &state, TPCLogRecord &rec) |
|
int | ProcessPushReq (const std::string &resource, XrdHttpExtReq &req) |
|
int | ProcessPullReq (const std::string &resource, XrdHttpExtReq &req) |
|
bool | ConfigureFSLib (XrdOucStream &Config, std::string &path1, bool &path1_alt, std::string &path2, bool &path2_alt) |
|
bool | Configure (const char *configfn, XrdOucEnv *myEnv) |
|
bool | ConfigureLogger (XrdOucStream &Config) |
|
void | logTransferEvent (LogMask lvl, const TPCLogRecord &record, const std::string &event, const std::string &message="") |
|
◆ TPCHandler()
◆ ~TPCHandler()
virtual TPC::TPCHandler::~TPCHandler |
( |
| ) |
|
|
virtual |
◆ closesocket_callback()
static int TPC::TPCHandler::closesocket_callback |
( |
void * |
clientp, |
|
|
curl_socket_t |
fd |
|
) |
| |
|
staticprivate |
◆ Configure()
bool TPC::TPCHandler::Configure |
( |
const char * |
configfn, |
|
|
XrdOucEnv * |
myEnv |
|
) |
| |
|
private |
◆ ConfigureCurlCA()
void TPC::TPCHandler::ConfigureCurlCA |
( |
CURL * |
curl | ) |
|
|
private |
◆ ConfigureFSLib()
bool TPC::TPCHandler::ConfigureFSLib |
( |
XrdOucStream & |
Config, |
|
|
std::string & |
path1, |
|
|
bool & |
path1_alt, |
|
|
std::string & |
path2, |
|
|
bool & |
path2_alt |
|
) |
| |
|
private |
◆ ConfigureLogger()
bool TPC::TPCHandler::ConfigureLogger |
( |
XrdOucStream & |
Config | ) |
|
|
private |
◆ GetAuthz()
static std::string TPC::TPCHandler::GetAuthz |
( |
XrdHttpExtReq & |
req | ) |
|
|
staticprivate |
◆ Init()
virtual int TPC::TPCHandler::Init |
( |
const char * |
cfgfile | ) |
|
|
inlinevirtual |
◆ logTransferEvent()
void TPC::TPCHandler::logTransferEvent |
( |
LogMask |
lvl, |
|
|
const TPCLogRecord & |
record, |
|
|
const std::string & |
event, |
|
|
const std::string & |
message = "" |
|
) |
| |
|
private |
◆ MatchesPath()
virtual bool TPC::TPCHandler::MatchesPath |
( |
const char * |
verb, |
|
|
const char * |
path |
|
) |
| |
|
virtual |
Tells if the incoming path is recognized as one of the paths that have to be processed.
Implements XrdHttpExtHandler.
◆ opensocket_callback()
static int TPC::TPCHandler::opensocket_callback |
( |
void * |
clientp, |
|
|
curlsocktype |
purpose, |
|
|
struct curl_sockaddr * |
address |
|
) |
| |
|
staticprivate |
◆ OpenWaitStall()
int TPC::TPCHandler::OpenWaitStall |
( |
XrdSfsFile & |
fh, |
|
|
const std::string & |
resource, |
|
|
int |
mode, |
|
|
int |
openMode, |
|
|
const XrdSecEntity & |
sec, |
|
|
const std::string & |
authz |
|
) |
| |
|
private |
◆ ProcessOptionsReq()
◆ ProcessPullReq()
int TPC::TPCHandler::ProcessPullReq |
( |
const std::string & |
resource, |
|
|
XrdHttpExtReq & |
req |
|
) |
| |
|
private |
◆ ProcessPushReq()
int TPC::TPCHandler::ProcessPushReq |
( |
const std::string & |
resource, |
|
|
XrdHttpExtReq & |
req |
|
) |
| |
|
private |
◆ ProcessReq()
◆ RedirectTransfer()
◆ RunCurlBasic()
◆ sockopt_setcloexec_callback()
static int TPC::TPCHandler::sockopt_setcloexec_callback |
( |
void * |
clientp, |
|
|
curl_socket_t |
curlfd, |
|
|
curlsocktype |
purpose |
|
) |
| |
|
staticprivate |
◆ m_block_size
size_t TPC::TPCHandler::m_block_size |
|
staticprivate |
◆ m_ca_file
◆ m_cadir
std::string TPC::TPCHandler::m_cadir |
|
private |
◆ m_cafile
std::string TPC::TPCHandler::m_cafile |
|
private |
◆ m_desthttps
bool TPC::TPCHandler::m_desthttps |
|
private |
◆ m_first_timeout
int TPC::TPCHandler::m_first_timeout |
|
private |
◆ m_log
◆ m_marker_period
int TPC::TPCHandler::m_marker_period |
|
staticprivate |
◆ m_monid
uint64_t TPC::TPCHandler::m_monid |
|
staticprivate |
◆ m_monid_mutex
◆ m_pipelining_multiplier
const int TPC::TPCHandler::m_pipelining_multiplier = 1 |
|
staticprivate |
◆ m_sfs
◆ m_small_block_size
size_t TPC::TPCHandler::m_small_block_size |
|
staticprivate |
◆ m_timeout
int TPC::TPCHandler::m_timeout |
|
private |
◆ usingEC
bool TPC::TPCHandler::usingEC |
|
private |
The documentation for this class was generated from the following file: