DCacheStorageMaker Class Reference

Inheritance diagram for DCacheStorageMaker:

Public Member Functions
bool	check (const std::string &proto, const std::string &path, const AuxSettings &aux, IOOffset *size=nullptr) const override
std::unique_ptr< Storage >	open (const std::string &proto, const std::string &path, int mode, AuxSettings const &aux) const override
void	stagein (const std::string &proto, const std::string &path, const AuxSettings &aux) const override
Public Member Functions inherited from StorageMaker
	StorageMaker ()=default
virtual	~StorageMaker ()=default

Private Member Functions
void	setTimeout (unsigned int timeout) const

Static Private Member Functions
static std::string	normalise (const std::string &proto, const std::string &path)

Detailed Description

Definition at line 9 of file DCacheStorageMaker.cc.

Member Function Documentation

check()

bool DCacheStorageMaker::check ( const std::string &  proto, const std::string &  path, const AuxSettings &  aux, IOOffset *  size = nullptr  ) const

inlineoverridevirtual

Reimplemented from StorageMaker.

Definition at line 59 of file DCacheStorageMaker.cc.

                                                      {
    setTimeout(aux.timeout);
    std::string testpath(normalise(proto, path));
    if (dc_access(testpath.c_str(), R_OK) != 0)
      return false;
 
    if (size) {
      struct stat64 buf;
      if (dc_stat64(testpath.c_str(), &buf) != 0)
        return false;
 
      *size = buf.st_size;
    }
 
    return true;
  }

References printConversionInfo::aux, visDQMUpload::buf, normalise(), castor_dqm_sourceclient_file_cfg::path, setTimeout(), findQualityFiles::size, and AlCaHLTBitMon_QueryRunRegistry::string.

normalise()

static std::string DCacheStorageMaker::normalise ( const std::string &  proto, const std::string &  path  )

inlinestaticprivate

Return appropriate path for use with dcap library. If the path is in the URL form ([gsi]dcap://host:port/path), return the full URL as it is. If the path is /pnfs form (dcap:/pnfs/path), return only the path part, unless the protocol is 'gsidcap', in which case return the whole thing.

Definition at line 14 of file DCacheStorageMaker.cc.

                                                                            {
    size_t p = path.find("/pnfs");
    if (p < 3)
      return (proto == "gsidcap") ? proto + ':' + path.substr(p) : path.substr(p);
 
    // remove multiple "/"
    p = path.find_first_not_of('/');
 
    // it's url, return the full thing
    return proto + "://" + path.substr(p);
  }

References AlCaHLTBitMon_ParallelJobs::p, and castor_dqm_sourceclient_file_cfg::path.

Referenced by check(), open(), and stagein().

open()

std::unique_ptr<Storage> DCacheStorageMaker::open ( const std::string &  proto, const std::string &  path, int  mode, AuxSettings const &  aux  ) const

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 29 of file DCacheStorageMaker.cc.

                                                                       {
    setTimeout(aux.timeout);
    const 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;
 
    auto file = std::make_unique<DCacheFile>(normalise(proto, path), mode);
    return f->wrapNonLocalFile(std::move(file), proto, std::string(), mode);
  }

References printConversionInfo::aux, StorageFactory::CACHE_HINT_STORAGE, f, FrontierConditions_GlobalTag_cff::file, StorageFactory::get(), ALCARECOPromptCalibProdSiPixelAli0T_cff::mode, eostools::move(), normalise(), IOFlags::OpenUnbuffered, castor_dqm_sourceclient_file_cfg::path, StorageFactory::READ_HINT_UNBUFFERED, setTimeout(), and AlCaHLTBitMon_QueryRunRegistry::string.

setTimeout()

void DCacheStorageMaker::setTimeout ( unsigned int  timeout ) const

inlineprivate

Definition at line 80 of file DCacheStorageMaker.cc.

                                              {
    if (timeout != 0)
      dc_setOpenTimeout(timeout);
  }

Referenced by check(), open(), and stagein().

stagein()

void DCacheStorageMaker::stagein ( const std::string &  proto, const std::string &  path, const AuxSettings &  aux  ) const

inlineoverridevirtual

Reimplemented from StorageMaker.

Definition at line 47 of file DCacheStorageMaker.cc.

                                                                                                     {
    setTimeout(aux.timeout);
    std::string npath = normalise(proto, path);
    if (dc_stage(npath.c_str(), 0, nullptr) != 0) {
      cms::Exception ex("FileStageInError");
      ex << "Cannot stage in file '" << npath << "', error was: " << dc_strerror(dc_errno) << " (dc_errno=" << dc_errno
         << ")";
      ex.addContext("Calling DCacheStorageMaker::stagein()");
      throw ex;
    }
  }

References cms::Exception::addContext(), printConversionInfo::aux, normalise(), castor_dqm_sourceclient_file_cfg::path, setTimeout(), and AlCaHLTBitMon_QueryRunRegistry::string.