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 31 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 20 of file uriUtils.cc.

References lut2db_cfg::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 41 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 90 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 lut2db_cfg::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 79 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 105 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 44 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 54 of file stringArchiveIO.cc.

References m, and ntuplemaker::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 114 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 29 of file stringArchiveIO.cc.

References ntuplemaker::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;
    }