[Python-checkins] python/dist/src/Lib/bsddb __init__.py,1.9,1.10

[greg at users.sourceforge.net]

Update of /cvsroot/python/python/dist/src/Lib/bsddb
In directory sc8-pr-cvs1:/tmp/cvs-serv11621/bsddb

Modified Files:
	__init__.py 
Log Message:
Use a threadsafe private DBEnv for each bsddb compatibility interface
db that is opened.  DB_THREAD and DB_INIT_LOCK allow for multithreaded
access.  DB_PRIVATE prevents the DBEnv from using the filesystem
(making it only usable by this process; and in this implementation
using one DBEnv per bsddb database)


Index: __init__.py
===================================================================
RCS file: /cvsroot/python/python/dist/src/Lib/bsddb/__init__.py,v
retrieving revision 1.9
retrieving revision 1.10
diff -C2 -d -r1.9 -r1.10
*** __init__.py	21 Sep 2003 00:08:14 -0000	1.9
--- __init__.py	27 Sep 2003 23:00:19 -0000	1.10
***************
*** 190,194 ****
  
      flags = _checkflag(flag)
!     d = db.DB()
      d.set_flags(hflags)
      if cachesize is not None: d.set_cachesize(0, cachesize)
--- 190,195 ----
  
      flags = _checkflag(flag)
!     e = _openDBEnv()
!     d = db.DB(e)
      d.set_flags(hflags)
      if cachesize is not None: d.set_cachesize(0, cachesize)
***************
*** 207,211 ****
  
      flags = _checkflag(flag)
!     d = db.DB()
      if cachesize is not None: d.set_cachesize(0, cachesize)
      if pgsize is not None: d.set_pagesize(pgsize)
--- 208,213 ----
  
      flags = _checkflag(flag)
!     e = _openDBEnv()
!     d = db.DB(e)
      if cachesize is not None: d.set_cachesize(0, cachesize)
      if pgsize is not None: d.set_pagesize(pgsize)
***************
*** 225,229 ****
  
      flags = _checkflag(flag)
!     d = db.DB()
      if cachesize is not None: d.set_cachesize(0, cachesize)
      if pgsize is not None: d.set_pagesize(pgsize)
--- 227,232 ----
  
      flags = _checkflag(flag)
!     e = _openDBEnv()
!     d = db.DB(e)
      if cachesize is not None: d.set_cachesize(0, cachesize)
      if pgsize is not None: d.set_pagesize(pgsize)
***************
*** 239,242 ****
--- 242,249 ----
  #----------------------------------------------------------------------
  
+ def _openDBEnv():
+     e = db.DBEnv()
+     e.open('.', db.DB_PRIVATE | db.DB_CREATE | db.DB_THREAD | db.DB_INIT_LOCK | db.DB_INIT_MPOOL)
+     return e
  
  def _checkflag(flag):