Merge pull request #6085 from ipfs/fix/thread-safe-mem-datastore

make in-memory datastore thread-safe

repo/fsrepo/datastores.go

@@ -10,6 +10,7 @@ import (
 
 	ds "github.com/ipfs/go-datastore"
 	"github.com/ipfs/go-datastore/mount"
+	dssync "github.com/ipfs/go-datastore/sync"
 	"github.com/ipfs/go-ds-measure"
 )
 
@@ -174,7 +175,7 @@ func (c *memDatastoreConfig) DiskSpec() DiskSpec {
 }
 
 func (c *memDatastoreConfig) Create(string) (repo.Datastore, error) {
-	return ds.NewMapDatastore(), nil
+	return dssync.MutexWrap(ds.NewMapDatastore()), nil
 }
 
 type logDatastoreConfig struct {

repo/repo.go

@@ -59,5 +59,5 @@ type Repo interface {
 // Datastore is the interface required from a datastore to be
 // acceptable to FSRepo.
 type Datastore interface {
-	ds.Batching // should be threadsafe, just be careful
+	ds.Batching // must be thread-safe
 }