aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorr@freesoftwareextremist.com <r@freesoftwareextremist.com>2020-08-22 07:02:37 +0000
committerr <r@freesoftwareextremist.com>2020-08-22 07:42:52 +0000
commita4a1ce9677e95a5f0503386e972f1f65c6037e2e (patch)
treecbdd29cfc4dac5116506e362db764620f9fe5e3b
parent9cd9e8bc7c9713cf574f809668f09acbb6284a0d (diff)
downloadbloat-a4a1ce9677e95a5f0503386e972f1f65c6037e2e.tar.gz
bloat-a4a1ce9677e95a5f0503386e972f1f65c6037e2e.zip
Update kv store
-rw-r--r--kv/kv.go41
1 files changed, 20 insertions, 21 deletions
diff --git a/kv/kv.go b/kv/kv.go
index 2cfcd60..0f51e07 100644
--- a/kv/kv.go
+++ b/kv/kv.go
@@ -15,7 +15,7 @@ var (
)
type Database struct {
- data map[string][]byte
+ cache map[string][]byte
basedir string
m sync.RWMutex
}
@@ -27,40 +27,37 @@ func NewDatabse(basedir string) (db *Database, err error) {
}
return &Database{
- data: make(map[string][]byte),
+ cache: make(map[string][]byte),
basedir: basedir,
}, nil
}
func (db *Database) Set(key string, val []byte) (err error) {
- if len(key) < 1 {
+ if len(key) < 1 || strings.ContainsRune(key, os.PathSeparator) {
return errInvalidKey
}
- db.m.Lock()
- defer func() {
- if err != nil {
- delete(db.data, key)
- }
- db.m.Unlock()
- }()
-
- db.data[key] = val
-
err = ioutil.WriteFile(filepath.Join(db.basedir, key), val, 0644)
+ if err != nil {
+ return
+ }
+
+ db.m.Lock()
+ db.cache[key] = val
+ db.m.Unlock()
return
}
func (db *Database) Get(key string) (val []byte, err error) {
- if len(key) < 1 {
+ if len(key) < 1 || strings.ContainsRune(key, os.PathSeparator) {
return nil, errInvalidKey
}
db.m.RLock()
- defer db.m.RUnlock()
+ data, ok := db.cache[key]
+ db.m.RUnlock()
- data, ok := db.data[key]
if !ok {
data, err = ioutil.ReadFile(filepath.Join(db.basedir, key))
if err != nil {
@@ -68,7 +65,9 @@ func (db *Database) Get(key string) (val []byte, err error) {
return nil, err
}
- db.data[key] = data
+ db.m.Lock()
+ db.cache[key] = data
+ db.m.Unlock()
}
val = make([]byte, len(data))
@@ -82,11 +81,11 @@ func (db *Database) Remove(key string) {
return
}
- db.m.Lock()
- defer db.m.Unlock()
-
- delete(db.data, key)
os.Remove(filepath.Join(db.basedir, key))
+ db.m.Lock()
+ delete(db.cache, key)
+ db.m.Unlock()
+
return
}