|
|
| version 1.160.2.37.2.15, 2003/04/02 09:32:11 | version 1.183, 2007/02/17 11:50:19 |
|---|---|
| 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_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 17 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 25 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; |
| class VForm; | class VForm; |
| class VResponse; | class VResponse; |
| Line 44 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; | |
| ///@{ core data | public: |
| class Trace { | |
| const String* fname; | |
| Operation::Origin forigin; | |
| public: | |
| Trace(): fname(0) {} | |
| void clear() { fname=0; } | |
| operator bool() const { return fname!=0; } | |
| /// classes | Trace(const String* aname, const Operation::Origin aorigin): |
| HashStringValue fclasses; | fname(aname), forigin(aorigin) {} |
| /// already used files to avoid cyclic uses | const String* name() const { return fname; } |
| Hash<const StringBody, bool> used_files; | const Operation::Origin origin() const { return forigin; } |
| }; | |
| /** endless execute(execute(... preventing counter | enum Skip { |
| @see ANTI_ENDLESS_EXECUTE_RECOURSION | SKIP_NOTHING, |
| */ | SKIP_BREAK, |
| uint anti_endless_execute_recoursion; | SKIP_CONTINUE |
| }; | |
| ///@} | private: |
| Pool fpool; | |
| public: | |
| Pool& pool() { return fpool; } | |
| private: | |
| union StackItem { | union StackItem { |
| private: | |
| Value* fvalue; | Value* fvalue; |
| ArrayOperation* fops; | ArrayOperation* fops; |
| VMethodFrame* fmethod_frame; | VMethodFrame* fmethod_frame; |
| public: | public: |
| Value& value() const { return *fvalue; } | Value& value() const { return *fvalue; } |
| const String& string() const { | const String& string() const { |
| const String* result=fvalue->get_string(); | return fvalue->as_string(); |
| assert(result); | |
| return *result; | |
| } | } |
| ArrayOperation& ops() const { return *fops; } | ArrayOperation& ops() const { return *fops; } |
| VMethodFrame& method_frame() const { return *fmethod_frame; } | VMethodFrame& method_frame() const { return *fmethod_frame; } |
| Line 82 class Request: public PA_Object { | Line 95 class Request: public PA_Object { |
| StackItem(VMethodFrame& amethod_frame): fmethod_frame(&amethod_frame) {} | 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 | |
| /// classes | |
| HashStringValue fclasses; | |
| /// already used files to avoid cyclic uses | |
| 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 | |
| @see ANTI_ENDLESS_EXECUTE_RECOURSION | |
| */ | |
| uint anti_endless_execute_recoursion; | |
| ///@} | |
| /// execution stack | /// execution stack |
| Stack<StackItem> stack; | Stack<StackItem> stack; |
| /// exception stack trace | |
| Exception_trace exception_trace; | |
| public: | public: |
| //@{ request processing status | //@{ request processing status |
| /// exception stack trace | |
| //Stack<String*> exception_trace; | |
| /// contexts | /// contexts |
| VMethodFrame* method_frame; | VMethodFrame* method_frame; |
| Value* rcontext; | Value* rcontext; |
| Line 101 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 | /// @see Stack::wipe_unused |
| void wipe_unused_execution_stack() { | void wipe_unused_execution_stack() { |
| stack.wipe_unused(); | stack.wipe_unused(); |
| Line 152 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 235 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 256 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 274 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 | |
| GdomeDOMString_auto_ptr transcode(const StringBody s); | |
| /// @see Charset::transcode | /// @see Charset::transcode |
| const String& transcode(GdomeDOMString* s); | xmlChar* transcode(const String::Body s); |
| /// @see Charset::transcode | /// @see Charset::transcode |
| const String& transcode(xmlChar* s); | const String& transcode(const xmlChar* s); |
| #endif | #endif |
| Line 295 private: | Line 386 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 362 class Request_context_saver { | Line 441 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 376 class Request_context_saver { | Line 457 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 426 public: | Line 511 public: |
| #define CONTENT_DISPOSITION_NAME "content-disposition" | #define CONTENT_DISPOSITION_NAME "content-disposition" |
| #define CONTENT_DISPOSITION_VALUE "attachment" | #define CONTENT_DISPOSITION_VALUE "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 |
| Line 435 extern const String auto_method_name; | Line 523 extern const String auto_method_name; |
| extern const String body_name; | extern const String body_name; |
| extern const String content_disposition_name; | extern const String content_disposition_name; |
| extern const String content_disposition_value; | extern const String content_disposition_value; |
| 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" |