|
|
| version 1.148, 2001/08/06 16:18:26 | version 1.191, 2002/01/16 10:28:35 |
|---|---|
| Line 2 | Line 2 |
| Parser: request class main part. @see compile.C and execute.C. | Parser: request class main part. @see compile.C and execute.C. |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexander Petrosyan <paf@design.ru> (http://paf.design.ru) | |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | $Id$ |
| */ | */ |
| static const char *RCSId="$Id$"; | |
| #include "pa_config_includes.h" | |
| #include "pcre.h" | |
| #include "internal.h" | |
| extern "C" unsigned char pcre_default_tables[]; // pcre/chartables.c | |
| #include "pa_sapi.h" | #include "pa_sapi.h" |
| #include "pa_common.h" | #include "pa_common.h" |
| Line 25 extern "C" unsigned char pcre_default_ta | Line 19 extern "C" unsigned char pcre_default_ta |
| #include "pa_vtable.h" | #include "pa_vtable.h" |
| #include "pa_vfile.h" | #include "pa_vfile.h" |
| #include "pa_dictionary.h" | #include "pa_dictionary.h" |
| #include "pa_charsets.h" | |
| #include "pa_charset.h" | |
| /// content type of exception response, when no @MAIN:exception handler defined | /// content type of exception response, when no @MAIN:exception handler defined |
| const char *UNHANDLED_EXCEPTION_CONTENT_TYPE="text/plain"; | const char *UNHANDLED_EXCEPTION_CONTENT_TYPE="text/plain"; |
| Line 35 const char *ORIGINS_CONTENT_TYPE="text/p | Line 31 const char *ORIGINS_CONTENT_TYPE="text/p |
| Methoded *MOP_create(Pool&); | Methoded *MOP_create(Pool&); |
| static void load_charset(const Hash::Key& akey, Hash::Val *avalue, | |
| void *) { | |
| charsets->load_charset(akey, static_cast<Value *>(avalue)->as_string()); | |
| } | |
| // | // |
| Request::Request(Pool& apool, | Request::Request(Pool& apool, |
| Info& ainfo, | Info& ainfo, |
| String::Untaint_lang adefault_lang) : Pooled(apool), | uchar adefault_lang, |
| bool status_allowed) : Pooled(apool), | |
| stack(apool), | stack(apool), |
| OP(*MOP_create(apool)), | OP(*MOP_create(apool)), |
| env(apool), | env(apool), |
| status(apool), | |
| form(apool), | form(apool), |
| math(apool), | math(apool), |
| request(apool, *this), | request(apool, *this), |
| Line 55 Request::Request(Pool& apool, | Line 58 Request::Request(Pool& apool, |
| default_content_type(0), | default_content_type(0), |
| mime_types(0), | mime_types(0), |
| main_class(0), | main_class(0), |
| connection(0), | fconnection(0), |
| pcre_tables(0), | |
| classes_conf(apool), | classes_conf(apool), |
| anti_endless_execute_recoursion(0) | anti_endless_execute_recoursion(0), |
| trace(apool) | |
| #ifdef RESOURCES_DEBUG | |
| ,sql_connect_time(0),sql_request_time(0) | |
| #endif | |
| { | { |
| // default charsets | |
| pool().set_source_charset(*utf8_charset); | |
| pool().set_client_charset(*utf8_charset); | |
| // maybe expire old caches | |
| cache_managers->maybe_expire(); | |
| /// directly used | /// directly used |
| // operators | // operators |
| OP.register_directly_used(*this); | OP.register_directly_used(*this); |
| Line 70 Request::Request(Pool& apool, | Line 83 Request::Request(Pool& apool, |
| /// methodless | /// methodless |
| // env class | // env class |
| classes().put(*NEW String(pool(), ENV_CLASS_NAME), &env); | classes().put(*NEW String(pool(), ENV_CLASS_NAME), &env); |
| // status class | |
| if(status_allowed) | |
| classes().put(*NEW String(pool(), STATUS_CLASS_NAME), &status); | |
| // request class | // request class |
| classes().put(*NEW String(pool(), REQUEST_CLASS_NAME), &request); | classes().put(*NEW String(pool(), REQUEST_CLASS_NAME), &request); |
| // cookie class | // cookie class |
| Line 86 Request::Request(Pool& apool, | Line 102 Request::Request(Pool& apool, |
| classes().put(math.get_class()->base()->name(), &math); | classes().put(math.get_class()->base()->name(), &math); |
| } | } |
| static void element2ctypes(unsigned char *tables, | |
| Value& ctype, const String& name, | |
| unsigned char bit, | |
| int group_offset=-1, | |
| bool skip_ws=true) { | |
| Value *value=ctype.get_element(name); | |
| if(!value) | |
| return; | |
| unsigned char *ctypes_table=tables+ctypes_offset; | |
| const unsigned char *cstr= | |
| (const unsigned char *)value->as_string().cstr(String::UL_AS_IS); | |
| for(; *cstr; cstr++) { | |
| unsigned char c=*cstr; | |
| if(skip_ws && (c=='\n' || c=='\t' || c==' ')) | |
| continue; | |
| ctypes_table[c]|=bit; | |
| if(group_offset>=0) | |
| tables[cbits_offset+group_offset+c/8] |= 1 << (c%8); | |
| } | |
| } | |
| static void cstr2ctypes(unsigned char *tables, const unsigned char *cstr, | |
| unsigned char bit) { | |
| unsigned char *ctypes_table=tables+ctypes_offset; | |
| ctypes_table[0]=bit; | |
| for(; *cstr; cstr++) { | |
| unsigned char c=*cstr; | |
| ctypes_table[c]|=bit; | |
| } | |
| } | |
| static void prepare_case_tables(unsigned char *tables) { | |
| unsigned char *lcc_table=tables+lcc_offset; | |
| unsigned char *fcc_table=tables+fcc_offset; | |
| for(int i=0; i<0x100; i++) | |
| lcc_table[i]=fcc_table[i]=i; | |
| } | |
| static void element2case(unsigned char *tables, Value& ctype, const String& name) { | |
| Value *value=ctype.get_element(name); | |
| if(!value) | |
| return; | |
| unsigned char *lcc_table=tables+lcc_offset; | |
| unsigned char *fcc_table=tables+fcc_offset; | |
| const unsigned char *cstr= | |
| (const unsigned char *)value->as_string().cstr(String::UL_AS_IS); | |
| unsigned char from=0; | |
| for(; *cstr; cstr++) { | |
| unsigned char c=*cstr; | |
| if(c=='\n' || c=='\t' || c==' ') | |
| continue; | |
| if(from) { | |
| lcc_table[from]=c; | |
| fcc_table[from]=c; fcc_table[c]=from; | |
| from=0; | |
| } else | |
| from=c; | |
| } | |
| } | |
| /** | /** |
| load MAIN class, execute @main. | load MAIN class, execute @main. |
| MAIN class consists of all the auto.p files we'd manage to find | MAIN class consists of all the auto.p files we'd manage to find |
| Line 152 static void element2case(unsigned char * | Line 109 static void element2case(unsigned char * |
| the file user requested us to process | the file user requested us to process |
| all located classes become children of one another, | all located classes become children of one another, |
| composing class we name 'MAIN' | composing class we name 'MAIN' |
| @test log stack trace | |
| */ | */ |
| void Request::core(const char *root_auto_path, bool root_auto_fail, | void Request::core( |
| const char *site_auto_path, bool site_auto_fail, | const char *root_config_filespec, bool root_config_fail_on_read_problem, |
| const char *site_config_filespec, bool site_config_fail_on_read_problem, | |
| bool header_only) { | bool header_only) { |
| //_asm { int 3 } | |
| bool need_rethrow=false; Exception rethrow_me; | #ifdef RESOURCES_DEBUG |
| TRY { | //measures |
| struct timeval mt[10]; | |
| //measure:before all | |
| gettimeofday(&mt[0],NULL); | |
| #endif | |
| try { | |
| char *auto_filespec=(char *)malloc(MAX_STRING); | char *auto_filespec=(char *)malloc(MAX_STRING); |
| // loading root auto.p | // loading root config |
| if(root_auto_path) { | if(root_config_filespec) { |
| String& filespec=*NEW String(pool()); | String& filespec=*NEW String(pool()); |
| filespec.APPEND_CLEAN(root_auto_path, 0, "root_auto", 0); | filespec.APPEND_CLEAN(root_config_filespec, 0, "root_config", 0); |
| filespec.APPEND_CONST("/" AUTO_FILE_NAME); | |
| main_class=use_file( | main_class=use_file( |
| filespec, | filespec, |
| true/*ignore class_path*/, root_auto_fail, | true/*ignore class_path*/, root_config_fail_on_read_problem, |
| main_class_name, main_class); | main_class_name, main_class); |
| } | } |
| // charsets must only be specified in root config | |
| // so that users would not interfere | |
| if(main_class) { | |
| /* $MAIN:CHARSETS[ | |
| $.charsetname1[/full/path/to/charset/file.cfg] | |
| ... | |
| ] | |
| */ | |
| if(Value *vcharsets=main_class->get_element(*charsets_name)) { | |
| if(Hash *charsets=vcharsets->get_hash(0)) | |
| charsets->for_each(load_charset); | |
| else | |
| throw Exception(0, 0, | |
| &vcharsets->name(), | |
| "must be hash"); | |
| } | |
| } | |
| // configure root options | // configure root options |
| // until someone with less privileges have overriden them | // until someone with less privileges have overriden them |
| OP.configure_admin(*this); | OP.configure_admin(*this); |
| methoded_array->configure_admin(*this); | methoded_array->configure_admin(*this); |
| // loading site auto.p | // loading site config |
| if(site_auto_path) { | if(site_config_filespec) { |
| String& filespec=*NEW String(pool()); | String& filespec=*NEW String(pool()); |
| filespec.APPEND_CLEAN(site_auto_path, 0, "site_auto", 0); | filespec.APPEND_CLEAN(site_config_filespec, 0, "site_config", 0); |
| filespec.APPEND_CONST("/" AUTO_FILE_NAME); | |
| main_class=use_file( | main_class=use_file( |
| filespec, | filespec, |
| true/*ignore class_path*/, site_auto_fail, | true/*ignore class_path*/, site_config_fail_on_read_problem, |
| main_class_name, main_class); | main_class_name, main_class); |
| } | } |
| Line 192 void Request::core(const char *root_auto | Line 172 void Request::core(const char *root_auto |
| // to the one beside requested file. | // to the one beside requested file. |
| // all assigned bases from upper dir | // all assigned bases from upper dir |
| { | { |
| Array ladder(pool()); | |
| const char *after=info.path_translated; | const char *after=info.path_translated; |
| size_t drlen=strlen(info.document_root); | size_t drlen=strlen(info.document_root); |
| if(memcmp(after, info.document_root, drlen)==0) { | if(memcmp(after, info.document_root, drlen)==0) { |
| Line 201 void Request::core(const char *root_auto | Line 180 void Request::core(const char *root_auto |
| --after; | --after; |
| } | } |
| int step=0; | |
| while(const char *before=strchr(after, '/')) { | while(const char *before=strchr(after, '/')) { |
| String& step=*NEW String(pool()); | String& sfile_spec=*NEW String(pool()); |
| if(after!=info.path_translated) { | if(after!=info.path_translated) { |
| step.APPEND_CLEAN( | sfile_spec.APPEND_CLEAN( |
| info.path_translated, before+1/* / */-info.path_translated, | info.path_translated, before-info.path_translated, |
| "path-translated-scanned", ladder.size()); | "path-translated-scanned", step++); |
| step << AUTO_FILE_NAME; | sfile_spec << "/" AUTO_FILE_NAME; |
| ladder+=&step; | |
| main_class=use_file(sfile_spec, | |
| true/*ignore class_path*/, false/*ignore read problem*/, | |
| main_class_name, main_class); | |
| } | } |
| after=before+1; | after=before+1; |
| } | } |
| for(int i=0; i<ladder.size(); i++) { | |
| const String& sfile_spec=*ladder.get_string(i); | |
| main_class=use_file(sfile_spec, | |
| true/*ignore class_path*/, false/*ignore read problem*/, | |
| main_class_name, main_class); | |
| } | |
| } | } |
| // compile requested file | // compile requested file |
| Line 231 void Request::core(const char *root_auto | Line 208 void Request::core(const char *root_auto |
| OP.configure_user(*this); | OP.configure_user(*this); |
| methoded_array->configure_user(*this); | methoded_array->configure_user(*this); |
| // $MAIN:DEFAULTS | |
| Value *defaults=main_class->get_element(*defaults_name); | |
| // value must be allocated on request's pool for that pool used on | |
| // meaning constructing @see attributed_meaning_to_string | |
| default_content_type=defaults?defaults->get_element(*content_type_name):0; | |
| if(Value *element=main_class->get_element(*user_html_name)) | |
| if(Table *table=element->get_table()) | |
| pool().set_tag(NEW Dictionary(*table)); | |
| // $MAIN:MIME-TYPES | // $MAIN:MIME-TYPES |
| if(Value *element=main_class->get_element(*mime_types_name)) | if(Value *element=main_class->get_element(*mime_types_name)) |
| if(Table *table=element->get_table()) | if(Table *table=element->get_table()) |
| mime_types=table; | mime_types=table; |
| /* | |
| $MAIN:CTYPE[ | |
| $.white-space[ | |
| ^#09^#0A^#0B^#0C^#0D^#20] | |
| $.digit[ | |
| 0123456789] | |
| $.hex-digit[ | |
| 0123456789ABCDEFabcdef] | |
| $.letter[ | |
| ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz] | |
| $.word[ | |
| 0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ_abcdefghijklmnopqrstuvwxyz] | |
| $.lowercase[ | |
| AaBbCcDdEeFfGgHhIiJjKkLlMmNnOoPpQqRrSsTtUuVvWwXxYyZz] | |
| ] | |
| */ | |
| if(Value *ctype=main_class->get_element(*ctype_name)) { | |
| // lowcase, flipcase, bits digit+word+whitespace, masks | |
| pcre_tables=(unsigned char *)calloc(tables_length); | |
| prepare_case_tables(pcre_tables); | |
| element2ctypes(pcre_tables, *ctype, *ctype_white_space_name, ctype_space, cbit_space, false); | |
| element2ctypes(pcre_tables, *ctype, *ctype_digit_name, ctype_digit, cbit_digit); | |
| element2ctypes(pcre_tables, *ctype, *ctype_hex_digit_name, ctype_xdigit); | |
| element2ctypes(pcre_tables, *ctype, *ctype_letter_name, ctype_letter); | |
| element2ctypes(pcre_tables, *ctype, *ctype_word_name, ctype_word, cbit_word); | |
| cstr2ctypes(pcre_tables, (const unsigned char *)"*+?{^.$|()[", ctype_meta); | |
| element2case(pcre_tables, *ctype, *ctype_lowercase_name); | |
| } else | |
| pcre_tables=pcre_default_tables; | |
| // filling form fields | // filling form fields |
| form.fill_fields(*this); | form.fill_fields_and_tables(*this); |
| // filling cookies | // filling cookies |
| cookie.fill_fields(*this); | cookie.fill_fields(*this); |
| #ifdef RESOURCES_DEBUG | |
| //measure:after compile | |
| gettimeofday(&mt[1],NULL); | |
| #endif | |
| // execute @main[] | // execute @main[] |
| const String *body_string=execute_virtual_method( | const String *body_string=execute_virtual_method(*main_class, *main_method_name); |
| *main_class, *main_method_name); | |
| if(!body_string) | if(!body_string) |
| THROW(0,0, | throw Exception(0,0, |
| 0, | 0, |
| "'"MAIN_METHOD_NAME"' method not found"); | "'"MAIN_METHOD_NAME"' method not found"); |
| #ifdef RESOURCES_DEBUG | |
| //measure:after main | |
| gettimeofday(&mt[2],NULL); | |
| #endif | |
| VString body_vstring_before_post_process(*body_string); | VString body_vstring_before_post_process(*body_string); |
| VString *body_vstring_after_post_process=&body_vstring_before_post_process; | VString *body_vstring_after_post_process=&body_vstring_before_post_process; |
| // @postprocess | // @postprocess |
| if(Value *value=main_class->get_element(*post_process_method_name)) | if(Value *value=main_class->get_element(*post_process_method_name)) |
| if(Junction *junction=value->get_junction()) | if(Junction *junction=value->get_junction()) |
| Line 307 void Request::core(const char *root_auto | Line 249 void Request::core(const char *root_auto |
| frame.store_param(method->name, | frame.store_param(method->name, |
| &body_vstring_before_post_process); | &body_vstring_before_post_process); |
| body_vstring_after_post_process= | body_vstring_after_post_process= |
| NEW VString(*execute_method(frame, *method)); | NEW VString(execute_method(frame, *method)); |
| } | } |
| bool origins_mode=main_class->get_element(*origins_mode_name)!=0; | bool origins_mode=main_class->get_element(*origins_mode_name)!=0; |
| Line 324 void Request::core(const char *root_auto | Line 266 void Request::core(const char *root_auto |
| response.fields().put(*content_type_name, | response.fields().put(*content_type_name, |
| NEW VString(*NEW String(pool(), ORIGINS_CONTENT_TYPE))); | NEW VString(*NEW String(pool(), ORIGINS_CONTENT_TYPE))); |
| #ifdef RESOURCES_DEBUG | |
| //measure:after postprocess | |
| gettimeofday(&mt[3],NULL); | |
| #endif | |
| // OK. write out the result | // OK. write out the result |
| output_result(*body_file, header_only); | output_result(*body_file, header_only); |
| } | |
| CATCH(e) { // request handling problem | #ifdef RESOURCES_DEBUG |
| //measure:after output_result | |
| gettimeofday(&mt[9],NULL); | |
| t[9]=mt[9].tv_sec+mt[9].tv_usec/1000000.0; | |
| double t[10]; | |
| for(int i=0;i<10;i++) | |
| t[i]=mt[i].tv_sec+mt[i].tv_usec/1000000.0; | |
| //measure:log2 compile,main,postprocess,output | |
| SAPI::log(pool(), "rmeasure: %s,%.2f,%.2f,%.2f %.2f,%.2f %.2f", | |
| info.uri, | |
| t[1]-t[0], | |
| t[2]-t[1], | |
| t[3]-t[2], | |
| sql_connect_time,sql_request_time, | |
| t[9]-t[3] | |
| ); | |
| #endif | |
| } catch(const Exception& e) { // request handling problem | |
| // we're returning not result, but error explanation | // we're returning not result, but error explanation |
| TRY { | try { |
| // log the beast | // log the beast |
| const String *problem_source=e.problem_source(); | const String *problem_source=e.problem_source(); |
| if(problem_source && problem_source->size()) | if(problem_source && problem_source->size()) |
| SAPI::log(pool(), | SAPI::log(pool(), |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| "%s(%d): " | ORIGIN_FILE_LINE_FORMAT": " |
| #endif | #endif |
| "'%s' %s [%s %s]", | "'%s' %s [%s %s]", |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| problem_source->origin().file?problem_source->origin().file:"global", | problem_source->origin().file?problem_source->origin().file:"global", |
| problem_source->origin().line, | problem_source->origin().line, |
| #endif | #endif |
| problem_source->cstr(String::UL_AS_IS), | problem_source->cstr(), |
| e.comment(), | e.comment(), |
| e.type()?e.type()->cstr(String::UL_AS_IS):"-", | e.type()?e.type()->cstr():"-", |
| e.code()?e.code()->cstr(String::UL_AS_IS):"-" | e.code()?e.code()->cstr():"-" |
| ); | ); |
| else | else |
| SAPI::log(pool(), | SAPI::log(pool(), |
| "%s [%s %s]", | "%s [%s %s]", |
| e.comment(), | e.comment(), |
| e.type()?e.type()->cstr(String::UL_AS_IS):"-", | e.type()?e.type()->cstr():"-", |
| e.code()?e.code()->cstr(String::UL_AS_IS):"-" | e.code()?e.code()->cstr():"-" |
| ); | ); |
| // reset language to default | // reset language to default |
| flang=fdefault_lang; | flang=fdefault_lang; |
| if(flang==String::UL_USER_HTML) | |
| flang=String::UL_HTML; // no _ & Co conversions in @exception[params] | |
| // reset response | // reset response |
| response.fields().clear(); | response.fields().clear(); |
| Line 372 void Request::core(const char *root_auto | Line 335 void Request::core(const char *root_auto |
| if(Value *value=main_class->get_element(*exception_method_name)) | if(Value *value=main_class->get_element(*exception_method_name)) |
| if(Junction *junction=value->get_junction()) | if(Junction *junction=value->get_junction()) |
| if(const Method *method=junction->method) { | if(const Method *method=junction->method) { |
| // preparing to pass parameters to | // preparing to pass parameters to |
| // @exception[origin;source;comment;type;code] | // @exception[origin;source;comment;type;code;stack] |
| VMethodFrame frame(pool(), value->name(), *junction); | VMethodFrame frame(pool(), value->name(), *junction); |
| frame.set_self(*main_class); | frame.set_self(*main_class); |
| Line 385 void Request::core(const char *root_auto | Line 348 void Request::core(const char *root_auto |
| const Origin& origin=problem_source->origin(); | const Origin& origin=problem_source->origin(); |
| if(origin.file) { | if(origin.file) { |
| char *buf=(char *)malloc(MAX_STRING); | char *buf=(char *)malloc(MAX_STRING); |
| size_t buf_size=snprintf(buf, MAX_STRING, "%s(%d):", | size_t buf_size=snprintf(buf, MAX_STRING, ORIGIN_FILE_LINE_FORMAT, |
| origin.file, 1+origin.line); | origin.file, 1+origin.line); |
| String *origin_file_line=NEW String(pool(), | origin_value=NEW VString(*NEW String(pool(), |
| buf, buf_size, true); | buf, buf_size, true)); |
| origin_value=NEW VString(*origin_file_line); | |
| } | } |
| } | } |
| #endif | #endif |
| Line 433 void Request::core(const char *root_auto | Line 395 void Request::core(const char *root_auto |
| code_value=NEW VVoid(pool()); | code_value=NEW VVoid(pool()); |
| frame.store_param(method->name, code_value); | frame.store_param(method->name, code_value); |
| // $stack[^table::set{name origin}] | |
| Array& stack_trace_columns=*NEW Array(pool()); | |
| stack_trace_columns+=NEW String(pool(), "name"); | |
| stack_trace_columns+=NEW String(pool(), "origin"); | |
| Table& stack_trace=*NEW Table(pool(), 0, &stack_trace_columns); | |
| Array_iter tracei(trace); | |
| while(tracei.has_next()) { | |
| Array& row=*NEW Array(pool()); | |
| const String *name=(const String *)tracei.next(); | |
| row+=name; // name column | |
| #ifndef NO_STRING_ORIGIN | |
| const Origin& origin=name->origin(); | |
| if(origin.file) { | |
| char *buf=(char *)malloc(MAX_STRING); | |
| size_t buf_size=snprintf(buf, MAX_STRING, ORIGIN_FILE_LINE_FORMAT, | |
| origin.file, 1+origin.line); | |
| row+=NEW String(pool(), buf, buf_size, true); // origin column | |
| } | |
| #endif | |
| stack_trace+=&row; | |
| } | |
| frame.store_param(method->name, | |
| NEW VTable(pool(), &stack_trace)); | |
| // future $response:body= | // future $response:body= |
| // execute ^exception[origin;source;comment;type;code] | // execute ^exception[origin;source;comment;type;code;stack] |
| body_string=execute_method(frame, *method); | body_string=&execute_method(frame, *method); |
| } | } |
| } | } |
| Line 450 void Request::core(const char *root_auto | Line 437 void Request::core(const char *root_auto |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| const Origin& origin=problem_source->origin(); | const Origin& origin=problem_source->origin(); |
| if(origin.file) | if(origin.file) |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "%s(%d): ", | printed+=snprintf(buf+printed, MAX_STRING-printed, |
| origin.file, 1+origin.line); | ORIGIN_FILE_LINE_FORMAT": ", |
| origin.file, 1+origin.line | |
| ); | |
| #endif | #endif |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "'%s' ", | printed+=snprintf(buf+printed, MAX_STRING-printed, "'%s' ", |
| problem_source->cstr(String::UL_AS_IS)); | problem_source->cstr()); |
| } | } |
| printed+=snprintf(buf+printed, MAX_STRING-printed, "%s", | printed+=snprintf(buf+printed, MAX_STRING-printed, "%s", |
| e.comment()); | e.comment()); |
| const String *type=e.type(); | const String *type=e.type(); |
| if(type) { | if(type) { |
| printed+=snprintf(buf+printed, MAX_STRING-printed, " type: %s", | printed+=snprintf(buf+printed, MAX_STRING-printed, " type: %s", |
| type->cstr(String::UL_AS_IS)); | type->cstr()); |
| const String *code=e.code(); | const String *code=e.code(); |
| if(code) | if(code) |
| printed+=snprintf(buf+printed, MAX_STRING-printed, ", code: %s", | printed+=snprintf(buf+printed, MAX_STRING-printed, ", code: %s", |
| code->cstr(String::UL_AS_IS)); | code->cstr()); |
| } | } |
| // future $response:content-type | // future $response:content-type |
| Line 480 void Request::core(const char *root_auto | Line 469 void Request::core(const char *root_auto |
| // ERROR. write it out | // ERROR. write it out |
| output_result(*body_file, header_only); | output_result(*body_file, header_only); |
| } catch(const Exception& ) { | |
| /*re*/throw; | |
| } | } |
| CATCH(e) { | |
| // exception in request exception handler | |
| // remember to rethrow it | |
| rethrow_me=e; need_rethrow=true; | |
| } | |
| END_CATCH | |
| } | } |
| END_CATCH // do not use pool() after this point - no exception handler set | |
| // any throw() would try to use zero exception() pointer | |
| if(need_rethrow) // were there an exception for us to rethrow? | |
| THROW(rethrow_me.type(), rethrow_me.code(), | |
| rethrow_me.problem_source(), | |
| rethrow_me.comment()); | |
| } | } |
| VStateless_class *Request::use_file(const String& file_name, | VStateless_class *Request::use_file(const String& file_name, |
| Line 507 VStateless_class *Request::use_file(cons | Line 485 VStateless_class *Request::use_file(cons |
| used_files.put(file_name, (Hash::Val *)true); | used_files.put(file_name, (Hash::Val *)true); |
| const String *file_spec; | const String *file_spec; |
| if(ignore_class_path || file_name.first_char()=='/') { | if(ignore_class_path) // ignore_class_path? |
| // ignore_class_path | absolute path, no need to scan MAIN:class_path | |
| file_spec=&file_name; | file_spec=&file_name; |
| } else { | else if(file_name.first_char()=='/') //absolute path, no need to scan MAIN:CLASS_PATH? |
| file_spec=0; | file_spec=&absolute(file_name); |
| if(main_class) | else { |
| if(Value *element=main_class->get_element(*class_path_name)) | file_spec=0; |
| if(Table *table=element->get_table()) { | if(main_class) |
| int size=table->size(); | if(Value *element=main_class->get_element(*class_path_name)) { |
| for(int i=size; i--; ) { | if(element->is_string()) { |
| const String& path=*static_cast<Array *>(table->get(i))->get_string(0); | file_spec=file_readable(absolute(element->as_string()), file_name); // found at class_path? |
| String *test_file_spec=NEW String(path); | } else if(Table *table=element->get_table()) { |
| *test_file_spec << "/"; | int size=table->size(); |
| *test_file_spec << file_name; | for(int i=size; i--; ) { |
| if(file_readable(*test_file_spec)) { | const String& path=*static_cast<Array *>(table->get(i))->get_string(0); |
| file_spec=test_file_spec; // found along class_path | if(file_spec=file_readable(absolute(path), file_name)) |
| break; | break; // found along class_path |
| } | |
| } | |
| if(!file_spec) | |
| THROW(0, 0, | |
| &file_name, | |
| "not found along " CLASS_PATH_NAME); | |
| } | } |
| if(!file_spec) | } else |
| THROW(0, 0, | throw Exception(0, 0, |
| &file_name, | &element->name(), |
| "can not be loaded because no " CLASS_PATH_NAME " specified"); | "must be string or table"); |
| if(!file_spec) | |
| throw Exception(0, 0, | |
| &file_name, | |
| "not found along " MAIN_CLASS_NAME ":" CLASS_PATH_NAME); | |
| } | |
| if(!file_spec) | |
| throw Exception(0, 0, | |
| &file_name, | |
| "usage failed - no " MAIN_CLASS_NAME ":" CLASS_PATH_NAME " were specified"); | |
| } | } |
| char *source=file_read_text(pool(), *file_spec, fail_on_read_problem); | char *source=file_read_text(pool(), *file_spec, fail_on_read_problem); |
| Line 578 const String& Request::absolute(const St | Line 558 const String& Request::absolute(const St |
| static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning, | static void add_header_attribute(const Hash::Key& aattribute, Hash::Val *ameaning, |
| void *info) { | void *info) { |
| String *attribute_to_exclude=static_cast<String *>(info); | Request& r=*static_cast<Request *>(info); |
| if(aattribute==*attribute_to_exclude) | if(aattribute==BODY_NAME |
| || aattribute==CHARSET_NAME) | |
| return; | return; |
| Value& lmeaning=*static_cast<Value *>(ameaning); | Value& lmeaning=*static_cast<Value *>(ameaning); |
| Pool& pool=lmeaning.pool(); | Pool& pool=lmeaning.pool(); |
| SAPI::add_header_attribute(pool, | SAPI::add_header_attribute(pool, |
| aattribute.cstr(String::UL_AS_IS), | aattribute.cstr(), |
| attributed_meaning_to_string(lmeaning, String::UL_HTTP_HEADER).cstr()); | attributed_meaning_to_string(lmeaning, String::UL_HTTP_HEADER).cstr()); |
| } | } |
| void Request::output_result(const VFile& body_file, bool header_only) { | void Request::output_result(const VFile& body_file, bool header_only) { |
| Line 609 void Request::output_result(const VFile& | Line 590 void Request::output_result(const VFile& |
| if(VString *vfile_name=static_cast<VString *>(body_file.fields().get(*name_name))) | if(VString *vfile_name=static_cast<VString *>(body_file.fields().get(*name_name))) |
| if(vfile_name->string()!=NONAME_DAT) { | if(vfile_name->string()!=NONAME_DAT) { |
| VHash& vhash=*NEW VHash(pool()); | VHash& vhash=*NEW VHash(pool()); |
| vhash.hash().put(*content_disposition_filename_name, vfile_name); | vhash.hash(0).put(*content_disposition_filename_name, vfile_name); |
| response.fields().put(*content_disposition_name, &vhash); | response.fields().put(*content_disposition_name, &vhash); |
| } | } |
| // prepare header: $response:fields without :body | // prepare header: $response:fields without :body |
| response.fields().for_each(add_header_attribute, /*excluding*/ body_name); | response.fields().for_each(add_header_attribute, this); |
| // prepare... | // transcode |
| const void *body=body_file.value_ptr(); | const void *client_body; |
| size_t content_length=body_file.value_size(); | size_t client_content_length; |
| Charset::transcode(pool(), | |
| pool().get_source_charset(), body_file.value_ptr(), body_file.value_size(), | |
| pool().get_client_charset(), client_body, client_content_length | |
| ); | |
| // prepare header: content-length | // prepare header: content-length |
| if(content_length) { // useful for redirecting [header "location: http://..."] | if(client_content_length) { // useful for redirecting [header "location: http://..."] |
| char content_length_cstr[MAX_NUMBER]; | char content_length_cstr[MAX_NUMBER]; |
| snprintf(content_length_cstr, MAX_NUMBER, "%u", content_length); | snprintf(content_length_cstr, MAX_NUMBER, "%u", client_content_length); |
| SAPI::add_header_attribute(pool(), "content-length", content_length_cstr); | SAPI::add_header_attribute(pool(), "content-length", content_length_cstr); |
| } | } |
| Line 632 void Request::output_result(const VFile& | Line 617 void Request::output_result(const VFile& |
| // send body | // send body |
| if(!header_only) | if(!header_only) |
| SAPI::send_body(pool(), body, content_length); | SAPI::send_body(pool(), client_body, client_content_length); |
| } | } |
| const String& Request::mime_type_of(const char *user_file_name_cstr) { | const String& Request::mime_type_of(const char *user_file_name_cstr) { |
| Line 643 const String& Request::mime_type_of(cons | Line 628 const String& Request::mime_type_of(cons |
| if(const String *result=mime_types->item(1)) | if(const String *result=mime_types->item(1)) |
| return *result; | return *result; |
| else | else |
| THROW(0, 0, | throw Exception(0, 0, |
| mime_types->origin_string(), | mime_types->origin_string(), |
| "MIME-TYPE table column elements must not be empty"); | "MIME-TYPE table column elements must not be empty"); |
| } | } |