gs Namespace Reference

Namespaces
	Private

Functions
std::string	fileDirname (const char *filename)
std::string	fileTail (const char *filename)
std::string	joinDir1WithName2 (const char *fname1, const char *fname2)
StringArchive *	loadStringArchiveFromArchive (AbsArchive &arch, const unsigned long long id)
std::string	localFileURI (const char *filename)
StringArchive *	readCompressedStringArchive (const char *filename)
StringArchive *	readCompressedStringArchiveExt (const char *filename, const char *suffix)
StringArchive *	readStringArchive (const char *filename)
bool	writeBinaryCatalog (std::ostream &os, const unsigned compressionCode, const unsigned mergeLevel, const std::vector< std::string > &annotations, const AbsCatalog &catalog, const unsigned formatId)
bool	writeCompressedStringArchive (const StringArchive &ar, const char *filename, const unsigned inCompressionMode, const int compressionLevel, const unsigned minSizeToCompress, const unsigned bufSize)
bool	writeCompressedStringArchiveExt (const StringArchive &ar, const char *filename, const char *suffix)
bool	writeStringArchive (const StringArchive &ar, const char *filename)

Function Documentation

std::string gs::fileDirname

(

const char *

filename

)

Definition at line 29 of file uriUtils.cc.

References AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by joinDir1WithName2().

                                              {
    assert(filename);
    const char *progname = std::strrchr(filename, '/');
    if (progname)
      return std::string(filename, progname - filename);
    else
      return std::string(".");
  }

std::string gs::fileTail

(

const char *

filename

)

Definition at line 19 of file uriUtils.cc.

References corrVsCorr::filename, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by joinDir1WithName2().

                                           {
    assert(filename);
    const char *progname = std::strrchr(filename, '/');
    if (progname)
      ++progname;
    else
      progname = filename;
    return std::string(progname);
  }

std::string gs::joinDir1WithName2	(	const char *	fname1,
		const char *	fname2
	)

Definition at line 38 of file uriUtils.cc.

References fileDirname(), fileTail(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                      {
    std::string res(fileDirname(fname1));
    res += '/';
    res += fileTail(fname2);
    return res;
  }

StringArchive* gs::loadStringArchiveFromArchive	(	AbsArchive &	arch,
		const unsigned long long	id
	)

Definition at line 80 of file stringArchiveIO.cc.

References AlCaHLTBitMon_ParallelJobs::p.

                                                                                             {
    Reference<StringArchive> ref(arch, id);
    if (!ref.unique()) {
      std::ostringstream os;
      os << "In gs::loadStringArchiveFromArchive: "
         << "StringArchive item with id " << id << " not found";
      throw gs::IOInvalidArgument(os.str());
    }
    CPP11_auto_ptr<StringArchive> p = ref.get(0);
    return p.release();
  }

std::string gs::localFileURI

(

const char *

filename

)

Definition at line 8 of file uriUtils.cc.

References corrVsCorr::filename, and AlCaHLTBitMon_QueryRunRegistry::string.

                                               {
    assert(filename);
    if (strlen(filename) == 0)
      throw gs::IOInvalidArgument("In gs::localFileURI: empty file name");
    std::string uri("file://");
    if (filename[0] != '/')
      uri += "./";
    uri += filename;
    return uri;
  }

StringArchive* gs::readCompressedStringArchive

(

const char *

filename

)

Definition at line 71 of file stringArchiveIO.cc.

Referenced by readCompressedStringArchiveExt().

                                                                   {
    assert(filename);
    std::ifstream is(filename, std::ios_base::binary);
    if (!is.is_open())
      throw IOOpeningFailure("gs::readCompressedStringArchive", filename);
    CPP11_auto_ptr<StringArchive> ar = read_compressed_item<StringArchive>(is);
    return ar.release();
  }

StringArchive* gs::readCompressedStringArchiveExt	(	const char *	filename,
		const char *	suffix
	)

Definition at line 92 of file stringArchiveIO.cc.

References readCompressedStringArchive(), readStringArchive(), and suffix_matches().

                                                                                          {
    if (suffix_matches(filename, suffix))
      return readCompressedStringArchive(filename);
    else
      return readStringArchive(filename);
  }

StringArchive* gs::readStringArchive

(

const char *

filename

)

Definition at line 39 of file stringArchiveIO.cc.

Referenced by readCompressedStringArchiveExt().

                                                         {
    assert(filename);
    std::ifstream is(filename, std::ios_base::binary);
    if (!is.is_open())
      throw IOOpeningFailure("gs::readStringArchive", filename);
    CPP11_auto_ptr<StringArchive> ar = read_item<StringArchive>(is);
    return ar.release();
  }

bool gs::writeBinaryCatalog	(	std::ostream &	os,
		const unsigned	compressionCode,
		const unsigned	mergeLevel,
		const std::vector< std::string > &	annotations,
		const AbsCatalog &	catalog,
		const unsigned	formatId
	)

Definition at line 4 of file CatalogIO.cc.

                                                   {
    os.seekp(0, std::ios_base::beg);

    const unsigned endianness = 0x01020304;
    const unsigned char sizelong = sizeof(long);

    write_pod(os, formatId);
    write_pod(os, endianness);
    write_pod(os, sizelong);
    write_pod(os, compressionCode);
    write_pod(os, mergeLevel);
    write_pod_vector(os, annotations);

    return !os.fail() && catalog.classId().write(os) && catalog.write(os);
  }

bool gs::writeCompressedStringArchive	(	const StringArchive &	ar,
		const char *	filename,
		const unsigned	inCompressionMode,
		const int	compressionLevel,
		const unsigned	minSizeToCompress,
		const unsigned	bufSize
	)

Definition at line 48 of file stringArchiveIO.cc.

References funct::m, haddnano::of, and mps_update::status.

Referenced by writeCompressedStringArchiveExt().

                                                            {
    assert(filename);
    if (inCompressionMode > CStringStream::BZIP2)
      throw gs::IOInvalidArgument(
          "In gs::writeCompressedStringArchive: "
          "compression mode argument out of range");
    const CStringStream::CompressionMode m = static_cast<CStringStream::CompressionMode>(inCompressionMode);
    bool status = false;
    {
      std::ofstream of(filename, std::ios_base::binary);
      if (of.is_open()) {
        const_cast<StringArchive &>(ar).flush();
        status = write_compressed_item(of, ar, m, compressionLevel, minSizeToCompress, bufSize);
      }
    }
    return status;
  }

bool gs::writeCompressedStringArchiveExt	(	const StringArchive &	ar,
		const char *	filename,
		const char *	suffix
	)

Definition at line 99 of file stringArchiveIO.cc.

References suffix_matches(), writeCompressedStringArchive(), and writeStringArchive().

                                                                                                          {
    if (suffix_matches(filename, suffix))
      return writeCompressedStringArchive(ar, filename);
    else
      return writeStringArchive(ar, filename);
  }

bool gs::writeStringArchive	(	const StringArchive &	ar,
		const char *	filename
	)

Definition at line 26 of file stringArchiveIO.cc.

References haddnano::of, and mps_update::status.

Referenced by writeCompressedStringArchiveExt().

                                                                         {
    assert(filename);
    bool status = false;
    {
      std::ofstream of(filename, std::ios_base::binary);
      if (of.is_open()) {
        const_cast<StringArchive &>(ar).flush();
        status = write_item(of, ar);
      }
    }
    return status;
  }