|
|
| version 1.24.2.1, 2001/02/25 16:08:25 | version 1.86.2.9, 2003/01/27 15:07:47 |
|---|---|
| Line 1 | Line 1 |
| /* | /** @file |
| $Id$ | Parser: Parser: reference counting classes decls. |
| Copyright (c) 2001, 2003 ArtLebedev Group (http://www.artlebedev.com) | |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | |
| */ | */ |
| #ifndef PA_POOL_H | #ifndef PA_POOL_H |
| #define PA_POOL_H | #define PA_POOL_H |
| #include <stddef.h> | static const char* IDENT_POOL_H="$Date$"; |
| #include "pa_config_includes.h" | |
| #ifdef XML | |
| # include "gdome.h" | |
| // for xmlChar | |
| # include "libxml/tree.h" | |
| #endif | |
| void *pa_malloc(size_t size); | |
| void *pa_calloc(size_t size); | |
| void pa_free(void *ptr); | |
| void *pa_realloc(void *ptr, size_t size); | |
| // forwards | |
| //class String; | |
| class Exception; | class Exception; |
| class Temp_exception; | class String; |
| class Charset; | |
| class GdomeDOMString_auto_ptr; | |
| /* * | |
| Pool mechanizm allows users not to free up allocated memory, | |
| leaving that problem to 'pools'. | |
| @see Pooled | |
| * / | |
| class Pool { | class Pool { |
| friend Temp_exception; | |
| public: | public: |
| Pool() : fexception(0) {} | Pool(void *astorage); |
| ~Pool() {} | |
| Exception& exception() const { return *fexception; } | |
| void *malloc(size_t size) { | //{@ statistics |
| return check(real_malloc(size), size); | size_t total_allocated() { return ftotal_allocated; } |
| unsigned int total_times() { return ftotal_times; } | |
| //}@ | |
| void set_context(void *acontext) { fcontext=acontext; } | |
| void *get_context() { return fcontext; } | |
| /// allocates some bytes on pool | |
| void *malloc(size_t size, int place=0) { | |
| return check(real_malloc(size, place), size); | |
| } | } |
| /// allocates some bytes clearing them with zeros | |
| void *calloc(size_t size) { | void *calloc(size_t size) { |
| return check(real_calloc(size), size); | return check(real_calloc(size), size); |
| } | } |
| private: // implementation defined | /// registers a routine to clean up non-pooled allocations |
| void register_cleanup(void (*cleanup) (void *), void *data) { | |
| if(!real_register_cleanup(cleanup, data)) | |
| fail_register_cleanup(); | |
| } | |
| //{@ helpers | |
| void *copy(const void *buf, const size_t size); | |
| char *copy(const char *cstr); | |
| //}@ | |
| //{@ source charset | |
| void set_source_charset(Charset& acharset); | |
| Charset& get_source_charset(); | |
| //}@ | |
| //{@ client charset | |
| void set_client_charset(Charset& charset); | |
| Charset& get_client_charset(); | |
| //}@ | |
| #ifdef XML | |
| /// @see Charset::transcode_cstr(xmlChar *s); | |
| const char *transcode_cstr(xmlChar *s); | |
| /// @see Charset::transcode(xmlChar *s); | |
| String& transcode(xmlChar *s | |
| #ifndef NO_STRING_ORIGIN | |
| , const String *origin | |
| #endif | |
| ); | |
| /// @see Charset::transcode_cstr(GdomeDOMString *s); | |
| const char *transcode_cstr(GdomeDOMString *s); | |
| /// @see Charset::transcode(GdomeDOMString *s); | |
| String& transcode(GdomeDOMString *s | |
| #ifndef NO_STRING_ORIGIN | |
| , const String *origin | |
| #endif | |
| ); | |
| /// @see Charset::transcode_cstr(const char *buf, size_t buf_size=0); | |
| xmlChar *transcode_buf2xchar(const char *buf, size_t buf_size=0); | |
| /// @see Charset::transcode(const String& s) | |
| GdomeDOMString_auto_ptr transcode(const String& s); | |
| #endif | |
| private: | |
| void *fstorage; | |
| void *fcontext; | |
| Charset *source_charset; | |
| Charset *client_charset; | |
| void *real_malloc(size_t size); | private: |
| //{ | |
| /// @name implementation defined | |
| void *real_malloc(size_t size, int place); | |
| void *real_calloc(size_t size); | void *real_calloc(size_t size); |
| bool real_register_cleanup(void (*cleanup) (void *), void *data); | |
| //} | |
| private: | private: |
| // checks whether mem allocated OK. throws exception otherwise | /// checks whether mem allocated OK. throws exception otherwise |
| void *check(void *ptr, size_t size) { | void *check(void *ptr, size_t size) { |
| if(ptr) | if(ptr) { |
| ftotal_allocated+=size; | |
| ftotal_times++; | |
| return ptr; | return ptr; |
| } | |
| fail(size); | fail_alloc(size); |
| // never reached | // never reached |
| return 0; | return 0; |
| } | } |
| // throws proper exception | /// throws allocation exception |
| void fail(size_t size) const; | void fail_alloc(size_t size) const; |
| protected: // exception handling | /// throws register cleanup exception |
| void fail_register_cleanup() const; | |
| // exception replacement mechanism is 'protected' from direct usage | private: // statistics |
| // Temp_exception_change object enforces paired set/restore | |
| Exception *set_exception(Exception *e){ | size_t ftotal_allocated; |
| Exception *r=fexception; | unsigned int ftotal_times; |
| fexception=e; | |
| return r; | |
| } | |
| void restore_exception(Exception *e) { | |
| fexception=e; | |
| } | |
| private: | |
| // current request's exception object | |
| Exception *fexception; | |
| private: //disabled | private: //disabled |
| // Pool(const Pool&) {} | Pool(const Pool&); |
| Pool& operator = (const Pool&) { return *this; } | Pool& operator= (const Pool&); |
| }; | }; |
| */ | |
| /** | |
| Base for all classes that are allocated in 'pools'. | |
| Holds Pool object. Contains useful wrappers to it's methods. | |
| @see NEW | |
| * / | |
| // all classes that are members parents of packed class [String] | |
| // sould be packed also to avoid sparc odd st/lduh problem | |
| #include "pa_pragma_pack_begin.h" | |
| class Pooled { | class Pooled { |
| // the pool i'm allocated on | // the pool i'm allocated on |
| Pool& fpool; | Pool *fpool; |
| public: | public: |
| /// the Pooled-sole: Pooled instances can be allocated in Pool rather then on heap | |
| static void *operator new(size_t size, Pool& apool) { | static void *operator new(size_t size, Pool& apool) { |
| return apool.malloc(size); | return apool.malloc(size, 1); |
| } | } |
| Pooled(Pool& apool) : fpool(apool) { | Pooled(Pool& apool) : fpool(&apool) {} |
| } | |
| /// my pool | |
| Pool& pool() const { return *fpool; } | |
| Pool& pool() const { return fpool; } | /** used for moving objects from one pool to another. |
| in between object can have no pool and can not be used | |
| @see SQL_Driver_manager | |
| * / | |
| void set_pool(Pool *apool) { fpool=apool; } | |
| //{ | |
| /// @name useful wrapper around pool | |
| void *malloc(size_t size, int place=0) const { return fpool->malloc(size, place); } | |
| void *calloc(size_t size) const { return fpool->calloc(size); } | |
| void register_cleanup(void (*cleanup) (void *), void *data) { fpool->register_cleanup(cleanup, data); } | |
| void *copy(const void *buf, const size_t size) { return fpool->copy(buf, size); } | |
| char *copy(const char *cstr) { return fpool->copy(cstr); } | |
| #ifdef XML | |
| const char *transcode_cstr(GdomeDOMString *s) { return fpool->transcode_cstr(s); } | |
| String& transcode(GdomeDOMString *s | |
| #ifndef NO_STRING_ORIGIN | |
| , const String *origin | |
| #endif | |
| ) { | |
| return fpool->transcode(s | |
| #ifndef NO_STRING_ORIGIN | |
| , origin | |
| #endif | |
| ); | |
| } | |
| void *malloc(size_t size) const { return fpool.malloc(size); } | #endif |
| void *calloc(size_t size) const { return fpool.calloc(size); } | //} |
| Exception& exception() const { return fpool.exception(); } | |
| }; | }; |
| #include "pa_pragma_pack_end.h" | |
| /// useful macro for creating objects on current Pooled object Pooled::pool() | |
| #define NEW new(pool()) | #define NEW new(pool()) |
| */ | |
| #define override | |
| void *operator new(size_t size) { | |
| return pa_malloc(size); | |
| } | |
| void operator delete(void *ptr) { | |
| pa_free(ptr); | |
| } | |
| class PA_Allocated { | |
| public: | |
| /// the sole: instances allocated using our functions | |
| static void *operator new(size_t size) { | |
| return pa_malloc(size); | |
| } | |
| static void operator delete(void *ptr) { | |
| pa_free(ptr); | |
| } | |
| }; | |
| /** | |
| Base for all Parser classes, memory allocation/dallocation goes via pa_malloc/pa_free. | |
| */ | |
| class PA_Object: public PA_Allocated { | |
| mutable unsigned long references; | |
| public: | |
| PA_Object(): references(0) {} | |
| virtual ~PA_Object()=0; | |
| void ref() const { | |
| references++; | |
| } | |
| void unref() const { | |
| if(references) { | |
| if(--references==0) | |
| delete this; | |
| } | |
| } | |
| }; | |
| class Temp_exception { | template<typename T> class object_ptr { |
| Pool pool; | T *ptr; |
| Exception *saved_exception; | public: |
| public: | typedef T element_type; |
| Temp_exception(Pool& apool, Exception& exception) : | |
| pool(apool), | explicit object_ptr(T *ptr = 0) { |
| saved_exception(apool.set_exception(&exception)) { | this->ptr=ptr; |
| if(ptr) | |
| ptr->ref(); | |
| } | |
| object_ptr(const object_ptr<T>& src) { | |
| ptr=src.get(); | |
| ptr->ref(); | |
| } | |
| object_ptr<T>& operator=(const object_ptr<T>& src) { | |
| if(this!=&src) | |
| if(ptr!=src.get()) { | |
| if(ptr) | |
| ptr->unref(); | |
| ptr=src.get(); | |
| if(ptr) | |
| ptr->ref(); | |
| } | |
| return *this; | |
| } | |
| ~object_ptr() { | |
| if(ptr) | |
| ptr->unref(); | |
| } | |
| T& operator*() const { | |
| return *get(); | |
| } | |
| T *operator->() const { | |
| return get(); | |
| } | } |
| ~Temp_exception() { | T *get() const { |
| pool.restore_exception(saved_exception); | return ptr; |
| } | |
| // so one could assign object_ptr<const T> to object_ptr<T> | |
| operator object_ptr<const T>() const{ | |
| return *this; | |
| } | |
| operator bool() const { | |
| return get()!=0; | |
| } | |
| operator !() const { | |
| return get()==0; | |
| } | } |
| }; | }; |
| #define TRY \ | #define DECLARE_OBJECT_PTR(name) typedef object_ptr<name> name##Ptr; |
| { \ | |
| Exception temp_exception; \ | |
| Temp_exception le(pool(), temp_exception); \ | |
| if(setjmp(temp_exception.mark)==0) | |
| #define THROW exception()._throw | |
| #define CATCH(e) \ | |
| else{ \ | |
| Exception& e=temp_exception; | |
| #define END_CATCH \ | /// TEMPLATE CLASS smart_ptr, stolen from stl:auto_ptr |
| } \ | template<class T> |
| class smart_ptr { | |
| public: | |
| typedef T element_type; | |
| explicit smart_ptr(T *_P = 0) | |
| : _Owns(_P != 0), _Ptr(_P) {} | |
| smart_ptr(const smart_ptr<T>& _Y) | |
| : _Owns(_Y._Owns), _Ptr(_Y.release()) {} | |
| smart_ptr<T>& operator=(const smart_ptr<T>& _Y) | |
| {if (this != &_Y) | |
| {if (_Ptr != _Y.get()) | |
| {if (_Owns) | |
| delete _Ptr; | |
| _Owns = _Y._Owns; } | |
| else if (_Y._Owns) | |
| _Owns = true; | |
| _Ptr = _Y.release(); } | |
| return (*this); } | |
| ~smart_ptr() | |
| {if (_Owns) | |
| delete _Ptr; } | |
| T& operator*() const | |
| {return (*get()); } | |
| T *get() const | |
| {return (_Ptr); } | |
| T *release() const | |
| {((smart_ptr<T> *)this)->_Owns = false; | |
| return (_Ptr); } | |
| // so one could assign smart_ptr<const T> to smart_ptr<T> | |
| operator smart_ptr<const T>() const { | |
| return *this; | |
| } | |
| operator bool() const { | |
| return get(); | |
| } | } |
| // usage: | operator T*() const { |
| // TRY { ...; if(?) RAISE(?); ...; } CATCH(e) { catch-code e.comment() } END_CATCH | return _Ptr; |
| } | |
| private: | |
| bool _Owns; | |
| T *_Ptr; | |
| }; | |
| // convinient types | |
| typedef smart_ptr<char> CharPtr; | |
| #endif | #endif |