--- parser3/src/main/pa_pool.C 2001/10/19 15:27:42 1.37 +++ parser3/src/main/pa_pool.C 2020/12/15 17:10:36 1.66 @@ -1,130 +1,57 @@ /** @file Parser: pool class. - Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) - Author: Alexander Petrosyan (http://design.ru/paf) - - $Id: pa_pool.C,v 1.37 2001/10/19 15:27:42 parser Exp $ + Copyright (c) 2000-2020 Art. Lebedev Studio (http://www.artlebedev.com) + Author: Alexandr Petrosian (http://paf.design.ru) */ #include "pa_pool.h" #include "pa_exception.h" #include "pa_common.h" +#include "pa_sapi.h" +#include "pa_charset.h" -#ifdef XML -#include -#endif - -Pool::Pool(void *astorage) : - fstorage(astorage), fcontext(0), ftag(0) -#ifdef XML - , transcoder(0) -#endif - { -#ifdef XML - charset=new(*this) String(*this, "UTF-8"); -#else - charset=new(*this) String(*this, ""); -#endif -} +volatile const char * IDENT_PA_POOL_C="$Id: pa_pool.C,v 1.66 2020/12/15 17:10:36 moko Exp $" IDENT_PA_POOL_H; + +// Pool + +Pool::Pool(){} +static void cleanup(Pool::Cleanup item, int) { + if(item.cleanup) + item.cleanup(item.data); +} Pool::~Pool() { -#ifdef XML - delete transcoder; -#endif -} - -void Pool::fail_alloc(size_t size) const { - throw Exception(0, 0, - 0, - "failed to allocate %u bytes", size); -} - -void Pool::fail_register_cleanup() const { - throw Exception(0, 0, - 0, - "failed to register cleanup"); -} - -void Pool::set_charset(const String &new_charset) { - if(new_charset!=*charset) { -#ifdef XML - delete transcoder; transcoder=0; // flag "we need new transcoder" -#endif - charset=&new_charset; // for this charset - } -} - -#ifdef XML -void Pool::update_transcoder() { - if(transcoder) - return; - - XMLTransService::Codes resValue; - transcoder=XMLPlatformUtils::fgTransService->makeNewTranscoderFor(charset->cstr(), resValue, 60); - if(!transcoder) - throw Exception(0, 0, - charset, - "unsupported encoding"); -} - -const char *Pool::transcode_cstr(const XalanDOMString& s) { - update_transcoder(); - - const unsigned int len=s.size()*2; - XMLByte* dest=(XMLByte *)malloc((len+1)*sizeof(XMLByte)); - bool error=true; - try { - if(transcoder) { - unsigned int charsEaten; - unsigned int size=transcoder->transcodeTo( - s.c_str(), s.length(), - dest, len, - charsEaten, - XMLTranscoder::UnRep_RepChar //UnRep_Throw - ); - dest[size]=0; - error=false; - } - } catch(XMLException& e) { - Exception::convert(*this, 0, e); - } - return (const char *)dest; -} -String& Pool::transcode(const XalanDOMString& s) { - return *new(*this) String(*this, transcode_cstr(s)); -} - -std::auto_ptr Pool::transcode_buf(const char *buf, size_t buf_size) { - update_transcoder(); - - unsigned int dest_size=0; - XMLCh* dest=(XMLCh *)malloc((buf_size+1)*sizeof(XMLCh)); - unsigned char *charSizes=(unsigned char *)malloc(buf_size*sizeof(unsigned char)); - XalanDOMString *result; - try { - if(transcoder) { - unsigned int bytesEaten; - unsigned int dest_size=transcoder->transcodeFrom( - (unsigned char *)buf, - (const unsigned int)buf_size, - dest, (const unsigned int)buf_size, - bytesEaten, - charSizes - ); - result=new XalanDOMString(dest, dest_size); - } - } catch(XMLException& e) { - Exception::convert(*this, 0, e); - result=0; //calm, compiler - } - - return std::auto_ptr(result); + //__asm__("int3"); + //_asm int 3; + //fprintf(stderr, "cleanups: %d\n", cleanups.size()); + // cleanups first, because they use some object's memory pointers + cleanups.for_each(cleanup, 0); +} + +void Pool::register_cleanup(void (*cleanup) (void *), void *data) { + cleanups+=Cleanup(cleanup, data); } -std::auto_ptr Pool::transcode(const String& s) { - const char *cstr=s.cstr(String::UL_XML); - return transcode_buf(cstr, strlen(cstr)); +static void unregister_cleanup(Pool::Cleanup& item, void* cleanup_data) { + if(item.data==cleanup_data) + item.cleanup=0; +} +void Pool::unregister_cleanup(void *cleanup_data) { + cleanups.for_each_ref(::unregister_cleanup, cleanup_data); +} + +// Pooled + +static void cleanup(void *data) { + static_cast(data)->~Pooled(); } -#endif +Pooled::Pooled(Pool& apool): fpool(apool) { + fpool.register_cleanup(cleanup, this); +} + +/// Sole: this got called automatically from Pool::~Pool() +Pooled::~Pooled() { + fpool.unregister_cleanup(this); +}