Annotation of parser3/src/classes/hashfile.C, revision 1.8
1.1 parser 1: /** @file
2: Parser: @b hashfile parser class.
3:
4: Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com)
5: Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)
6:
1.8 ! parser 7: $Id: hashfile.C,v 1.7 2001/10/24 10:49:47 parser Exp $
1.1 parser 8: */
9:
10: #include "pa_config_includes.h"
1.4 parser 11: #include "classes.h"
1.1 parser 12: #ifdef HAVE_LIBDB
13:
14: #include "pa_request.h"
15: #include "pa_vhashfile.h"
16: #include "pa_vhash.h"
17:
18: // defines
19:
20: #define HASH_CLASS_NAME "hashfile"
21:
22: // class
23:
24: class MHashfile : public Methoded {
25: public: // VStateless_class
26: Value *create_new_value(Pool& pool) { return new(pool) VHashfile(pool); }
27:
28: public:
29: MHashfile(Pool& pool);
30: public: // Methoded
31: bool used_directly() { return true; }
32: };
33:
34: // methods
35:
1.3 parser 36: static void _open(Request& r, const String& method_name, MethodParams *params) {
1.1 parser 37: Pool& pool=r.pool();
38: VHashfile& self=*static_cast<VHashfile *>(r.self);
39:
1.3 parser 40: // file_spec
41: const String &file_spec=params->as_string(0, "filename must be string");
1.1 parser 42:
1.3 parser 43: self.set_connection(
44: DB_manager->get_connection(
45: r.absolute(file_spec),
46: method_name)
47: );
48: }
49:
50:
51: static void _transaction(Request& r, const String& method_name, MethodParams *params) {
52: Pool& pool=r.pool();
53: VHashfile& self=*static_cast<VHashfile *>(r.self);
54:
55: // body code
56: Value& body_code=params->as_junction(0, "body must be code");
57:
58: // connection
59: DB_Connection& connection=self.get_connection(&method_name);
60:
61: // transaction
62: Auto_transaction transaction(connection);
63:
64: // execute body
65: try {
66: r.write_assign_lang(r.process(body_code));
67: } catch(...) { // process/commit problem
68: transaction.mark_to_rollback();
69:
70: /*re*/throw;
71: }
72: }
73:
74: static void _clear(Request& r, const String& method_name, MethodParams *params) {
75: Pool& pool=r.pool();
76:
77: // file_spec
78: const String &file_spec=params->as_string(0, "filename must be string");
79:
80: DB_manager->clear_dbfile(r.absolute(file_spec));
1.1 parser 81: }
82:
1.5 parser 83: static void _hash(Request& r, const String& method_name, MethodParams *params) {
84: Pool& pool=r.pool();
85: VHashfile& self=*static_cast<VHashfile *>(r.self);
86:
87: // write out result
88: VHash& result=*new(pool) VHash(pool, *self.get_hash(&method_name));
89: result.set_name(method_name);
90: r.write_no_lang(result);
91: }
92:
1.7 parser 93: static void _cache(Request& r, const String& method_name, MethodParams *params) {
94: Pool& pool=r.pool();
95: VHashfile& self=*static_cast<VHashfile *>(r.self);
96:
97: // key, expires, body code
98: const String &key=params->as_string(0, "key must be string");
99: double expires=params->as_double(1, "expires must be number", r);
100: Value& body_code=params->as_junction(2, "body must be code");
101:
102: // connection
103: DB_Connection& connection=self.get_connection(&method_name);
104:
105: // transaction
106: Auto_transaction transaction(connection);
107:
108: // execute body
109: try {
110: if(expires) { // 'expires' specified? try cached copy...
111: if(String *cached_body=connection.get(key)) { // have cached copy?
112: r.write_assign_lang(*cached_body);
113: // happy with it
114: return;
115: }
116: } else // 'expires'=0, forget cached copy
117: connection.remove(key);
118:
1.8 ! parser 119: // save
! 120: Autosave_marked_to_cancel_cache saved(self);
! 121:
1.7 parser 122: // process
123: Value& processed_body=r.process(body_code);
124: r.write_assign_lang(processed_body);
125:
1.8 ! parser 126: // put it to cache if 'expires' specified & never called ^delete[]
! 127: if(expires && !self.marked_to_cancel_cache())
1.7 parser 128: connection.put(key, processed_body.as_string(), time(0)+(time_t)expires);
129: } catch(...) { // process/commit problem
130: transaction.mark_to_rollback();
131:
132: /*re*/throw;
133: }
134: }
135:
1.8 ! parser 136: static void _delete(Request& r, const String& method_name, MethodParams *params) {
! 137: Pool& pool=r.pool();
! 138: VHashfile& self=*static_cast<VHashfile *>(r.self);
! 139:
! 140: if(params->size()==0)
! 141: self.mark_to_cancel_cache();
! 142: else {
! 143: // key
! 144: const String &key=params->as_string(0, "key must be string");
! 145: // connection
! 146: DB_Connection& connection=self.get_connection(&method_name);
! 147: // remove
! 148: connection.remove(key);
! 149: }
! 150: }
! 151:
1.1 parser 152: // constructor
153:
154: MHashfile::MHashfile(Pool& apool) : Methoded(apool) {
155: set_name(*NEW String(pool(), HASH_CLASS_NAME));
156:
1.3 parser 157: // ^hashfile::open[filename]
158: add_native_method("open", Method::CT_DYNAMIC, _open, 1, 1);
159: // ^transaction{code}
160: add_native_method("transaction", Method::CT_DYNAMIC, _transaction, 1, 1);
161: // ^hashfile:clear[filename]
162: add_native_method("clear", Method::CT_STATIC, _clear, 1, 1);
1.5 parser 163: // ^hash[]
164: add_native_method("hash", Method::CT_DYNAMIC, _hash, 0, 0);
1.1 parser 165: // ^cache[key](seconds){code}
166: add_native_method("cache", Method::CT_DYNAMIC, _cache, 3, 3);
1.8 ! parser 167: // ^hashfile.delete[key]
! 168: add_native_method("delete", Method::CT_DYNAMIC, _delete, 0, 1);
1.1 parser 169: }
170:
171: // global variable
172:
173: Methoded *hashfile_base_class;
174:
1.4 parser 175: #endif
176:
1.1 parser 177: // creator
178:
179: Methoded *MHashfile_create(Pool& pool) {
1.4 parser 180: return
181: #ifdef HAVE_LIBDB
182: hashfile_base_class=new(pool) MHashfile(pool)
183: #else
184: 0
185: #endif
186: ;
1.1 parser 187: }
E-mail:
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to hashfile.C CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [parser3project] / parser3 / src / classes