diff --git a/pkg/services/object/head/distributed.go b/pkg/services/object/head/distributed.go index 7d07dc075..25f55745c 100644 --- a/pkg/services/object/head/distributed.go +++ b/pkg/services/object/head/distributed.go @@ -63,7 +63,7 @@ func (h *distributedHeader) prepare(ctx context.Context, prm *Prm) error { if prm.local { // use local-only placement builder - builder = util.NewLocalPlacement(placement.NewNetworkMapBuilder(nm), h.localAddrSrc) + builder = util.NewLocalPlacement(builder, h.localAddrSrc) } // set placement builder diff --git a/pkg/services/object/put/streamer.go b/pkg/services/object/put/streamer.go index 4662a1c50..838bbe7ff 100644 --- a/pkg/services/object/put/streamer.go +++ b/pkg/services/object/put/streamer.go @@ -108,7 +108,7 @@ func (p *Streamer) preparePrm(prm *PutInitPrm) error { prm.traverseOpts = append(prm.traverseOpts, placement.SuccessAfter(1)) // use local-only placement builder - builder = util.NewLocalPlacement(placement.NewNetworkMapBuilder(nm), p.localAddrSrc) + builder = util.NewLocalPlacement(builder, p.localAddrSrc) } // set placement builder diff --git a/pkg/services/object/search/streamer.go b/pkg/services/object/search/streamer.go index 5300fb49d..29af9a7f3 100644 --- a/pkg/services/object/search/streamer.go +++ b/pkg/services/object/search/streamer.go @@ -113,7 +113,7 @@ func (p *Streamer) preparePrm(prm *Prm) error { traverseOpts = append(traverseOpts, placement.SuccessAfter(1)) // use local-only placement builder - builder = util.NewLocalPlacement(placement.NewNetworkMapBuilder(nm), p.localAddrSrc) + builder = util.NewLocalPlacement(builder, p.localAddrSrc) } // set placement builder