node/object/put: push meta only if the consistency policy asks for it

Signed-off-by: Pavel Karpy <[email protected]>

pkg/services/object/put/distributed.go

@@ -33,7 +33,8 @@ type distributedTarget struct {
 	objMeta            object.ContentMeta
 	networkMagicNumber uint32
 
-	cnrClient *chaintcontainer.Client
+	cnrClient               *chaintcontainer.Client
+	metainfoConsistencyAttr string
 
 	metaMtx             sync.RWMutex
 	objSharedMeta       []byte
@@ -154,7 +155,7 @@ func (t *distributedTarget) Close() (oid.ID, error) {
 		return oid.ID{}, err
 	}
 
-	if t.localNodeInContainer {
+	if t.localNodeInContainer && t.metainfoConsistencyAttr != "" {
 		t.metaMtx.RLock()
 		defer t.metaMtx.RUnlock()
 

pkg/services/object/put/streamer.go

@@ -8,6 +8,7 @@ import (
 	"github.com/nspcc-dev/neofs-node/pkg/core/client"
 	"github.com/nspcc-dev/neofs-node/pkg/services/object/internal"
 	"github.com/nspcc-dev/neofs-node/pkg/services/object/util"
+	"github.com/nspcc-dev/neofs-sdk-go/container"
 	neofsecdsa "github.com/nspcc-dev/neofs-sdk-go/crypto/ecdsa"
 	"github.com/nspcc-dev/neofs-sdk-go/object"
 	"github.com/nspcc-dev/neofs-sdk-go/user"
@@ -237,11 +238,12 @@ func (p *Streamer) newCommonTarget(prm *PutInitPrm) internal.Target {
 
 			return rt
 		},
-		relay:                relay,
-		fmt:                  p.fmtValidator,
-		localNodeInContainer: prm.localNodeInContainer,
-		localNodeSigner:      prm.localNodeSigner,
-		cnrClient:            p.cfg.cnrClient,
+		relay:                   relay,
+		fmt:                     p.fmtValidator,
+		localNodeInContainer:    prm.localNodeInContainer,
+		localNodeSigner:         prm.localNodeSigner,
+		cnrClient:               p.cfg.cnrClient,
+		metainfoConsistencyAttr: metaAttribute(prm.cnr),
 	}
 }
 
@@ -271,3 +273,7 @@ func (p *Streamer) Close() (*PutResponse, error) {
 		id: id,
 	}, nil
 }
+
+func metaAttribute(cnr container.Container) string {
+	return cnr.Attribute("__NEOFS__METAINFO_CONSISTENCY")
+}