shared_file_pos.hpp

Go to the documentation of this file.

/*****************************************************************************
** Ifdefs
*****************************************************************************/

#ifndef ECL_DEVICES_SHARED_FILE_POS_HPP_
#define ECL_DEVICES_SHARED_FILE_POS_HPP_

/*****************************************************************************
** Cross Platform Functionality
*****************************************************************************/

#include <ecl/config/ecl.hpp>
#if defined(ECL_IS_POSIX)

/*****************************************************************************
** Includes
*****************************************************************************/

#include <map>
#include <string>
#include <ecl/exceptions/standard_exception.hpp>
#include <ecl/threads/mutex.hpp>
#include "detail/character_buffer.hpp"
#include "ofile.hpp"
#include "traits.hpp"

/*****************************************************************************
** Namespaces
*****************************************************************************/

namespace ecl {

/*****************************************************************************
** Forward Definition
*****************************************************************************/

class SharedFile;

/*****************************************************************************
** Interfaces
*****************************************************************************/

namespace devices {

/*****************************************************************************
** Interface [SharedFileCommon]
*****************************************************************************/
class SharedFileCommon {
public:
    SharedFileCommon() : error_handler(NoError) {};
    SharedFileCommon(const std::string &name, ecl::WriteMode mode) ecl_throw_decl(StandardException);
    virtual ~SharedFileCommon() {}

    friend class ecl::SharedFile;
    friend class SharedFileManager;

private:
    unsigned int count;
    ecl::Mutex mutex;
    OFile file;
        Error error_handler;
};

class SharedFileManager {
public:
        static SharedFileCommon* RegisterSharedFile(const std::string &name, ecl::WriteMode mode = New) ecl_throw_decl(StandardException);
        static bool DeRegisterSharedFile(const std::string &name) ecl_throw_decl(StandardException);
private:
        static ecl::Mutex mutex;
        static std::map<std::string,SharedFileCommon*> opened_files;
};

} // namespace devices

/*****************************************************************************
** Interface [SharedFile]
*****************************************************************************/
class SharedFile {
public:
        /*********************
        ** C&D
        **********************/
        SharedFile() {};
        SharedFile(const std::string &name, WriteMode mode = New) ecl_throw_decl(StandardException);
        virtual ~SharedFile();

        bool open(const std::string &name, WriteMode mode = New) ecl_throw_decl(StandardException);

        /*********************
        ** Shared File Methods
        **********************/
        unsigned int count() { return shared_instance->count; }

        /*********************
        ** OutputDevice Methods
        **********************/
        bool open() { return shared_instance->file.open(); }
        long write(const char &c) ecl_debug_throw_decl(StandardException);
        long write(const char* s, unsigned long n) ecl_debug_throw_decl(StandardException);
        bool flush() ecl_debug_throw_decl(StandardException);

        const Error& error() const { return shared_instance->error_handler; }

private:
        devices::SharedFileCommon* shared_instance;
        devices::CharBuffer buffer;
};

/*****************************************************************************
** Traits [SharedFile]
*****************************************************************************/
template <>
class is_sink<SharedFile> : public True {};

} // namespace ecl

#endif /* ECL_IS_POSIX */
#endif /* ECL_DEVICES_SHARED_FILE_POS_HPP_ */