Make stat and list calls sequential for virtual views

internal/grpc/services/gateway/storageprovider.go

@@ -1161,13 +1161,12 @@ func (s *svc) stat(ctx context.Context, req *provider.StatRequest) (*provider.St
 func (s *svc) statAcrossProviders(ctx context.Context, req *provider.StatRequest, providers []*registry.ProviderInfo) (*provider.StatResponse, error) {
 	infoFromProviders := make([]*provider.ResourceInfo, len(providers))
 	errors := make([]error, len(providers))
-	var wg sync.WaitGroup
 
 	for i, p := range providers {
-		wg.Add(1)
-		go s.statOnProvider(ctx, req, infoFromProviders[i], p, &errors[i], &wg)
+		r, e := s.statOnProvider(ctx, req, p)
+		infoFromProviders[i] = r
+		errors[i] = e
 	}
-	wg.Wait()
 
 	var totalSize uint64
 	for i := range providers {
@@ -1196,12 +1195,11 @@ func (s *svc) statAcrossProviders(ctx context.Context, req *provider.StatRequest
 	}, nil
 }
 
-func (s *svc) statOnProvider(ctx context.Context, req *provider.StatRequest, res *provider.ResourceInfo, p *registry.ProviderInfo, e *error, wg *sync.WaitGroup) {
-	defer wg.Done()
+func (s *svc) statOnProvider(ctx context.Context, req *provider.StatRequest, p *registry.ProviderInfo) (*provider.ResourceInfo, error) {
 	c, err := s.getStorageProviderClient(ctx, p)
 	if err != nil {
-		*e = errors.Wrap(err, "error connecting to storage provider="+p.Address)
-		return
+		e := errors.Wrap(err, "error connecting to storage provider="+p.Address)
+		return nil, e
 	}
 
 	resPath := path.Clean(req.Ref.GetPath())
@@ -1211,13 +1209,10 @@ func (s *svc) statOnProvider(ctx context.Context, req *provider.StatRequest, res
 	}
 	r, err := c.Stat(ctx, &provider.StatRequest{Ref: &provider.Reference{Path: newPath}})
 	if err != nil {
-		*e = errors.Wrap(err, fmt.Sprintf("gateway: error calling Stat %s: %+v", newPath, p))
-		return
-	}
-	if res == nil {
-		res = &provider.ResourceInfo{}
+		e := errors.Wrap(err, fmt.Sprintf("gateway: error calling Stat %s: %+v", newPath, p))
+		return nil, e
 	}
-	*res = *r.Info
+	return r.Info, nil
 }
 
 func (s *svc) Stat(ctx context.Context, req *provider.StatRequest) (*provider.StatResponse, error) {
@@ -1429,13 +1424,10 @@ func (s *svc) listContainer(ctx context.Context, req *provider.ListContainerRequ
 	infoFromProviders := make([][]*provider.ResourceInfo, len(providers))
 	errors := make([]error, len(providers))
 	indirects := make([]bool, len(providers))
-	var wg sync.WaitGroup
 
 	for i, p := range providers {
-		wg.Add(1)
-		go s.listContainerOnProvider(ctx, req, &infoFromProviders[i], p, &indirects[i], &errors[i], &wg)
+		s.listContainerOnProvider(ctx, req, &infoFromProviders[i], p, &indirects[i], &errors[i])
 	}
-	wg.Wait()
 
 	infos := []*provider.ResourceInfo{}
 	nestedInfos := make(map[string][]*provider.ResourceInfo)
@@ -1480,8 +1472,7 @@ func (s *svc) listContainer(ctx context.Context, req *provider.ListContainerRequ
 	}, nil
 }
 
-func (s *svc) listContainerOnProvider(ctx context.Context, req *provider.ListContainerRequest, res *[]*provider.ResourceInfo, p *registry.ProviderInfo, ind *bool, e *error, wg *sync.WaitGroup) {
-	defer wg.Done()
+func (s *svc) listContainerOnProvider(ctx context.Context, req *provider.ListContainerRequest, res *[]*provider.ResourceInfo, p *registry.ProviderInfo, ind *bool, e *error) {
 	c, err := s.getStorageProviderClient(ctx, p)
 	if err != nil {
 		*e = errors.Wrap(err, "error connecting to storage provider="+p.Address)

pkg/storage/utils/eosfs/eosfs.go

@@ -769,8 +769,6 @@ func (fs *eosfs) getMDShareFolder(ctx context.Context, p string, mdKeys []string
 }
 
 func (fs *eosfs) ListFolder(ctx context.Context, ref *provider.Reference, mdKeys []string) ([]*provider.ResourceInfo, error) {
-	log := appctx.GetLogger(ctx)
-
 	p, err := fs.resolve(ctx, ref)
 	if err != nil {
 		return nil, errors.Wrap(err, "eosfs: error resolving reference")