logos-storage/nim-datastore
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-datastore.git synced 2026-01-06 23:53:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

cleanup tiered ds

Browse Source
This commit is contained in:
Dmitriy Ryajov 2022-09-19 17:13:34 -06:00
parent 7f9c319b98
commit c0f6e38fda
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
1 changed files with 12 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
datastore/tieredds.nim
View File

@ -55,31 +55,26 @@ method delete*(
method get*(
self: TieredDatastore,
key: Key): Future[?!(?seq[byte])] {.async, locks: "unknown".} =
key: Key): Future[?!seq[byte]] {.async, locks: "unknown".} =
var
bytesOpt: ?seq[byte]
bytes: seq[byte]
for store in self.stores:
let
getRes = await store.get(key)
without bytes =? (await store.get(key)):
continue
if getRes.isErr: return getRes
bytesOpt = getRes.get
if bytes.len <= 0:
continue
# put found data into stores logically in front of the current store
if bytes =? bytesOpt:
for s in self.stores:
if s == store: break
let
putRes = await s.put(key, bytes)
for s in self.stores:
if s == store: break
if(
let res = await s.put(key, bytes); res.isErr):
return failure res.error
if putRes.isErr: return failure putRes.error.msg
break
return success bytesOpt
return success bytes
method put*(
self: TieredDatastore,