// Connector
//
// Douglas Thrift
//
// $Id$

#include <menes/c++/standard.hh>

#include <menes/hop/bind.hpp>
#include <menes/xml/document.hpp>
#include <menes/xml/nodeset.hpp>
#include <menes/xml/parse.hpp>

#include "Connector.hpp"

Connector::Connector(const cse::String& configuration) : running(true), cleanup(hop::BindAll(&Connector::Cleanup, this))
{
	_R<xml::Document> document(xml::Parse(configuration));
	_R<xml::Node> configuration_(*document/"configuration");

	driver = dbi::GetDriver(*configuration_/"driver");
	host = *configuration_/"host";
	user = *configuration_/"user";
	password = *configuration_/"password";
	database = *configuration_/"database";
}

_R<dbi::Connection> Connector::Connect()
{
	_R<dbi::Connection> connection;

	_synchronized (connectionsLock)
		if (!connections.Pop(connection))
			connection = driver->Connect(host, user, password, database);

	return connection;
}

void Connector::Release(const _R<dbi::Connection>& connection)
{
	_synchronized (connectionsLock)
		connections.Push(connection);
}

int Connector::Cleanup()
{
	while (running)
	{
		::timespec sleep = { 60, 0 }, remaining;

		while (running && ::nanosleep(&sleep, &remaining) == -1)
			sleep = remaining;

		_synchronized (connectionsLock)
			connections.Clear();
	}

	return 0;
}