5 files changed, 180 insertions, 0 deletions

diff --git a/lib/.gitignore b/lib/.gitignore
new file mode 100644
index 0000000..7a5e754
--- a/dev/null
+++ b/lib/.gitignore
@@ -0,0 +1,7 @@
+Makefile.in
+.libs
+.deps
+Makefile
+*.lo
+*.o
+*.la
diff --git a/lib/Makefile.am b/lib/Makefile.am
new file mode 100644
index 0000000..a904569
--- a/dev/null
+++ b/lib/Makefile.am
@@ -0,0 +1,16 @@
+lib_LTLIBRARIES = libkonforka.la
+
+INCLUDES = -I${top_srcdir}/include
+AM_CXXFLAGS = ${PQXX_CFLAGS}
+LDADD = ${PQXX_LIBS}
+
+EXTRA_DIST = pqxx_pile.cc
+EXTRA_SOURCES=
+if HAVE_PQXX
+EXTRA_SOURCES += pqxx_pile.cc
+endif
+
+libkonforka_la_SOURCES = \
+        exception.cc \
+        pointer_map.cc \
+        ${EXTRA_SOURCES}
diff --git a/lib/exception.cc b/lib/exception.cc
new file mode 100644
index 0000000..65302bf
--- a/dev/null
+++ b/lib/exception.cc
@@ -0,0 +1,66 @@
+#include <string.h>
+#include <errno.h>
+#include "konforka/exception.h"
+
+namespace konforka {
+
+    /*
+     * code_point
+     */
+
+    code_point::code_point(const string& w)
+        : where(w), line(-1) { }
+    code_point::code_point(const string& fi,const string& fu,int l)
+        : file(fi), function(fu), line(l) {
+            make_where();
+        }
+
+    const char *code_point::c_str() const throw() {
+        return where.c_str();
+    }
+
+    void code_point::make_where() {
+        static char tmp[8];
+        snprintf(tmp,sizeof(tmp),"%d",line);
+        where = file + ":" + tmp + " [" + function + "]";
+    }
+    
+    /*
+     * exception
+     */
+
+    exception::exception(const string& whe,const string& wha)
+        : _where(whe), _what(wha) { }
+    exception::exception(const string& fi,const string& fu,int l,const string& w)
+        : _where(fi,fu,l), _what(w) { }
+    exception::~exception() throw() { }
+
+    const char *exception::where() const throw() {
+        return _where.c_str();
+    }
+    const char *exception::what() const throw() {
+        return _what.c_str();
+    }
+
+    void exception::see(const string& w) {
+        _seen.push_back(code_point(w));
+    }
+    void exception::see(const string& fi,const string& fu,int l) {
+        _seen.push_back(code_point(fi,fu,l));
+    }
+
+    /*
+     * system_error
+     */
+
+    system_error::system_error(const string& whe,const string& wha)
+        : _errno(errno), exception(whe,wha) { }
+    system_error::system_error(const string& fi,const string& fu,int l,const string& w)
+        : _errno(errno), exception(fi,fu,l,w) { }
+    system_error::~system_error() throw() { }
+
+    const char *system_error::why() const throw() {
+        return strerror(errno); // TODO: strerror_r
+    }
+
+}
diff --git a/lib/pointer_map.cc b/lib/pointer_map.cc
new file mode 100644
index 0000000..44f7ebc
--- a/dev/null
+++ b/lib/pointer_map.cc
@@ -0,0 +1,74 @@
+#include <cassert>
+#include <map>
+#include <string>
+using namespace std;
+#include "konforka/exception.h"
+#include "konforka/pointer_map.h"
+
+namespace konforka {
+
+    /*
+     * to_t->from_t->from->to
+     */
+    class mpointer_t {
+        public:
+            void *ptr;
+            int ref;
+
+            mpointer_t() : ptr(0), ref(0) { }
+
+            void _ref() { ref++; }
+            void _unref() { ref--; }
+    };
+    typedef map<void*,mpointer_t> map_ptr_1_t;
+    typedef map<string,map_ptr_1_t> map_ptr_2_t;
+    typedef map<string,map_ptr_2_t> map_ptr_t;
+
+    static map_ptr_t pointer_map;
+    
+    void _map_pointer(const type_info& tf,void *pf,const type_info& tt,void *pt) {
+        mpointer_t& mpt = pointer_map[tf.name()][tt.name()][pf];
+        if(mpt.ref) {
+            if(mpt.ptr != pt)
+                throw exception(CODEPOINT,"trying to remap existing pointer with different value");
+        }else{
+            mpt.ptr = pt;
+        }
+        mpt.ref++;
+    }
+    void _unmap_pointer(const type_info& tf,void *pf,const type_info& tt,void *pt) {
+        map_ptr_t::iterator i1 = pointer_map.find(tf.name());
+        if(i1==pointer_map.end())
+            throw exception(CODEPOINT,"no pointer of such type has ever been mapped");
+        map_ptr_2_t::iterator i2 = i1->second.find(tt.name());
+        if(i2==i1->second.end())
+            throw exception(CODEPOINT,"no pointer has ever been mapped to the object of this type");
+        map_ptr_1_t::iterator i3 = i2->second.find(pf);
+        if(i3==i2->second.end())
+            throw exception(CODEPOINT,"this pointer has never been mapped");
+        assert(i3->second.ref>0);
+        if(--(i3->second.ref))
+            return;
+        i2->second.erase(i3);
+        if(!i2->second.empty())
+            return;
+        i1->second.erase(i2);
+        if(!i1->second.empty())
+            return;
+        pointer_map.erase(i1);
+    }
+    void *_mapped_pointer(const type_info& tf,void *pf,const type_info& tt) {
+        map_ptr_t::iterator i1 = pointer_map.find(tf.name());
+        if(i1==pointer_map.end())
+            throw exception(CODEPOINT,"no pointer of such type has ever been mapped");
+        map_ptr_2_t::iterator i2 = i1->second.find(tt.name());
+        if(i2==i1->second.end())
+            throw exception(CODEPOINT,"no pointer has ever been mapped to the object of this type");
+        map_ptr_1_t::iterator i3 = i2->second.find(pf);
+        if(i3==i2->second.end())
+            throw exception(CODEPOINT,"this pointer has never been mapped");
+        assert(i3->second.ref>0);
+        return i3->second.ptr;
+    }
+
+}
diff --git a/lib/pqxx_pile.cc b/lib/pqxx_pile.cc
new file mode 100644
index 0000000..d6623bb
--- a/dev/null
+++ b/lib/pqxx_pile.cc
@@ -0,0 +1,17 @@
+#include "konforka/pqxx_pile.h"
+
+namespace konforka {
+
+    template class resource_pile_generic_ptr_factory<string,pqxx::connection>;
+    template class resource_pile_generic_ptr_factory<string,pqxx::lazyconnection>;
+    template class resource_pile_generic_ptr_factory<string,pqxx::asyncconnection>;
+
+    template class resource_pile_base<string,pqxx::connection*,resource_pile_generic_ptr_factory<string,pqxx::connection> >;
+    template class resource_pile_base<string,pqxx::lazyconnection*,resource_pile_generic_ptr_factory<string,pqxx::lazyconnection> >;
+    template class resource_pile_base<string,pqxx::asyncconnection*,resource_pile_generic_ptr_factory<string,pqxx::asyncconnection> >;
+
+    template class pqxx_piled_connection_base<pqxx::connection>;
+    template class pqxx_piled_connection_base<pqxx::lazyconnection>;
+    template class pqxx_piled_connection_base<pqxx::asyncconnection>;
+
+}