parser3/src/main/pa_request.C - diff

Return to pa_request.C CVS log

Up to [parser3project] / parser3 / src / main

Diff for /parser3/src/main/pa_request.C between versions 1.245.2.37.2.13 and 1.245.2.37.2.24

version 1.245.2.37.2.13, 2003/03/24 17:52:19	version 1.245.2.37.2.24, 2003/04/03 10:18:24
Line 30 static const char* IDENT_REQUEST_C="$Dat	Line 30 static const char* IDENT_REQUEST_C="$Dat
#include "pa_vform.h"	#include "pa_vform.h"
#include "pa_vcookie.h"	#include "pa_vcookie.h"
#include "pa_vresponse.h"	#include "pa_vresponse.h"
	#include "pa_vmemory.h"

// consts	// consts

Line 47 const char* ORIGINS_CONTENT_TYPE="text/p	Line 48 const char* ORIGINS_CONTENT_TYPE="text/p
#define MAIN_METHOD_NAME "main"	#define MAIN_METHOD_NAME "main"
#define AUTO_METHOD_NAME "auto"	#define AUTO_METHOD_NAME "auto"
#define BODY_NAME "body"	#define BODY_NAME "body"
	#define EXCEPTION_TYPE_PART_NAME "type"
	#define EXCEPTION_SOURCE_PART_NAME "source"
	#define EXCEPTION_COMMENT_PART_NAME "comment"
	#define EXCEPTION_HANDLED_PART_NAME "handled"

// globals	// globals

Line 56 const String content_disposition_name(CO	Line 61 const String content_disposition_name(CO
const String content_disposition_value(CONTENT_DISPOSITION_VALUE);	const String content_disposition_value(CONTENT_DISPOSITION_VALUE);
const String content_disposition_filename_name(CONTENT_DISPOSITION_FILENAME_NAME);	const String content_disposition_filename_name(CONTENT_DISPOSITION_FILENAME_NAME);
const String body_name(BODY_NAME);	const String body_name(BODY_NAME);
	const String exception_type_part_name(EXCEPTION_TYPE_PART_NAME);
	const String exception_source_part_name(EXCEPTION_SOURCE_PART_NAME);
	const String exception_comment_part_name(EXCEPTION_COMMENT_PART_NAME);
	const String exception_handled_part_name(EXCEPTION_HANDLED_PART_NAME);

// defines for statics	// defines for statics

Line 82 static const String class_path_name(CLAS	Line 91 static const String class_path_name(CLAS

// op.C	// op.C
VStateless_class& VClassMAIN_create();	VStateless_class& VClassMAIN_create();
// op.C
VHash& exception2vhash(const Exception& e);

//	//
Request::Request(SAPI_Info& asapi_info, Request_info& arequest_info,	Request::Request(SAPI_Info& asapi_info, Request_info& arequest_info,
Line 96 Request::Request(SAPI_Info& asapi_info,	Line 103 Request::Request(SAPI_Info& asapi_info,
rcontext(0),	rcontext(0),
wcontext(0),	wcontext(0),
flang(adefault_lang),	flang(adefault_lang),
fconnection(),	fconnection(0),
finterrupted(false),	finterrupted(false),

// public	// public
Line 124 Request::Request(SAPI_Info& asapi_info,	Line 131 Request::Request(SAPI_Info& asapi_info,
// private mime types	// private mime types
mime_types(0)	mime_types(0)
{	{
	// file_no=0 => unknown
	file_list+=StringBody("UNKNOWN");
	file_list+=StringBody("-body of process-"); // pseudo_file_no__process

// maybe expire old caches	// maybe expire old caches
cache_managers.maybe_expire();	cache_managers.maybe_expire();

Line 159 Request::Request(SAPI_Info& asapi_info,	Line 170 Request::Request(SAPI_Info& asapi_info,
Value& math=*new VMath;	Value& math=*new VMath;
classes().put(math.get_class()->base_class()->name(), &math);	classes().put(math.get_class()->base_class()->name(), &math);
}	}
	// memory class
	{
	Value& memory=*new VMemory;
	classes().put(memory.get_class()->base_class()->name(), &memory);
	}
}	}

Request::~Request() {	Request::~Request() {
Line 250 gettimeofday(&mt[0],NULL);	Line 266 gettimeofday(&mt[0],NULL);
while(const char* before=strchr(after, '/')) {	while(const char* before=strchr(after, '/')) {
String& sfile_spec=*new String;	String& sfile_spec=*new String;
if(after!=request_info.path_translated) {	if(after!=request_info.path_translated) {
sfile_spec.append(	sfile_spec.append_strdup(
request_info.path_translated, before-request_info.path_translated,	request_info.path_translated, before-request_info.path_translated,
String::L_CLEAN);	String::L_CLEAN);
sfile_spec << "/" AUTO_FILE_NAME;	sfile_spec << "/" AUTO_FILE_NAME;
Line 265 gettimeofday(&mt[0],NULL);	Line 281 gettimeofday(&mt[0],NULL);

// compile requested file	// compile requested file
String& spath_translated=*new String;	String& spath_translated=*new String;
spath_translated.append(request_info.path_translated, 0, String::L_TAINTED);	spath_translated.append_help_length(request_info.path_translated, 0, String::L_TAINTED);
use_file(main_class,	use_file(main_class,
spath_translated, true/* ignore class_path */,	spath_translated, true/* ignore class_path */,
true/* fail on read problem/, true/ fail on abscence */);	true/* fail on read problem/, true/ fail on abscence */);
Line 324 gettimeofday(&mt[2],NULL);	Line 340 gettimeofday(&mt[2],NULL);
}	}

VFile* body_file=body_vstring_after_post_process->as_vfile(	VFile* body_file=body_vstring_after_post_process->as_vfile(
String::L_UNSPECIFIED);	String::L_UNSPECIFIED, &charsets);

// extract response body	// extract response body
Value* body_value=response.fields().get(download_name);	Value* body_value=response.fields().get(download_name);
Line 333 gettimeofday(&mt[2],NULL);	Line 349 gettimeofday(&mt[2],NULL);
body_value=response.fields().get(body_name);	body_value=response.fields().get(body_name);

if(body_value) // there is some $response:body	if(body_value) // there is some $response:body
body_file=body_value->as_vfile();	body_file=body_value->as_vfile(String::L_UNSPECIFIED, &charsets);

#ifdef RESOURCES_DEBUG	#ifdef RESOURCES_DEBUG
//measure:after postprocess	//measure:after postprocess
Line 363 t[9]-t[3]	Line 379 t[9]-t[3]
#endif	#endif
} catch(const Exception& e) { // request handling problem	} catch(const Exception& e) { // request handling problem
// we're returning not result, but error explanation	// we're returning not result, but error explanation
try {	// try {
	#define PA_URI_FORMAT "%s: "
	#define PA_ORIGIN_FILE_POS_FORMAT "%s(%d:%d): "
	#define PA_SOURCE_FORMAT "'%s' "
	#define PA_COMMENT_TYPE_FORMAT "%s [%s]"
// log the beast	// log the beast
if(const String* problem_source=e.problem_source())	Request::Exception_details details=get_details(e);
SAPI::log(sapi_info,
"%s: "	if(details.problem_source) { // do we know the guy?
"'%s' %s [%s]",	if(details.trace) { // do whe know where he came from?
request_info.uri,	Operation::Info origin=details.trace.origin();
problem_source->cstr(),	SAPI::log(sapi_info,
e.comment(),	PA_URI_FORMAT
e.type()	PA_ORIGIN_FILE_POS_FORMAT
);	PA_SOURCE_FORMAT PA_COMMENT_TYPE_FORMAT,
else	request_info.uri,
	file_list[origin.file_no], 1+origin.line, 1+origin.col,
	details.problem_source->cstr(),
	e.comment(), e.type()
	);
	} else
	SAPI::log(sapi_info,
	PA_URI_FORMAT
	PA_SOURCE_FORMAT PA_COMMENT_TYPE_FORMAT,
	request_info.uri,
	details.problem_source->cstr(),
	e.comment(), e.type()
	);
	} else
SAPI::log(sapi_info,	SAPI::log(sapi_info,
"%s: "	PA_URI_FORMAT
"%s [%s]",	PA_COMMENT_TYPE_FORMAT,
request_info.uri,	request_info.uri,
e.comment(), e.type()	e.comment(), e.type()
);	);
Line 399 t[9]-t[3]	Line 432 t[9]-t[3]
false)) {	false)) {
if(Junction* junction=value->get_junction()) {	if(Junction* junction=value->get_junction()) {
if(const Method *method=junction->method) {	if(const Method *method=junction->method) {
// preparing to pass parameters to	// preparing to pass parameters to
// @unhandled_exception[exception;stack]	// @unhandled_exception[exception;stack]
VMethodFrame frame(/method->name, / junction, 0/no caller*/);	VMethodFrame frame(/method->name, / junction, 0/no caller*/);
frame.set_self(main_class);	frame.set_self(main_class);

// $exception	// $exception
frame.store_param(exception2vhash(e));	frame.store_param(details.vhash);
// $stack[^table::set{name origin}]	// $stack[^table::set{name origin}]
Table::columns_type stack_trace_columns(new ArrayString);	Table::columns_type stack_trace_columns(new ArrayString);
*stack_trace_columns+=new String("name");	*stack_trace_columns+=new String("name");
*stack_trace_columns+=new String("file");	*stack_trace_columns+=new String("file");
*stack_trace_columns+=new String("lineno");	*stack_trace_columns+=new String("lineno");
Table& stack_trace=*new Table(stack_trace_columns);	*stack_trace_columns+=new String("colno");
/Array_iterator<String> tracei(exception_trace);	Table& stack_trace=*new Table(stack_trace_columns);
while(tracei.has_next()) {	if(!exception_trace.is_empty()/signed!/)
Table::element_type row(new ArrayString);	for(size_t i=exception_trace.bottom_index(); i<=exception_trace.top_index(); i++) {
	Trace trace=exception_trace.get(i);
const String* name=tracei.next();	Table::element_type row(new ArrayString);
*row+=name; // name column
#ifndef NO_STRING_ORIGIN	*row+=trace.name(); // name column
const String_fragment::Origin& origin=name->origin();	Operation::Info origin=trace.origin();
if(origin.file) {	if(origin.file_no) {
*row+=StringBody(origin.file, 0, true)); // file column	*row+=new String(file_list[origin.file_no], String::L_TAINTED); // 'file' column
*row+=StringBody(	*row+=new String(StringBody::Format(1+origin.line), String::L_CLEAN); // 'lineno' column
pool().format_integer(1+origin.line),	*row+=new String(StringBody::Format(1+origin.col), String::L_CLEAN); // 'colno' column
0, true)); // line column	}
}	stack_trace+=row;
#endif	}
*stack_trace+=row;	frame.store_param(*new VTable(&stack_trace));
}*/
frame.store_param(*new VTable(&stack_trace));	// future $response:body=
	// execute ^unhandled_exception[exception;stack]
// future $response:body=	body_string=&execute_method(frame, *method);
// execute ^unhandled_exception[exception;stack]
body_string=&execute_method(frame, *method);
}	}
}	}
}	}
Line 448 t[9]-t[3]	Line 479 t[9]-t[3]
/*const String_fragment::Origin& origin=problem_source->origin();	/*const String_fragment::Origin& origin=problem_source->origin();
if(origin.file)	if(origin.file)
printed+=snprintf(buf+printed, MAX_STRING-printed,	printed+=snprintf(buf+printed, MAX_STRING-printed,
ORIGIN_FILE_LINE_FORMAT": ",	PA_ORIGIN_FILE_POS_FORMAT,
origin.file, 1+origin.line	origin.file, 1+origin.line
);	);
printed+=snprintf(buf+printed, MAX_STRING-printed, "'%s' ",	printed+=snprintf(buf+printed, MAX_STRING-printed, "'%s' ",
Line 468 t[9]-t[3]	Line 499 t[9]-t[3]
}	}

VString body_vstring(*body_string);	VString body_vstring(*body_string);
VFile* body_file=body_vstring.as_vfile();	VFile* body_file=body_vstring.as_vfile(String::L_UNSPECIFIED, &charsets);

// ERROR. write it out	// ERROR. write it out
output_result(body_file, header_only, false);	output_result(body_file, header_only, false);
} catch(const Exception& ) {	// } catch(const Exception& ) {
rethrow;	// rethrow;
}	// }
}	}
}	}

	size_t Request::register_file(StringBody file_spec) {
	file_list+=file_spec;
	return file_list.count()-1;
	}

void Request::use_file(VStateless_class& aclass,	void Request::use_file(VStateless_class& aclass,
const String& file_name, bool ignore_class_path,	const String& file_name, bool ignore_class_path,
bool fail_on_read_problem, bool fail_on_file_absence) {	bool fail_on_read_problem, bool fail_on_file_absence) {
// cyclic dependence check	// cyclic dependence check
if(used_files.get(file_name))	if(used_files.get(file_name))
return;	return;
Line 489 void Request::use_file(VStateless_class&	Line 525 void Request::use_file(VStateless_class&
const String* file_spec;	const String* file_spec;
if(ignore_class_path) // ignore_class_path?	if(ignore_class_path) // ignore_class_path?
file_spec=&file_name;	file_spec=&file_name;
else if(file_name.first_char()=='/') //absolute path, no need to scan MAIN:CLASS_PATH?	else if(file_name.first_char()=='/') //absolute path? [no need to scan MAIN:CLASS_PATH]
file_spec=&absolute(file_name);	file_spec=&absolute(file_name);
else {	else {
file_spec=0;	file_spec=0;
Line 523 void Request::use_file(VStateless_class&	Line 559 void Request::use_file(VStateless_class&
return;	return;

if(const char* source=file_read_text(charsets.source(), *file_spec, fail_on_read_problem))	if(const char* source=file_read_text(charsets.source(), *file_spec, fail_on_read_problem))
use_buf(aclass, source, *file_spec, file_spec->cstr());	use_buf(aclass, source, register_file(*file_spec));
}	}


void Request::use_buf(VStateless_class& aclass,	void Request::use_buf(VStateless_class& aclass,
const char* source,	const char* source,
const String& filespec, const char* filespec_cstr) {	uint file_no) {
// temporary zero @conf so to maybe-replace it in compiled code	// temporary zero @conf so to maybe-replace it in compiled code
Temp_method temp_method_conf(aclass, conf_method_name, 0);	Temp_method temp_method_conf(aclass, conf_method_name, 0);
// temporary zero @auto so to maybe-replace it in compiled code	// temporary zero @auto so to maybe-replace it in compiled code
Temp_method temp_method_auto(aclass, auto_method_name, 0);	Temp_method temp_method_auto(aclass, auto_method_name, 0);

// compile loaded class	// compile loaded class
VStateless_class& cclass=compile(&aclass, source, filespec_cstr);	VStateless_class& cclass=compile(&aclass, source, file_no);

// locate and execute possible @conf[] static	// locate and execute possible @conf[] static
VString* vfilespec=new VString(filespec);	VString* vfilespec=
	new VString(*new String(file_list[file_no], String::L_TAINTED));
Execute_nonvirtual_method_result executed=execute_nonvirtual_method(cclass,	Execute_nonvirtual_method_result executed=execute_nonvirtual_method(cclass,
conf_method_name, vfilespec,	conf_method_name, vfilespec,
false/no string result needed/);	false/no string result needed/);
Line 665 GdomeDOMString_auto_ptr Request::transco	Line 702 GdomeDOMString_auto_ptr Request::transco
return charsets.source().transcode(s);	return charsets.source().transcode(s);
}	}

	GdomeDOMString_auto_ptr Request::transcode(const StringBody s) {
	return charsets.source().transcode(s);
	}

const String& Request::transcode(GdomeDOMString* s) {	const String& Request::transcode(GdomeDOMString* s) {
return charsets.source().transcode(s);	return charsets.source().transcode(s);
}	}
Line 673 const String& Request::transcode(xmlChar	Line 714 const String& Request::transcode(xmlChar
return charsets.source().transcode(s);	return charsets.source().transcode(s);
}	}
#endif	#endif


	const Request::Trace Request::Exception_trace::extract_origin(const String*& problem_source) {
	Trace result;
	if(!is_empty()) {
	result=bottom_value();
	if(!problem_source) { // we don't know who trigged the bug?
	problem_source=result.name(); // consider the stack-top-guy did that
	fbottom++;
	} else if(result.name()==problem_source) // it is that same guy?
	fbottom++; // throw away that trace
	else // stack top contains not us
	result.clear();
	}

	return result;
	}

	Request::Exception_details Request::get_details(const Exception& e) {
	const String* problem_source=e.problem_source();
	Trace trace=exception_trace.extract_origin(problem_source);

	VHash& vhash=*new VHash; HashStringValue& hash=vhash.hash();

	// $.type
	if(const char* type=e.type(true))
	hash.put(exception_type_part_name, new VString(*new String(type)));

	// $.source
	if(problem_source) {
	String& source=*new String;
	source.append(problem_source, String::L_TAINTED, true/forced*/);

	hash.put(exception_source_part_name, new VString(source));
	}

	// $.file lineno colno
	if(trace) {
	const Operation::Info origin=trace.origin();
	hash.put(StringBody("file"),
	new VString(*new String(file_list[origin.file_no], String::L_TAINTED)));
	hash.put(StringBody("lineno"), new VInt(1+origin.line));
	hash.put(StringBody("colno"), new VInt(1+origin.col));
	}

	// $.comment
	if(const char* comment=e.comment(true))
	hash.put(exception_comment_part_name,
	new VString(new String(comment, 0, true/tainted*/)));

	// $.handled(0)
	hash.put(exception_handled_part_name, new VBool(false));

	return Request::Exception_details(trace, problem_source, vhash);
	}

	//

E-mail:

Removed from v.1.245.2.37.2.13
changed lines
	Added in v.1.245.2.37.2.24