parser3/src/main/pa_stylesheet_manager.C - diff

Return to pa_stylesheet_manager.C CVS log

Up to [parser3project] / parser3 / src / main

Diff for /parser3/src/main/pa_stylesheet_manager.C between versions 1.1 and 1.16.2.4

version 1.1, 2001/10/22 16:44:42	version 1.16.2.4, 2003/02/21 08:50:03
Line 1	Line 1
/** @file	/** @file
Parser: sql driver manager implementation.	Parser: sql driver manager implementation.

Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com)	Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com)
Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)	Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)

$Id$
*/	*/
#include "pa_config_includes.h"	#include "pa_config_includes.h"
#ifdef XML	#ifdef XML

	static const char* IDENT_STYLESHEET_MANAGER_C="$Date$";

#include "pa_stylesheet_manager.h"	#include "pa_stylesheet_manager.h"
#include "pa_stylesheet_connection.h"	#include "pa_stylesheet_connection.h"
#include "ltdl.h"
#include "pa_exception.h"	#include "pa_exception.h"
#include "pa_common.h"	#include "pa_common.h"
#include "pa_threads.h"	#include "pa_threads.h"
#include "pa_stack.h"	#include "pa_stack.h"
	#include "pa_vhash.h"
	#include "pa_vtable.h"

// globals	// globals

Line 43 static void expire_connections(const Has	Line 44 static void expire_connections(const Has

// Stylesheet_manager	// Stylesheet_manager

Stylesheet_manager::Stylesheet_manager(Pool& pool) : Pooled(pool),	Stylesheet_manager::Stylesheet_manager(Pool& apool) : Cache_manager(apool),
connection_cache(pool),	connection_cache(apool),
prev_expiration_pass_time(0) {	prev_expiration_pass_time(0) {
}	}
Stylesheet_manager::~Stylesheet_manager() {	Stylesheet_manager::~Stylesheet_manager() {
connection_cache.for_each(expire_connections,	connection_cache.for_each(expire_connections,
reinterpret_cast<void >((time_t)0/=in past=expire all*/));	reinterpret_cast<void >(time(0)+1/=in future=expire all*/));
}	}

Stylesheet_connection& Stylesheet_manager::get_connection(const String& request_file_spec) {	Stylesheet_connection_ptr Stylesheet_manager::get_connection(const String& request_file_spec) {
Pool& pool=request_file_spec.pool(); // request pool	Pool& pool=request_file_spec.pool(); // request pool

// first trying to get cached stylesheet	// first trying to get cached stylesheet
Stylesheet_connection *result=get_connection_from_cache(request_file_spec);	Stylesheet_connection *connection=get_connection_from_cache(request_file_spec);
if(!result) {	if(!connection) {
// then just construct it	// then just construct it

// make global_file_spec C-string on global pool	// make global_file_spec C-string on global pool
const char *request_file_spec_cstr=request_file_spec.cstr(String::UL_FILE_SPEC);	CharPtr global_file_spec_cstr=request_file_spec.cstr(this->pool(pool), String::UL_FILE_SPEC);
char global_file_spec_cstr=(char )malloc(strlen(request_file_spec_cstr)+1);
strcpy(global_file_spec_cstr, request_file_spec_cstr);
// make global_file_spec string on global pool	// make global_file_spec string on global pool
String& global_file_spec=*new(this->pool()) String(this->pool(), global_file_spec_cstr);	String& global_file_spec=*new(this->pool()) String(this->pool(), global_file_spec_cstr);

result=new(this->pool()) Stylesheet_connection(this->pool(), global_file_spec);	connection=new(this->pool()) Stylesheet_connection(this->pool(), global_file_spec);
}	}
// associate with services[request] (deassociates at close)	// associate with services[request] (deassociates at close)
result->set_services(&pool);	connection->set_services(&pool);
// return it	// return autoclosing object for it
return *result;	return Stylesheet_connection_ptr(connection);
}	}

void Stylesheet_manager::close_connection(const String& file_spec,	void Stylesheet_manager::close_connection(const String& file_spec,
Line 88 void Stylesheet_manager::close_connectio	Line 87 void Stylesheet_manager::close_connectio
Stylesheet_connection *Stylesheet_manager::get_connection_from_cache(const String& file_spec) {	Stylesheet_connection *Stylesheet_manager::get_connection_from_cache(const String& file_spec) {
SYNCHRONIZED;	SYNCHRONIZED;

maybe_expire_connection_cache();

if(Stack connections=static_cast<Stack >(connection_cache.get(file_spec)))	if(Stack connections=static_cast<Stack >(connection_cache.get(file_spec)))
while(connections->top_index()>=0) { // there are cached stylesheets to that 'file_spec'	while(connections->top_index()>=0) { // there are cached stylesheets to that 'file_spec'
Stylesheet_connection result=static_cast<Stylesheet_connection >(connections->pop());	Stylesheet_connection result=static_cast<Stylesheet_connection >(connections->pop());
Line 112 void Stylesheet_manager::put_connection_	Line 109 void Stylesheet_manager::put_connection_
connections->push(&connection);	connections->push(&connection);
}	}

void Stylesheet_manager::maybe_expire_connection_cache() {	void Stylesheet_manager::maybe_expire_cache() {
time_t now=time(0);	time_t now=time(0);

if(prev_expiration_pass_time<now-CHECK_EXPIRED_CONNECTION_SECONDS) {	if(prev_expiration_pass_time<now-CHECK_EXPIRED_CONNECTION_SECONDS) {
Line 122 void Stylesheet_manager::maybe_expire_co	Line 119 void Stylesheet_manager::maybe_expire_co
prev_expiration_pass_time=now;	prev_expiration_pass_time=now;
}	}
}	}

	static void add_connection_to_status_cache_table(Array::Item value, void info) {
	Stylesheet_connection& connection=static_cast<Stylesheet_connection >(value);
	Table& table=static_cast<Table >(info);

	if(connection.connected()) {
	Pool& pool=table.pool();
	Array& row=*new(pool) Array(pool);

	// file
	row+=&connection.file_spec();
	// time
	time_t time_stamp=connection.get_time_used();
	row+=new(pool) String(pool, pool.copy(ctime(&time_stamp)));

	table+=&row;
	}
	}
	static void add_connections_to_status_cache_table(const Hash::Key& key, Hash::Val value, void info) {
	Stack& stack=static_cast<Stack >(value);
	Array_iter iter(stack);
	for(int countdown=stack.top_index(); countdown-->=0; )
	add_connection_to_status_cache_table(iter.next(), info);
	}
	Value& Stylesheet_manager::get_status(Pool& pool, const String *source) {
	VHash& result=*new(pool) VHash(pool);

	// cache
	{
	Array& columns=*new(pool) Array(pool);
	columns+=new(pool) String(pool, "file");
	columns+=new(pool) String(pool, "time");
	Table& table=*new(pool) Table(pool, 0, &columns, connection_cache.size());

	connection_cache.for_each(add_connections_to_status_cache_table, &table);

	result.hash(source).put(*new(pool) String(pool, "cache"), new(pool) VTable(pool, &table));
	}

	return result;
	}

#endif	#endif

E-mail:

Removed from v.1.1
changed lines
	Added in v.1.16.2.4