LBRYCommunity/lbry-rocksdb
1
0
Fork 0
Code Issues 6 Pull requests 2 Projects Releases Packages Wiki Activity

Update _rocksdb.pyx

Browse source
This commit is contained in:
iFA 2021-03-11 18:19:40 +01:00 committed by GitHub
parent a846ec9af5
commit 92b8097048
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
rocksdb/_rocksdb.pyx
View file

@ -159,7 +159,8 @@ cdef class PyGenericComparator(PyComparator):
def __dealloc__(self): def __dealloc__(self):
if not self.comparator_ptr == NULL: if not self.comparator_ptr == NULL:
del self.comparator_ptr with nogil:
del self.comparator_ptr
cdef object get_ob(self): cdef object get_ob(self):
return self.ob return self.ob
@ -771,7 +772,8 @@ cdef class _ColumnFamilyHandle:
def __dealloc__(self): def __dealloc__(self):
if not self.handle == NULL: if not self.handle == NULL:
del self.handle with nogil:
del self.handle
@staticmethod @staticmethod
cdef from_handle_ptr(db.ColumnFamilyHandle* handle): cdef from_handle_ptr(db.ColumnFamilyHandle* handle):
@ -879,7 +881,8 @@ cdef class ColumnFamilyOptions(object):
def __dealloc__(self): def __dealloc__(self):
if not self.copts == NULL: if not self.copts == NULL:
del self.copts with nogil:
del self.copts
def __init__(self, **kwargs): def __init__(self, **kwargs):
self.py_comparator = BytewiseComparator() self.py_comparator = BytewiseComparator()
@ -1290,8 +1293,9 @@ cdef class Options(ColumnFamilyOptions):
def __dealloc__(self): def __dealloc__(self):
if not self.opts == NULL: if not self.opts == NULL:
self.copts = NULL with nogil:
del self.opts del self.copts
del self.opts
def __init__(self, **kwargs): def __init__(self, **kwargs):
ColumnFamilyOptions.__init__(self) ColumnFamilyOptions.__init__(self)
@ -1545,7 +1549,8 @@ cdef class WriteBatch(object):
def __dealloc__(self): def __dealloc__(self):
if not self.batch == NULL: if not self.batch == NULL:
del self.batch with nogil:
del self.batch
def put(self, key, value): def put(self, key, value):
cdef db.ColumnFamilyHandle* cf_handle = NULL cdef db.ColumnFamilyHandle* cf_handle = NULL
@ -1753,13 +1758,13 @@ cdef class DB(object):
db.CancelAllBackgroundWork(self.db, c_safe) db.CancelAllBackgroundWork(self.db, c_safe)
# We have to make sure we delete the handles so rocksdb doesn't # We have to make sure we delete the handles so rocksdb doesn't
# assert when we delete the db # assert when we delete the db
del self.cf_handles[:] self.cf_handles.clear()
for copts in self.cf_options: for copts in self.cf_options:
if copts: if copts:
copts.in_use = False copts.in_use = False
del self.cf_options[:] self.cf_options.clear()
with nogil: with nogil:
st = self.db.Close() self.db.Close()
self.db = NULL self.db = NULL
if self.opts is not None: if self.opts is not None:
self.opts.in_use = False self.opts.in_use = False
@ -2299,7 +2304,8 @@ cdef class BaseIterator(object):
def __dealloc__(self): def __dealloc__(self):
if not self.ptr == NULL: if not self.ptr == NULL:
del self.ptr with nogil:
del self.ptr
def __iter__(self): def __iter__(self):
return self return self