sn/object: Refactor forwarding code

cthulhu-rider · cthulhu-rider · commit 8a947a587e70 · 2026-02-11T20:40:57.000+03:00
Drop node info parameters since public key is no longer accessed.

Signed-off-by: Leonard Lyubich &lt;leonard@morphbits.io&gt;
diff --git a/pkg/services/object/get/get.go b/pkg/services/object/get/get.go
@@ -71,7 +71,7 @@ func (s *Service) proxyGetRequest(ctx context.Context, sortedNodeLists [][]netma
 				continue
 			}
 
-			hdr, err := proxyFn(ctx, node, conn)
+			hdr, err := proxyFn(ctx, conn)
 			if err == nil {
 				if headWriter != nil {
 					return headWriter.WriteHeader(hdr)
@@ -204,7 +204,7 @@ func (s *Service) proxyHashRequest(ctx context.Context, sortedNodeLists [][]netm
 				continue
 			}
 
-			hashes, err := proxyFn(ctx, node, conn)
+			hashes, err := proxyFn(ctx, conn)
 			if err == nil {
 				return hashes, nil
 			}
diff --git a/pkg/services/object/get/get_test.go b/pkg/services/object/get/get_test.go
@@ -95,7 +95,7 @@ func newTestClient() *testClient {
 	}
 }
 
-func (c *testClient) getObject(exec *execCtx, _ client.NodeInfo) (*object.Object, io.ReadCloser, error) {
+func (c *testClient) getObject(exec *execCtx) (*object.Object, io.ReadCloser, error) {
 	v, ok := c.results[exec.address()]
 	if !ok {
 		var errNotFound apistatus.ObjectNotFound
diff --git a/pkg/services/object/get/prm.go b/pkg/services/object/get/prm.go
@@ -37,8 +37,8 @@ type RangeHashPrm struct {
 	forwardedRangeHashResponse [][]byte
 }
 
-type RequestForwarder func(context.Context, coreclient.NodeInfo, coreclient.MultiAddressClient) (*object.Object, error)
-type RangeRequestForwarder func(context.Context, coreclient.NodeInfo, coreclient.MultiAddressClient) ([][]byte, error)
+type RequestForwarder func(context.Context, coreclient.MultiAddressClient) (*object.Object, error)
+type RangeRequestForwarder func(context.Context, coreclient.MultiAddressClient) ([][]byte, error)
 
 // HeadPrm groups parameters of Head service call.
 type HeadPrm struct {
diff --git a/pkg/services/object/get/remote.go b/pkg/services/object/get/remote.go
@@ -17,7 +17,7 @@ func (exec *execCtx) processNode(info client.NodeInfo) bool {
 		return true
 	}
 
-	obj, reader, err := remoteClient.getObject(exec, info)
+	obj, reader, err := remoteClient.getObject(exec)
 
 	var errSplitInfo *object.SplitInfoError
 
diff --git a/pkg/services/object/get/service.go b/pkg/services/object/get/service.go
@@ -60,7 +60,7 @@ type Service struct {
 type Option func(*cfg)
 
 type getClient interface {
-	getObject(*execCtx, client.NodeInfo) (*object.Object, io.ReadCloser, error)
+	getObject(*execCtx) (*object.Object, io.ReadCloser, error)
 }
 
 type cfg struct {
diff --git a/pkg/services/object/get/util.go b/pkg/services/object/get/util.go
@@ -176,9 +176,9 @@ func (c *clientCacheWrapper) get(ctx context.Context, info coreclient.NodeInfo)
 	}, nil
 }
 
-func (c *clientWrapper) getObject(exec *execCtx, info coreclient.NodeInfo) (*object.Object, io.ReadCloser, error) {
+func (c *clientWrapper) getObject(exec *execCtx) (*object.Object, io.ReadCloser, error) {
 	if exec.isForwardingEnabled() {
-		obj, err := exec.prm.forwarder(exec.ctx, info, c.client)
+		obj, err := exec.prm.forwarder(exec.ctx, c.client)
 		return obj, nil, err
 	}
 
@@ -219,7 +219,7 @@ func (c *clientWrapper) getObject(exec *execCtx, info coreclient.NodeInfo) (*obj
 	}
 
 	if rngH := exec.prmRangeHash; rngH != nil && exec.isRangeHashForwardingEnabled() {
-		exec.prmRangeHash.forwardedRangeHashResponse, err = exec.prm.rangeForwarder(exec.ctx, info, c.client)
+		exec.prmRangeHash.forwardedRangeHashResponse, err = exec.prm.rangeForwarder(exec.ctx, c.client)
 		return nil, nil, err
 	}
 
diff --git a/pkg/services/object/put/prm.go b/pkg/services/object/put/prm.go
@@ -18,7 +18,7 @@ type PutInitPrm struct {
 
 	copiesNumber uint32
 
-	relay func(client.NodeInfo, client.MultiAddressClient) error
+	relay func(client.MultiAddressClient) error
 
 	containerNodes       ContainerNodes
 	ecPart               iec.PartInfo
@@ -48,7 +48,7 @@ func (p *PutInitPrm) WithObject(v *object.Object) *PutInitPrm {
 	return p
 }
 
-func (p *PutInitPrm) WithRelay(f func(client.NodeInfo, client.MultiAddressClient) error) *PutInitPrm {
+func (p *PutInitPrm) WithRelay(f func(client.MultiAddressClient) error) *PutInitPrm {
 	if p != nil {
 		p.relay = f
 	}
diff --git a/pkg/services/object/put/streamer.go b/pkg/services/object/put/streamer.go
@@ -25,7 +25,7 @@ type Streamer struct {
 
 	target internal.Target
 
-	relay func(client.NodeInfo, client.MultiAddressClient) error
+	relay func(client.MultiAddressClient) error
 
 	maxPayloadSz uint64 // network config
 
@@ -256,7 +256,7 @@ func (p *Streamer) newCommonTarget(prm *PutInitPrm) internal.Target {
 				return fmt.Errorf("could not create SDK client %s: %w", node.info.AddressGroup(), err)
 			}
 
-			return p.relay(node.info, c)
+			return p.relay(c)
 		}
 	}
 
diff --git a/pkg/services/object/search/container.go b/pkg/services/object/search/container.go
@@ -74,7 +74,7 @@ func (exec *execCtx) executeOnContainer(ectx context.Context) {
 				return
 			}
 
-			ids, err := c.searchObjects(ctx, exec, info)
+			ids, err := c.searchObjects(ctx, exec)
 			if err != nil {
 				lg.Debug("remote operation failed",
 					zap.Error(err))
diff --git a/pkg/services/object/search/prm.go b/pkg/services/object/search/prm.go
@@ -29,7 +29,7 @@ type IDListWriter interface {
 
 // RequestForwarder is a callback for forwarding of the
 // original Search requests.
-type RequestForwarder func(coreclient.NodeInfo, coreclient.MultiAddressClient) ([]oid.ID, error)
+type RequestForwarder func(coreclient.MultiAddressClient) ([]oid.ID, error)
 
 // SetCommonParameters sets common parameters of the operation.
 func (p *Prm) SetCommonParameters(common *util.CommonPrm) {
diff --git a/pkg/services/object/search/search_test.go b/pkg/services/object/search/search_test.go
@@ -88,7 +88,7 @@ func (ts *testStorage) search(exec *execCtx) ([]oid.ID, error) {
 	return v.ids, v.err
 }
 
-func (ts *testStorage) searchObjects(_ context.Context, exec *execCtx, _ clientcore.NodeInfo) ([]oid.ID, error) {
+func (ts *testStorage) searchObjects(_ context.Context, exec *execCtx) ([]oid.ID, error) {
 	v, ok := ts.items[exec.containerID()]
 	if !ok {
 		return nil, nil
diff --git a/pkg/services/object/search/service.go b/pkg/services/object/search/service.go
@@ -26,7 +26,7 @@ type Option func(*cfg)
 type searchClient interface {
 	// searchObjects searches objects on the specified node.
 	// MUST NOT modify execCtx as it can be accessed concurrently.
-	searchObjects(context.Context, *execCtx, client.NodeInfo) ([]oid.ID, error)
+	searchObjects(context.Context, *execCtx) ([]oid.ID, error)
 }
 
 // Containers provides information about NeoFS containers necessary for the
diff --git a/pkg/services/object/search/util.go b/pkg/services/object/search/util.go
@@ -72,9 +72,9 @@ func (c *clientConstructorWrapper) get(ctx context.Context, info client.NodeInfo
 	}, nil
 }
 
-func (c *clientWrapper) searchObjects(ctx context.Context, exec *execCtx, info client.NodeInfo) ([]oid.ID, error) {
+func (c *clientWrapper) searchObjects(ctx context.Context, exec *execCtx) ([]oid.ID, error) {
 	if exec.prm.forwarder != nil {
-		return exec.prm.forwarder(info, c.client)
+		return exec.prm.forwarder(c.client)
 	}
 
 	key, err := exec.svc.keyStore.GetKey(nil)
diff --git a/pkg/services/object/server.go b/pkg/services/object/server.go
@@ -272,15 +272,13 @@ func newIntermediatePutStream(signer ecdsa.PrivateKey, base *putsvc.Streamer, ct
 	}
 }
 
-func (x *putStream) sendToRemoteNode(node client.NodeInfo, c client.MultiAddressClient) error {
-	nodePub := node.PublicKey()
+func (x *putStream) sendToRemoteNode(c client.MultiAddressClient) error {
 	return c.ForEachGRPCConn(x.ctx, func(ctx context.Context, conn *grpc.ClientConn) error {
-		return putToRemoteNode(ctx, conn, nodePub, x.initReq, x.chunkReqs) // TODO: log error
+		return putToRemoteNode(ctx, conn, x.initReq, x.chunkReqs) // TODO: log error
 	})
 }
 
-func putToRemoteNode(ctx context.Context, conn *grpc.ClientConn, nodePub []byte,
-	initReq *protoobject.PutRequest, chunkReqs []*protoobject.PutRequest) error {
+func putToRemoteNode(ctx context.Context, conn *grpc.ClientConn, initReq *protoobject.PutRequest, chunkReqs []*protoobject.PutRequest) error {
 	stream, err := protoobject.NewObjectServiceClient(conn).Put(ctx)
 	if err != nil {
 		return fmt.Errorf("stream opening failed: %w", err)
@@ -719,7 +717,7 @@ func convertHeadPrm(signer ecdsa.PrivateKey, req *protoobject.HeadRequest, resp
 	if meta == nil {
 		return getsvc.HeadPrm{}, errors.New("missing meta header")
 	}
-	p.SetRequestForwarder(func(ctx context.Context, node client.NodeInfo, c client.MultiAddressClient) (*object.Object, error) {
+	p.SetRequestForwarder(func(ctx context.Context, c client.MultiAddressClient) (*object.Object, error) {
 		var err error
 		onceResign.Do(func() {
 			req.MetaHeader = &protosession.RequestMetaHeader{
@@ -939,7 +937,7 @@ func convertHashPrm(signer ecdsa.PrivateKey, ss sessions, req *protoobject.GetRa
 	if meta == nil {
 		return getsvc.RangeHashPrm{}, errors.New("missing meta header")
 	}
-	p.SetRangeHashRequestForwarder(func(ctx context.Context, node client.NodeInfo, c client.MultiAddressClient) ([][]byte, error) {
+	p.SetRangeHashRequestForwarder(func(ctx context.Context, c client.MultiAddressClient) ([][]byte, error) {
 		var err error
 		onceResign.Do(func() {
 			req.MetaHeader = &protosession.RequestMetaHeader{
@@ -954,19 +952,17 @@ func convertHashPrm(signer ecdsa.PrivateKey, ss sessions, req *protoobject.GetRa
 			return nil, err
 		}
 
-		nodePub := node.PublicKey()
 		var hs [][]byte
 		return hs, c.ForEachGRPCConn(ctx, func(ctx context.Context, conn *grpc.ClientConn) error {
 			var err error
-			hs, err = getHashesFromRemoteNode(ctx, conn, nodePub, req)
+			hs, err = getHashesFromRemoteNode(ctx, conn, req)
 			return err // TODO: log error
 		})
 	})
 	return p, nil
 }
 
-func getHashesFromRemoteNode(ctx context.Context, conn *grpc.ClientConn, nodePub []byte,
-	req *protoobject.GetRangeHashRequest) ([][]byte, error) {
+func getHashesFromRemoteNode(ctx context.Context, conn *grpc.ClientConn, req *protoobject.GetRangeHashRequest) ([][]byte, error) {
 	resp, err := protoobject.NewObjectServiceClient(conn).GetRangeHash(ctx, req)
 	if err != nil {
 		return nil, fmt.Errorf("GetRangeHash rpc failure: %w", err)
@@ -1151,7 +1147,7 @@ func convertGetPrm(signer ecdsa.PrivateKey, req *protoobject.GetRequest, stream
 		respStream: stream,
 	}
 
-	p.SetRequestForwarder(func(ctx context.Context, node client.NodeInfo, c client.MultiAddressClient) (*object.Object, error) {
+	p.SetRequestForwarder(func(ctx context.Context, c client.MultiAddressClient) (*object.Object, error) {
 		var err error
 		onceResign.Do(func() {
 			req.MetaHeader = &protosession.RequestMetaHeader{
@@ -1438,7 +1434,7 @@ func convertRangePrm(signer ecdsa.PrivateKey, req *protoobject.GetRangeRequest,
 	if meta == nil {
 		return getsvc.RangePrm{}, errors.New("missing meta header")
 	}
-	p.SetRequestForwarder(func(ctx context.Context, node client.NodeInfo, c client.MultiAddressClient) (*object.Object, error) {
+	p.SetRequestForwarder(func(ctx context.Context, c client.MultiAddressClient) (*object.Object, error) {
 		var err error
 		onceResign.Do(func() {
 			req.MetaHeader = &protosession.RequestMetaHeader{
@@ -1452,9 +1448,8 @@ func convertRangePrm(signer ecdsa.PrivateKey, req *protoobject.GetRangeRequest,
 			return nil, err
 		}
 
-		nodePub := node.PublicKey()
 		return nil, c.ForEachGRPCConn(ctx, func(ctx context.Context, conn *grpc.ClientConn) error {
-			err := continueRangeFromRemoteNode(ctx, conn, nodePub, req, stream, &respondedPayload)
+			err := continueRangeFromRemoteNode(ctx, conn, req, stream, &respondedPayload)
 			if errors.Is(err, io.EOF) {
 				return nil
 			}
@@ -1464,7 +1459,7 @@ func convertRangePrm(signer ecdsa.PrivateKey, req *protoobject.GetRangeRequest,
 	return p, nil
 }
 
-func continueRangeFromRemoteNode(ctx context.Context, conn *grpc.ClientConn, nodePub []byte, req *protoobject.GetRangeRequest,
+func continueRangeFromRemoteNode(ctx context.Context, conn *grpc.ClientConn, req *protoobject.GetRangeRequest,
 	stream *rangeStream, respondedPayload *int) error {
 	rangeStream, err := protoobject.NewObjectServiceClient(conn).GetRange(ctx, req)
 	if err != nil {
@@ -1647,7 +1642,7 @@ func convertSearchPrm(ctx context.Context, signer ecdsa.PrivateKey, req *protoob
 	if meta == nil {
 		return searchsvc.Prm{}, errors.New("missing meta header")
 	}
-	p.SetRequestForwarder(func(node client.NodeInfo, c client.MultiAddressClient) ([]oid.ID, error) {
+	p.SetRequestForwarder(func(c client.MultiAddressClient) ([]oid.ID, error) {
 		var err error
 		onceResign.Do(func() {
 			req.MetaHeader = &protosession.RequestMetaHeader{
@@ -1661,18 +1656,17 @@ func convertSearchPrm(ctx context.Context, signer ecdsa.PrivateKey, req *protoob
 			return nil, err
 		}
 
-		nodePub := node.PublicKey()
 		var res []oid.ID
 		return res, c.ForEachGRPCConn(ctx, func(ctx context.Context, conn *grpc.ClientConn) error {
 			var err error
-			res, err = searchOnRemoteNode(ctx, conn, nodePub, req)
+			res, err = searchOnRemoteNode(ctx, conn, req)
 			return err // TODO: log error
 		})
 	})
 	return p, nil
 }
 
-func searchOnRemoteNode(ctx context.Context, conn *grpc.ClientConn, nodePub []byte, req *protoobject.SearchRequest) ([]oid.ID, error) {
+func searchOnRemoteNode(ctx context.Context, conn *grpc.ClientConn, req *protoobject.SearchRequest) ([]oid.ID, error) {
 	searchStream, err := protoobject.NewObjectServiceClient(conn).Search(ctx, req)
 	if err != nil {
 		return nil, err
@@ -2182,8 +2176,7 @@ func (s *Server) searchOnRemoteNode(ctx context.Context, node sdknetmap.NodeInfo
 	}
 	var info client.NodeInfo
 	info.SetAddressGroup(endpoints)
-	nodePub := node.PublicKey()
-	info.SetPublicKey(nodePub)
+	info.SetPublicKey(node.PublicKey())
 	c, err := s.nodeClients.Get(ctx, info)
 	if err != nil {
 		return nil, false, fmt.Errorf("get node client: %w", err)
@@ -2193,12 +2186,12 @@ func (s *Server) searchOnRemoteNode(ctx context.Context, node sdknetmap.NodeInfo
 	var more bool
 	return items, more, c.ForEachGRPCConn(ctx, func(ctx context.Context, conn *grpc.ClientConn) error {
 		var err error
-		items, more, err = searchOnRemoteAddress(ctx, conn, nodePub, req)
+		items, more, err = searchOnRemoteAddress(ctx, conn, req)
 		return err // TODO: log error
 	})
 }
 
-func searchOnRemoteAddress(ctx context.Context, conn *grpc.ClientConn, nodePub []byte,
+func searchOnRemoteAddress(ctx context.Context, conn *grpc.ClientConn,
 	req *protoobject.SearchV2Request) ([]sdkclient.SearchResultItem, bool, error) {
 	resp, err := protoobject.NewObjectServiceClient(conn).SearchV2(ctx, req)
 	if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,7 @@ func (s *Service) proxyGetRequest(ctx context.Context, sortedNodeLists [][]netma`
`71`	`71`	`continue`
`72`	`72`	`}`
`73`	`73`
`74`		`- hdr, err := proxyFn(ctx, node, conn)`
	`74`	`+ hdr, err := proxyFn(ctx, conn)`
`75`	`75`	`if err == nil {`
`76`	`76`	`if headWriter != nil {`
`77`	`77`	`return headWriter.WriteHeader(hdr)`
`@@ -204,7 +204,7 @@ func (s *Service) proxyHashRequest(ctx context.Context, sortedNodeLists [][]netm`
`204`	`204`	`continue`
`205`	`205`	`}`
`206`	`206`
`207`		`- hashes, err := proxyFn(ctx, node, conn)`
	`207`	`+ hashes, err := proxyFn(ctx, conn)`
`208`	`208`	`if err == nil {`
`209`	`209`	`return hashes, nil`
`210`	`210`	`}`
Original file line number	Diff line number	Diff line change
`@@ -95,7 +95,7 @@ func newTestClient() *testClient {`
`95`	`95`	`}`
`96`	`96`	`}`
`97`	`97`
`98`		`-func (c testClient) getObject(exec execCtx, _ client.NodeInfo) (*object.Object, io.ReadCloser, error) {`
	`98`	`+func (c testClient) getObject(exec execCtx) (*object.Object, io.ReadCloser, error) {`
`99`	`99`	`v, ok := c.results[exec.address()]`
`100`	`100`	`if !ok {`
`101`	`101`	`var errNotFound apistatus.ObjectNotFound`
Original file line number	Diff line number	Diff line change
`@@ -37,8 +37,8 @@ type RangeHashPrm struct {`
`37`	`37`	`forwardedRangeHashResponse [][]byte`
`38`	`38`	`}`
`39`	`39`
`40`		`-type RequestForwarder func(context.Context, coreclient.NodeInfo, coreclient.MultiAddressClient) (*object.Object, error)`
`41`		`-type RangeRequestForwarder func(context.Context, coreclient.NodeInfo, coreclient.MultiAddressClient) ([][]byte, error)`
	`40`	`+type RequestForwarder func(context.Context, coreclient.MultiAddressClient) (*object.Object, error)`
	`41`	`+type RangeRequestForwarder func(context.Context, coreclient.MultiAddressClient) ([][]byte, error)`
`42`	`42`
`43`	`43`	`// HeadPrm groups parameters of Head service call.`
`44`	`44`	`type HeadPrm struct {`
Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ func (exec *execCtx) processNode(info client.NodeInfo) bool {`
`17`	`17`	`return true`
`18`	`18`	`}`
`19`	`19`
`20`		`- obj, reader, err := remoteClient.getObject(exec, info)`
	`20`	`+ obj, reader, err := remoteClient.getObject(exec)`
`21`	`21`
`22`	`22`	`var errSplitInfo *object.SplitInfoError`
`23`	`23`
Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,7 @@ type Service struct {`
`60`	`60`	`type Option func(*cfg)`
`61`	`61`
`62`	`62`	`type getClient interface {`
`63`		`- getObject(execCtx, client.NodeInfo) (object.Object, io.ReadCloser, error)`
	`63`	`+ getObject(execCtx) (object.Object, io.ReadCloser, error)`
`64`	`64`	`}`
`65`	`65`
`66`	`66`	`type cfg struct {`
Original file line number	Diff line number	Diff line change
`@@ -176,9 +176,9 @@ func (c *clientCacheWrapper) get(ctx context.Context, info coreclient.NodeInfo)`
`176`	`176`	`}, nil`
`177`	`177`	`}`
`178`	`178`
`179`		`-func (c clientWrapper) getObject(exec execCtx, info coreclient.NodeInfo) (*object.Object, io.ReadCloser, error) {`
	`179`	`+func (c clientWrapper) getObject(exec execCtx) (*object.Object, io.ReadCloser, error) {`
`180`	`180`	`if exec.isForwardingEnabled() {`
`181`		`- obj, err := exec.prm.forwarder(exec.ctx, info, c.client)`
	`181`	`+ obj, err := exec.prm.forwarder(exec.ctx, c.client)`
`182`	`182`	`return obj, nil, err`
`183`	`183`	`}`
`184`	`184`
`@@ -219,7 +219,7 @@ func (c clientWrapper) getObject(exec execCtx, info coreclient.NodeInfo) (*obj`
`219`	`219`	`}`
`220`	`220`
`221`	`221`	`if rngH := exec.prmRangeHash; rngH != nil && exec.isRangeHashForwardingEnabled() {`
`222`		`- exec.prmRangeHash.forwardedRangeHashResponse, err = exec.prm.rangeForwarder(exec.ctx, info, c.client)`
	`222`	`+ exec.prmRangeHash.forwardedRangeHashResponse, err = exec.prm.rangeForwarder(exec.ctx, c.client)`
`223`	`223`	`return nil, nil, err`
`224`	`224`	`}`
`225`	`225`
Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ type PutInitPrm struct {`
`18`	`18`
`19`	`19`	`copiesNumber uint32`
`20`	`20`
`21`		`- relay func(client.NodeInfo, client.MultiAddressClient) error`
	`21`	`+ relay func(client.MultiAddressClient) error`
`22`	`22`
`23`	`23`	`containerNodes ContainerNodes`
`24`	`24`	`ecPart iec.PartInfo`
`@@ -48,7 +48,7 @@ func (p PutInitPrm) WithObject(v object.Object) *PutInitPrm {`
`48`	`48`	`return p`
`49`	`49`	`}`
`50`	`50`
`51`		`-func (p PutInitPrm) WithRelay(f func(client.NodeInfo, client.MultiAddressClient) error) PutInitPrm {`
	`51`	`+func (p PutInitPrm) WithRelay(f func(client.MultiAddressClient) error) PutInitPrm {`
`52`	`52`	`if p != nil {`
`53`	`53`	`p.relay = f`
`54`	`54`	`}`
Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ type Streamer struct {`
`25`	`25`
`26`	`26`	`target internal.Target`
`27`	`27`
`28`		`- relay func(client.NodeInfo, client.MultiAddressClient) error`
	`28`	`+ relay func(client.MultiAddressClient) error`
`29`	`29`
`30`	`30`	`maxPayloadSz uint64 // network config`
`31`	`31`
`@@ -256,7 +256,7 @@ func (p Streamer) newCommonTarget(prm PutInitPrm) internal.Target {`
`256`	`256`	`return fmt.Errorf("could not create SDK client %s: %w", node.info.AddressGroup(), err)`
`257`	`257`	`}`
`258`	`258`
`259`		`- return p.relay(node.info, c)`
	`259`	`+ return p.relay(c)`
`260`	`260`	`}`
`261`	`261`	`}`
`262`	`262`
Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ func (exec *execCtx) executeOnContainer(ectx context.Context) {`
`74`	`74`	`return`
`75`	`75`	`}`
`76`	`76`
`77`		`- ids, err := c.searchObjects(ctx, exec, info)`
	`77`	`+ ids, err := c.searchObjects(ctx, exec)`
`78`	`78`	`if err != nil {`
`79`	`79`	`lg.Debug("remote operation failed",`
`80`	`80`	`zap.Error(err))`