summary refs log tree commit diff stats
path: root/svc/leveldb.go
diff options
context:
space:
mode:
authorBen Morrison <ben@gbmor.dev>2019-06-13 20:18:05 -0400
committerBen Morrison <ben@gbmor.dev>2019-06-13 20:18:10 -0400
commit9c90526a24f32a00ad35073a09839189eb8aa007 (patch)
treecd8aa746d88512bb44a1c8e69f73a4e63e7af772 /svc/leveldb.go
parent88dbd876a9635fa515ed29875816d05975272597 (diff)
downloadgetwtxt-9c90526a24f32a00ad35073a09839189eb8aa007.tar.gz
removed mutex from remoteRegistries
slices are safe to use concurrently already.
leaving as a struct for possible expansion later.
Diffstat (limited to 'svc/leveldb.go')
-rw-r--r--svc/leveldb.go6
1 files changed, 0 insertions, 6 deletions
diff --git a/svc/leveldb.go b/svc/leveldb.go
index 655979a..7446dad 100644
--- a/svc/leveldb.go
+++ b/svc/leveldb.go
@@ -31,11 +31,9 @@ func (lvl *dbLevel) push() error {
 	}
 	twtxtCache.Mu.RUnlock()
 
-	remoteRegistries.Mu.RLock()
 	for k, v := range remoteRegistries.List {
 		dbBasket.Put([]byte("remote*"+string(k)), []byte(v))
 	}
-	remoteRegistries.Mu.RUnlock()
 
 	return lvl.db.Write(dbBasket, nil)
 }
@@ -51,9 +49,7 @@ func (lvl *dbLevel) pull() {
 		field := split[1]
 
 		if urls == "remote" {
-			remoteRegistries.Mu.Lock()
 			remoteRegistries.List = append(remoteRegistries.List, val)
-			remoteRegistries.Mu.Unlock()
 			continue
 		}
 
@@ -90,9 +86,7 @@ func (lvl *dbLevel) pull() {
 		twtxtCache.Mu.Unlock()
 	}
 
-	remoteRegistries.Mu.Lock()
 	remoteRegistries.List = dedupe(remoteRegistries.List)
-	remoteRegistries.Mu.Unlock()
 
 	iter.Release()
 	errLog("Error while pulling DB into registry cache: ", iter.Error())