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

Add files via upload

Browse source
This commit is contained in:
iFA 2021-04-14 09:09:06 +02:00 committed by GitHub
parent 92b8097048
commit f166a5dca3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 15 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
rocksdb/_rocksdb.pyx
View file

@ -159,8 +159,7 @@ cdef class PyGenericComparator(PyComparator):
def __dealloc__(self): def __dealloc__(self):
if not self.comparator_ptr == NULL: if not self.comparator_ptr == NULL:
with nogil: del self.comparator_ptr
del self.comparator_ptr
cdef object get_ob(self): cdef object get_ob(self):
return self.ob return self.ob
@ -772,8 +771,7 @@ cdef class _ColumnFamilyHandle:
def __dealloc__(self): def __dealloc__(self):
if not self.handle == NULL: if not self.handle == NULL:
with nogil: del self.handle
del self.handle
@staticmethod @staticmethod
cdef from_handle_ptr(db.ColumnFamilyHandle* handle): cdef from_handle_ptr(db.ColumnFamilyHandle* handle):
@ -881,8 +879,7 @@ cdef class ColumnFamilyOptions(object):
def __dealloc__(self): def __dealloc__(self):
if not self.copts == NULL: if not self.copts == NULL:
with nogil: del self.copts
del self.copts
def __init__(self, **kwargs): def __init__(self, **kwargs):
self.py_comparator = BytewiseComparator() self.py_comparator = BytewiseComparator()
@ -1293,9 +1290,8 @@ cdef class Options(ColumnFamilyOptions):
def __dealloc__(self): def __dealloc__(self):
if not self.opts == NULL: if not self.opts == NULL:
with nogil: self.copts = NULL
del self.copts del self.opts
del self.opts
def __init__(self, **kwargs): def __init__(self, **kwargs):
ColumnFamilyOptions.__init__(self) ColumnFamilyOptions.__init__(self)
@ -1439,6 +1435,12 @@ cdef class Options(ColumnFamilyOptions):
def __set__(self, value): def __set__(self, value):
self.opts.WAL_size_limit_MB = value self.opts.WAL_size_limit_MB = value
property max_total_wal_size:
def __get__(self):
return self.opts.max_total_wal_size
def __set__(self, value):
self.opts.max_total_wal_size = value
property manifest_preallocation_size: property manifest_preallocation_size:
def __get__(self): def __get__(self):
return self.opts.manifest_preallocation_size return self.opts.manifest_preallocation_size
@ -1549,8 +1551,7 @@ cdef class WriteBatch(object):
def __dealloc__(self): def __dealloc__(self):
if not self.batch == NULL: if not self.batch == NULL:
with nogil: del self.batch
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
@ -2304,8 +2305,7 @@ cdef class BaseIterator(object):
def __dealloc__(self): def __dealloc__(self):
if not self.ptr == NULL: if not self.ptr == NULL:
with nogil: del self.ptr
del self.ptr
def __iter__(self): def __iter__(self):
return self return self

3
rocksdb/options.pxd
View file

@ -87,7 +87,8 @@ cdef extern from "rocksdb/options.h" namespace "rocksdb":
int table_cache_numshardbits int table_cache_numshardbits
uint64_t WAL_ttl_seconds uint64_t WAL_ttl_seconds
uint64_t ttl uint64_t ttl
uint64_t WAL_size_limit_MB uint64_t WAL_size_limit_MB # Not supported
uint64_t max_total_wal_size
size_t manifest_preallocation_size size_t manifest_preallocation_size
cpp_bool allow_mmap_reads cpp_bool allow_mmap_reads
cpp_bool allow_mmap_writes cpp_bool allow_mmap_writes