|
|
| version 1.160.2.37.2.19, 2003/04/03 06:54:27 | version 1.180.8.1, 2006/04/09 12:25:04 |
|---|---|
| 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 25 static const char* IDENT_REQUEST_H="$Dat | Line 26 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 45 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; } | |
| }; | |
| private: | |
| Pool fpool; | |
| public: | |
| Pool& pool() { return fpool; } | |
| private: | |
| union StackItem { | union StackItem { |
| Value* fvalue; | Value* fvalue; |
| ArrayOperation* fops; | ArrayOperation* fops; |
| Line 52 class Request: public PA_Object { | Line 76 class Request: public PA_Object { |
| 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 66 class Request: public PA_Object { | Line 88 class Request: public PA_Object { |
| StackItem(VMethodFrame& amethod_frame): fmethod_frame(&amethod_frame) {} | StackItem(VMethodFrame& amethod_frame): fmethod_frame(&amethod_frame) {} |
| }; | }; |
| class Trace { | class Exception_trace: public Stack<Trace> { |
| const String* fname; | size_t fbottom; |
| Operation::Info forigin; | |
| public: | public: |
| Trace(const String* aname, Operation::Info aorigin): | Exception_trace(): fbottom(0) {} |
| fname(aname), forigin(aorigin) {} | |
| const String* name() { return fname; } | size_t bottom_index() { return fbottom; } |
| Operation::Info origin() { return forigin; } | 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 83 class Request: public PA_Object { | Line 114 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 | /// list of all used files, Operation::file_no = index to it |
| Array<StringBody> file_list; | 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 98 class Request: public PA_Object { | Line 129 class Request: public PA_Object { |
| Stack<StackItem> stack; | Stack<StackItem> stack; |
| /// exception stack trace | /// exception stack trace |
| Stack<Trace> exception_trace; | Exception_trace exception_trace; |
| public: | public: |
| //@{ request processing status | //@{ request processing status |
| Line 113 public: | Line 144 public: |
| //@} | //@} |
| /// interrupted flag, raised on signals [SIGPIPE] | /// interrupted flag, raised on signals [SIGPIPE] |
| bool finterrupted; | bool finterrupted; |
| int fbreak; | |
| 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 164 public: | Line 210 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, |
| uint file_no); // 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 247 public: | Line 297 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_break(int abreak) { fbreak=abreak; } | |
| int get_break() { return fbreak; } | |
| public: | public: |
| /// info from web server | /// info from web server |
| Line 270 public: | Line 323 public: |
| VCookie& cookie; | VCookie& cookie; |
| /// 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 286 public: // status read methods | Line 339 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 307 private: | Line 377 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, uint file_no); | 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); | |
| //{ 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(Value& ncontext, const String& name, bool can_call_operator); | Value& get_element(Value& ncontext, const String& name, bool can_call_operator); |
| private: // defaults | private: // defaults |
| Line 374 class Request_context_saver { | Line 432 class Request_context_saver { |
| Request& fr; | Request& fr; |
| /// exception stack trace | /// exception stack trace |
| size_t exception_trace; | size_t exception_trace_top; |
| size_t exception_trace_bottom; | |
| /// execution stack | /// execution stack |
| size_t stack; | size_t stack; |
| uint anti_endless_execute_recoursion; | |
| /// contexts | /// contexts |
| VMethodFrame* method_frame; | VMethodFrame* method_frame; |
| Value* rcontext; | Value* rcontext; |
| Line 388 class Request_context_saver { | Line 448 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 439 public: | Line 503 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_FILENAME_NAME "filename" | #define CONTENT_DISPOSITION_FILENAME_NAME "filename" |
| #define EXCEPTION_HANDLED_PART_NAME "handled" | |
| // externs | // externs |
| Line 449 extern const String content_disposition_ | Line 515 extern const String content_disposition_ |
| extern const String content_disposition_value; | extern const String content_disposition_value; |
| 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" |