6067355637

Committed 03 Sep 2023 11:32PM UTC coverage: 66.95% (+0.02%) from 66.93%

Build # 6067355637

Build Type

push

github

Committed by

web-flow

Commit Message

Adapt RocksDB 8.4.4 (#125)

Run Details

3 of 3 new or added lines in 1 file covered. (100.0%)

3308 of 4941 relevant lines covered (66.95%)

0.69 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/wal_iterator.go

package grocksdb

// #include <stdlib.h>
// #include "rocksdb/c.h"
import "C"
import "unsafe"

// WalIterator is iterator for WAL Files.
type WalIterator struct {
        c *C.rocksdb_wal_iterator_t
}

// NewNativeWalIterator returns new WalIterator.
func newNativeWalIterator(c unsafe.Pointer) *WalIterator {
        return &WalIterator{c: (*C.rocksdb_wal_iterator_t)(c)}
}

// Valid check if current WAL is valid.
func (iter *WalIterator) Valid() bool {
        return C.rocksdb_wal_iter_valid(iter.c) != 0
}

// Next moves next.
func (iter *WalIterator) Next() {
        C.rocksdb_wal_iter_next(iter.c)
}

// Err returns error happened during iteration.
func (iter *WalIterator) Err() (err error) {
        var cErr *C.char
        C.rocksdb_wal_iter_status(iter.c, &cErr)
        err = fromCError(cErr)
        return
}

// Destroy free iterator.
func (iter *WalIterator) Destroy() {
        C.rocksdb_wal_iter_destroy(iter.c)
        iter.c = nil
}

// GetBatch returns the current write_batch and the sequence number of the
// earliest transaction contained in the batch.
func (iter *WalIterator) GetBatch() (*WriteBatch, uint64) {
        var cSeq C.uint64_t
        cB := C.rocksdb_wal_iter_get_batch(iter.c, &cSeq)
        return newNativeWriteBatch(cB), uint64(cSeq)
}

1	package grocksdb
2
3	// #include <stdlib.h>
4	// #include "rocksdb/c.h"
5	import "C"
6	import "unsafe"
7
8	// WalIterator is iterator for WAL Files.
9	type WalIterator struct {
10	c *C.rocksdb_wal_iterator_t
11	}
12
13	// NewNativeWalIterator returns new WalIterator.
14	func newNativeWalIterator(c unsafe.Pointer) *WalIterator {	×
15	return &WalIterator{c: (*C.rocksdb_wal_iterator_t)(c)}	×
16	}	×
17
18	// Valid check if current WAL is valid.
19	func (iter *WalIterator) Valid() bool {	×
20	return C.rocksdb_wal_iter_valid(iter.c) != 0	×
21	}	×
22
23	// Next moves next.
24	func (iter *WalIterator) Next() {	×
25	C.rocksdb_wal_iter_next(iter.c)	×
26	}	×
27
28	// Err returns error happened during iteration.
29	func (iter *WalIterator) Err() (err error) {	×
30	var cErr *C.char	×
31	C.rocksdb_wal_iter_status(iter.c, &cErr)	×
32	err = fromCError(cErr)	×
33	return	×
34	}	×
35
36	// Destroy free iterator.
37	func (iter *WalIterator) Destroy() {	×
38	C.rocksdb_wal_iter_destroy(iter.c)	×
39	iter.c = nil	×
40	}	×
41
42	// GetBatch returns the current write_batch and the sequence number of the
43	// earliest transaction contained in the batch.
44	func (iter WalIterator) GetBatch() (WriteBatch, uint64) {	×
45	var cSeq C.uint64_t	×
46	cB := C.rocksdb_wal_iter_get_batch(iter.c, &cSeq)	×
47	return newNativeWriteBatch(cB), uint64(cSeq)	×
48	}	×

linxGnu / grocksdb / 6067355637

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous