--- parser3/src/classes/hashfile.C 2002/02/08 08:30:10 1.22 +++ parser3/src/classes/hashfile.C 2003/11/06 10:25:40 1.26 @@ -1,139 +1,74 @@ /** @file Parser: @b hashfile parser class. - 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) - - $Id: hashfile.C,v 1.22 2002/02/08 08:30:10 paf Exp $ */ -#include "pa_config_includes.h" + +static const char* IDENT="$Id: hashfile.C,v 1.26 2003/11/06 10:25:40 paf Exp $"; + #include "classes.h" -#ifdef DB2 #include "pa_request.h" +#include "pa_vmethod_frame.h" #include "pa_vhashfile.h" #include "pa_vhash.h" -// defines - -#define HASH_CLASS_NAME "hashfile" - // class class MHashfile : public Methoded { public: // VStateless_class - Value *create_new_value(Pool& pool) { return new(pool) VHashfile(pool); } + Value *create_new_value() { return new VHashfile; } public: - MHashfile(Pool& pool); + MHashfile(); public: // Methoded bool used_directly() { return true; } }; -// methods +// global variable -static void _open(Request& r, const String& method_name, MethodParams *params) { - Pool& pool=r.pool(); - VHashfile& self=*static_cast(r.self); - - self.assign( - r.absolute(params->as_string(0, "DB_HOME must be string")), - params->as_string(1, "filename must be string") - ); -} +DECLARE_CLASS_VAR(hashfile, new MHashfile, 0); -static void _transaction(Request& r, const String& method_name, MethodParams *params) { - Pool& pool=r.pool(); - VHashfile& self=*static_cast(r.self); - - // body code - Value& body_code=params->as_junction(0, "body must be code"); - - // table - DB_Table_ptr table_ptr=self.get_table_ptr(&method_name); +// methods - // execute body - r.write_assign_lang(r.process(body_code)); +static void _open(Request& r, MethodParams& params) { + VHashfile& self=GET_SELF(r, VHashfile); + + self.open(r.absolute(params.as_string(0, "filename must be string"))); } -static void _hash(Request& r, const String& method_name, MethodParams *params) { - Pool& pool=r.pool(); - VHashfile& self=*static_cast(r.self); +static void _hash(Request& r, MethodParams& params) { + VHashfile& self=GET_SELF(r, VHashfile); // write out result - VHash& result=*new(pool) VHash(pool, *self.get_hash(&method_name)); - result.set_name(method_name); + VHash& result=*new VHash(*self.get_hash()); r.write_no_lang(result); } -static void _cache(Request& r, const String& method_name, MethodParams *params) { - Pool& pool=r.pool(); - VHashfile& self=*static_cast(r.self); +static void _delete(Request& r, MethodParams& params) { + VHashfile& self=GET_SELF(r, VHashfile); - // key, expires, body code - const String &key=params->as_string(0, "key must be string"); - time_t lifespan=(time_t)params->as_double(1, "lifespan must be number", r); - Value& body_code=params->as_junction(2, "body must be code"); - - DB_Table_ptr table_ptr=self.get_table_ptr(&method_name); - - if(lifespan) { // 'lifespan' specified? try cached copy... - if(String *cached_body=table_ptr->get(pool, key, lifespan)) { // have cached copy? - r.write_assign_lang(*cached_body); - // happy with it - return; - } - } else // 'lifespan'=0, forget cached copy - table_ptr->remove(key); - - // save - Autosave_marked_to_cancel_cache saved(self); - - // process - Value& processed_body=r.process(body_code); - r.write_assign_lang(processed_body); - - // put it to cache if 'lifespan' specified & never called ^delete[] - if(lifespan && !self.marked_to_cancel_cache()) - table_ptr->put(key, processed_body.as_string(), lifespan); + // key + const String &key=params.as_string(0, "key must be string"); + // remove + self.remove(key); } -static void _delete(Request& r, const String& method_name, MethodParams *params) { - Pool& pool=r.pool(); - VHashfile& self=*static_cast(r.self); - - if(params->size()==0) - self.mark_to_cancel_cache(); - else { - // key - const String &key=params->as_string(0, "key must be string"); - // remove - self.get_table_ptr(&method_name)->remove(key); - } +static void _clear(Request& r, MethodParams&) { + VHashfile& self=GET_SELF(r, VHashfile); + self.clear(); } -static void _clear(Request& r, const String& method_name, MethodParams *) { - Pool& pool=r.pool(); - VHashfile& self=*static_cast(r.self); - DB_Cursor cursor(*self.get_table_ptr(&method_name), &method_name); +#if LATER +static void _foreach(Request& r, MethodParams& params) { + VHashfile& self=GET_SELF(r, VHashfile); - while(true) { - if(!cursor.move(DB_NEXT)) - break; - - cursor.remove(0/*flags*/); - } -} - -static void _foreach(Request& r, const String& method_name, MethodParams *params) { - Pool& pool=r.pool(); - VHashfile& self=*static_cast(r.self); - - const String& key_var_name=params->as_string(0, "key-var name must be string"); - const String& value_var_name=params->as_string(1, "value-var name must be string"); - Value& body_code=params->as_junction(2, "body must be code"); - Value *delim_maybe_code=params->size()>3?¶ms->get(3):0; + const String& key_var_name=params.as_string(0, "key-var name must be string"); + const String& value_var_name=params.as_string(1, "value-var name must be string"); + Value& body_code=params.as_junction(2, "body must be code"); + Value *delim_maybe_code=params.size()>3?¶ms.get(3):0; bool need_delim=false; Value& var_context=*body_code.get_junction()->wcontext; @@ -166,41 +101,18 @@ static void _foreach(Request& r, const S } } +#endif // constructor -MHashfile::MHashfile(Pool& apool) : Methoded(apool) { - set_name(*NEW String(pool(), HASH_CLASS_NAME)); - +MHashfile::MHashfile(): Methoded("hashfile") { // ^hashfile::open[db_home;filename] - add_native_method("open", Method::CT_DYNAMIC, _open, 2, 2); - // ^transaction{code} - add_native_method("transaction", Method::CT_DYNAMIC, _transaction, 1, 1); + add_native_method("open", Method::CT_DYNAMIC, _open, 1, 1); // ^hash[] add_native_method("hash", Method::CT_DYNAMIC, _hash, 0, 0); - // ^cache[key](seconds){code} - add_native_method("cache", Method::CT_DYNAMIC, _cache, 3, 3); // ^hashfile.delete[key] - add_native_method("delete", Method::CT_DYNAMIC, _delete, 0, 1); + add_native_method("delete", Method::CT_DYNAMIC, _delete, 1, 1); // ^hashfile.clear[] add_native_method("clear", Method::CT_DYNAMIC, _clear, 0, 0); // ^hashfile.foreach[key;value]{code}[delim] - add_native_method("foreach", Method::CT_DYNAMIC, _foreach, 2+1, 2+1+1); -} - -// global variable - -Methoded *hashfile_base_class; - -#endif - -// creator - -Methoded *MHashfile_create(Pool& pool) { - return -#ifdef DB2 - hashfile_base_class=new(pool) MHashfile(pool) -#else - 0 -#endif - ; +// add_native_method("foreach", Method::CT_DYNAMIC, _foreach, 2+1, 2+1+1); }