|
|
| version 1.160.2.37.2.7, 2003/03/24 09:39:55 | version 1.187, 2007/10/22 16:38:20 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: request class decl. | Parser: request class decl. |
| 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) |
| */ | */ |
| #ifndef PA_REQUEST_H | #ifndef PA_REQUEST_H |
| #define PA_REQUEST_H | #define PA_REQUEST_H |
| static const char* IDENT_REQUEST_H="$Date$"; | static const char * const IDENT_REQUEST_H="$Date$"; |
| #include "pa_request_info.h" | #include "pa_pool.h" |
| #include "pa_hash.h" | #include "pa_hash.h" |
| #include "pa_wcontext.h" | #include "pa_wcontext.h" |
| #include "pa_value.h" | #include "pa_value.h" |
| Line 18 static const char* IDENT_REQUEST_H="$Dat | Line 18 static const char* IDENT_REQUEST_H="$Dat |
| #include "pa_request_info.h" | #include "pa_request_info.h" |
| #include "pa_request_charsets.h" | #include "pa_request_charsets.h" |
| #include "pa_sapi.h" | #include "pa_sapi.h" |
| #include "pa_vconsole.h" | |
| #ifdef RESOURCES_DEBUG | #ifdef RESOURCES_DEBUG |
| #include <sys/resource.h> | #include <sys/resource.h> |
| Line 26 static const char* IDENT_REQUEST_H="$Dat | Line 27 static const char* IDENT_REQUEST_H="$Dat |
| // consts | // consts |
| const uint ANTI_ENDLESS_EXECUTE_RECOURSION=1000; | const uint ANTI_ENDLESS_EXECUTE_RECOURSION=1000; |
| const size_t pseudo_file_no__process=1; | |
| // forwards | // forwards |
| class Temp_lang; | class Temp_lang; |
| class Methoded; | class Methoded; |
| class VMethodFrame; | class VMethodFrame; |
| class GdomeDOMString_auto_ptr; | class VMail; |
| class VMail; DECLARE_OBJECT_PTR(VMail); | class VForm; |
| class VForm; DECLARE_OBJECT_PTR(VForm); | class VResponse; |
| class VResponse; DECLARE_OBJECT_PTR(VResponse); | class VCookie; |
| class VCookie; DECLARE_OBJECT_PTR(VCookie); | class VStateless_class; |
| class VStateless_class; DECLARE_OBJECT_PTR(VStateless_class); | |
| /// Main workhorse. | /// Main workhorse. |
| class Request: public PA_Object { | class Request: public PA_Object { |
| Line 45 class Request: public PA_Object { | Line 46 class Request: public PA_Object { |
| friend class Temp_connection; | friend class Temp_connection; |
| friend class Request_context_saver; | friend class Request_context_saver; |
| friend class Temp_request_self; | friend class Temp_request_self; |
| friend class Exception_trace; | |
| public: | |
| class Trace { | |
| const String* fname; | |
| Operation::Origin forigin; | |
| public: | |
| Trace(): fname(0) {} | |
| void clear() { fname=0; } | |
| operator bool() const { return fname!=0; } | |
| Trace(const String* aname, const Operation::Origin aorigin): | |
| fname(aname), forigin(aorigin) {} | |
| const String* name() const { return fname; } | |
| const Operation::Origin origin() const { return forigin; } | |
| }; | |
| enum Skip { | |
| SKIP_NOTHING, | |
| SKIP_BREAK, | |
| SKIP_CONTINUE | |
| }; | |
| private: | |
| Pool fpool; | |
| public: | |
| Pool& pool() { return fpool; } | |
| private: | |
| union StackItem { | |
| Value* fvalue; | |
| ArrayOperation* fops; | |
| VMethodFrame* fmethod_frame; | |
| public: | |
| Value& value() const { return *fvalue; } | |
| const String& string() const { | |
| return fvalue->as_string(); | |
| } | |
| ArrayOperation& ops() const { return *fops; } | |
| VMethodFrame& method_frame() const { return *fmethod_frame; } | |
| /// needed to fill unused Array entries | |
| StackItem() {} | |
| StackItem(Value& avalue): fvalue(&avalue) {} | |
| StackItem(ArrayOperation& aops): fops(&aops) {} | |
| StackItem(VMethodFrame& amethod_frame): fmethod_frame(&amethod_frame) {} | |
| }; | |
| class Exception_trace: public Stack<Trace> { | |
| size_t fbottom; | |
| public: | |
| Exception_trace(): fbottom(0) {} | |
| size_t bottom_index() { return fbottom; } | |
| void set_bottom_index(size_t abottom) { fbottom=abottom; } | |
| element_type bottom_value() { return get(bottom_index()); } | |
| void clear() { | |
| ftop=fbottom=0; | |
| } | |
| bool is_empty() { | |
| return ftop==fbottom; | |
| } | |
| const element_type extract_origin(const String*& problem_source); | |
| }; | |
| ///@{ core data | ///@{ core data |
| Line 52 class Request: public PA_Object { | Line 121 class Request: public PA_Object { |
| HashStringValue fclasses; | HashStringValue fclasses; |
| /// already used files to avoid cyclic uses | /// already used files to avoid cyclic uses |
| Hash<const StringBody&, bool> used_files; | Hash<const String::Body, bool> used_files; |
| /// list of all used files, Operation::file_no = index to it | |
| Array<String::Body> file_list; | |
| /** endless execute(execute(... preventing counter | /** endless execute(execute(... preventing counter |
| @see ANTI_ENDLESS_EXECUTE_RECOURSION | @see ANTI_ENDLESS_EXECUTE_RECOURSION |
| Line 61 class Request: public PA_Object { | Line 132 class Request: public PA_Object { |
| ///@} | ///@} |
| public: | /// execution stack |
| Stack<StackItem> stack; | |
| union StackItem { | |
| const String* string() const { return value->get_string(); } | |
| Value* value; | |
| ArrayOperation* ops; | |
| VMethodFrame* method_frame; | |
| /// needed to fill unused Array entries | /// exception stack trace |
| StackItem() {} | Exception_trace exception_trace; |
| StackItem(Value* avalue): value(avalue) {} | public: |
| StackItem(ArrayOperation* aops): ops(aops) {} | |
| StackItem(VMethodFrame* amethod_frame): method_frame(amethod_frame) {} | |
| }; | |
| //@{ request processing status | //@{ request processing status |
| /// exception stack trace | |
| //Stack<String*> exception_trace; | |
| /// execution stack | |
| Stack<StackItem> stack; | |
| /// contexts | /// contexts |
| VMethodFrame* method_frame; | VMethodFrame* method_frame; |
| Value* rcontext; | Value* rcontext; |
| Line 92 public: | Line 151 public: |
| //@} | //@} |
| /// interrupted flag, raised on signals [SIGPIPE] | /// interrupted flag, raised on signals [SIGPIPE] |
| bool finterrupted; | bool finterrupted; |
| Skip fskip; | |
| public: | public: |
| uint register_file(String::Body file_spec); | |
| struct Exception_details { | |
| const Trace trace; | |
| const String* problem_source; | |
| VHash& vhash; | |
| Exception_details( | |
| const Trace atrace, | |
| const String* aproblem_source, | |
| VHash& avhash): trace(atrace), problem_source(aproblem_source), vhash(avhash) {} | |
| }; | |
| Exception_details get_details(const Exception& e); | |
| const char* get_exception_cstr(const Exception& e, Exception_details& details); | |
| /// @see Stack::wipe_unused | |
| void wipe_unused_execution_stack() { | |
| stack.wipe_unused(); | |
| } | |
| #ifdef RESOURCES_DEBUG | #ifdef RESOURCES_DEBUG |
| /// measures | /// measures |
| Line 127 public: | Line 206 public: |
| // anti_endless_execute_recoursion | // anti_endless_execute_recoursion |
| if(++anti_endless_execute_recoursion==ANTI_ENDLESS_EXECUTE_RECOURSION) { | if(++anti_endless_execute_recoursion==ANTI_ENDLESS_EXECUTE_RECOURSION) { |
| anti_endless_execute_recoursion=0; // give @exception a chance | anti_endless_execute_recoursion=0; // give @exception a chance |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| 0, //&name, | 0, //&name, |
| "call canceled - endless recursion detected"); | "call canceled - endless recursion detected"); |
| } | } |
| Line 138 public: | Line 217 public: |
| /// compiles the file, maybe forcing it's class @a name and @a base_class. | /// compiles the file, maybe forcing it's class @a name and @a base_class. |
| void use_file(VStateless_class& aclass, | void use_file(VStateless_class& aclass, |
| const String& file_name, | const String& file_name, |
| const String* main_alias=0, | |
| bool ignore_class_path=false, | bool ignore_class_path=false, |
| bool fail_on_read_problem=true, bool fail_on_file_absence=true); // pa_request.C | bool fail_on_read_problem=true, |
| bool fail_on_file_absence=true); // pa_request.C | |
| /// compiles a @a source buffer | /// compiles a @a source buffer |
| void use_buf(VStateless_class& aclass, | void use_buf(VStateless_class& aclass, |
| const char* source, | const char* source, |
| const String& filespec, const char* filespec_cstr); // pa_request.C | const String* main_alias, |
| uint file_no, | |
| int line_no_offset=0); // pa_request.C | |
| /// processes any code-junction there may be inside of @a value | /// processes any code-junction there may be inside of @a value |
| StringOrValue process(Value& input_value, bool intercept_string=true); // execute.C | StringOrValue process(Value& input_value, bool intercept_string=true); // execute.C |
| Line 209 public: | Line 292 public: |
| const String& mime_type_of(const char* user_file_name_cstr); | const String& mime_type_of(const char* user_file_name_cstr); |
| /// returns current SQL connection if any | /// returns current SQL connection if any |
| SQL_Connection* connection(const String* source) { | SQL_Connection* connection(bool fail_on_error=true) { |
| if(!fconnection && source) | if(fail_on_error && !fconnection) |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| source, | 0, |
| "outside of 'connect' operator"); | "outside of 'connect' operator"); |
| return fconnection; | return fconnection; |
| Line 221 public: | Line 304 public: |
| void set_interrupted(bool ainterrupted) { finterrupted=ainterrupted; } | void set_interrupted(bool ainterrupted) { finterrupted=ainterrupted; } |
| bool get_interrupted() { return finterrupted; } | bool get_interrupted() { return finterrupted; } |
| void set_skip(Skip askip) { fskip=askip; } | |
| Skip get_skip() { return fskip; } | |
| public: | public: |
| /// info from web server | /// info from web server |
| Line 242 public: | Line 328 public: |
| VResponse& response; | VResponse& response; |
| /// $cookie:elements | /// $cookie:elements |
| VCookie& cookie; | VCookie& cookie; |
| /// $console | |
| VConsole& console; | |
| /// classes configured data | /// classes configured data |
| HashStringObject classes_conf; | Hash<const String::Body, void*> classes_conf; |
| public: // status read methods | public: // status read methods |
| Line 260 public: // status read methods | Line 348 public: // status read methods |
| } | } |
| */ | */ |
| /// for @main[] | |
| const String* execute_virtual_method(Value& aself, const String& method_name); | |
| /// for @postprocess[body] | |
| StringOrValue execute_method(VMethodFrame& amethodFrame, const Method& method); | |
| //{ for @conf[filespec] and @auto[filespec] and parser://method/call | |
| const String* execute_method(Value& aself, | |
| const Method& method, VString* optional_param, | |
| bool do_return_string); | |
| struct Execute_nonvirtual_method_result { | |
| const String* string; | |
| Method* method; | |
| Execute_nonvirtual_method_result(): string(0), method(0) {} | |
| }; | |
| Execute_nonvirtual_method_result execute_nonvirtual_method(VStateless_class& aclass, | |
| const String& method_name, | |
| VString* optional_param, | |
| bool do_return_string); | |
| //} | |
| #ifdef XML | #ifdef XML |
| public: // charset helpers | public: // charset helpers |
| /// @see Charset::transcode | /// @see Charset::transcode |
| GdomeDOMString_auto_ptr transcode(const String& s); | xmlChar* transcode(const String& s); |
| /// @see Charset::transcode | /// @see Charset::transcode |
| const String& transcode(GdomeDOMString* s | xmlChar* transcode(const String::Body s); |
| #ifndef NO_STRING_ORIGIN | |
| , const String& origin | |
| #endif | |
| ); | |
| /// @see Charset::transcode | /// @see Charset::transcode |
| const String& transcode(xmlChar* s | const String& transcode(const xmlChar* s); |
| #ifndef NO_STRING_ORIGIN | |
| , const String& origin | |
| #endif | |
| ); | |
| #endif | #endif |
| Line 287 private: | Line 387 private: |
| void configure_admin(VStateless_class& conf_class); | void configure_admin(VStateless_class& conf_class); |
| void configure(); | |
| private: // compile.C | private: // compile.C |
| VStateless_class& compile(VStateless_class* aclass, const char* source, const char* file); | VStateless_class& compile(VStateless_class* aclass, |
| const char* source, const String* main_alias, | |
| uint file_no, | |
| int line_no_offset); | |
| private: // execute.C | private: // execute.C |
| /// for @postprocess[body] | void put_element(Value& ncontext, const String& name, Value& value); |
| const String& execute_method(VMethodFrame& amethodFrame, const Method& method); | Value& get_element(Value& ncontext, const String& name, bool can_call_operator); |
| //{ for @conf[filespec] and @auto[filespec] | |
| const String* execute_method(Value& aself, | |
| const Method& method, VString* optional_param, | |
| bool do_return_string); | |
| struct Execute_nonvirtual_method_result { | |
| const String* string; | |
| Method* method; | |
| Execute_nonvirtual_method_result(): string(0), method(0) {} | |
| }; | |
| Execute_nonvirtual_method_result execute_nonvirtual_method(VStateless_class& aclass, | |
| const String& method_name, VString* optional_param, | |
| bool do_return_string); | |
| //} | |
| /// for @main[] | |
| const String* execute_virtual_method(Value& aself, const String& method_name); | |
| Value* get_element(bool can_call_operator); | |
| private: // defaults | private: // defaults |
| Line 354 class Request_context_saver { | Line 442 class Request_context_saver { |
| Request& fr; | Request& fr; |
| /// exception stack trace | /// exception stack trace |
| int exception_trace; | size_t exception_trace_top; |
| size_t exception_trace_bottom; | |
| /// execution stack | /// execution stack |
| int stack; | size_t stack; |
| uint anti_endless_execute_recoursion; | |
| /// contexts | /// contexts |
| VMethodFrame *method_frame; | VMethodFrame* method_frame; |
| Value *rcontext; | Value* rcontext; |
| WContext *wcontext; | WContext* wcontext; |
| /// current language | /// current language |
| String::Language flang; | String::Language flang; |
| /// current connection | /// current connection |
| Line 368 class Request_context_saver { | Line 458 class Request_context_saver { |
| public: | public: |
| Request_context_saver(Request& ar) : | Request_context_saver(Request& ar) : |
| //exception_trace(ar.exception_trace.top_index()), | fr(ar), |
| exception_trace_top(ar.exception_trace.top_index()), | |
| exception_trace_bottom(ar.exception_trace.bottom_index()), | |
| stack(ar.stack.top_index()), | stack(ar.stack.top_index()), |
| anti_endless_execute_recoursion(ar.anti_endless_execute_recoursion), | |
| method_frame(ar.method_frame), | method_frame(ar.method_frame), |
| rcontext(ar.rcontext), | rcontext(ar.rcontext), |
| wcontext(ar.wcontext), | wcontext(ar.wcontext), |
| flang(ar.flang), | flang(ar.flang), |
| fconnection(ar.fconnection), | fconnection(ar.fconnection) {} |
| fr(ar) {} | |
| void restore() { | void restore() { |
| //fr.exception_trace.top_index(exception_trace); | fr.exception_trace.set_top_index(exception_trace_top); |
| fr.stack.top_index(stack); | fr.exception_trace.set_bottom_index(exception_trace_bottom); |
| fr.stack.set_top_index(stack); | |
| fr.anti_endless_execute_recoursion=anti_endless_execute_recoursion; | |
| fr.method_frame=method_frame, fr.rcontext=rcontext; fr.wcontext=wcontext; | fr.method_frame=method_frame, fr.rcontext=rcontext; fr.wcontext=wcontext; |
| fr.flang=flang; | fr.flang=flang; |
| fr.fconnection=fconnection; | fr.fconnection=fconnection; |
| Line 416 public: | Line 510 public: |
| // defines for externs | // defines for externs |
| #define CONTENT_TRANSFER_ENCODING_NAME "content-transfer-encoding" | |
| #define CONTENT_DISPOSITION_NAME "content-disposition" | #define CONTENT_DISPOSITION_NAME "content-disposition" |
| #define CONTENT_DISPOSITION_VALUE "attachment" | #define CONTENT_DISPOSITION_ATTACHMENT "attachment" |
| #define CONTENT_DISPOSITION_INLINE "inline" | |
| #define CONTENT_DISPOSITION_FILENAME_NAME "filename" | #define CONTENT_DISPOSITION_FILENAME_NAME "filename" |
| #define EXCEPTION_HANDLED_PART_NAME "handled" | |
| // externs | // externs |
| extern const String main_method_name; | extern const String main_method_name; |
| extern const String auto_method_name; | extern const String auto_method_name; |
| extern const String body_name; | extern const String body_name; |
| extern const String content_transfer_encoding_name; | |
| extern const String content_disposition_name; | extern const String content_disposition_name; |
| extern const String content_disposition_value; | extern const String content_disposition_attachment; |
| extern const String content_disposition_inline; | |
| extern const String content_disposition_filename_name; | extern const String content_disposition_filename_name; |
| extern const String exception_type_part_name; | |
| extern const String exception_source_part_name; | |
| extern const String exception_comment_part_name; | |
| extern const String exception_handled_part_name; | |
| // defines for statics | // defines for statics |
| #define MAIN_CLASS_NAME "MAIN" | #define MAIN_CLASS_NAME "MAIN" |