logos-storage/nim-leveldb
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-leveldb.git synced 2026-01-08 16:43:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

asynchronous default

Browse Source
This commit is contained in:
Xie Yanbo 2020-02-27 20:34:11 +08:00
parent bd0e208256
commit c2ca9d6715
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/leveldb.nim
View File

@ -111,7 +111,7 @@ proc open*(path: string, create = true, reuse = true, paranoidChecks = true,
result.db = leveldb_open(options, path, addr errPtr) result.db = leveldb_open(options, path, addr errPtr)
checkError(errPtr) checkError(errPtr)
proc put*(self: LevelDb, key: string, value: string, sync = true) = proc put*(self: LevelDb, key: string, value: string, sync = false) =
assert self.db != nil assert self.db != nil
var errPtr: cstring = nil var errPtr: cstring = nil
let writeOptions = if sync: self.syncWriteOptions else: self.asyncWriteOptions let writeOptions = if sync: self.syncWriteOptions else: self.asyncWriteOptions
@ -150,7 +150,7 @@ proc getOrDefault*(self: LevelDb, key: string, default = ""): string =
else: else:
result = val.get() result = val.get()
proc delete*(self: LevelDb, key: string, sync = true) = proc delete*(self: LevelDb, key: string, sync = false) =
var errPtr: cstring = nil var errPtr: cstring = nil
let writeOptions = if sync: self.syncWriteOptions else: self.asyncWriteOptions let writeOptions = if sync: self.syncWriteOptions else: self.asyncWriteOptions
leveldb_delete(self.db, writeOptions, key, key.len, addr errPtr) leveldb_delete(self.db, writeOptions, key, key.len, addr errPtr)
@ -166,7 +166,7 @@ proc newBatch*(): LevelDbWriteBatch =
new(result, destroy) new(result, destroy)
result.batch = leveldb_writebatch_create() result.batch = leveldb_writebatch_create()
proc put*(self: LevelDbWriteBatch, key: string, value: string, sync = true) = proc put*(self: LevelDbWriteBatch, key: string, value: string, sync = false) =
leveldb_writebatch_put(self.batch, key, key.len.csize, value, value.len.csize) leveldb_writebatch_put(self.batch, key, key.len.csize, value, value.len.csize)
proc append*(self, source: LevelDbWriteBatch) = proc append*(self, source: LevelDbWriteBatch) =