--- parser3/src/include/pa_request.h 2016/11/29 14:32:32 1.243 +++ parser3/src/include/pa_request.h 2017/02/01 14:40:10 1.248 @@ -8,7 +8,7 @@ #ifndef PA_REQUEST_H #define PA_REQUEST_H -#define IDENT_PA_REQUEST_H "$Id: pa_request.h,v 1.243 2016/11/29 14:32:32 moko Exp $" +#define IDENT_PA_REQUEST_H "$Id: pa_request.h,v 1.248 2017/02/01 14:40:10 moko Exp $" #include "pa_pool.h" #include "pa_hash.h" @@ -35,8 +35,9 @@ class VCookie; class VStateless_class; class VConsole; -extern int pa_execute_recoursion_limit; extern int pa_loop_limit; +extern int pa_execute_recoursion_limit; +extern size_t pa_file_size_limit; /// Main workhorse. class Request: public PA_Object { @@ -64,8 +65,10 @@ public: enum Skip { SKIP_NOTHING, + SKIP_CONTINUE, SKIP_BREAK, - SKIP_CONTINUE + SKIP_RETURN, + SKIP_INTERRUPTED }; private: @@ -146,10 +149,12 @@ public: /// current connection SQL_Connection* fconnection; //@} - /// interrupted flag, raised on signals [SIGPIPE] - bool finterrupted; - Skip fskip; + +private: + int fin_cycle; + Skip fskip; + VMethodFrame* freturn_method_frame; public: uint register_file(String::Body file_spec); @@ -253,6 +258,7 @@ public: 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_used_filespec(uint file_no); @@ -291,11 +297,11 @@ public: 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; } + 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; } bool get_in_cycle() { return fin_cycle>0; } @@ -393,17 +399,6 @@ private: // mime types /// $MAIN: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 SQL_Connection* set_connection(SQL_Connection* aconnection) { @@ -488,6 +483,23 @@ 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. class Temp_class_replace { Request& frequest;