[BACK]Return to pa_request.h CVS log [TXT] [DIR] Up to [parser3project] / parser3 / src / include

Diff for /parser3/src/include/pa_request.h between versions 1.274 and 1.287

version 1.274, 2026/09/25 12:55:42 version 1.287, 2026/10/14 23:18:32
Line 12 Line 12
   
 #include "pa_pool.h"  #include "pa_pool.h"
 #include "pa_hash.h"  #include "pa_hash.h"
   #include "pa_file.h"
 #include "pa_wcontext.h"  #include "pa_wcontext.h"
 #include "pa_value.h"  #include "pa_value.h"
 #include "pa_vhash.h"  #include "pa_vhash.h"
Line 36  const size_t pseudo_file_no__process=1; Line 37  const size_t pseudo_file_no__process=1;
   
 // forwards  // forwards
   
 class Temp_lang;  
 class Methoded;  class Methoded;
 class VMethodFrame;  class VMethodFrame;
 class VMail;  class VMail;
Line 53  extern int pa_execute_recursion_limit; Line 53  extern int pa_execute_recursion_limit;
 extern int pa_httpd_timeout;  extern int pa_httpd_timeout;
 extern size_t pa_file_size_limit;  extern size_t pa_file_size_limit;
   
   class Code_cache;
   
 /// Main workhorse.  /// Main workhorse.
 class Request: public PA_Object {  class Request: public PA_Object {
         friend class Temp_lang;  
         friend class Temp_connection;          friend class Temp_connection;
         friend class Temp_request_self;          friend class Temp_request_self;
         friend class Temp_value_element;          friend class Temp_value_element;
Line 63  class Request: public PA_Object { Line 64  class Request: public PA_Object {
         friend class Request_context_saver;          friend class Request_context_saver;
         friend class Exception_trace;          friend class Exception_trace;
         friend class VException;          friend class VException;
           friend class Code_cache_manager;
   
 public:  public:
         class Trace {          class Trace {
Line 128  private: Line 130  private:
                         return fsize==fbottom;                          return fsize==fbottom;
                 }                  }
   
                 Table &table(Request &r, const String* problem_source);                  Table &table(Request &r, const String* problem_source) {
                           return table(r, problem_source, bottom_index(), top_index());
                   }
                   Table &table(Request &r, const String* problem_source, size_t bottom, size_t top);
         };          };
   
         ///@{ core data          ///@{ core data
Line 144  private: Line 149  private:
   
         /// endless execute(execute(... preventing counter          /// endless execute(execute(... preventing counter
         int anti_endless_execute_recursion;          int anti_endless_execute_recursion;
           int execute_recursion_limit;
           void recursion_limit_reached();
   
         ///@}          ///@}
   
Line 161  public: Line 168  public:
         VMethodFrame* method_frame;          VMethodFrame* method_frame;
         Value* rcontext;          Value* rcontext;
         WContext* wcontext;          WContext* wcontext;
         /// current language  
         String::Language flang;  
         /// current connection          /// current connection
         SQL_Connection* fconnection;          SQL_Connection* fconnection;
         //@}          //@}
Line 205  public: Line 210  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 header_only, const String& amain_method_name = main_method_name, const String* amain_class_name = NULL);          void core(const char* config_filespec, const String& amain_method_name = main_method_name, const String* amain_class_name = NULL);
   
           /// ^response:stream[part]: the headers go with the first part, the result of @main or exception is not sent then
           void stream(Value& part);
   
         /// executes ops          /// executes ops
         void execute(ArrayOperation& ops); // execute.C          void execute(ArrayOperation& ops); // execute.C
Line 240  public: Line 248  public:
   
         /// execute ops with anti-recursion check          /// execute ops with anti-recursion check
         void recursion_checked_execute(ArrayOperation& ops) {          void recursion_checked_execute(ArrayOperation& ops) {
                 if(++anti_endless_execute_recursion>=pa_execute_recursion_limit) {                  if(++anti_endless_execute_recursion>=execute_recursion_limit)
                         anti_endless_execute_recursion=0; // give @exception a chance                          recursion_limit_reached();
                         throw Exception(PARSER_RUNTIME, 0, "call canceled - endless recursion detected");  
                 }  
                 execute(ops); // execute it                  execute(ops); // execute it
                 anti_endless_execute_recursion--;                  anti_endless_execute_recursion--;
         }          }
   
           /// take the recovery reserve back if recursion limit is far enough
           void recursion_limit_try_restore() {
                   if(execute_recursion_limit>pa_execute_recursion_limit && anti_endless_execute_recursion<pa_execute_recursion_limit/2)
                           execute_recursion_limit=pa_execute_recursion_limit;
           }
   
         ///          ///
         void use_file_directly(const String& file_spec, bool fail_on_file_absence=true, bool with_auto_p=false);          void use_file_directly(const String& file_spec, bool fail_on_file_absence=true, bool with_auto_p=false);
   
Line 257  public: Line 269  public:
         /// 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);
   
         /// compiles a @a source buffer          /// compiles a @a source buffer, recording it into @a code if given, or replays the cached @a code
         void use_buf(VStateless_class& aclass, const char* source, const String* main_alias, uint file_no, int line_no_offset=0);          void use_buf(VStateless_class& aclass, const char* source, const String* main_alias, uint file_no, int line_no_offset=0, Code_cache* code=0);
   
         /// processes any code-junction there may be inside of @a value          /// processes any code-junction there may be inside of @a value
         Value& process_getter(Junction& junction); // execute.C          Value& process_getter(Junction& junction); // execute.C
Line 293  public: Line 305  public:
         /// returns relative to @a path  path to @a file           /// returns relative to @a path  path to @a file 
         const String& relative(const char* apath, const String& relative_name);          const String& relative(const char* apath, const String& relative_name);
   
         const String& full_disk_path(const String& relative_name);          /// '/'-normalized disk path of a file name; a uri of another scheme is returned as is if allowed, otherwise throws
           const String& full_disk_path(const String& relative_name, uint allowed=0);
           /// '/'-normalized full_disk_path of a real file on disk, which does not throw: 0 for a uri or a remote, invalid or tainted file:// one
           const String* real_disk_path(const String& name);
   
         /// returns the mime type of 'user_file_name'          /// returns the mime type of 'user_file_name'
         const String& mime_type_of(const String* file_name);          const String& mime_type_of(const String* file_name);
Line 386  private: Line 401  private:
   
 private: // compile.C  private: // compile.C
   
         ArrayClass& compile(VStateless_class* aclass, const char* source, const String* main_alias, uint file_no, int line_no_offset);          ArrayClass& compile(VStateless_class* aclass, const char* source, const String* main_alias, uint file_no, int line_no_offset, Code_cache* code);
   
 private: // execute.C  private: // execute.C
   
Line 395  private: // execute.C Line 410  private: // execute.C
         Value& get_element4call(Value& ncontext, const String& name);          Value& get_element4call(Value& ncontext, const String& name);
 #endif  #endif
   
 private: // defaults  
   
         const String::Language fdefault_lang;  
   
 private: // mime types  private: // mime types
   
         /// $MAIN:MIME-TYPES          /// $MAIN:MIME-TYPES
         Table *mime_types;          Table *mime_types;
   
   private: // true if ^response:stream[] was used
   
           bool fheaders_sent;
   
 private: // connection manipulation  private: // connection manipulation
   
         SQL_Connection* set_connection(SQL_Connection* aconnection) {          SQL_Connection* set_connection(SQL_Connection* aconnection) {
Line 425  class VException: public VHashReference Line 440  class VException: public VHashReference
         Exception fexception;          Exception fexception;
         String::Body ffile;          String::Body ffile;
         Value* fhandled;          Value* fhandled;
           size_t ftrace_bottom, ftrace_top;
 public:  public:
         Operation::Origin origin;          Operation::Origin origin;
         const String* problem_source;          const String* problem_source;
Line 436  public: Line 452  public:
         override const VJunction* put_element(const String& name, Value* value);          override const VJunction* put_element(const String& name, Value* value);
   
         Value* handled();          Value* handled();
           Table& stack(Request& r);
           void expire_trace() { ftrace_top=size_t(-1); }
 };  };
   
 /// Auto-object used to save request context across ^try body  /// Auto-object used to save request context across ^try body
Line 444  class Request_context_saver { Line 462  class Request_context_saver {
   
         /// execution stack          /// execution stack
         size_t stack;          size_t stack;
         uint anti_endless_execute_recursion;          int anti_endless_execute_recursion;
         /// contexts          /// contexts
         VMethodFrame* method_frame;          VMethodFrame* method_frame;
         Value* rcontext;          Value* rcontext;
         WContext* wcontext;          WContext* wcontext;
         /// current language  
         String::Language flang;   
         /// current connection          /// current connection
         SQL_Connection* fconnection;          SQL_Connection* fconnection;
   
Line 462  public: Line 478  public:
                 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),  
                 fconnection(ar.fconnection) {}                  fconnection(ar.fconnection) {}
         void restore() {          void restore() {
                 fr.stack.set_top_index(stack);                  fr.stack.set_top_index(stack);
                 fr.anti_endless_execute_recursion=anti_endless_execute_recursion;                  fr.anti_endless_execute_recursion=anti_endless_execute_recursion;
                 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.fconnection=fconnection;                  fr.fconnection=fconnection;
         }          }
 };  };
Removed from v.1.274  
changed lines
  Added in v.1.287

E-mail: