Annotation of parser3/src/main/pa_stylesheet_manager.C, revision 1.21
1.1 parser 1: /** @file
2: Parser: sql driver manager implementation.
3:
1.17 paf 4: Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com)
1.13 paf 5: Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
1.1 parser 6: */
7: #include "pa_config_includes.h"
8: #ifdef XML
1.14 paf 9:
1.21 ! paf 10: static const char * const IDENT_STYLESHEET_MANAGER_C="$Date: 2003/11/20 16:34:27 $";
1.1 parser 11:
12: #include "pa_stylesheet_manager.h"
13: #include "pa_exception.h"
14: #include "pa_common.h"
15: #include "pa_threads.h"
16: #include "pa_stack.h"
1.2 paf 17: #include "pa_vhash.h"
1.3 paf 18: #include "pa_vtable.h"
1.1 parser 19:
20: // globals
21:
1.17 paf 22: Stylesheet_manager stylesheet_manager;
1.1 parser 23:
24: // consts
25:
1.17 paf 26: const time_t SECOND=1;
27: const time_t EXPIRE_UNUSED_CONNECTION_SECONDS=5*60;
28: const time_t CHECK_EXPIRED_CONNECTION_SECONDS=EXPIRE_UNUSED_CONNECTION_SECONDS*2;
1.1 parser 29:
30: // helpers
31:
1.17 paf 32: static void expire_connection(Stylesheet_connection& connection, time_t older_dies) {
1.1 parser 33: if(connection.connected() && connection.expired(older_dies))
34: connection.disconnect();
35: }
1.17 paf 36: static void expire_connections(
37: Stylesheet_manager::connection_cache_type::key_type /*key*/,
38: Stylesheet_manager::connection_cache_type::value_type stack,
39: time_t older_dies) {
1.19 paf 40: for(size_t i=0; i<stack->top_index(); i++)
1.17 paf 41: expire_connection(*stack->get(i), older_dies);
1.1 parser 42: }
43:
1.17 paf 44: // Stylesheet_connection methods
1.1 parser 45:
1.17 paf 46: void Stylesheet_connection::close() {
47: stylesheet_manager.close_connection(ffile_spec, *this);
1.1 parser 48: }
49:
1.17 paf 50: // Stylesheet_manager methods
1.1 parser 51:
1.17 paf 52: Stylesheet_manager::Stylesheet_manager(): prev_expiration_pass_time(0) {
1.1 parser 53:
1.18 paf 54: cache_managers.put(String::Body("stylesheet"), this);
1.17 paf 55: }
56:
57: Stylesheet_manager::~Stylesheet_manager() {
58: connection_cache.for_each(expire_connections, time(0)+SECOND/*=in future=expire all*/);
59: }
60:
1.21 ! paf 61: Stylesheet_connection_ptr Stylesheet_manager::get_connection(String::Body file_spec) {
1.17 paf 62: Stylesheet_connection* result=get_connection_from_cache(file_spec);
63: if(!result)
64: result=new Stylesheet_connection(file_spec);
65: return Stylesheet_connection_ptr(result);
1.1 parser 66: }
67:
1.21 ! paf 68: void Stylesheet_manager::close_connection(String::Body file_spec, Stylesheet_connection& connection) {
1.1 parser 69: put_connection_to_cache(file_spec, connection);
70: }
71:
72: // stylesheet cache
73: /// @todo get rid of memory spending Stack [zeros deep inside got accumulated]
1.21 ! paf 74: Stylesheet_connection* Stylesheet_manager::get_connection_from_cache(String::Body file_spec) {
1.1 parser 75: SYNCHRONIZED;
76:
1.17 paf 77: if(connection_cache_type::value_type connections=connection_cache.get(file_spec))
78: while(!connections->is_empty()) { // there are cached stylesheets to that 'file_spec'
79: Stylesheet_connection* result=connections->pop();
1.1 parser 80: if(result->connected()) // not expired?
81: return result;
82: }
83:
84: return 0;
85: }
86:
1.21 ! paf 87: void Stylesheet_manager::put_connection_to_cache(String::Body file_spec,
1.17 paf 88: Stylesheet_connection& connection) {
1.1 parser 89: SYNCHRONIZED;
90:
1.17 paf 91: connection_cache_type::value_type connections=connection_cache.get(file_spec);
1.1 parser 92: if(!connections) { // there are no cached stylesheets to that 'file_spec' yet?
1.17 paf 93: connections=new connection_cache_value_type;
1.1 parser 94: connection_cache.put(file_spec, connections);
95: }
96: connections->push(&connection);
97: }
98:
1.5 paf 99: void Stylesheet_manager::maybe_expire_cache() {
1.1 parser 100: time_t now=time(0);
101:
102: if(prev_expiration_pass_time<now-CHECK_EXPIRED_CONNECTION_SECONDS) {
1.17 paf 103: connection_cache.for_each(expire_connections, now-EXPIRE_UNUSED_CONNECTION_SECONDS);
1.1 parser 104:
105: prev_expiration_pass_time=now;
106: }
107: }
1.17 paf 108: /*
1.3 paf 109: static void add_connection_to_status_cache_table(Array::Item *value, void *info) {
110: Stylesheet_connection& connection=*static_cast<Stylesheet_connection *>(value);
111: Table& table=*static_cast<Table *>(info);
112:
113: if(connection.connected()) {
1.17 paf 114: =table.pool();
115: Array& row=*new Array();
1.3 paf 116:
1.4 paf 117: // file
1.3 paf 118: row+=&connection.file_spec();
1.4 paf 119: // time
1.3 paf 120: time_t time_stamp=connection.get_time_used();
1.17 paf 121: row+=new String(pool.copy(ctime(&time_stamp)));
1.3 paf 122:
123: table+=&row;
124: }
125: }
126: static void add_connections_to_status_cache_table(const Hash::Key& key, Hash::Val *value, void *info) {
127: Stack& stack=*static_cast<Stack *>(value);
128: Array_iter iter(stack);
129: for(int countdown=stack.top_index(); countdown-->=0; )
130: add_connection_to_status_cache_table(iter.next(), info);
131: }
1.17 paf 132: */
133: Value* Stylesheet_manager::get_status() {
134: VHash* result=new VHash;
135: /*
1.2 paf 136: // cache
137: {
1.17 paf 138: Array& columns=*new Array();
139: columns+=new String("file");
140: columns+=new String("time");
141: Table& table=*new Table(0, &columns, connection_cache.length());
1.2 paf 142:
143: connection_cache.for_each(add_connections_to_status_cache_table, &table);
144:
1.17 paf 145: result.hash(source).put(*new String("cache"), new VTable(&table));
1.2 paf 146: }
1.17 paf 147: */
1.2 paf 148: return result;
149: }
150:
1.1 parser 151: #endif
E-mail:
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to pa_stylesheet_manager.C CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [parser3project] / parser3 / src / main