36 virtual int Init(
const char *cfgfile) {
return 0;}
69 const std::string &authz);
81 off_t bytes_transferred);
91 size_t streams, std::vector<TPC::State*> streams_handles,
95 const char *log_prefix);
102 std::string &path2,
bool &path2_alt);
108 const std::string &event,
const std::string &message=
"");
122 #ifdef USE_PIPELINING
Utility functions for XrdHTTP.
void CURL
Definition: XrdTpcState.hh:12
void CURL
Definition: XrdTpcTPC.hh:14
Definition: XrdTpcState.hh:19
Definition: XrdTpcTPC.hh:28
int RunCurlBasic(CURL *curl, XrdHttpExtReq &req, TPC::State &state, const char *log_prefix)
int ProcessOptionsReq(XrdHttpExtReq &req)
std::string m_cadir
Definition: XrdTpcTPC.hh:113
TPCHandler(XrdSysError *log, const char *config, XrdOucEnv *myEnv)
bool ConfigureLogger(XrdOucStream &Config)
void logTransferEvent(LogMask lvl, const TPCLogRecord &record, const std::string &event, const std::string &message="")
static XrdSysMutex m_monid_mutex
Definition: XrdTpcTPC.hh:114
int ProcessPullReq(const std::string &resource, XrdHttpExtReq &req)
virtual int ProcessReq(XrdHttpExtReq &req)
static uint64_t m_monid
Definition: XrdTpcTPC.hh:115
static const int m_pipelining_multiplier
Definition: XrdTpcTPC.hh:125
bool m_desthttps
Definition: XrdTpcTPC.hh:112
static std::string GetAuthz(XrdHttpExtReq &req)
static int m_marker_period
Definition: XrdTpcTPC.hh:110
int OpenWaitStall(XrdSfsFile &fh, const std::string &resource, int mode, int openMode, const XrdSecEntity &sec, const std::string &authz)
virtual bool MatchesPath(const char *verb, const char *path)
Tells if the incoming path is recognized as one of the paths that have to be processed.
virtual int Init(const char *cfgfile)
Initializes the external request handler.
Definition: XrdTpcTPC.hh:36
int ProcessPushReq(const std::string &resource, XrdHttpExtReq &req)
XrdSysError m_log
Definition: XrdTpcTPC.hh:116
int RedirectTransfer(const std::string &redirect_resource, XrdHttpExtReq &req, XrdOucErrInfo &error, TPCLogRecord &)
static size_t m_block_size
Definition: XrdTpcTPC.hh:111
bool ConfigureFSLib(XrdOucStream &Config, std::string &path1, bool &path1_alt, std::string &path2, bool &path2_alt)
XrdSfsFileSystem * m_sfs
Definition: XrdTpcTPC.hh:117
bool Configure(const char *configfn, XrdOucEnv *myEnv)
Definition: XrdHttpExtHandler.hh:79
Definition: XrdHttpExtHandler.hh:45
Definition: XrdOucEnv.hh:42
Definition: XrdOucErrInfo.hh:99
Definition: XrdOucStream.hh:47
Definition: XrdSecEntity.hh:64
Definition: XrdSfsInterface.hh:816
Definition: XrdSfsInterface.hh:362
Definition: XrdSysError.hh:90
Definition: XrdSysPthread.hh:166
Definition: XrdTpcState.hh:16
LogMask
Definition: XrdTpcTPC.hh:20
@ All
Definition: XrdTpcTPC.hh:25
@ Info
Definition: XrdTpcTPC.hh:22
@ Error
Definition: XrdTpcTPC.hh:24
@ Debug
Definition: XrdTpcTPC.hh:21
@ Warning
Definition: XrdTpcTPC.hh:23
Definition: XrdTpcTPC.hh:40
int tpc_status
Definition: XrdTpcTPC.hh:54
std::string remote
Definition: XrdTpcTPC.hh:51
TPCLogRecord()
Definition: XrdTpcTPC.hh:42
int status
Definition: XrdTpcTPC.hh:53
off_t bytes_transferred
Definition: XrdTpcTPC.hh:56
std::string name
Definition: XrdTpcTPC.hh:52
unsigned streams
Definition: XrdTpcTPC.hh:55
std::string local
Definition: XrdTpcTPC.hh:50
std::string log_prefix
Definition: XrdTpcTPC.hh:49