---

DCacheStorageMaker Class Reference

Inheritance diagram for DCacheStorageMaker:

List of all members.

Public Member Functions
virtual bool	check (const std::string &proto, const std::string &path, IOOffset *size=0)
virtual Storage *	open (const std::string &proto, const std::string &path, int mode, const std::string &tmpdir)
	Open a storage object for the given URL (protocol + path), using the mode bits.
virtual void	stagein (const std::string &proto, const std::string &path)
Static Private Member Functions
static std::string	normalise (const std::string &proto, const std::string &path)
	Return appropriate path for use with dcap library.

---

Detailed Description

Definition at line 10 of file DCacheStorageMaker.cc.

---

Member Function Documentation

virtual bool DCacheStorageMaker::check	(	const std::string &	proto,
		const std::string &	path,
		IOOffset *	size = 0
	)			[inline, virtual]

Reimplemented from StorageMaker.

Definition at line 70 of file DCacheStorageMaker.cc.

References normalise(), and size.

  {
    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;
  }

static std::string DCacheStorageMaker::normalise	(	const std::string &	proto,
		const std::string &	path
	)			[inline, static, private]

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

References p.

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

  {
    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);
  }

virtual Storage* DCacheStorageMaker::open	(	const std::string &	proto,
		const std::string &	path,
		int	mode,
		const std::string &	tmpdir
	)			[inline, virtual]

Open a storage object for the given URL (protocol + path), using the mode bits.

No temporary files are downloaded.

Implements StorageMaker.

Definition at line 32 of file DCacheStorageMaker.cc.

References StorageFactory::accounting(), StorageFactory::CACHE_HINT_AUTO_DETECT, StorageFactory::CACHE_HINT_LAZY_DOWNLOAD, StorageFactory::CACHE_HINT_STORAGE, StorageFactory::cacheHint(), f, file, StorageFactory::get(), normalise(), IOFlags::OpenUnbuffered, IOFlags::OpenWrite, StorageFactory::READ_HINT_UNBUFFERED, StorageFactory::readHint(), and StorageFactory::tempDir().

  {
    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;

    Storage *file = new DCacheFile(normalise(proto, path), mode);
    if ((cacheHint == StorageFactory::CACHE_HINT_LAZY_DOWNLOAD
         || cacheHint == StorageFactory::CACHE_HINT_AUTO_DETECT)
        && ! (mode & IOFlags::OpenWrite))
    {
      if (f->accounting())
        file = new StorageAccountProxy(proto, file);
      file = new LocalCacheFile(file, f->tempDir());
    }
    return file;
  }

virtual void DCacheStorageMaker::stagein	(	const std::string &	proto,
		const std::string &	path
	)			[inline, virtual]

Reimplemented from StorageMaker.

Definition at line 59 of file DCacheStorageMaker.cc.

References Exception, and normalise().

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

---

The documentation for this class was generated from the following file:

• Utilities/DCacheAdaptor/plugins/DCacheStorageMaker.cc

---