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

Iterator notifies errors via 'it.status()'

Browse source
This commit is contained in:
hofmockel 2014-01-19 13:41:49 +01:00
parent 0d20a2564a
commit ccfa2b522e
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
rocksdb/_rocksdb.pyx
View file

@ -1259,6 +1259,7 @@ cdef class BaseIterator(object):
cdef object ret = self.get_ob() cdef object ret = self.get_ob()
with nogil: with nogil:
self.ptr.Next() self.ptr.Next()
check_status(self.ptr.status())
return ret return ret
def __reversed__(self): def __reversed__(self):
@ -1267,15 +1268,18 @@ cdef class BaseIterator(object):
cpdef seek_to_first(self): cpdef seek_to_first(self):
with nogil: with nogil:
self.ptr.SeekToFirst() self.ptr.SeekToFirst()
check_status(self.ptr.status())
cpdef seek_to_last(self): cpdef seek_to_last(self):
with nogil: with nogil:
self.ptr.SeekToLast() self.ptr.SeekToLast()
check_status(self.ptr.status())
cpdef seek(self, key): cpdef seek(self, key):
cdef Slice c_key = bytes_to_slice(key) cdef Slice c_key = bytes_to_slice(key)
with nogil: with nogil:
self.ptr.Seek(c_key) self.ptr.Seek(c_key)
check_status(self.ptr.status())
cdef object get_ob(self): cdef object get_ob(self):
return None return None
@ -1286,6 +1290,7 @@ cdef class KeysIterator(BaseIterator):
cdef Slice c_key cdef Slice c_key
with nogil: with nogil:
c_key = self.ptr.key() c_key = self.ptr.key()
check_status(self.ptr.status())
return slice_to_bytes(c_key) return slice_to_bytes(c_key)
@cython.internal @cython.internal
@ -1294,6 +1299,7 @@ cdef class ValuesIterator(BaseIterator):
cdef Slice c_value cdef Slice c_value
with nogil: with nogil:
c_value = self.ptr.value() c_value = self.ptr.value()
check_status(self.ptr.status())
return slice_to_bytes(c_value) return slice_to_bytes(c_value)
@cython.internal @cython.internal
@ -1304,6 +1310,7 @@ cdef class ItemsIterator(BaseIterator):
with nogil: with nogil:
c_key = self.ptr.key() c_key = self.ptr.key()
c_value = self.ptr.value() c_value = self.ptr.value()
check_status(self.ptr.status())
return (slice_to_bytes(c_key), slice_to_bytes(c_value)) return (slice_to_bytes(c_key), slice_to_bytes(c_value))
@cython.internal @cython.internal
@ -1334,4 +1341,5 @@ cdef class ReversedIterator(object):
cdef object ret = self.it.get_ob() cdef object ret = self.it.get_ob()
self.it.ptr.Prev() self.it.ptr.Prev()
check_status(self.it.ptr.status())
return ret return ret