TrueCloudLab
/
frostfs-node
18
1
Fork 20
Code Issues 88 Pull Requests 8 Actions Releases Activity

[#172] Use ContainersOf() for container list fetching 

Previously we were limited by ~2048 containers because of
neo-go VM limits.

Signed-off-by: Evgenii Stratonikov <e.stratonikov@yadro.com>
pull/172/head
Evgenii Stratonikov 2023-03-24 11:57:35 +03:00
parent 7b2e16f1f3
commit 48beb51aa2
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/frostfs-node/cache.go
View File

@ -242,7 +242,7 @@ func newCachedContainerLister(c *cntClient.Client, ttl time.Duration) ttlContain
}
}
list, err := c.List(id)
list, err := c.ContainersOf(id)
if err != nil {
return nil, err
}
@ -260,7 +260,7 @@ func newCachedContainerLister(c *cntClient.Client, ttl time.Duration) ttlContain
// the cache.
func (s ttlContainerLister) List(id *user.ID) ([]cid.ID, error) {
if id == nil {
return s.client.List(nil)
return s.client.ContainersOf(nil)
}
item, err := s.inner.get(id.EncodeToString())

2
cmd/frostfs-node/tree.go
View File

@ -31,7 +31,7 @@ func (c cnrSource) Get(id cid.ID) (*container.Container, error) {
}
func (c cnrSource) List() ([]cid.ID, error) {
return c.cli.List(nil)
return c.cli.ContainersOf(nil)
}
func initTreeService(c *cfg) {

2
pkg/innerring/processors/audit/scheduler.go
View File

@ -13,7 +13,7 @@ import (
var ErrInvalidIRNode = errors.New("node is not in the inner ring list")
func (ap *Processor) selectContainersToAudit(epoch uint64) ([]cid.ID, error) {
containers, err := ap.containerClient.List(nil)
containers, err := ap.containerClient.ContainersOf(nil)
if err != nil {
return nil, fmt.Errorf("can't get list of containers to start audit: %w", err)
}