[#1313] blobovnicza: Prevent concurrent Put/Close

Signed-off-by: Evgenii Stratonikov <e.stratonikov@yadro.com>

pkg/local_object_storage/blobovnicza/blobovnicza.go

@@ -22,7 +22,7 @@ type Blobovnicza struct {
 	boltDB *bbolt.DB
 
 	opened     bool
-	controlMtx sync.Mutex
+	controlMtx sync.RWMutex
 }
 
 // Option is an option of Blobovnicza's constructor.

pkg/local_object_storage/blobovnicza/delete.go

@@ -45,6 +45,9 @@ func (b *Blobovnicza) Delete(ctx context.Context, prm DeletePrm) (DeleteRes, err
 		))
 	defer span.End()
 
+	b.controlMtx.RLock()
+	defer b.controlMtx.RUnlock()
+
 	addrKey := addressKey(prm.addr)
 
 	found := false

pkg/local_object_storage/blobovnicza/exists.go

@@ -21,6 +21,9 @@ func (b *Blobovnicza) Exists(ctx context.Context, addr oid.Address) (bool, error
 		))
 	defer span.End()
 
+	b.controlMtx.RLock()
+	defer b.controlMtx.RUnlock()
+
 	addrKey := addressKey(addr)
 
 	err := b.boltDB.View(func(tx *bbolt.Tx) error {

pkg/local_object_storage/blobovnicza/get.go

@@ -51,6 +51,9 @@ func (b *Blobovnicza) Get(ctx context.Context, prm GetPrm) (GetRes, error) {
 		))
 	defer span.End()
 
+	b.controlMtx.RLock()
+	defer b.controlMtx.RUnlock()
+
 	var (
 		data    []byte
 		addrKey = addressKey(prm.addr)

pkg/local_object_storage/blobovnicza/iterate.go

@@ -128,6 +128,9 @@ func (b *Blobovnicza) Iterate(ctx context.Context, prm IteratePrm) (IterateRes,
 		))
 	defer span.End()
 
+	b.controlMtx.RLock()
+	defer b.controlMtx.RUnlock()
+
 	var elem IterationElement
 
 	if err := b.boltDB.View(func(tx *bbolt.Tx) error {

pkg/local_object_storage/blobovnicza/move.go

@@ -29,6 +29,9 @@ func (b *Blobovnicza) PutMoveInfo(ctx context.Context, prm MoveInfo) error {
 		))
 	defer span.End()
 
+	b.controlMtx.RLock()
+	defer b.controlMtx.RUnlock()
+
 	key := addressKey(prm.Address)
 
 	err := b.boltDB.Update(func(tx *bbolt.Tx) error {

pkg/local_object_storage/blobovnicza/put.go

@@ -64,6 +64,9 @@ func (b *Blobovnicza) Put(ctx context.Context, prm PutPrm) (PutRes, error) {
 		))
 	defer span.End()
 
+	b.controlMtx.RLock()
+	defer b.controlMtx.RUnlock()
+
 	sz := uint64(len(prm.objData))
 	bucketName := bucketForSize(sz)
 	key := addressKey(prm.addr)