--- parser3/src/classes/op.C 2002/10/31 10:23:45 1.124 +++ parser3/src/classes/op.C 2003/03/17 14:48:04 1.127.4.1 @@ -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/31 10:23:45 $"; +static const char* IDENT_OP_C="$Date: 2003/03/17 14:48:04 $"; #include "classes.h" #include "pa_common.h" @@ -136,7 +136,7 @@ static void _process(Request& r, const S strncpy(local_place, method_name.cstr(), MAX_STRING-1); place[MAX_STRING-1]=0; size_t place_size=strlen(local_place)+1; #endif - char *heap_place=(char *)r.malloc(place_size); + char *heap_place=(char *)r.malloc_atomic(place_size); memcpy(heap_place, local_place, place_size); // process source code, append processed methods to 'self' class @@ -249,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(); } } @@ -428,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 */) { @@ -568,7 +569,7 @@ VHash& exception2vhash(Pool& pool, const } if(const char *ecomment=e.comment(true)) { int comment_size=strlen(ecomment); - char *pcomment=(char *)pool.malloc(comment_size); + char *pcomment=(char *)pool.malloc_atomic(comment_size); memcpy(pcomment, ecomment, comment_size); hash.put(*exception_comment_part_name, new(pool) VString(*new(pool) String(pool, pcomment, comment_size, true/*tainted*/))); @@ -598,7 +599,7 @@ static void _try_operator(Request& r, co 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; @@ -646,6 +647,10 @@ static void _throw_operator(Request& r, throw Exception(type, &source, "%s", comment?comment:""); } } + +static void _gc_operator(Request& r, const String& method_name, MethodParams *params) { + r.pool().collect_garbage(); +} // constructor @@ -705,6 +710,7 @@ VClassMAIN::VClassMAIN(Pool& apool): VCl // ^throw[type;source;comment] add_native_method("throw", Method::CT_ANY, _throw_operator, 1, 3); + add_native_method("gc", Method::CT_ANY, _gc_operator, 0, 0); } // constructor & configurator