--- parser3/src/classes/op.C 2002/10/16 07:32:51 1.121 +++ parser3/src/classes/op.C 2003/04/04 09:59:56 1.128 @@ -1,11 +1,11 @@ /** @file Parser: parser @b operators. - Copyright (c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com) + Copyright (c) 2001, 2003 ArtLebedev Group (http://www.artlebedev.com) Author: Alexandr Petrosian (http://paf.design.ru) */ -static const char* IDENT_OP_C="$Date: 2002/10/16 07:32:51 $"; +static const char* IDENT_OP_C="$Date: 2003/04/04 09:59:56 $"; #include "classes.h" #include "pa_common.h" @@ -102,7 +102,7 @@ static void _process(Request& r, const S { Value& vjunction=params->as_junction(params->size()-1, "body must be code"); - VStateless_class *target_class=target_self.get_class(); + VStateless_class *target_class=target_self.get_last_derived_class(); if(!target_class) throw Exception("parser.runtime", &method_name, @@ -152,8 +152,6 @@ static void _process(Request& r, const S // after restoring current-request-lang // maybe-execute @main[] if(main_method) { - // temporarily set request's self to target_self - Temp_request_self trs(r, target_self); // temporarily set method_frame's self to target_self Temp_method_frame_self tmfs(*r.get_method_frame(), target_self); // execute! @@ -251,8 +249,8 @@ struct timeval mt[2]; Value& body_code=params->as_junction(1, "body must be code"); Table *protocol2driver_and_client=0; - if(Value *sql=r.main_class.get_element(*new(pool) String(pool, MAIN_SQL_NAME), &r.main_class, false)) { - if(Value *element=sql->get_element(*new(pool) String(pool, MAIN_SQL_DRIVERS_NAME), sql, false)) { + if(Value *sql=r.main_class.get_element(*new(pool) String(pool, MAIN_SQL_NAME), r.main_class, false)) { + if(Value *element=sql->get_element(*new(pool) String(pool, MAIN_SQL_DRIVERS_NAME), *sql, false)) { protocol2driver_and_client=element->get_table(); } } @@ -404,9 +402,9 @@ static void locked_process_and_cache_put info.data->expires=0; // flag it so that could be easily checked by caller } const String *locked_process_and_cache_put(Request& r, - Value& body_code, - Cache_data& data, - const String& file_spec) { + Value& body_code, + Cache_data& data, + const String& file_spec) { Locked_process_and_cache_put_action_info info={ &r, &data, @@ -430,6 +428,7 @@ String *cache_get(Pool& pool, const Stri if(file_read(pool, file_spec, data, data_size, false/*as_text*/, + 0, 0, //no params&out_fields false/*fail_on_read_problem*/) && data_size/* ignore reads which are empty due to non-unary open+lockEX conflict with lockSH */) { @@ -588,16 +587,19 @@ static void _try_operator(Request& r, co Value& catch_code=params->as_junction(1, "catch_code must be code"); StringOrValue result; + // taking snapshot of try-context + Request_context_saver try_context(r); try { - Request_context_saver context_saved(r); // taking snapshot of request processing status, restoring it at } result=r.process(body_code); - context_saved.restore(); // manually restoring context } catch(const Exception& e) { + Request_context_saver throw_context(r); // taking snapshot of throw-context [stack trace contains error] + try_context.restore(); // restoring try-context to perform catch-code + VHash& vhash=exception2vhash(pool, e); Junction *junction=catch_code.get_junction(); Value *method_frame=junction->method_frame; - Value *saved_exception_var_value=method_frame->get_element(*exception_var_name, method_frame, false); + Value *saved_exception_var_value=method_frame->get_element(*exception_var_name, *method_frame, false); junction->method_frame->put_element(*exception_var_name, &vhash, false); result=r.process(catch_code); bool handled=false; @@ -605,10 +607,12 @@ static void _try_operator(Request& r, co handled=value->as_bool(); junction->method_frame->put_element(*exception_var_name, saved_exception_var_value, false); - if(!handled) + if(!handled) { + throw_context.restore(); // restoring throw-context [exception were not handled] throw(e); // rethrow + } } - // write it out + // write out result r.write_pass_lang(result); }