XrdClFileSystem.hh

Go to the documentation of this file.

//------------------------------------------------------------------------------
// Copyright (c) 2011-2014 by European Organization for Nuclear Research (CERN)
// Author: Lukasz Janyst <ljanyst@cern.ch>
//------------------------------------------------------------------------------
// This file is part of the XRootD software suite.
//
// 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/>.
//
// In applying this licence, CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
//------------------------------------------------------------------------------
 
#ifndef __XRD_CL_FILE_SYSTEM_HH__
#define __XRD_CL_FILE_SYSTEM_HH__
 
#include "XrdCl/XrdClURL.hh"
#include "XrdCl/XrdClStatus.hh"
#include "XrdOuc/XrdOucEnum.hh"
#include "XrdOuc/XrdOucCompiler.hh"
#include "XrdCl/XrdClXRootDResponses.hh"
#include "XrdSys/XrdSysPthread.hh"
#include "XProtocol/XProtocol.hh"
#include <string>
#include <vector>
 
namespace XrdCl
{
  class PostMaster;
  class FileSystemPlugIn;
  class File;
  struct MessageSendParams;
 
  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct QueryCode
  {
    //--------------------------------------------------------------------------
    //--------------------------------------------------------------------------
    enum Code
    {
      Config         = kXR_Qconfig,    
      ChecksumCancel = kXR_Qckscan,    
      Checksum       = kXR_Qcksum,     
      Opaque         = kXR_Qopaque,    
      OpaqueFile     = kXR_Qopaquf,    
      OpaqueQ        = kXR_Qopaqug,    
      Prepare        = kXR_QPrep,      
      Space          = kXR_Qspace,     
      Stats          = kXR_QStats,     
      Visa           = kXR_Qvisa,      
      XAttr          = kXR_Qxattr,     
      FInfo          = kXR_QFinfo,     
      FSInfo         = kXR_QFSinfo     
    };
  };
 
  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct OpenFlags
  {
    //--------------------------------------------------------------------------
    //--------------------------------------------------------------------------
    enum Flags
    {
      None     = 0,                 
      Compress = kXR_compress,      
      Delete   = kXR_delete,        
      Force    = kXR_force,         
      MakePath = kXR_mkpath,        
      New      = kXR_new,           
      NoWait   = kXR_nowait,        
//      Append   = kXR_open_apnd,   //!< Open only for appending
      Read     = kXR_open_read,     
      Update   = kXR_open_updt,     
      Write    = kXR_open_wrto,     
      POSC     = kXR_posc,          
      Refresh  = kXR_refresh,       
      Replica  = kXR_replica,       
      SeqIO    = kXR_seqio,         
      PrefName = kXR_prefname,      
      IntentDirList = kXR_4dirlist, 
      Dup      = kXR_dup<<16,       
      Samefs   = kXR_samefs<<16     
    };
  };
  XRDOUC_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          
    };
  };
  XRDOUC_ENUM_OPERATORS( Access::Mode )
 
  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct MkDirFlags
  {
    enum Flags
    {
      None     = 0,  
      MakePath = 1   
    };
  };
  XRDOUC_ENUM_OPERATORS( MkDirFlags::Flags )
 
  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct DirListFlags
  {
    enum Flags
    {
      None      = 0,  
      Stat      = 1,  
      Locate    = 2,  
      Recursive = 4,  
      Merge     = 8,  
      Chunked   = 16, 
      Zip       = 32, 
      Cksm      = 64  
    };
  };
  XRDOUC_ENUM_OPERATORS( DirListFlags::Flags )
 
  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct PrepareFlags
  {
    enum Flags
    {
      None        = 0,              
      Colocate    = kXR_coloc,      
      Fresh       = kXR_fresh,      
      Stage       = kXR_stage,      
      WriteMode   = kXR_wmode,      
      Cancel      = kXR_cancel,     
      Evict       = kXR_evict << 8  
    };
  };
  XRDOUC_ENUM_OPERATORS( PrepareFlags::Flags )
 
  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  struct FileSystemImpl;
 
  //----------------------------------------------------------------------------
  //----------------------------------------------------------------------------
  class FileSystem
  {
    friend class AssignLBHandler;
    friend class ForkHandler;
 
    public:
      typedef std::vector<LocationInfo> LocationList; 
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      FileSystem( const URL &url, bool enablePlugIns = true );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      ~FileSystem();
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Locate( const std::string &path,
                           OpenFlags::Flags   flags,
                           ResponseHandler   *handler,
                           time_t             timeout = 0 )
                           XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Locate( const std::string  &path,
                           OpenFlags::Flags    flags,
                           LocationInfo      *&response,
                           time_t              timeout  = 0 )
                           XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DeepLocate( const std::string &path,
                               OpenFlags::Flags   flags,
                               ResponseHandler   *handler,
                               time_t             timeout = 0 )
                               XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DeepLocate( const std::string  &path,
                               OpenFlags::Flags   flags,
                               LocationInfo      *&response,
                               time_t              timeout  = 0 )
                               XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Mv( const std::string &source,
                       const std::string &dest,
                       ResponseHandler   *handler,
                       time_t             timeout = 0 )
                       XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Mv( const std::string &source,
                       const std::string &dest,
                       time_t             timeout = 0 )
                       XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Query( QueryCode::Code  queryCode,
                          const Buffer    &arg,
                          ResponseHandler *handler,
                          time_t           timeout = 0 )
                          XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Query( QueryCode::Code   queryCode,
                          const Buffer     &arg,
                          Buffer          *&response,
                          time_t            timeout = 0 )
                          XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Truncate( const std::string &path,
                             uint64_t           size,
                             ResponseHandler   *handler,
                             time_t             timeout = 0 )
                             XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Truncate( const std::string &path,
                             uint64_t           size,
                             time_t             timeout = 0 )
                             XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Rm( const std::string &path,
                       ResponseHandler   *handler,
                       time_t             timeout = 0 )
                       XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Rm( const std::string &path,
                       time_t             timeout = 0 )
                       XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus MkDir( const std::string &path,
                          MkDirFlags::Flags  flags,
                          Access::Mode       mode,
                          ResponseHandler   *handler,
                          time_t             timeout = 0 )
                          XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus MkDir( const std::string &path,
                          MkDirFlags::Flags  flags,
                          Access::Mode       mode,
                          time_t             timeout = 0 )
                          XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus RmDir( const std::string &path,
                          ResponseHandler   *handler,
                          time_t             timeout = 0 )
                          XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus RmDir( const std::string &path,
                          time_t             timeout = 0 )
                          XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus ChMod( const std::string &path,
                          Access::Mode       mode,
                          ResponseHandler   *handler,
                          time_t             timeout = 0 )
                          XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus ChMod( const std::string &path,
                          Access::Mode       mode,
                          time_t             timeout = 0 )
                          XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Ping( ResponseHandler *handler,
                         time_t           timeout = 0 )
                         XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Ping( time_t timeout = 0 ) XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Stat( const std::string &path,
                         ResponseHandler   *handler,
                         time_t             timeout = 0 )
                         XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Stat( const std::string  &path,
                         StatInfo          *&response,
                         time_t              timeout = 0 )
                         XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus StatVFS( const std::string &path,
                            ResponseHandler   *handler,
                            time_t             timeout = 0 )
                            XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus StatVFS( const std::string  &path,
                            StatInfoVFS       *&response,
                            time_t              timeout = 0 )
                            XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Protocol( ResponseHandler *handler,
                             time_t           timeout = 0 )
                             XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Protocol( ProtocolInfo *&response,
                             time_t         timeout = 0 )
                             XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DirList( const std::string   &path,
                            DirListFlags::Flags  flags,
                            ResponseHandler     *handler,
                            time_t               timeout = 0 )
                            XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DirList( const std::string    &path,
                            DirListFlags::Flags   flags,
                            DirectoryList       *&response,
                            time_t                timeout = 0 )
                            XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus SendCache( const std::string &info,
                              ResponseHandler   *handler,
                              time_t             timeout = 0 )
                              XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus SendCache( const std::string  &info,
                              Buffer            *&response,
                              time_t              timeout = 0 )
                              XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus SendInfo( const std::string &info,
                             ResponseHandler   *handler,
                             time_t             timeout = 0 )
                             XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus SendInfo( const std::string  &info,
                             Buffer            *&response,
                             time_t              timeout = 0 )
                             XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Prepare( const std::vector<std::string> &fileList,
                            PrepareFlags::Flags             flags,
                            uint8_t                         priority,
                            ResponseHandler                *handler,
                            time_t                          timeout = 0 )
                            XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus Prepare( const std::vector<std::string>  &fileList,
                            PrepareFlags::Flags              flags,
                            uint8_t                          priority,
                            Buffer                         *&response,
                            time_t                           timeout = 0 )
                            XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus SetXAttr( const std::string           &path,
                             const std::vector<xattr_t>  &attrs,
                             ResponseHandler             *handler,
                             time_t                       timeout = 0 );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus SetXAttr( const std::string           &path,
                             const std::vector<xattr_t>  &attrs,
                             std::vector<XAttrStatus>    &result,
                             time_t                       timeout = 0 );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus GetXAttr( const std::string               &path,
                             const std::vector<std::string>  &attrs,
                             ResponseHandler                 *handler,
                             time_t                           timeout = 0 );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus GetXAttr( const std::string               &path,
                             const std::vector<std::string>  &attrs,
                             std::vector<XAttr>              &result,
                             time_t                           timeout = 0 );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DelXAttr( const std::string               &path,
                             const std::vector<std::string>  &attrs,
                             ResponseHandler                 *handler,
                             time_t                           timeout = 0 );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus DelXAttr( const std::string               &path,
                             const std::vector<std::string>  &attrs,
                             std::vector<XAttrStatus>        &result,
                             time_t                           timeout = 0 );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus ListXAttr( const std::string         &path,
                              ResponseHandler           *handler,
                              time_t                     timeout = 0 );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus ListXAttr( const std::string    &path,
                              std::vector<XAttr>   &result,
                              time_t                timeout = 0 );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      bool SetProperty( const std::string &name, const std::string &value );
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      bool GetProperty( const std::string &name, std::string &value ) const;
 
    private:
      FileSystem(const FileSystem &other);
      FileSystem &operator = (const FileSystem &other);
 
      //------------------------------------------------------------------------
      // Lock the internal lock
      //------------------------------------------------------------------------
      void Lock();
 
      //------------------------------------------------------------------------
      // Unlock the internal lock
      //------------------------------------------------------------------------
      void UnLock();
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      XRootDStatus SendSet( const char        *prefix,
                            const std::string &info,
                            ResponseHandler   *handler,
                            time_t             timeout = 0 )
                            XRD_WARN_UNUSED_RESULT;
 
      //------------------------------------------------------------------------
      //------------------------------------------------------------------------
      template<typename T>
      Status XAttrOperationImpl( kXR_char              subcode,
                                 kXR_char              options,
                                 const std::string    &path,
                                 const std::vector<T> &attrs,
                                 ResponseHandler      *handler,
                                 time_t                timeout = 0 );
 
      FileSystemImpl   *pImpl;   //< pointer to implementation (TODO: once we can break ABI we can use a shared pointer here, and then we can drop the FileSystemData in source file)
      FileSystemPlugIn *pPlugIn; //< file system plug-in
  };
}
 
#endif // __XRD_CL_FILE_SYSTEM_HH__