|
|
| version 1.181, 2006/04/09 13:38:47 | version 1.203, 2010/08/11 16:21:52 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: request class decl. | Parser: request class decl. |
| Copyright (c) 2001-2005 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2009 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 18 static const char * const IDENT_REQUEST_ | Line 18 static const char * const IDENT_REQUEST_ |
| #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 104 private: | Line 105 private: |
| element_type bottom_value() { return get(bottom_index()); } | element_type bottom_value() { return get(bottom_index()); } |
| void clear() { | void clear() { |
| ftop=fbottom=0; | fused=fbottom=0; |
| } | } |
| bool is_empty() { | bool is_empty() { |
| return ftop==fbottom; | return fused==fbottom; |
| } | } |
| const element_type extract_origin(const String*& problem_source); | const element_type extract_origin(const String*& problem_source); |
| Line 117 private: | Line 118 private: |
| ///@{ core data | ///@{ core data |
| /// classes | /// classes |
| HashStringValue fclasses; | HashString<Value*> fclasses; |
| /// already used files to avoid cyclic uses | /// already used files to avoid cyclic uses |
| Hash<const String::Body, bool> used_files; | HashString<bool> used_files; |
| HashString<bool> searched_along_class_path; | |
| /// list of all used files, Operation::file_no = index to it | /// list of all used files, Operation::file_no = index to it |
| Array<String::Body> file_list; | Array<String::Body> file_list; |
| Line 151 public: | Line 153 public: |
| /// interrupted flag, raised on signals [SIGPIPE] | /// interrupted flag, raised on signals [SIGPIPE] |
| bool finterrupted; | bool finterrupted; |
| Skip fskip; | Skip fskip; |
| int fin_cycle; | |
| public: | public: |
| uint register_file(String::Body file_spec); | uint register_file(String::Body file_spec); |
| Line 186 public: | Line 189 public: |
| ~Request(); | ~Request(); |
| /// global classes | /// global classes |
| HashStringValue& classes() { return fclasses; } | HashString<Value*>& classes() { return fclasses; } |
| Value* get_class(const String& name); | |
| /** | /** |
| core request processing | core request processing |
| Line 200 public: | Line 204 public: |
| /// executes ops | /// executes ops |
| void execute(ArrayOperation& ops); // execute.C | void execute(ArrayOperation& ops); // execute.C |
| void op_call(VMethodFrame &frame); | |
| void op_call_write(VMethodFrame &frame); | |
| Value& construct(Value &class_value, const Method &method); | |
| /// execute ops with anti-recoursion check | /// execute ops with anti-recoursion check |
| void recoursion_checked_execute(/*const String& name, */ArrayOperation& ops) { | void recoursion_checked_execute(/*const String& name, */ArrayOperation& ops) { |
| // 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 213 public: | Line 221 public: |
| anti_endless_execute_recoursion--; | anti_endless_execute_recoursion--; |
| } | } |
| /// | |
| void use_file_directly(VStateless_class& aclass, | |
| const String& file_spec, | |
| bool fail_on_read_problem=true, | |
| bool fail_on_file_absence=true); | |
| /// 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, | const String* use_filespec); |
| bool ignore_class_path=false, | |
| 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* main_alias, | const String* main_alias, |
| uint file_no, | uint file_no, |
| int line_no_offset=0); // pa_request.C | int line_no_offset=0); |
| /// processes any code-junction there may be inside of @a value | /// processes any code-junction there may be inside of @a value |
| StringOrValue process_getter(Junction& junction); // execute.C | |
| StringOrValue process(Value& input_value, bool intercept_string=true); // execute.C | StringOrValue process(Value& input_value, bool intercept_string=true); // execute.C |
| void process_write(Value& input_value); // execute.C | |
| //@{ convinient helpers | //@{ convinient helpers |
| const String& process_to_string(Value& input_value) { | const String& process_to_string(Value& input_value) { |
| return process(input_value, true/*intercept_string*/).as_string(); | return process(input_value, true/*intercept_string*/).as_string(); |
| Line 237 public: | Line 251 public: |
| return process(input_value, intercept_string).as_value(); | return process(input_value, intercept_string).as_value(); |
| } | } |
| //@} | //@} |
| const String* get_method_filename(const Method* method); // execute.C | |
| const String* get_used_filename(uint file_no); | |
| #define DEFINE_DUAL(modification) \ | #define DEFINE_DUAL(modification) \ |
| void write_##modification##_lang(StringOrValue dual) { \ | void write_##modification##_lang(StringOrValue dual) { \ |
| Line 293 public: | Line 308 public: |
| /// returns current SQL connection if any | /// returns current SQL connection if any |
| SQL_Connection* connection(bool fail_on_error=true) { | SQL_Connection* connection(bool fail_on_error=true) { |
| if(fail_on_error && !fconnection) | if(fail_on_error && !fconnection) |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| 0, | 0, |
| "outside of 'connect' operator"); | "outside of 'connect' operator"); |
| Line 306 public: | Line 321 public: |
| void set_skip(Skip askip) { fskip=askip; } | void set_skip(Skip askip) { fskip=askip; } |
| Skip get_skip() { return fskip; } | Skip get_skip() { return fskip; } |
| void set_in_cycle(int adelta) { fin_cycle+=adelta; } | |
| bool get_in_cycle() { return fin_cycle>0; } | |
| public: | public: |
| /// info from web server | /// info from web server |
| Line 327 public: | Line 345 public: |
| VResponse& response; | VResponse& response; |
| /// $cookie:elements | /// $cookie:elements |
| VCookie& cookie; | VCookie& cookie; |
| /// $console | |
| VConsole& console; | |
| /// classes configured data | /// classes configured data |
| Hash<const String::Body, void*> classes_conf; | HashString<void*> classes_conf; |
| public: // status read methods | public: // status read methods |
| Line 352 public: // status read methods | Line 372 public: // status read methods |
| StringOrValue execute_method(VMethodFrame& amethodFrame, const Method& method); | StringOrValue execute_method(VMethodFrame& amethodFrame, const Method& method); |
| //{ for @conf[filespec] and @auto[filespec] and parser://method/call | //{ for @conf[filespec] and @auto[filespec] and parser://method/call |
| const String* execute_method(Value& aself, | const String* execute_method(Value& aself, |
| const Method& method, VString* optional_param, | const Method& method, Value* optional_param, |
| bool do_return_string); | bool do_return_string); |
| struct Execute_nonvirtual_method_result { | struct Execute_nonvirtual_method_result { |
| const String* string; | const String* string; |
| Line 360 public: // status read methods | Line 380 public: // status read methods |
| Execute_nonvirtual_method_result(): string(0), method(0) {} | Execute_nonvirtual_method_result(): string(0), method(0) {} |
| }; | }; |
| Execute_nonvirtual_method_result execute_nonvirtual_method(VStateless_class& aclass, | Execute_nonvirtual_method_result execute_nonvirtual_method(VStateless_class& aclass, |
| const String& method_name, VString* optional_param, | const String& method_name, |
| VString* optional_param, | |
| bool do_return_string); | bool do_return_string); |
| //} | //} |
| Line 387 private: | Line 408 private: |
| private: // compile.C | private: // compile.C |
| VStateless_class& compile(VStateless_class* aclass, | ArrayClass& compile(VStateless_class* aclass, |
| const char* source, const String* main_alias, | const char* source, const String* main_alias, |
| uint file_no, | uint file_no, |
| int line_no_offset); | int line_no_offset); |
| private: // execute.C | private: // execute.C |
| void put_element(Value& ncontext, const String& name, Value& value); | void put_element(Value& ncontext, const String& name, Value* value); |
| Value& get_element(Value& ncontext, const String& name, bool can_call_operator); | Value& get_element(Value& ncontext, const String& name); |
| private: // defaults | private: // defaults |
| Line 503 public: | Line 524 public: |
| } | } |
| }; | }; |
| /// Auto-object used for break out of cycle check | |
| class InCycle { | |
| Request& frequest; | |
| public: | |
| InCycle(Request& arequest) : frequest(arequest) { | |
| frequest.set_in_cycle(1); | |
| } | |
| ~InCycle() { | |
| frequest.set_in_cycle(-1); | |
| } | |
| }; | |
| // defines for externs | // defines for externs |
| #define CONTENT_DISPOSITION_NAME "content-disposition" | |
| #define CONTENT_DISPOSITION_VALUE "attachment" | |
| #define CONTENT_DISPOSITION_FILENAME_NAME "filename" | |
| #define EXCEPTION_HANDLED_PART_NAME "handled" | #define EXCEPTION_HANDLED_PART_NAME "handled" |
| Line 517 public: | Line 546 public: |
| 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_disposition_name; | |
| extern const String content_disposition_value; | |
| extern const String content_disposition_filename_name; | |
| extern const String exception_type_part_name; | extern const String exception_type_part_name; |
| extern const String exception_source_part_name; | extern const String exception_source_part_name; |