XrdClRedirectorRegistry.hh

Go to the documentation of this file.

/*
 * XrdClRedirectorRegister.hh
 *
 *  Created on: May 23, 2016
 *      Author: simonm
 */
 
#ifndef SRC_XRDCL_XRDCLREDIRECTORREGISTRY_HH_
#define SRC_XRDCL_XRDCLREDIRECTORREGISTRY_HH_
 
#include "XrdCl/XrdClXRootDResponses.hh"
#include "XrdCl/XrdClURL.hh"
#include "XrdCl/XrdClJobManager.hh"
#include "XrdSys/XrdSysPthread.hh"
 
#include <string>
#include <vector>
#include <map>
 
namespace XrdCl
{
 
class Message;
class IncomingMsgHandler;
class OutgoingMsgHandler;
 
//--------------------------------------------------------------------------------
//--------------------------------------------------------------------------------
class RedirectJob: public Job
{
  public:
    //------------------------------------------------------------------------
    //------------------------------------------------------------------------
    RedirectJob( IncomingMsgHandler *handler ) : pHandler( handler )
    {
    }
 
    //------------------------------------------------------------------------
    //------------------------------------------------------------------------
    virtual ~RedirectJob()
    {
    }
 
    //------------------------------------------------------------------------
    //------------------------------------------------------------------------
    virtual void Run( void *arg );
 
  private:
    IncomingMsgHandler *pHandler;
};
 
//--------------------------------------------------------------------------------
//--------------------------------------------------------------------------------
class VirtualRedirector
{
  public:
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual ~VirtualRedirector(){}
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual XRootDStatus HandleRequest( const Message *msg,
                                        IncomingMsgHandler *handler ) = 0;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual XRootDStatus Load( ResponseHandler *userHandler ) = 0;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual std::string GetTargetName() const = 0;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual std::string GetCheckSum( const std::string &type ) const = 0;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual std::vector<std::string> GetSupportedCheckSums() const = 0;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual long long GetSize() const = 0;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual const std::vector<std::string>& GetReplicas() = 0;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    virtual int Count( Message *req ) const = 0;
};
 
//--------------------------------------------------------------------------------
//--------------------------------------------------------------------------------
class RedirectorRegistry
{
 
  public:
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    static RedirectorRegistry& Instance();
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    ~RedirectorRegistry();
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    XRootDStatus Register( const URL &url );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    XRootDStatus RegisterAndWait( const URL &url );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    VirtualRedirector* Get( const URL &url ) const;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    void Release( const URL &url );
 
  private:
 
    typedef std::map< std::string, std::pair<VirtualRedirector*, size_t> > RedirectorMap;
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    XRootDStatus RegisterImpl( const URL &url, ResponseHandler *handler );
 
    //----------------------------------------------------------------------------
    //----------------------------------------------------------------------------
    static URL ConvertLocalfile( const URL &url );
 
    //----------------------------------------------------------------------------
    // Constructor (private!).
    //----------------------------------------------------------------------------
    RedirectorRegistry() {}
 
    //----------------------------------------------------------------------------
    // Copy constructor (private!).
    //----------------------------------------------------------------------------
    RedirectorRegistry( const RedirectorRegistry & );
 
    //----------------------------------------------------------------------------
    // Assignment operator (private!).
    //----------------------------------------------------------------------------
    RedirectorRegistry& operator=( const RedirectorRegistry & );
 
    RedirectorMap pRegistry;
 
    mutable XrdSysMutex pMutex;
};
 
} /* namespace XrdCl */
 
#endif /* SRC_XRDCL_XRDCLREDIRECTORREGISTRY_HH_ */