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.166 and 1.205

version 1.166, 2003/10/21 04:45:19	version 1.205, 2010/09/04 23:33:21
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 32 const size_t pseudo_file_no__process=1;	Line 34 const size_t pseudo_file_no__process=1;
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 63 public:	Line 64 public:
const Operation::Origin origin() const { return forigin; }	const Operation::Origin origin() const { return forigin; }
};	};

	enum Skip {
	SKIP_NOTHING,
	SKIP_BREAK,
	SKIP_CONTINUE
	};

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

private:	private:
union StackItem {	union StackItem {
Line 72 private:	Line 83 private:
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 96 private:	Line 105 private:
element_type bottom_value() { return get(bottom_index()); }	element_type bottom_value() { return get(bottom_index()); }

void clear() {	void clear() {
ftop=fbottom=0;	fused=fbottom=0;
}	}

bool is_empty() {	bool is_empty() {
return ftop==fbottom;	return fused==fbottom;
}	}

const element_type extract_origin(const String*& problem_source);	const element_type extract_origin(const String*& problem_source);
Line 109 private:	Line 118 private:
///@{ 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 String::Body, 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<String::Body> file_list;	Array<String::Body> file_list;

Line 142 public:	Line 152 public:
//@}	//@}
/// interrupted flag, raised on signals [SIGPIPE]	/// interrupted flag, raised on signals [SIGPIPE]
bool finterrupted;	bool finterrupted;
	Skip fskip;
	int fin_cycle;

public:	public:
size_t register_file(String::Body file_spec);	uint register_file(String::Body file_spec);

struct Exception_details {	struct Exception_details {
const Trace trace;	const Trace trace;
Line 157 public:	Line 169 public:
VHash& avhash): trace(atrace), problem_source(aproblem_source), vhash(avhash) {}	VHash& avhash): trace(atrace), problem_source(aproblem_source), vhash(avhash) {}
};	};
Exception_details get_details(const Exception& e);	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() {
Line 176 public:	Line 189 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 190 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(/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 203 public:	Line 221 public:
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.
void use_file(VStateless_class& aclass,	void use_file(VStateless_class& aclass,
const String& file_name,	const String& file_name,
const String* main_alias=0,	const String* use_filespec);
bool ignore_class_path=false,
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,
const String* main_alias,	const String* main_alias,
uint file_no); // pa_request.C	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 226 public:	Line 251 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 282 public:	Line 308 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 292 public:	Line 318 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 313 public:	Line 345 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 331 public: // status read methods	Line 365 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 String::Body 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 352 private:	Line 408 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,	ArrayClass& compile(VStateless_class* aclass,
const char* source, const String* main_alias,	const char* source, const String* main_alias,
uint file_no);	uint file_no,
	int line_no_offset);

private: // execute.C	private: // execute.C

/// for @postprocess[body]	Value& get_element(Value& ncontext, const String& name);
StringOrValue 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 437 class Request_context_saver {	Line 478 class Request_context_saver {

public:	public:
Request_context_saver(Request& ar) :	Request_context_saver(Request& ar) :
	fr(ar),
exception_trace_top(ar.exception_trace.top_index()),	exception_trace_top(ar.exception_trace.top_index()),
exception_trace_bottom(ar.exception_trace.bottom_index()),	exception_trace_bottom(ar.exception_trace.bottom_index()),
stack(ar.stack.top_index()),	stack(ar.stack.top_index()),
Line 445 public:	Line 487 public:
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.set_top_index(exception_trace_top);	fr.exception_trace.set_top_index(exception_trace_top);
fr.exception_trace.set_bottom_index(exception_trace_bottom);	fr.exception_trace.set_bottom_index(exception_trace_bottom);
Line 486 public:	Line 527 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 content_disposition_filename_name;

extern const String exception_type_part_name;	extern const String exception_type_part_name;
extern const String exception_source_part_name;	extern const String exception_source_part_name;

E-mail:

Removed from v.1.166
changed lines
	Added in v.1.205