parser3/src/include/pa_request.h - diff

Return to pa_request.h CVS log

Up to [parser3project] / parser3 / src / include

Diff for /parser3/src/include/pa_request.h between versions 1.160.2.37.2.17 and 1.207

version 1.160.2.37.2.17, 2003/04/02 16:05:19	version 1.207, 2010/09/24 08:18:57
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_hash.h"	#include "pa_hash.h"
#include "pa_wcontext.h"	#include "pa_wcontext.h"
#include "pa_value.h"	#include "pa_value.h"
Line 17 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 25 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 uint ANTI_ENDLESS_JSON_STRING_RECOURSION=100;
	const size_t pseudo_file_no__process=1;

// forwards	// forwards

class Temp_lang;	class Temp_lang;
class Methoded;	class Methoded;
class VMethodFrame;	class VMethodFrame;
class GdomeDOMString_auto_ptr;
class VMail;	class VMail;
class VForm;	class VForm;
class VResponse;	class VResponse;
Line 44 class Request: public PA_Object {	Line 47 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
	};

	private:
	Pool fpool;
	public:
	Pool& pool() { return fpool; }

	private:
union StackItem {	union StackItem {
Value* fvalue;	Value* fvalue;
ArrayOperation* fops;	ArrayOperation* fops;
Line 52 class Request: public PA_Object {	Line 84 class Request: public PA_Object {
public:	public:
Value& value() const { return *fvalue; }	Value& value() const { return *fvalue; }
const String& string() const {	const String& string() const {
const String* result=fvalue->get_string();	return fvalue->as_string();
assert(result);
return *result;
}	}
ArrayOperation& ops() const { return *fops; }	ArrayOperation& ops() const { return *fops; }
VMethodFrame& method_frame() const { return *fmethod_frame; }	VMethodFrame& method_frame() const { return *fmethod_frame; }
Line 66 class Request: public PA_Object {	Line 96 class Request: public PA_Object {
StackItem(VMethodFrame& amethod_frame): fmethod_frame(&amethod_frame) {}	StackItem(VMethodFrame& amethod_frame): fmethod_frame(&amethod_frame) {}
};	};

class Trace {	class Exception_trace: public Stack<Trace> {
const String* fname;	size_t fbottom;
Operation::Info forigin;
public:	public:
Trace(const String* aname, Operation::Info aorigin):	Exception_trace(): fbottom(0) {}
fname(aname), forigin(aorigin) {}
	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;
	}

const String* name() { return fname; }	bool is_empty() {
Operation::Info origin() { return forigin; }	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<const StringBody, 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<StringBody> file_list;	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
*/	*/
uint anti_endless_execute_recoursion;	uint anti_endless_execute_recoursion;

	uint anti_endless_json_string_recoursion;

///@}	///@}

/// execution stack	/// execution stack
Stack<StackItem> stack;	Stack<StackItem> stack;

/// exception stack trace	/// exception stack trace
Stack<Trace> exception_trace;	Exception_trace exception_trace;
public:	public:

//@{ request processing status	//@{ request processing status
Line 113 public:	Line 155 public:
//@}	//@}
/// 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);

	struct Exception_details {
	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	/// @see Stack::wipe_unused
void wipe_unused_execution_stack() {	void wipe_unused_execution_stack() {
stack.wipe_unused();	stack.wipe_unused();
Line 134 public:	Line 192 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 148 public:	Line 207 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 161 public:	Line 224 public:
anti_endless_execute_recoursion--;	anti_endless_execute_recoursion--;
}	}

	uint json_string_recoursion_go_down(){
	if(++anti_endless_json_string_recoursion==ANTI_ENDLESS_JSON_STRING_RECOURSION){
	anti_endless_json_string_recoursion=0;
	throw Exception(PARSER_RUNTIME,
	0,
	"call canceled - endless json recursion detected");
	}
	return anti_endless_json_string_recoursion;
	}

	void json_string_recoursion_go_up(){
	if(anti_endless_json_string_recoursion)
	anti_endless_json_string_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,
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
void use_buf(VStateless_class& aclass,	void use_buf(VStateless_class& aclass,
const char* source,	const char* source,
uint file_no); // 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_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 181 public:	Line 269 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 237 public:	Line 326 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 247 public:	Line 336 public:
void set_interrupted(bool ainterrupted) { finterrupted=ainterrupted; }	void set_interrupted(bool ainterrupted) { finterrupted=ainterrupted; }
bool get_interrupted() { return finterrupted; }	bool get_interrupted() { return finterrupted; }

	void set_skip(Skip askip) { fskip=askip; }
	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 268 public:	Line 363 public:
VResponse& response;	VResponse& response;
/// $cookie:elements	/// $cookie:elements
VCookie& 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

Line 286 public: // status read methods	Line 383 public: // status read methods
}	}
*/	*/

	/// public for ^reflection:copy[]
	void put_element(Value& ncontext, const String& name, Value* value);

	/// 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(const String& s);	xmlChar* transcode(const String& s);
/// @see Charset::transcode
GdomeDOMString_auto_ptr transcode(const StringBody s);
/// @see Charset::transcode	/// @see Charset::transcode
const String& transcode(GdomeDOMString* s);	xmlChar* transcode(const String::Body s);
/// @see Charset::transcode	/// @see Charset::transcode
const String& transcode(xmlChar* s);	const String& transcode(const xmlChar* s);

#endif	#endif

Line 307 private:	Line 426 private:

void configure_admin(VStateless_class& conf_class);	void configure_admin(VStateless_class& conf_class);

	void configure();

private: // compile.C	private: // compile.C

VStateless_class& compile(VStateless_class* aclass, const char* source, uint file_no);	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]	Value& get_element(Value& ncontext, const String& name);
const String& execute_method(VMethodFrame& amethodFrame, const Method& method);
//{ for @conf[filespec] and @auto[filespec]
const String* execute_method(Value& aself,
const Method& method, VString* 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);
//}
/// for @main[]
const String* execute_virtual_method(Value& aself, const String& method_name);

Value& get_element(Value& ncontext, const String& name, bool can_call_operator);

private: // defaults	private: // defaults

Line 374 class Request_context_saver {	Line 480 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;
	uint anti_endless_json_string_recoursion;
/// contexts	/// contexts
VMethodFrame *method_frame;	VMethodFrame* method_frame;
Value *rcontext;	Value* rcontext;
WContext *wcontext;	WContext* wcontext;
/// current language	/// current language
String::Language flang;	String::Language flang;
/// current connection	/// current connection
Line 388 class Request_context_saver {	Line 497 class Request_context_saver {

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),
	anti_endless_json_string_recoursion(ar.anti_endless_json_string_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.anti_endless_json_string_recoursion=anti_endless_json_string_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 433 public:	Line 548 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 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 exception_type_part_name;
extern const String 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

E-mail:

Removed from v.1.160.2.37.2.17
changed lines
	Added in v.1.207