XrdClFileSystem.hh

Go to the documentation of this file.

//------------------------------------------------------------------------------
// Copyright (c) 2011-2012 by European Organization for Nuclear Research (CERN)
// Author: Lukasz Janyst <ljanyst@cern.ch>
//------------------------------------------------------------------------------
// XRootD is free software: you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// XRootD is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with XRootD.  If not, see <http://www.gnu.org/licenses/>.
//------------------------------------------------------------------------------

#ifndef __XRD_CL_FILE_SYSTEM_HH__
#define __XRD_CL_FILE_SYSTEM_HH__

#include "XrdCl/XrdClURL.hh"
#include "XrdCl/XrdClStatus.hh"
#include "XrdCl/XrdClEnum.hh"
#include "XrdCl/XrdClXRootDResponses.hh"
#include "XrdSys/XrdSysPthread.hh"
#include "XProtocol/XProtocol.hh"
#include <string>
#include <vector>

namespace XrdCl
{
  class PostMaster;
  class Message;
  struct MessageSendParams;

  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct QueryCode
  {
    //--------------------------------------------------------------------------
    //--------------------------------------------------------------------------
    enum Code
    {
      Config         = kXR_Qconfig,    
      ChecksumCancel = kXR_Qckscan,    
      Checksum       = kXR_Qcksum,     
      Opaque         = kXR_Qopaque,    
      OpaqueFile     = kXR_Qopaquf,    
      Prepare        = kXR_QPrep,      
      Space          = kXR_Qspace,     
      Stats          = kXR_QStats,     
      Visa           = kXR_Qvisa,      
      XAttr          = kXR_Qxattr      
    };
  };

  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct OpenFlags
  {
    //--------------------------------------------------------------------------
    //--------------------------------------------------------------------------
    enum Flags
    {
      None     = 0,              
      Delete   = kXR_delete,     

      Force    = kXR_force,      
      MakePath = kXR_mkpath,     

      New      = kXR_new,        

      NoWait   = kXR_nowait,     





      Append   = kXR_open_apnd,  
      Read     = kXR_open_read,  
      Update   = kXR_open_updt,  
      POSC     = kXR_posc,       

      Refresh  = kXR_refresh,    

      Replica  = kXR_replica,    

      SeqIO    = kXR_seqio       
    };
  };
  XRDCL_ENUM_OPERATORS( OpenFlags::Flags )

  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct Access
  {
    //--------------------------------------------------------------------------
    //--------------------------------------------------------------------------
    enum Mode
    {
      None = 0,
      UR   = kXR_ur,         
      UW   = kXR_uw,         
      UX   = kXR_ux,         
      GR   = kXR_gr,         
      GW   = kXR_gw,         
      GX   = kXR_gx,         
      OR   = kXR_or,         
      OW   = kXR_ow,         
      OX   = kXR_ox          
    };
  };
  XRDCL_ENUM_OPERATORS( Access::Mode )

  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct MkDirFlags
  {
    enum Flags
    {
      None     = 0,  
      MakePath = 1   
    };
  };
  XRDCL_ENUM_OPERATORS( MkDirFlags::Flags )

  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct DirListFlags
  {
    enum Flags
    {
      None   = 0,  
      Stat   = 1,  
      Locate = 2  

    };
  };
  XRDCL_ENUM_OPERATORS( DirListFlags::Flags )

  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct PrepareFlags
  {
    enum Flags
    {
      Colocate    = kXR_coloc,    
      Fresh       = kXR_fresh,    

      Stage       = kXR_stage,    

      WriteMode   = kXR_wmode     

    };
  };
  XRDCL_ENUM_OPERATORS( PrepareFlags::Flags )

  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  class FileSystem
  {
    friend class AssignLBHandler;
    friend class ForkHandler;

    public:
      typedef std::vector<LocationInfo> LocationList; 

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      FileSystem( const URL &url );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      ~FileSystem();

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Locate( const std::string &path,
                           OpenFlags::Flags   flags,
                           ResponseHandler   *handler,
                           uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Locate( const std::string  &path,
                           OpenFlags::Flags    flags,
                           LocationInfo      *&response,
                           uint16_t            timeout  = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DeepLocate( const std::string &path,
                               OpenFlags::Flags   flags,
                               ResponseHandler   *handler,
                               uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DeepLocate( const std::string  &path,
                               OpenFlags::Flags   flags,
                               LocationInfo      *&response,
                               uint16_t            timeout  = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Mv( const std::string &source,
                       const std::string &dest,
                       ResponseHandler   *handler,
                       uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Mv( const std::string &source,
                       const std::string &dest,
                       uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Query( QueryCode::Code  queryCode,
                          const Buffer    &arg,
                          ResponseHandler *handler,
                          uint16_t         timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Query( QueryCode::Code   queryCode,
                          const Buffer     &arg,
                          Buffer          *&response,
                          uint16_t          timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Truncate( const std::string &path,
                             uint64_t           size,
                             ResponseHandler   *handler,
                             uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Truncate( const std::string &path,
                             uint64_t           size,
                             uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Rm( const std::string &path,
                       ResponseHandler   *handler,
                       uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Rm( const std::string &path,
                       uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus MkDir( const std::string &path,
                          MkDirFlags::Flags  flags,
                          Access::Mode       mode,
                          ResponseHandler   *handler,
                          uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus MkDir( const std::string &path,
                          MkDirFlags::Flags  flags,
                          Access::Mode       mode,
                          uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus RmDir( const std::string &path,
                          ResponseHandler   *handler,
                          uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus RmDir( const std::string &path,
                          uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus ChMod( const std::string &path,
                          Access::Mode       mode,
                          ResponseHandler   *handler,
                          uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus ChMod( const std::string &path,
                          Access::Mode       mode,
                          uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Ping( ResponseHandler *handler,
                         uint16_t         timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Ping( uint16_t timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Stat( const std::string &path,
                         ResponseHandler   *handler,
                         uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Stat( const std::string  &path,
                         StatInfo          *&response,
                         uint16_t            timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus StatVFS( const std::string &path,
                            ResponseHandler   *handler,
                            uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus StatVFS( const std::string  &path,
                            StatInfoVFS       *&response,
                            uint16_t            timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Protocol( ResponseHandler *handler,
                             uint16_t         timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Protocol( ProtocolInfo *&response,
                             uint16_t       timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DirList( const std::string &path,
                            ResponseHandler   *handler,
                            uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DirList( const std::string    &path,
                            DirListFlags::Flags   flags,
                            DirectoryList       *&response,
                            uint16_t              timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus SendInfo( const std::string &info,
                             ResponseHandler   *handler,
                             uint16_t           timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus SendInfo( const std::string  &info,
                             Buffer            *&response,
                             uint16_t            timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Prepare( const std::vector<std::string> &fileList,
                            PrepareFlags::Flags             flags,
                            uint8_t                         priority,
                            ResponseHandler                *handler,
                            uint16_t                        timeout = 0 );

      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Prepare( const std::vector<std::string>  &fileList,
                            PrepareFlags::Flags              flags,
                            uint8_t                          priority,
                            Buffer                         *&response,
                            uint16_t                         timeout = 0 );

    private:

      //------------------------------------------------------------------------
      // Send a message in a locked environment
      //------------------------------------------------------------------------
      Status Send( Message                 *msg,
                   ResponseHandler         *handler,
                   const MessageSendParams &params );

      //------------------------------------------------------------------------
      // Assign a loadbalancer if it has not already been assigned
      //------------------------------------------------------------------------
      void AssignLoadBalancer( const URL &url );

      //------------------------------------------------------------------------
      // Lock the internal lock
      //------------------------------------------------------------------------
      void Lock()
      {
        pMutex.Lock();
      }

      //------------------------------------------------------------------------
      // Unlock the internal lock
      //------------------------------------------------------------------------
      void UnLock()
      {
        pMutex.UnLock();
      }

      XrdSysMutex  pMutex;
      bool         pLoadBalancerLookupDone;
      URL         *pUrl;
  };
}

#endif // __XRD_CL_FILE_SYSTEM_HH__