|
|
| version 1.15, 2003/12/02 13:24:32 | version 1.19, 2005/08/09 08:14:53 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: plugins to xml library, controlling i/o; implementation | Parser: plugins to xml library, controlling i/o; implementation |
| Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2005 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) |
| */ | */ |
| Line 13 static const char * const IDENT="$Date$" | Line 13 static const char * const IDENT="$Date$" |
| #include "libxslt/extensions.h" | #include "libxslt/extensions.h" |
| #include "pa_threads.h" | |
| #include "pa_globals.h" | #include "pa_globals.h" |
| #include "pa_request.h" | #include "pa_request.h" |
| static Hash<pa_thread_t, HashStringBool*> xml_dependencies; | |
| static void add_dependency(const String::Body url) { | |
| pa_thread_t thread_id=pa_get_thread_id(); | |
| HashStringBool* urls; | |
| { | |
| SYNCHRONIZED; | |
| // try to get existing for this thread_id | |
| urls=xml_dependencies.get(thread_id); | |
| } | |
| if(urls) // do we need to monitor now? | |
| urls->put(url, true); | |
| } | |
| void pa_xmlStartMonitoringDependencies() { | |
| pa_thread_t thread_id=pa_get_thread_id(); | |
| HashStringBool* urls=new HashStringBool; | |
| { | |
| SYNCHRONIZED; // find+fill blocked | |
| xml_dependencies.put(thread_id, urls); | |
| } | |
| } | |
| void pa_xmlStopMonitoringDependencies() { | |
| pa_thread_t thread_id=pa_get_thread_id(); | |
| { | |
| SYNCHRONIZED; // find+fill blocked | |
| xml_dependencies.put(thread_id, 0); | |
| } | |
| } | |
| HashStringBool* pa_xmlGetDependencies() { | |
| pa_thread_t thread_id=pa_get_thread_id(); | |
| { | |
| SYNCHRONIZED; // find+remove blocked | |
| HashStringBool* result=xml_dependencies.get(thread_id); | |
| xml_dependencies.remove(thread_id); | |
| return result; | |
| } | |
| } | |
| #ifndef DOXYGEN | #ifndef DOXYGEN |
| struct MemoryStream { | struct MemoryStream { |
| const char* m_buf; | const char* m_buf; |
| Line 37 struct MemoryStream { | Line 84 struct MemoryStream { |
| #endif | #endif |
| static void * | static void * |
| xmlFileOpen_ReadIntoStream (const char* filename, bool adjust_path_to_root_from_document_root=false) { | xmlFileOpen_ReadIntoStream (const char* do_not_store_filename, bool adjust_path_to_root_from_document_root=false) { |
| #ifdef PA_SAFE_MODE | |
| //copied from libxml/catalog.c | |
| # define XML_XML_DEFAULT_CATALOG "file:///etc/xml/catalog" | |
| // disable attempts to consult default catalog [usually, that file belongs to other user/group] | |
| if(strcmp(do_not_store_filename, XML_XML_DEFAULT_CATALOG)==0) | |
| return 0; | |
| #endif | |
| Request& r=pa_thread_request(); | Request& r=pa_thread_request(); |
| char adjust_buf[MAX_STRING]; | char adjust_buf[MAX_STRING]; |
| if(adjust_path_to_root_from_document_root) { | if(adjust_path_to_root_from_document_root) { |
| Line 47 xmlFileOpen_ReadIntoStream (const char* | Line 102 xmlFileOpen_ReadIntoStream (const char* |
| adjust_buf[0]=0; | adjust_buf[0]=0; |
| strcat(adjust_buf, document_root); | strcat(adjust_buf, document_root); |
| strcat(adjust_buf, &filename[16]); | strcat(adjust_buf, &do_not_store_filename[16]); |
| filename=adjust_buf; | do_not_store_filename=adjust_buf; |
| } else | } else |
| if(strstr(filename, "file://")) | if(strstr(do_not_store_filename, "file://")) |
| filename+=7/*strlen("file://")*/; | do_not_store_filename+=7/*strlen("file://")*/; |
| else if(strstr(filename, "://")) | else if(*do_not_store_filename && do_not_store_filename[1]!=':' && strstr(do_not_store_filename, "://")) { |
| pa_xmlStopMonitoringDependencies(); | |
| return 0; // plug out [do not handle other prefixes] | return 0; // plug out [do not handle other prefixes] |
| } | |
| const char* can_store_filename=pa_strdup(do_not_store_filename); | |
| add_dependency(can_store_filename); | |
| const char *buf; | const char *buf; |
| try { | try { |
| buf=file_read_text(r.charsets, *new String(filename)); | buf=file_read_text(r.charsets, *new String(can_store_filename)); |
| } catch(const Exception& e) { | } catch(const Exception& e) { |
| if(strcmp(e.type(), "file.missing")==0) | |
| return 0; // let the library try that and report an error properly | |
| buf=e.comment(); | buf=e.comment(); |
| } catch(...) { | } catch(...) { |
| buf="xmlFileOpenLocalhost: unknown error"; | buf="xmlFileOpen_ReadIntoStream: unknown error"; |
| } | } |
| MemoryStream* stream=new(UseGC) MemoryStream; | MemoryStream* stream=new(UseGC) MemoryStream; |
| stream->m_buf=buf; | stream->m_buf=buf; |
| Line 69 xmlFileOpen_ReadIntoStream (const char* | Line 132 xmlFileOpen_ReadIntoStream (const char* |
| return (void *)stream; | return (void *)stream; |
| } | } |
| #ifdef PA_SAFE_MODE | |
| static int | static int |
| xmlFileMatchSafeMode(const char* file_spec_cstr) { | xmlFileMatchMonitor(const char* /*file_spec_cstr*/) { |
| return 1; // always intercept, causing xmlFileOpenSafeMode to be called | return 1; // always intercept, causing xmlFileOpenMonitor to be called |
| } | } |
| static void * | static void * |
| xmlFileOpenSafeMode(const char* filename) { | xmlFileOpenMonitor(const char* filename) { |
| return xmlFileOpen_ReadIntoStream(filename); // handles localfile case, else returns 0 | return xmlFileOpen_ReadIntoStream(filename); // handles localfile case, else returns 0 |
| } | } |
| #endif | |
| /** | /** |
| Line 181 pa_xmlFileCloseMethod (void * /*context* | Line 242 pa_xmlFileCloseMethod (void * /*context* |
| void pa_xml_io_init() { | void pa_xml_io_init() { |
| #ifdef PA_SAFE_MODE | // file open monitorer [for xslt cacher] |
| // safe mode checker, always fail match, but checks non-"://" there | // safe mode checker, always fail match, but checks non-"://" there |
| xmlRegisterInputCallbacks( | xmlRegisterInputCallbacks( |
| xmlFileMatchSafeMode, xmlFileOpenSafeMode, | xmlFileMatchMonitor, xmlFileOpenMonitor, |
| pa_xmlFileReadMethod, pa_xmlFileCloseMethod); | pa_xmlFileReadMethod, pa_xmlFileCloseMethod); |
| #endif | |
| // http://localhost/abc -> $ENV{DOCUMENT_ROOT}/abc | ./abc | // http://localhost/abc -> $ENV{DOCUMENT_ROOT}/abc | ./abc |
| xmlRegisterInputCallbacks( | xmlRegisterInputCallbacks( |
| xmlFileMatchLocalhost, xmlFileOpenLocalhost, | xmlFileMatchLocalhost, xmlFileOpenLocalhost, |