|
|
| version 1.244, 2016/12/29 15:24:49 | version 1.254, 2020/10/29 16:02:21 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: request class decl. | Parser: request class decl. |
| Copyright (c) 2001-2015 Art. Lebedev Studio (http://www.artlebedev.com) | Copyright (c) 2001-2017 Art. Lebedev Studio (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 65 public: | Line 65 public: |
| enum Skip { | enum Skip { |
| SKIP_NOTHING, | SKIP_NOTHING, |
| SKIP_CONTINUE, | |
| SKIP_BREAK, | SKIP_BREAK, |
| SKIP_CONTINUE | SKIP_RETURN, |
| SKIP_INTERRUPTED | |
| }; | }; |
| private: | private: |
| Line 87 private: | Line 89 private: |
| ArrayOperation& ops() const { return *fops; } | ArrayOperation& ops() const { return *fops; } |
| VMethodFrame& method_frame() const { return *fmethod_frame; } | VMethodFrame& method_frame() const { return *fmethod_frame; } |
| /// needed to fill unused Array entries | |
| StackItem() {} | |
| StackItem(Value& avalue): fvalue(&avalue) {} | StackItem(Value& avalue): fvalue(&avalue) {} |
| StackItem(ArrayOperation& aops): fops(&aops) {} | StackItem(ArrayOperation& aops): fops(&aops) {} |
| StackItem(VMethodFrame& amethod_frame): fmethod_frame(&amethod_frame) {} | StackItem(VMethodFrame& amethod_frame): fmethod_frame(&amethod_frame) {} |
| Line 147 public: | Line 147 public: |
| /// current connection | /// current connection |
| SQL_Connection* fconnection; | SQL_Connection* fconnection; |
| //@} | //@} |
| /// interrupted flag, raised on signals [SIGPIPE] | |
| bool finterrupted; | private: |
| Skip fskip; | |
| int fin_cycle; | int fin_cycle; |
| Skip fskip; | |
| VMethodFrame* freturn_method_frame; | |
| public: | public: |
| uint register_file(String::Body file_spec); | uint register_file(String::Body file_spec); |
| Line 189 public: | Line 191 public: |
| core request processing | core request processing |
| BEWARE: may throw exception to you: catch it! | BEWARE: may throw exception to you: catch it! |
| */ | */ |
| void core(const char* config_filespec, bool config_fail_on_read_problem, bool header_only); | void core(const char* config_filespec, bool header_only); |
| /// executes ops | /// executes ops |
| void execute(ArrayOperation& ops); // execute.C | void execute(ArrayOperation& ops); // execute.C |
| Line 233 public: | Line 235 public: |
| } | } |
| /// | /// |
| void use_file_directly(VStateless_class& aclass, const String& file_spec, bool fail_on_read_problem=true, bool fail_on_file_absence=true); | void use_file_directly(VStateless_class& aclass, const String& file_spec, bool fail_on_file_absence=true, bool with_auto_p=false); |
| /// 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, const String& file_name, const String* use_filespec); | void use_file(VStateless_class& aclass, const String& file_name, const String* use_filespec, bool with_auto_p=false); |
| /// for @USE only, calls ^use (which may be user-defined) | /// for @USE only, calls ^use (which may be user-defined) |
| void use_file(const String& file_name, const String* use_filespec, Operation::Origin origin); | void use_file(const String& file_name, const String* use_filespec, Operation::Origin origin); |
| Line 254 public: | Line 256 public: |
| return process(input_value).as_string(); | return process(input_value).as_string(); |
| } | } |
| //@} | //@} |
| const Operation::Origin get_method_origin(const Method* method); // execute.C | |
| const String* get_method_filespec(const Method* method); // execute.C | const String* get_method_filespec(const Method* method); // execute.C |
| const String* get_used_filespec(uint file_no); | const String* get_used_filespec(uint file_no); |
| Line 292 public: | Line 295 public: |
| return fconnection; | return fconnection; |
| } | } |
| void set_interrupted(bool ainterrupted) { finterrupted=ainterrupted; } | |
| bool get_interrupted() { return finterrupted; } | |
| void set_skip(Skip askip) { fskip=askip; } | |
| Skip get_skip() { return fskip; } | Skip get_skip() { return fskip; } |
| void set_skip(Skip askip) { fskip=askip; } | |
| void set_skip_return(VMethodFrame& amethod_frame) { fskip=SKIP_RETURN; freturn_method_frame=&amethod_frame; } | |
| inline bool check_skip_break() { bool result=fskip >= SKIP_BREAK; if(fskip <= SKIP_BREAK) fskip=SKIP_NOTHING; return result; } | |
| inline void check_skip_return() { if(fskip==SKIP_RETURN && method_frame==freturn_method_frame) fskip=SKIP_NOTHING; } | |
| void set_in_cycle(int adelta) { fin_cycle+=adelta; } | void set_in_cycle(int adelta) { fin_cycle+=adelta; } |
| bool get_in_cycle() { return fin_cycle>0; } | bool get_in_cycle() { return fin_cycle>0; } |
| Line 338 public: // status read methods | Line 341 public: // status read methods |
| /// public for ^reflection:copy[] | /// public for ^reflection:copy[] |
| void put_element(Value& ncontext, const String& name, Value* value); | void put_element(Value& ncontext, const String& name, Value* value); |
| /// for @main[] | /// for @main[] and parser://method/call |
| const String* execute_virtual_method(Value& aself, const String& method_name); | const String* execute_method(VStateless_class& aclass, const String& method_name, Value* optional_param = 0); |
| //{ for @conf[filespec] and @auto[filespec] and parser://method/call | //{ for @conf[filespec] and @auto[filespec] |
| const String* execute_method(Value& aself, const Method& method, Value* optional_param, bool do_return_string); | bool execute_method_if_exists(VStateless_class& aclass, const String& method_name, Value* optional_param); |
| 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 |
| Line 394 private: // mime types | Line 390 private: // mime types |
| /// $MAIN:MIME-TYPES | /// $MAIN:MIME-TYPES |
| Table *mime_types; | Table *mime_types; |
| private: // lang manipulation | |
| String::Language set_lang(String::Language alang) { | |
| String::Language result=flang; | |
| flang=alang; | |
| return result; | |
| } | |
| void restore_lang(String::Language alang) { | |
| flang=alang; | |
| } | |
| private: // connection manipulation | private: // connection manipulation |
| SQL_Connection* set_connection(SQL_Connection* aconnection) { | SQL_Connection* set_connection(SQL_Connection* aconnection) { |
| Line 489 public: | Line 474 public: |
| } | } |
| }; | }; |
| /// Auto-object used for break out of cycle check | |
| class TempSkip4Delimiter { | |
| Request& frequest; | |
| Request::Skip fskip; | |
| public: | |
| TempSkip4Delimiter(Request& arequest) : frequest(arequest), fskip(arequest.get_skip()) { | |
| frequest.set_skip(Request::SKIP_NOTHING); | |
| } | |
| // returns true if break required, should be called | |
| bool check_break() { | |
| if(frequest.get_skip()) | |
| fskip=frequest.get_skip(); | |
| frequest.set_skip(fskip <= Request::SKIP_BREAK ? Request::SKIP_NOTHING : fskip); | |
| return fskip >= Request::SKIP_BREAK; | |
| } | |
| }; | |
| /// Auto-object used for temporary changing Request::allow_class_replace. | /// Auto-object used for temporary changing Request::allow_class_replace. |
| class Temp_class_replace { | class Temp_class_replace { |
| Request& frequest; | Request& frequest; |