XRootD
TPC::TPCHandler Class Reference

#include <XrdTpcTPC.hh>

+ Inheritance diagram for TPC::TPCHandler:
+ Collaboration diagram for TPC::TPCHandler:

Public Member Functions

 TPCHandler (XrdSysError *log, const char *config, XrdOucEnv *myEnv)
 
virtual ~TPCHandler ()
 
virtual int Init (const char *cfgfile)
 Initializes the external request handler. More...
 
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. More...
 
virtual int ProcessReq (XrdHttpExtReq &req)
 
- Public Member Functions inherited from XrdHttpExtHandler
 XrdHttpExtHandler ()
 Constructor. More...
 
virtual ~XrdHttpExtHandler ()
 Destructor. More...
 

Static Public Attributes

static constexpr std::string_view OSS_TASK_OPAQUE = "oss.task=httptpc"
 

Detailed Description

Definition at line 46 of file XrdTpcTPC.hh.

Constructor & Destructor Documentation

◆ TPCHandler()

TPCHandler::TPCHandler ( XrdSysError log,
const char *  config,
XrdOucEnv myEnv 
)

Definition at line 289 of file XrdTpcTPC.cc.

289  :
290  m_desthttps(false),
291  m_fixed_route(false),
292  m_timeout(60),
293  m_first_timeout(120),
294  m_log(log->logger(), "TPC_"),
295  m_sfs(NULL)
296 {
297  if (!Configure(config, myEnv)) {
298  throw std::runtime_error("Failed to configure the HTTP third-party-copy handler.");
299  }
300 
301 // Extract out the TPC monitoring object (we share it with xrootd).
302 //
303  XrdXrootdGStream *gs = (XrdXrootdGStream*)myEnv->GetPtr("Tpc.gStream*");
304  if (gs)
305  TPCLogRecord::tpcMonitor = new XrdXrootdTpcMon("http",log->logger(),*gs);
306 }
void * GetPtr(const char *varname)
Definition: XrdOucEnv.cc:281
XrdSysLogger * logger(XrdSysLogger *lp=0)
Definition: XrdSysError.hh:141

References XrdOucEnv::GetPtr(), and XrdSysError::logger().

+ Here is the call graph for this function:

◆ ~TPCHandler()

TPCHandler::~TPCHandler ( )
virtual

Definition at line 281 of file XrdTpcTPC.cc.

281  {
282  m_sfs = NULL;
283 }

Member Function Documentation

◆ Init()

virtual int TPC::TPCHandler::Init ( const char *  cfgfile)
inlinevirtual

Initializes the external request handler.

Implements XrdHttpExtHandler.

Definition at line 54 of file XrdTpcTPC.hh.

54 {return 0;}

◆ MatchesPath()

bool 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.

Definition at line 234 of file XrdTpcTPC.cc.

234  {
235  return !strcmp(verb, "COPY") || !strcmp(verb, "OPTIONS");
236 }

◆ ProcessReq()

int TPCHandler::ProcessReq ( XrdHttpExtReq )
virtual

Process an HTTP request and send the response using the calling XrdHttpProtocol instance directly Returns 0 if ok, non0 if errors

Implements XrdHttpExtHandler.

Definition at line 253 of file XrdTpcTPC.cc.

253  {
254  if (req.verb == "OPTIONS") {
255  return ProcessOptionsReq(req);
256  }
257  auto header = XrdOucTUtils::caseInsensitiveFind(req.headers,"credential");
258  if (header != req.headers.end()) {
259  if (header->second != "none") {
260  m_log.Emsg("ProcessReq", "COPY requested an unsupported credential type: ", header->second.c_str());
261  return req.SendSimpleResp(400, NULL, NULL, "COPY requestd an unsupported Credential type", 0);
262  }
263  }
264  header = XrdOucTUtils::caseInsensitiveFind(req.headers,"source");
265  if (header != req.headers.end()) {
266  std::string src = PrepareURL(header->second);
267  return ProcessPullReq(src, req);
268  }
269  header = XrdOucTUtils::caseInsensitiveFind(req.headers,"destination");
270  if (header != req.headers.end()) {
271  return ProcessPushReq(header->second, req);
272  }
273  m_log.Emsg("ProcessReq", "COPY verb requested but no source or destination specified.");
274  return req.SendSimpleResp(400, NULL, NULL, "No Source or Destination specified", 0);
275 }
static std::string PrepareURL(const std::string &input)
Definition: XrdTpcTPC.cc:242
static std::map< std::string, T >::const_iterator caseInsensitiveFind(const std::map< std::string, T > &m, const std::string &lowerCaseSearchKey)
Definition: XrdOucTUtils.hh:79
int Emsg(const char *esfx, int ecode, const char *text1, const char *text2=0)
Definition: XrdSysError.cc:95

References XrdOucTUtils::caseInsensitiveFind(), XrdSysError::Emsg(), XrdHttpExtReq::headers, PrepareURL(), XrdHttpExtReq::SendSimpleResp(), and XrdHttpExtReq::verb.

+ Here is the call graph for this function:

Member Data Documentation

◆ OSS_TASK_OPAQUE

constexpr std::string_view TPC::TPCHandler::OSS_TASK_OPAQUE = "oss.task=httptpc"
staticconstexpr

Definition at line 55 of file XrdTpcTPC.hh.

Referenced by XrdTpcUtils::prepareOpenURL().


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