ibrcommon/ibrcommon/data/BLOB.h

Go to the documentation of this file.

/*
 * BLOB.h
 *
 *  Created on: 15.12.2009
 *      Author: morgenro
 */

#ifndef BLOB_H_
#define BLOB_H_

#include "ibrcommon/thread/Mutex.h"
#include "ibrcommon/data/File.h"
#include "ibrcommon/thread/Semaphore.h"
#include <iostream>
#include <sstream>
#include <fstream>

#ifdef __GNUC__
#define DEPRECATED(func) func __attribute__ ((deprecated))
#elif defined(_MSC_VER)
#define DEPRECATED(func) __declspec(deprecated) func
#else
#pragma message("WARNING: You need to implement DEPRECATED for this compiler")
#define DEPRECATED(func) func
#endif

namespace ibrcommon
{
        class CanNotOpenFileException : public ibrcommon::IOException
        {
        public:
                CanNotOpenFileException(ibrcommon::File f) throw() : IOException("Could not open file " + f.getPath() + ".")
                {
                };
        };

        class BLOB : public Mutex
        {
        public:
                static File tmppath;

                static ibrcommon::Semaphore _filelimit;

                bool _locked;

                virtual ~BLOB();

                virtual void clear() = 0;

                virtual void open() = 0;
                virtual void close() = 0;

                class Reference : public Mutex
                {
                public:
                        Reference(BLOB *blob);
                        Reference(const Reference &ref);
                        virtual ~Reference();

                        std::iostream& operator* ();

                        void enter() throw (ibrcommon::MutexException);

                        void leave() throw (ibrcommon::MutexException);

                        void trylock() throw (ibrcommon::MutexException);

                        void clear();

                        size_t getSize() const;

                private:
                        BLOB *_blob;
                };

        protected:
                BLOB();
                void increment();
                void decrement();
                bool isUnbound();

                virtual size_t getSize();

                virtual std::iostream &__get_stream() = 0;

        private:
                BLOB(const BLOB &ref); // forbidden copy constructor
                size_t _refcount;
                Mutex _reflock;
        };

        class StringBLOB : public BLOB
        {
        public:
                static BLOB::Reference create();
                virtual ~StringBLOB();

                virtual void clear();

                virtual void open();
                virtual void close();

        protected:
                std::iostream &__get_stream()
                {
                        return _stringstream;
                }

        private:
                StringBLOB();
                std::stringstream _stringstream;
        };

        class FileBLOB : public BLOB
        {
        public:
                static BLOB::Reference create(const File &f);
                virtual ~FileBLOB();

                virtual void clear();

                virtual void open();
                virtual void close();

        protected:
                std::iostream &__get_stream()
                {
                        return (*_filestream);
                }

        private:
                FileBLOB(const File &f);
                ibrcommon::locked_fstream _filestream;
                File _file;
        };

        class TmpFileBLOB : public BLOB
        {
        public:
                static BLOB::Reference create();
                virtual ~TmpFileBLOB();

                virtual void clear();

                virtual void open();
                virtual void close();

        protected:
                std::iostream &__get_stream()
                {
                        return (*_filestream);
                }

        private:
                TmpFileBLOB();
                void createtmpfile();
                ibrcommon::locked_fstream _filestream;
                int _fd;
                File _tmpfile;
        };
}

#endif /* BLOB_H_ */