XrdStorageMaker Class Reference

Inheritance diagram for XrdStorageMaker:

Public Member Functions
virtual bool	check (const std::string &proto, const std::string &path, IOOffset *size=0) override
virtual Storage *	open (const std::string &proto, const std::string &path, int mode) override
virtual void	setDebugLevel (unsigned int level) override
virtual void	setTimeout (unsigned int timeout) override
virtual void	stagein (const std::string &proto, const std::string &path) override
Public Member Functions inherited from StorageMaker
	StorageMaker (void)
virtual	~StorageMaker (void)

Private Attributes
unsigned int	timeout_ = 0

Detailed Description

Definition at line 9 of file XrdStorageMaker.cc.

Member Function Documentation

virtual bool XrdStorageMaker::check ( const std::string &  proto, const std::string &  path, IOOffset *  size = 0  )

inlineoverridevirtual

Reimplemented from StorageMaker.

Definition at line 59 of file XrdStorageMaker.cc.

References flags, findQualityFiles::size, AlCaHLTBitMon_QueryRunRegistry::string, and relmon_authenticated_wget::url.

  {
    std::string fullpath(proto + ":" + path);
    XrdClientAdmin admin(fullpath.c_str());
    if (! admin.Connect())
      return false; // FIXME: Throw?

    long      id;
    long      flags;
    long      modtime;
    long long xrdsize;

    XrdOucString str(fullpath.c_str());
    XrdClientUrlSet url(str);

    if (! admin.Stat(url.GetFile().c_str(), id, xrdsize, flags, modtime))
      return false; // FIXME: Throw?

    *size = xrdsize;
    return true;
  }

virtual Storage* XrdStorageMaker::open ( const std::string &  proto, const std::string &  path, int  mode  )

inlineoverridevirtual

Open a storage object for the given URL (protocol + path), using the mode bits. No temporary files are downloaded.

Implements StorageMaker.

Definition at line 17 of file XrdStorageMaker.cc.

References StorageFactory::CACHE_HINT_STORAGE, StorageFactory::cacheHint(), f, mergeVDriftHistosByStation::file, StorageFactory::get(), IOFlags::OpenUnbuffered, StorageFactory::READ_HINT_UNBUFFERED, StorageFactory::readHint(), setTimeout(), AlCaHLTBitMon_QueryRunRegistry::string, timeout_, and StorageFactory::wrapNonLocalFile().

  {
    // The important part here is not the cache size (which will get
    // auto-adjusted), but the fact the cache is set to something non-zero.
    // If we don't do this before creating the XrdFile object, caching will be
    // completely disabled, resulting in poor performance.
    EnvPutInt(NAME_READCACHESIZE, 20*1024*1024);

    // XrdClient has various timeouts which vary from 3 minutes to 8 hours.
    // This enforces an even default (10 minutes) more appropriate for the
    // cmsRun case.
    if (timeout_ <= 0) {setTimeout(600);}

    StorageFactory *f = StorageFactory::get();
    StorageFactory::ReadHint readHint = f->readHint();
    StorageFactory::CacheHint cacheHint = f->cacheHint();

    if (readHint != StorageFactory::READ_HINT_UNBUFFERED
        || cacheHint == StorageFactory::CACHE_HINT_STORAGE)
      mode &= ~IOFlags::OpenUnbuffered;
    else
      mode |=  IOFlags::OpenUnbuffered;

    std::string fullpath(proto + ":" + path);
    Storage *file = new XrdFile (fullpath, mode);
    return f->wrapNonLocalFile(file, proto, std::string(), mode);
  }

virtual void XrdStorageMaker::setDebugLevel ( unsigned int  level )

inlineoverridevirtual

Reimplemented from StorageMaker.

Definition at line 83 of file XrdStorageMaker.cc.

  {
    EnvPutInt("DebugLevel", level);
  }

virtual void XrdStorageMaker::setTimeout ( unsigned int  timeout )

inlineoverridevirtual

Reimplemented from StorageMaker.

Definition at line 88 of file XrdStorageMaker.cc.

References timeout_.

Referenced by open().

  {
    timeout_ = timeout;
    if (timeout == 0) {return;}
    EnvPutInt("ConnectTimeout", timeout/3+1); // Default 120.  This should allow multiple connections to timeout before the open fails.
    EnvPutInt("RequestTimeout", timeout/3+1); // Default 300.  This should allow almost three requests to be performed before the transaction times out.
    EnvPutInt("TransactionTimeout", timeout); // Default 28800

    // Safety mechanism - if client is redirected more than 255 times in 600
    // seconds, then we abort the interaction.
    EnvPutInt("RedirCntTimeout", 600); // Default 36000

    // Enforce some CMS defaults.
    EnvPutInt("MaxRedirectcount", 32); // Default 16
    EnvPutInt("ReconnectWait", 5); // Default 5
  }

virtual void XrdStorageMaker::stagein ( const std::string &  proto, const std::string &  path  )

inlineoverridevirtual

Reimplemented from StorageMaker.

Definition at line 47 of file XrdStorageMaker.cc.

References AlCaHLTBitMon_QueryRunRegistry::string, and relmon_authenticated_wget::url.

  {
    std::string fullpath(proto + ":" + path);
    XrdClientAdmin admin(fullpath.c_str());
    if (admin.Connect())
    {
      XrdOucString str(fullpath.c_str());
      XrdClientUrlSet url(str);
      admin.Prepare(url.GetFile().c_str(), kXR_stage | kXR_noerrs, 0);
    }
  }

Member Data Documentation

unsigned int XrdStorageMaker::timeout_ = 0

private

Definition at line 12 of file XrdStorageMaker.cc.

Referenced by open(), and setTimeout().