StormLcgGtStorageMaker Class Reference

Inheritance diagram for StormLcgGtStorageMaker:

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

Private Member Functions
std::string	getTURL (const std::string &surl) const

Detailed Description

Definition at line 12 of file StormLCGStorageMaker.cc.

Member Function Documentation

check()

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

inlineoverridevirtual

Reimplemented from StorageMaker.

Definition at line 70 of file StormLCGStorageMaker.cc.

                                                      {
    struct stat st;
    if (stat(getTURL(path).c_str(), &st) != 0)
      return false;
 
    if (size)
      *size = st.st_size;
 
    return true;
  }

References getTURL(), castor_dqm_sourceclient_file_cfg::path, findQualityFiles::size, and edm_modernize_messagelogger::stat.

getTURL()

std::string StormLcgGtStorageMaker::getTURL ( const std::string &  surl ) const

inlineprivate

Definition at line 14 of file StormLCGStorageMaker.cc.

                                                 {
    // PrepareToGet timeout
    std::string timeout("300");
    if (char *p = std::getenv("CMS_STORM_LCG_GT_TIMEOUT"))
      timeout = p;
 
    /* Build the command line:
    -b => no BDII contacted
    -T srmv2 => necessary with -b 
    -t timeout */
    std::string comm("lcg-gt -b -T srmv2 -t " + timeout + " srm:" + surl + " file 2>&1");
    LogDebug("StormLCGStorageMaker") << "command: " << comm << std::endl;
 
    FILE *pipe = popen(comm.c_str(), "r");
    if (!pipe)
      throw cms::Exception("StormLCGStorageMaker") << "failed to execute lcg-gt command: " << comm;
 
    // Get output
    int ch;
    std::string output;
    while ((ch = getc(pipe)) != EOF)
      output.push_back(ch);
    pclose(pipe);
 
    LogDebug("StormLCGStorageMaker") << "output: " << output << std::endl;
 
    // Extract TURL if possible.
    size_t start = output.find("file:", 0);
    if (start == std::string::npos)
      throw cms::Exception("StormLCGStorageMaker") << "no turl found in command '" << comm << "' output:\n" << output;
 
    start += 5;
    std::string turl(output, start, output.find_first_of('\n', start) - start);
    LogDebug("StormLCGStorageMaker") << "file to open: " << turl << std::endl;
    return turl;
  }

References Exception, LogDebug, convertSQLitetoXML_cfg::output, AlCaHLTBitMon_ParallelJobs::p, command_line::start, AlCaHLTBitMon_QueryRunRegistry::string, and mps_check::timeout.

Referenced by check(), and open().

open()

std::unique_ptr<Storage> StormLcgGtStorageMaker::open ( const std::string &  proto, const std::string &  surl, int  mode, const AuxSettings &    ) const

inlineoverridevirtual

Implements StorageMaker.

Definition at line 52 of file StormLCGStorageMaker.cc.

                                                                    {
    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;
 
    std::string path = getTURL(surl);
    auto file = std::make_unique<File>(path, mode);
    return f->wrapNonLocalFile(std::move(file), proto, path, mode);
  }

References StorageFactory::CACHE_HINT_STORAGE, f, geometryDiff::file, StorageFactory::get(), getTURL(), ALCARECOPromptCalibProdSiPixelAli0T_cff::mode, eostools::move(), IOFlags::OpenUnbuffered, castor_dqm_sourceclient_file_cfg::path, StorageFactory::READ_HINT_UNBUFFERED, and AlCaHLTBitMon_QueryRunRegistry::string.