|
|
| version 1.45, 2001/11/16 13:17:29 | version 1.61, 2003/11/07 13:59:22 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: pool class. | Parser: pool class. |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001, 2003 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexander Petrosyan <paf@design.ru> (http://paf.design.ru) | Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) |
| $Id$ | |
| */ | */ |
| static const char* IDENT_POOL_C="$Date$"; | |
| #include "pa_pool.h" | #include "pa_pool.h" |
| #include "pa_exception.h" | #include "pa_exception.h" |
| #include "pa_common.h" | #include "pa_common.h" |
| #include "pa_sapi.h" | #include "pa_sapi.h" |
| #include "pa_charset.h" | |
| #ifdef XML | // Pool |
| #include <util/PlatformUtils.hpp> | |
| #endif | Pool::Pool(){} |
| Pool::Pool(void *astorage) : | |
| fstorage(astorage), fcontext(0), | |
| ftotal_allocated(0), ftotal_times(0) | |
| #ifdef XML | |
| , transcoder(0) | |
| #endif | |
| { | |
| #ifdef XML | |
| charset=new(*this) String(*this, "UTF-8"); | |
| #else | |
| charset=new(*this) String(*this, ""); | |
| #endif | |
| } | |
| static void cleanup(Pool::Cleanup item, int) { | |
| if(item.cleanup) | |
| item.cleanup(item.data); | |
| } | |
| Pool::~Pool() { | Pool::~Pool() { |
| #ifdef XML | //__asm__("int3"); |
| delete transcoder; | //_asm int 3; |
| #endif | //fprintf(stderr, "cleanups: %d\n", cleanups.size()); |
| } | // cleanups first, because they use some object's memory pointers |
| cleanups.for_each(cleanup, 0); | |
| void Pool::fail_alloc(size_t size) const { | } |
| SAPI::die("out of pool memory: failed to allocate %u bytes; " | |
| "already allocated on pool: %u bytes in %u times", | void Pool::register_cleanup(void (*cleanup) (void *), void *data) { |
| size, | cleanups+=Cleanup(cleanup, data); |
| ftotal_allocated, ftotal_times); | |
| } | |
| void Pool::fail_register_cleanup() const { | |
| SAPI::die("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::provide_source(*this, 0, e); | |
| } | |
| return (const char *)dest; | |
| } | |
| String& Pool::transcode(const XalanDOMString& s) { | |
| return *new(*this) String(*this, transcode_cstr(s)); | |
| } | |
| std::auto_ptr<XalanDOMString> 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::provide_source(*this, 0, e); | |
| result=0; //calm, compiler | |
| } | |
| return std::auto_ptr<XalanDOMString>(result); | |
| } | } |
| std::auto_ptr<XalanDOMString> Pool::transcode(const String& s) { | |
| const char *cstr=s.cstr(String::UL_UNSPECIFIED); | |
| 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<Pooled*>(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); | |
| } |