ó Š¼†Rc@sddlZddlZddlmZddlmZddlmZdefd„ƒYZ ej ƒZ dZ defd „ƒYZed „Zd „Zd „Zdd „Zd„ZedƒZedƒZedƒZedƒZedƒZedƒZd„Zd„ZdS(iÿÿÿÿNi(tcustom(t benchmarking(t cache_hooktTransactionAbortedcBseZRS((t__name__t __module__(((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyR stwithnesscBseZd„Zd„ZRS(cCs|S(N((tself((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyt __enter__scCs!|dkrtƒntƒdS(N(tNonetcommit_transactiontabort_transaction(Rtatbtc((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyt__exit__s  (RRRR(((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyRs cCsˆddlm}tt_|ƒt_dt_|rGtj tjƒntdƒt j ƒWdQXtdƒt j ƒWdQXt ƒS(Niÿÿÿÿ(tStringIOs beginning sqlsbeginning cache(t cStringIORtTruetstatetreadonlytlogR trevisionRtstarttsql_hooktbeginRR(t benchmarkR((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pytbegin_transaction$s     c Cst}y!tdƒtjƒWdQXWnItk rr}tjƒtj rltj dk rltj jƒn‚nXyEtj r·tj dk r·tdƒtj j ƒt_ WdQXnWnt jƒtjƒ‚n;Xtdƒt j ƒWdQXtdƒtj ƒWdQXdS(Ns preparing sqlscommitting vcsscommitting cachescommitting sql(tFalseRRtpreparet ExceptiontabortRRRtversion_control_hookR tcommitRR(tsuccesste((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyR 3s*       cCsrz7tjr,tdƒtjƒWdQXn tjƒWdtjƒtj rmtjdk rmtjjƒnXdS(Nsabort committing cache( RRRRR!RRRR R (((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyR Js   cCs]ddlm}|dkrY|jtjƒ}|dk rY|j|ƒrYtjƒqYndS(Ni(t structureuusernameupassword(uusernameupassword(tR$t get_elementRtEDITOR_ANCESTORR tis_ancestor_oft update_auth(telementtpnametvaltformatR$tanc((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pytmaybe_update_auth_post_setpropXs  cs‡fd†}|S(NcsçtjrLtt_tjdk rLtdƒtjjƒt_WdQXqLnt t ˆƒ||Žtjdk rt tjˆƒ||Žnt j ƒt t dˆƒrÇt t dˆƒ||Žnˆdkrãt||ŽndS(Ns beginning vcstpost_tsetprop(RRRRR R RRRtgetattrRRtclearthasattrR/(targstkw(tname(sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyt hookhelperbs     ((R7R8((R7sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyt __passthroughasR1tdeletetesetattrtedeletetpsetattrtpdeletecCs$ttdƒrtjjƒSdSdS(NRR%(R4RRtgetvalue(((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pytget_log|s cCs:tjdkr3tjdk r3tjjƒt_ntjS(N(RRR RR t get_revision(((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyRA‚s(tsyst threadingR%RRRtcacheRRRtlocalRR RtobjectRRRR R R/R9R1R:R;R<R=R>R@RA(((sA/afs/athena.mit.edu/user/x/a/xavid/Public/bazki/lib/bazbase/db.pyts(