ó ;t/Uc@s\ddlZddlmZddlmZmZddlmZdefd„ƒYZ dS(iÿÿÿÿNi(texists(t GLOBAL_LOCKERt THREAD_LOCAL(tUseDatabaseStoredFiletConnectionPoolcBskeZiZeZed„ƒZded„Zed„ƒZd„Z d„Z d„Z ded„Z RS( cCs |t_dS(N(Rtfolder(R((sM/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/connection.pyt set_folder stcommitcCsÞt}|rLy-t|ƒr(||ƒnt||ƒƒWqLt}qLXn|jr°|r°tjƒtj|j }t |ƒ|jkr£|j |j ƒt}ntj ƒn|rÑy|jƒWqÑqÑXnd|_ dS(N(tTruetcallabletgetattrtFalset pool_sizeRtacquireRtPOOLSturitlentappendt connectiontreleasetclose_connectiontNone(tselftactiontreallyt succeededtpool((sM/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/connection.pytcloses*      cCs«ttdiƒjƒ}xG|D]?\}}x0|D](}t|dƒr2|jj|ƒq2q2WqWttdiƒjƒttdiƒjƒt|ƒr§|dƒndS(s; to close cleanly databases in a multithreaded environment t db_instancest_adaptertdb_instances_zombieN( R RtitemsthasattrRRtclearR R(Rtdbstdb_uidtdb_grouptdb((sM/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/connection.pytclose_all_instances2s   cCs«ttddƒ|_tjj|jƒrut|tƒru|jjtj ƒƒrutjj |jtj ƒƒ|_nt r§|jr§t |jƒ r§tj |jƒndS(NRt(R RRtostpathtisabst isinstanceRt startswithtgetcwdtrelpathR Rtmkdir(R((sM/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/connection.pytfind_or_make_work_folder@s$cCs-t|jƒr|j|ƒn|jƒdS(s'Hook for the after_connection parameterN(R t_after_connectiontafter_connection(R((sM/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/connection.pytafter_connection_hookMscCsdS(N((R((sM/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/connection.pyR2SscCsYt|ddƒdk rdS|dkr4|j}n|jsd|ƒ|_|o[|jjƒ|_nç|j}tj}xÒt rJt j ƒ||kr¢g||0` it will try pull the connection from the pool if the connection is not active (closed by db server) it will loop if not `self.pool_size` or no active connections in pool makes a new one RN(R Rt connectorR RtcursorRRRRRR tpopRtcheck_active_connectiontexecutet test_queryR3(RtfR5RR((sM/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/connection.pyt reconnectWs8              N(t__name__t __module__RRR7t staticmethodRRR&R0R3R2RR;(((sM/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/connection.pyR s!  ( R(t_compatRt_globalsRRthelpers.classesRtobjectR(((sM/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/packages/dal/pydal/connection.pyts