atexit saçmalığını kaldırıyoruz. Gürer sağ olsun.
This commit is contained in:
@@ -10,7 +10,6 @@
|
|||||||
#from bsddb.dbshelve import DBShelf
|
#from bsddb.dbshelve import DBShelf
|
||||||
import bsddb.dbshelve as shelve
|
import bsddb.dbshelve as shelve
|
||||||
import os, fcntl
|
import os, fcntl
|
||||||
import atexit
|
|
||||||
|
|
||||||
import util
|
import util
|
||||||
from config import config
|
from config import config
|
||||||
@@ -30,10 +29,6 @@ class PackageDB(object):
|
|||||||
self.dr = shelve.open(self.fname2)
|
self.dr = shelve.open(self.fname2)
|
||||||
|
|
||||||
self.lockfile = self.fname + '.lock'
|
self.lockfile = self.fname + '.lock'
|
||||||
if os.path.exists(self.lockfile):
|
|
||||||
# buraya hic bir zaman gelmemesi gerekiyor.
|
|
||||||
raise PackageDBError, "Lock file exists. Something is wrong!"
|
|
||||||
|
|
||||||
self.fdummy = file(self.lockfile, 'w')
|
self.fdummy = file(self.lockfile, 'w')
|
||||||
fcntl.flock(self.fdummy, fcntl.LOCK_EX)
|
fcntl.flock(self.fdummy, fcntl.LOCK_EX)
|
||||||
|
|
||||||
@@ -74,7 +69,6 @@ packagedbs = {}
|
|||||||
|
|
||||||
def add_db(name):
|
def add_db(name):
|
||||||
packagedbs[name] = PackageDB('repo-' + name)
|
packagedbs[name] = PackageDB('repo-' + name)
|
||||||
atexit.register(close, packagedbs[name])
|
|
||||||
|
|
||||||
def get_db(name):
|
def get_db(name):
|
||||||
return packagedbs[name]
|
return packagedbs[name]
|
||||||
@@ -105,17 +99,7 @@ def get_rev_deps(name):
|
|||||||
repo = which_repo(name)
|
repo = which_repo(name)
|
||||||
return get_db(repo).get_rev_deps(name)
|
return get_db(repo).get_rev_deps(name)
|
||||||
|
|
||||||
def close(pkg_db):
|
|
||||||
try:
|
|
||||||
fcntl.flock(pkg_db.fdummy, fcntl.LOCK_UN)
|
|
||||||
pkg_db.fdummy.close()
|
|
||||||
os.unlink(pkg_db.lockfile)
|
|
||||||
except ValueError:
|
|
||||||
# packagedb allready closed.
|
|
||||||
pass
|
|
||||||
|
|
||||||
|
|
||||||
#def remove_package
|
#def remove_package
|
||||||
|
|
||||||
inst_packagedb = PackageDB('local')
|
inst_packagedb = PackageDB('local')
|
||||||
atexit.register(close, inst_packagedb)
|
|
||||||
|
|||||||
Reference in New Issue
Block a user