XrdClMetalinkRedirector.hh

Go to the documentation of this file.

/*
 * XrdClMetalinkRedirector.hh
 *
 *  Created on: May 2, 2016
 *      Author: simonm
 */
 
#ifndef SRC_XRDCL_XRDCLMETALINKREDIRECTOR_HH_
#define SRC_XRDCL_XRDCLMETALINKREDIRECTOR_HH_
 
#include "XrdCl/XrdClMessageUtils.hh"
#include "XrdCl/XrdClRedirectorRegistry.hh"
 
#include <string>
#include <list>
#include <map>
 
 
class XrdOucFileInfo;
 
namespace XrdCl
{
 
class File;
class Message;
 
//----------------------------------------------------------------------------
//----------------------------------------------------------------------------
class MetalinkRedirector : public VirtualRedirector
{
    friend class MetalinkOpenHandler;
    friend class MetalinkReadHandler;
 
  public:
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    MetalinkRedirector( const std::string &url );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual ~MetalinkRedirector();
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    XRootDStatus Load( ResponseHandler *userHandler );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    XRootDStatus HandleRequest( const Message *msg, MsgHandler *handler );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    std::string GetTargetName() const
    {
      return pTarget;
    }
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    std::string GetCheckSum( const std::string &type ) const
    {
      std::string t = type != "adler32" ? type : "a32";
      CksumMap::const_iterator it = pChecksums.find( t );
      if( it == pChecksums.end() ) return std::string();
      return type + ":" + it->second;
    }
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    std::vector<std::string> GetSupportedCheckSums() const
    {
      std::vector<std::string> ret;
      CksumMap::const_iterator itr = pChecksums.begin();
      for( ; itr != pChecksums.end(); ++itr )
      {
        if( itr->first == "a32" ) ret.push_back( "adler32" );
        else ret.push_back( itr->first );
      }
      return ret;
    }
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    long long GetSize() const
    {
      return pFileSize;
    }
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    const std::vector<std::string>& GetReplicas()
    {
      return pReplicas;
    }
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual int Count( Message &req ) const;
 
  private:
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    XRootDStatus HandleRequestImpl( const Message *msg, MsgHandler *handler );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    XRootDStatus Parse( const std::string &metalink );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    void FinalizeInitialization( const XRootDStatus &status = XRootDStatus() );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    std::shared_ptr<Message> GetResponse( const Message *msg ) const;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    std::shared_ptr<Message> GetErrorMsg( const Message *msg, const std::string &errMsg, XErrorCode code ) const;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    void InitCksum( XrdOucFileInfo **fileInfos );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    void InitReplicas( XrdOucFileInfo **fileInfos );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    XRootDStatus GetReplica( const Message &msg, std::string &replica ) const;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    XRootDStatus GetCgiInfo( const Message &msg, const std::string &key, std::string &out ) const;
 
    typedef std::list< std::pair<const Message*, MsgHandler*> > RedirectList;
    typedef std::map<std::string, std::string>                  CksumMap;
    typedef std::vector<std::string>                            ReplicaList;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    ReplicaList::const_iterator GetReplica( const Message &msg ) const;
 
    RedirectList     pPendingRedirects;
    std::string      pUrl;
    File            *pFile;
    CksumMap         pChecksums;
    ReplicaList      pReplicas;
    bool             pReady;
    XRootDStatus     pStatus;
    std::string      pTarget;
    long long        pFileSize;
 
    XrdSysMutex      pMutex;
 
    static const std::string LocalFile;
 
};
 
} /* namespace XrdCl */
 
#endif /* SRC_XRDCL_XRDCLMETALINKREDIRECTOR_HH_ */