From 097e0abca9e34e00477047acb29c861f140f141e Mon Sep 17 00:00:00 2001 From: "Paul W. Homer" Date: Thu, 23 Mar 2017 14:46:40 -0400 Subject: [PATCH] Added in locking --- mem_db.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/mem_db.go b/mem_db.go index ef410e88..5307d1a7 100644 --- a/mem_db.go +++ b/mem_db.go @@ -78,6 +78,9 @@ type memDBIterator struct { } func (it *memDBIterator) Create(db *MemDB) *memDBIterator { + db.mtx.Lock() + defer db.mtx.Unlock() + if it == nil { it = &memDBIterator{} } @@ -104,6 +107,9 @@ func (it *memDBIterator) Key() []byte { } func (it *memDBIterator) Value() []byte { + it.db.mtx.Lock() + defer it.db.mtx.Unlock() + return it.db.db[it.keys[it.last]] }