32 using std::istringstream;
37 #include "BESUncompressManager3.h"
38 #include "BESUncompress3GZ.h"
39 #include "BESUncompress3BZ2.h"
40 #include "BESUncompress3Z.h"
42 #include "BESFileLockingCache.h"
44 #include "BESInternalError.h"
47 #include "TheBESKeys.h"
60 BESUncompressManager3::BESUncompressManager3()
78 BESUncompressManager3::UCIter i;
79 i = _uncompress_list.find(name);
80 if (i == _uncompress_list.end()) {
81 _uncompress_list[name] = method;
97 BESUncompressManager3::UCIter i;
98 i = _uncompress_list.find(name);
99 if (i != _uncompress_list.end()) {
139 BESDEBUG(
"uncompress2",
"BESUncompressManager3::uncompress() - src: " << src << endl );
152 std::ostringstream oss;
153 oss <<
"BESUncompressManager3::" << __func__ <<
"() - ";
154 oss <<
"The supplied Cache object is NULL. Decompression Requires An Operational Cache.";
159 string::size_type dot = src.rfind(
".");
160 if (dot == string::npos) {
161 BESDEBUG(
"uncompress2",
"BESUncompressManager3::uncompress() - no file extension" << endl );
165 string ext = src.substr(dot + 1, src.length() - dot);
171 BESDEBUG(
"uncompress2",
"BESUncompressManager3::uncompress() - not compressed " << endl );
180 BESDEBUG(
"uncompress2",
"BESUncompressManager3::uncompress() - is cached? " << src << endl );
184 BESDEBUG(
"uncompress",
"BESUncompressManager3::uncompress() - cached hit: " << cache_file << endl );
191 BESDEBUG(
"uncompress",
"BESUncompressManager3::uncompress() - caching " << cache_file << endl );
213 BESDEBUG(
"uncompress",
"BESUncompressManager3::uncompress() - cached hit: " << cache_file << endl );
221 BESDEBUG(
"uncompress",
"BESUncompressManager3::uncompress() - caught exception, unlocking cache and re-throw." << endl );
238 strm << BESIndent::LMarg <<
"BESUncompressManager3::dump - (" << (
void *)
this <<
")" << endl;
240 if (_uncompress_list.size()) {
241 strm << BESIndent::LMarg <<
"registered uncompression methods:" << endl;
243 BESUncompressManager3::UCIter i = _uncompress_list.begin();
244 BESUncompressManager3::UCIter ie = _uncompress_list.end();
245 for (; i != ie; i++) {
246 strm << BESIndent::LMarg << (*i).first << endl;
248 BESIndent::UnIndent();
251 strm << BESIndent::LMarg <<
"registered uncompress methods: none" << endl;
253 BESIndent::UnIndent();
257 BESUncompressManager3::TheManager()
259 if (_instance == 0) {
Implementation of a caching mechanism for compressed data.
virtual void unlock_cache()
virtual unsigned long long update_cache_info(const std::string &target)
Update the cache info file to include 'target'.
virtual bool create_and_lock(const std::string &target, int &fd)
Create a file in the cache and lock it for write access.
virtual void exclusive_to_shared_lock(int fd)
Transfer from an exclusive lock to a shared lock.
virtual bool get_read_lock(const std::string &target, int &fd)
Get a read-only lock on the file if it exists.
virtual bool cache_too_big(unsigned long long current_size) const
look at the cache size; is it too large? Look at the cache size and see if it is too big.
virtual void update_and_purge(const std::string &new_file)
Purge files from the cache.
virtual std::string get_cache_file_name(const std::string &src, bool mangle=true)
exception thrown if internal error encountered
static void uncompress(const std::string &src, int fd)
uncompress a file with the .bz2 file extension
static void uncompress(const std::string &src, int dest_fd)
uncompress a file with the .gz file extension
static void uncompress(const std::string &src, int fd)
uncompress a file with the .gz file extension
List of all registered decompression methods.
virtual bool add_method(const std::string &name, p_bes_uncompress method)
create_and_lock a uncompress method to the list
virtual p_bes_uncompress find_method(const std::string &name)
returns the uncompression method specified
virtual bool uncompress(const std::string &src, std::string &target, BESFileLockingCache *cache)
If the file 'src' should be uncompressed, do so and return a new file name on the value-result param ...
virtual void dump(std::ostream &strm) const
dumps information about this object