|
version 1.160.2.35, 2003/03/11 08:57:36
|
version 1.204, 2010/08/30 10:49:05
|
|
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-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) |
| */ |
*/ |
| |
|
| #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_pool.h" |
| #include "pa_request_info.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 19 static const char* IDENT_REQUEST_H="$Dat
|
Line 18 static const char* IDENT_REQUEST_H="$Dat
|
| #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 27 static const char* IDENT_REQUEST_H="$Dat
|
Line 27 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; |
| // defines |
|
| |
|
| #ifndef NO_STRING_ORIGIN |
|
| # define COMPILE_PARAMS \ |
|
| VStateless_class* aclass, const char* source \ |
|
| , const char* file |
|
| # define COMPILE(aclass, source, file) \ |
|
| real_compile(aclass, source, file) |
|
| #else |
|
| # define COMPILE_PARAMS \ |
|
| VStateless_class* aclass, const char* source |
|
| # define COMPILE(aclass, source, file) \ |
|
| real_compile(aclass, source) |
|
| #endif |
|
| |
|
| // forwards |
// forwards |
| |
|
| class Temp_lang; |
class Temp_lang; |
| class Methoded; |
class Methoded; |
| class VMethodFrame; |
class VMethodFrame; |
| class GdomeDOMString_auto_ptr; |
class VMail; |
| class VMail; DECLARE_OBJECT_PTR(VMail); |
class VForm; |
| class VForm; DECLARE_OBJECT_PTR(VForm); |
class VResponse; |
| class VResponse; DECLARE_OBJECT_PTR(VResponse); |
class VCookie; |
| class VCookie; DECLARE_OBJECT_PTR(VCookie); |
class VStateless_class; |
| class VStateless_class; DECLARE_OBJECT_PTR(VStateless_class); |
|
| |
|
| /// Main workhorse. |
/// Main workhorse. |
| class Request: public PA_Object { |
class Request: public PA_Object { |
|
Line 61 class Request: public PA_Object {
|
Line 46 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; } |
| |
}; |
| |
|
| |
enum Skip { |
| |
SKIP_NOTHING, |
| |
SKIP_BREAK, |
| |
SKIP_CONTINUE |
| |
}; |
| |
|
| /// all files and classes and other hard-to-place allocations go to this pool |
private: |
| Pool& fpool; |
Pool fpool; |
| |
public: |
| |
Pool& pool() { return fpool; } |
| |
|
| |
private: |
| |
union StackItem { |
| |
Value* fvalue; |
| |
ArrayOperation* fops; |
| |
VMethodFrame* fmethod_frame; |
| |
public: |
| |
Value& value() const { return *fvalue; } |
| |
const String& string() const { |
| |
return fvalue->as_string(); |
| |
} |
| |
ArrayOperation& ops() const { return *fops; } |
| |
VMethodFrame& method_frame() const { return *fmethod_frame; } |
| |
|
| |
/// needed to fill unused Array entries |
| |
StackItem() {} |
| |
StackItem(Value& avalue): fvalue(&avalue) {} |
| |
StackItem(ArrayOperation& aops): fops(&aops) {} |
| |
StackItem(VMethodFrame& amethod_frame): fmethod_frame(&amethod_frame) {} |
| |
}; |
| |
|
| |
class Exception_trace: public Stack<Trace> { |
| |
size_t fbottom; |
| |
public: |
| |
Exception_trace(): fbottom(0) {} |
| |
|
| |
size_t bottom_index() { return fbottom; } |
| |
void set_bottom_index(size_t abottom) { fbottom=abottom; } |
| |
element_type bottom_value() { return get(bottom_index()); } |
| |
|
| |
void clear() { |
| |
fused=fbottom=0; |
| |
} |
| |
|
| |
bool is_empty() { |
| |
return fused==fbottom; |
| |
} |
| |
|
| |
const element_type extract_origin(const String*& problem_source); |
| |
}; |
| |
|
| ///@{ 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<StringPtr, bool> used_files; |
HashString<bool> used_files; |
| |
HashString<bool> searched_along_class_path; |
| |
/// list of all used files, Operation::file_no = index to it |
| |
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 80 class Request: public PA_Object {
|
Line 133 class Request: public PA_Object {
|
| |
|
| ///@} |
///@} |
| |
|
| public: |
/// execution stack |
| |
Stack<StackItem> stack; |
| class StackItem { |
|
| public: |
|
| StringPtr string(Pool& pool) const { return value->get_string(&pool); } |
|
| ValuePtr value; |
|
| ArrayOperationPtr ops; |
|
| void *ptr; |
|
| |
|
| /// needed to fill unused Array entries |
/// exception stack trace |
| StackItem() {} |
Exception_trace exception_trace; |
| StackItem(ValuePtr avalue): value(avalue) {} |
public: |
| StackItem(ArrayOperationPtr aops): ops(aops) {} |
|
| StackItem(void *aptr): ptr(aptr) {} |
|
| }; |
|
| |
|
| //@{ request processing status |
//@{ request processing status |
| /// exception stack trace |
|
| Stack<StringPtr> exception_trace; |
|
| /// execution stack |
|
| Stack<StackItem> stack; |
|
| /// contexts |
/// contexts |
| VMethodFrame *method_frame; |
VMethodFrame* method_frame; |
| Value *rcontext; |
Value* rcontext; |
| WContext *wcontext; |
WContext* wcontext; |
| /// current language |
/// current language |
| String_UL flang; |
String::Language flang; |
| /// current connection |
/// current connection |
| SQL_Connection *fconnection; |
SQL_Connection* fconnection; |
| //@} |
//@} |
| /// interrupted flag, raised on signals [SIGPIPE] |
/// interrupted flag, raised on signals [SIGPIPE] |
| bool finterrupted; |
bool finterrupted; |
| |
Skip fskip; |
| |
int fin_cycle; |
| |
|
| public: |
public: |
| |
uint register_file(String::Body file_spec); |
| |
|
| /// all files and classes and other hard-to-place allocations go to this pool |
struct Exception_details { |
| Pool& pool() { return fpool; } |
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 |
| |
void wipe_unused_execution_stack() { |
| |
stack.wipe_unused(); |
| |
} |
| |
|
| #ifdef RESOURCES_DEBUG |
#ifdef RESOURCES_DEBUG |
| /// measures |
/// measures |
|
Line 124 public:
|
Line 182 public:
|
| double sql_request_time; |
double sql_request_time; |
| #endif |
#endif |
| |
|
| Request(Pool& apool, SAPI_Info& asapi_info, Request_info& arequest_info, |
Request(SAPI_Info& asapi_info, Request_info& arequest_info, |
| String_UL adefault_lang, ///< all tainted data default untainting lang |
String::Language adefault_lang, ///< all tainted data default untainting lang |
| bool status_allowed ///< status class allowed |
bool status_allowed ///< status class allowed |
| ); |
); |
| ~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 145 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(StringPtr 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, |
| name, |
0, //&name, |
| "call canceled - endless recursion detected"); |
"call canceled - endless recursion detected"); |
| } |
} |
| execute(ops); // execute it |
execute(ops); // execute it |
| 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. |
| VStateless_classPtr use_file(VStateless_class& aclass, |
void use_file(VStateless_class& aclass, |
| StringPtr file_name, |
const String& file_name, |
| bool ignore_class_path=false, |
const String* use_filespec); |
| 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 |
| VStateless_classPtr use_buf(VStateless_class& aclass, |
void use_buf(VStateless_class& aclass, |
| const char* source, |
const char* source, |
| StringPtr filespec, const char* filespec_cstr); // pa_request.C |
const String* main_alias, |
| |
uint file_no, |
| |
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(ValuePtr input_value, bool intercept_string=true); // execute.C |
StringOrValue process_getter(Junction& junction); // 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 |
| StringPtr process_to_string(ValuePtr input_value) { |
const String& process_to_string(Value& input_value) { |
| return process(input_value, true/*intercept_string*/).as_string(&pool()); |
return process(input_value, true/*intercept_string*/).as_string(); |
| } |
} |
| ValuePtr process_to_value(ValuePtr input_value, bool intercept_string=true) { |
Value& process_to_value(Value& input_value, bool intercept_string=true) { |
| 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) { \ |
| if(StringPtr string=dual.get_string()) \ |
if(const String* string=dual.get_string()) \ |
| write_##modification##_lang(*string); \ |
|
| else \ |
|
| write_##modification##_lang(dual.get_value()); \ |
|
| } |
|
| #define DEFINE_DUAL_CHECKED(modification) \ |
|
| void write_##modification##_lang(StringOrValue dual, StringPtr origin) { \ |
|
| if(StringPtr string=dual.get_string()) \ |
|
| write_##modification##_lang(*string); \ |
write_##modification##_lang(*string); \ |
| else \ |
else \ |
| write_##modification##_lang(dual.get_value(), origin); \ |
write_##modification##_lang(*dual.get_value()); \ |
| } |
} |
| |
|
| /// appending, sure of clean string inside |
/// appending, sure of clean string inside |
| void write_no_lang(const String& astring) { |
void write_no_lang(const String& astring) { |
| wcontext->write(astring, |
wcontext->write(astring, |
| String::UL_CLEAN | flang&String::UL_OPTIMIZE_BIT); |
(String::Language)(String::L_CLEAN | flang&String::L_OPTIMIZE_BIT)); |
| } |
} |
| /// appending sure value, that would be converted to clean string |
/// appending sure value, that would be converted to clean string |
| void write_no_lang(ValuePtr avalue) { |
void write_no_lang(Value& avalue) { |
| if(wcontext->get_in_expression()) |
if(wcontext->get_in_expression()) |
| wcontext->write(pool(), avalue); |
wcontext->write(avalue); |
| else |
else |
| wcontext->write(pool(), avalue, |
wcontext->write(avalue, |
| String::UL_CLEAN | flang&String::UL_OPTIMIZE_BIT); |
(String::Language)(String::L_CLEAN | flang&String::L_OPTIMIZE_BIT)); |
| } |
} |
| |
|
| /// appending string, passing language built into string being written |
/// appending string, passing language built into string being written |
| void write_pass_lang(const String& astring) { |
void write_pass_lang(const String& astring) { |
| wcontext->write(astring, String::UL_PASS_APPENDED); |
wcontext->write(astring, String::L_PASS_APPENDED); |
| } |
} |
| /// appending possible string, passing language built into string being written |
/// appending possible string, passing language built into string being written |
| void write_pass_lang(ValuePtr avalue) { |
void write_pass_lang(Value& avalue) { |
| wcontext->write(pool(), avalue, String::UL_PASS_APPENDED); |
wcontext->write(avalue, String::L_PASS_APPENDED); |
| } |
} |
| DEFINE_DUAL(pass) |
DEFINE_DUAL(pass) |
| |
|
| /// appending possible string, assigning untaint language |
/// appending possible string, assigning untaint language |
| void write_assign_lang(ValuePtr avalue) { |
void write_assign_lang(Value& avalue) { |
| wcontext->write(pool(), avalue, flang); |
wcontext->write(avalue, flang); |
| } |
|
| /// appending possible string, assigning untaint language |
|
| void write_assign_lang(ValuePtr avalue, StringPtr origin) { |
|
| wcontext->write(pool(), avalue, flang, origin); |
|
| } |
} |
| /// appending string, assigning untaint language |
/// appending string, assigning untaint language |
| void write_assign_lang(const String& astring) { |
void write_assign_lang(const String& astring) { |
| wcontext->write(astring, flang); |
wcontext->write(astring, flang); |
| } |
} |
| DEFINE_DUAL(assign) |
DEFINE_DUAL(assign) |
| DEFINE_DUAL_CHECKED(assign) |
|
| |
|
| /// returns relative to @a path path to @a file |
/// returns relative to @a path path to @a file |
| StringPtr relative(const char* apath, StringPtr relative_name); |
const String& relative(const char* apath, const String& relative_name); |
| |
|
| /// returns an absolute @a path to relative @a name |
/// returns an absolute @a path to relative @a name |
| StringPtr absolute(StringPtr relative_name); |
const String& absolute(const String& relative_name); |
| |
|
| /// returns the mime type of 'user_file_name_cstr' |
/// returns the mime type of 'user_file_name_cstr' |
| StringPtr mime_type_of(const char* user_file_name_cstr); |
const String& mime_type_of(const char* user_file_name_cstr); |
| |
|
| /// returns current SQL connection if any |
/// returns current SQL connection if any |
| SQL_Connection *connection(StringPtr source) { |
SQL_Connection* connection(bool fail_on_error=true) { |
| if(!fconnection && source) |
if(fail_on_error && !fconnection) |
| throw Exception("parser.runtime", |
throw Exception(PARSER_RUNTIME, |
| source, |
0, |
| "outside of 'connect' operator"); |
"outside of 'connect' operator"); |
| |
|
| return fconnection; |
return fconnection; |
| } |
} |
| |
|
| bool origins_mode(); |
void set_interrupted(bool ainterrupted) { finterrupted=ainterrupted; } |
| |
bool get_interrupted() { return finterrupted; } |
| |
|
| void interrupt() { finterrupted=true; } |
void set_skip(Skip askip) { fskip=askip; } |
| bool interrupted() { return finterrupted; } |
Skip get_skip() { return fskip; } |
| |
|
| |
void set_in_cycle(int adelta) { fin_cycle+=adelta; } |
| |
bool get_in_cycle() { return fin_cycle>0; } |
| |
|
| public: |
public: |
| |
|
|
Line 270 public:
|
Line 336 public:
|
| Request_charsets charsets; |
Request_charsets charsets; |
| |
|
| /// 'MAIN' class conglomerat & operators are methods of this class |
/// 'MAIN' class conglomerat & operators are methods of this class |
| VStateless_classPtr main_class; |
VStateless_class& main_class; |
| /// $form:elements |
/// $form:elements |
| VFormPtr form; |
VForm& form; |
| /// $mail |
/// $mail |
| VMailPtr mail; |
VMail& mail; |
| /// $response:elements |
/// $response:elements |
| VResponsePtr response; |
VResponse& response; |
| /// $cookie:elements |
/// $cookie:elements |
| VCookiePtr cookie; |
VCookie& cookie; |
| |
/// $console |
| |
VConsole& console; |
| |
|
| /// classes configured data |
/// classes configured data |
| HashStringObject classes_conf; |
HashString<void*> classes_conf; |
| |
|
| public: // status read methods |
public: // status read methods |
| |
|
| VMethodFrame *get_method_frame() { return method_frame; } |
VMethodFrame *get_method_frame() { return method_frame; } |
| ValuePtr get_self(); |
Value& get_self(); |
| #define GET_SELF(request, type) (*static_cast<type *>(request.get_self().get())) |
#define GET_SELF(request, type) (static_cast<type &>(request.get_self())) |
| /* for strange reason call to this: |
/* for strange reason call to this: |
| r.get_self<VHash>() |
r.get_self<VHash>() |
| refuses to compile |
refuses to compile |
|
Line 297 public: // status read methods
|
Line 365 public: // status read methods
|
| } |
} |
| */ |
*/ |
| |
|
| |
/// for @main[] |
| |
const String* execute_virtual_method(Value& aself, const String& method_name); |
| |
|
| |
/// executes parser method, use op_call(frame) to execute native method |
| |
void execute_method(VMethodFrame& aframe); |
| |
|
| |
//{ for @conf[filespec] and @auto[filespec] and parser://method/call |
| |
const String* execute_method(Value& aself, |
| |
const Method& method, Value* 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(StringPtr s); |
xmlChar* transcode(const String& s); |
| /// @see Charset::transcode |
/// @see Charset::transcode |
| StringPtr transcode(GdomeDOMString* s |
xmlChar* transcode(const String::Body s); |
| #ifndef NO_STRING_ORIGIN |
|
| , StringPtr origin |
|
| #endif |
|
| ); |
|
| /// @see Charset::transcode |
/// @see Charset::transcode |
| StringPtr transcode(xmlChar* s |
const String& transcode(const xmlChar* s); |
| #ifndef NO_STRING_ORIGIN |
|
| , StringPtr origin |
|
| #endif |
|
| ); |
|
| |
|
| #endif |
#endif |
| |
|
|
Line 322 private:
|
Line 403 private:
|
| /// already executed some @conf method |
/// already executed some @conf method |
| bool configure_admin_done; |
bool configure_admin_done; |
| |
|
| void configure_admin(VStateless_class& conf_class, StringPtr source); |
void configure_admin(VStateless_class& conf_class); |
| |
|
| |
void configure(); |
| |
|
| private: // compile.C |
private: // compile.C |
| |
|
| VStateless_class& real_compile(COMPILE_PARAMS); |
ArrayClass& 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); |
| StringPtr execute_method(VMethodFrame& amethodFrame, const Method& method); |
Value& get_element(Value& ncontext, const String& name); |
| //{ for @conf[filespec] and @auto[filespec] |
|
| StringPtr execute_method(ValuePtr aself, |
|
| const Method& method, VStringPtr optional_param, |
|
| bool do_return_string); |
|
| struct Execute_nonvirtual_method_result { |
|
| StringPtr string; |
|
| MethodPtr method; |
|
| }; |
|
| Execute_nonvirtual_method_result execute_nonvirtual_method(VStateless_class& aclass, |
|
| StringPtr method_name, VStringPtr optional_param, |
|
| bool do_return_string); |
|
| //} |
|
| /// for @main[] |
|
| StringPtr execute_virtual_method(ValuePtr aself, StringPtr method_name); |
|
| |
|
| ValuePtr get_element(StringPtr& remember_name, bool can_call_operator); |
|
| |
|
| private: // defaults |
private: // defaults |
| |
|
| const String_UL fdefault_lang; |
const String::Language fdefault_lang; |
| |
|
| private: // mime types |
private: // mime types |
| |
|
|
Line 360 private: // mime types
|
Line 430 private: // mime types
|
| |
|
| private: // lang manipulation |
private: // lang manipulation |
| |
|
| String_UL set_lang(String_UL alang) { |
String::Language set_lang(String::Language alang) { |
| String_UL result=flang; |
String::Language result=flang; |
| flang=alang; |
flang=alang; |
| return result; |
return result; |
| } |
} |
| void restore_lang(String_UL alang) { |
void restore_lang(String::Language alang) { |
| flang=alang; |
flang=alang; |
| } |
} |
| |
|
| private: // connection manipulation |
private: // connection manipulation |
| |
|
| SQL_Connection *set_connection(SQL_Connection *aconnection) { |
SQL_Connection* set_connection(SQL_Connection* aconnection) { |
| SQL_Connection *result=fconnection; |
SQL_Connection* result=fconnection; |
| fconnection=aconnection; |
fconnection=aconnection; |
| return result; |
return result; |
| } |
} |
| void restore_connection(SQL_Connection *aconnection) { |
void restore_connection(SQL_Connection* aconnection) { |
| fconnection=aconnection; |
fconnection=aconnection; |
| } |
} |
| |
|
| private: |
private: |
| |
|
| void output_result(VFilePtr body_file, bool header_only, bool as_attachment); |
void output_result(VFile* body_file, bool header_only, bool as_attachment); |
| }; |
}; |
| |
|
| /// Auto-object used to save request context across ^try body |
/// Auto-object used to save request context across ^try body |
|
Line 390 class Request_context_saver {
|
Line 460 class Request_context_saver {
|
| Request& fr; |
Request& fr; |
| |
|
| /// exception stack trace |
/// exception stack trace |
| int exception_trace; |
size_t exception_trace_top; |
| |
size_t exception_trace_bottom; |
| /// execution stack |
/// execution stack |
| int stack; |
size_t stack; |
| |
uint anti_endless_execute_recoursion; |
| /// contexts |
/// contexts |
| VMethodFrame *method_frame; |
VMethodFrame* method_frame; |
| Value *rcontext; |
Value* rcontext; |
| WContext *wcontext; |
WContext* wcontext; |
| /// current language |
/// current language |
| String_UL flang; |
String::Language flang; |
| /// current connection |
/// current connection |
| SQL_Connection *fconnection; |
SQL_Connection* fconnection; |
| |
|
| 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 424 public:
|
Line 500 public:
|
| /// Auto-object used for temporary changing Request::flang. |
/// Auto-object used for temporary changing Request::flang. |
| class Temp_lang { |
class Temp_lang { |
| Request& frequest; |
Request& frequest; |
| String_UL saved_lang; |
String::Language saved_lang; |
| public: |
public: |
| Temp_lang(Request& arequest, String_UL alang) : |
Temp_lang(Request& arequest, String::Language alang) : |
| frequest(arequest), |
frequest(arequest), |
| saved_lang(arequest.set_lang(alang)) { |
saved_lang(arequest.set_lang(alang)) { |
| } |
} |
|
Line 438 public:
|
Line 514 public:
|
| /// Auto-object used for temporary changing Request::fconnection. |
/// Auto-object used for temporary changing Request::fconnection. |
| class Temp_connection { |
class Temp_connection { |
| Request& frequest; |
Request& frequest; |
| SQL_Connection *saved_connection; |
SQL_Connection* saved_connection; |
| public: |
public: |
| Temp_connection(Request& arequest, SQL_Connection *aconnection) : |
Temp_connection(Request& arequest, SQL_Connection* aconnection) : |
| frequest(arequest), |
frequest(arequest), |
| saved_connection(arequest.set_connection(aconnection)) { |
saved_connection(arequest.set_connection(aconnection)) { |
| } |
} |
|
Line 449 public:
|
Line 525 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 EXCEPTION_HANDLED_PART_NAME "handled" |
| #define CONTENT_DISPOSITION_VALUE "attachment" |
|
| #define CONTENT_DISPOSITION_FILENAME_NAME "filename" |
|
| |
|
| // externs |
// externs |
| |
|
| extern StringPtr main_method_name; |
extern const String main_method_name; |
| extern StringPtr auto_method_name; |
extern const String auto_method_name; |
| extern StringPtr body_name; |
extern const String body_name; |
| extern StringPtr content_disposition_name; |
|
| extern StringPtr content_disposition_value; |
extern const String exception_type_part_name; |
| extern StringPtr content_disposition_filename_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 |
| |
|