forked from TrueCloudLab/frostfs-node
[#2165] services/tree: Do not export synchronizeAllTrees
It is used only privately. Signed-off-by: Evgenii Stratonikov <e.stratonikov@yadro.com>
This commit is contained in:
parent
c299b98afe
commit
06137dbf8e
1 changed files with 3 additions and 3 deletions
|
@ -26,10 +26,10 @@ var ErrNotInContainer = errors.New("node is not in container")
|
||||||
|
|
||||||
const defaultSyncWorkerCount = 20
|
const defaultSyncWorkerCount = 20
|
||||||
|
|
||||||
// SynchronizeAllTrees synchronizes all the trees of the container. It fetches
|
// synchronizeAllTrees synchronizes all the trees of the container. It fetches
|
||||||
// tree IDs from the other container nodes. Returns ErrNotInContainer if the node
|
// tree IDs from the other container nodes. Returns ErrNotInContainer if the node
|
||||||
// is not included in the container.
|
// is not included in the container.
|
||||||
func (s *Service) SynchronizeAllTrees(ctx context.Context, cid cid.ID) error {
|
func (s *Service) synchronizeAllTrees(ctx context.Context, cid cid.ID) error {
|
||||||
nodes, pos, err := s.getContainerNodes(cid)
|
nodes, pos, err := s.getContainerNodes(cid)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("can't get container nodes: %w", err)
|
return fmt.Errorf("can't get container nodes: %w", err)
|
||||||
|
@ -283,7 +283,7 @@ func (s *Service) syncLoop(ctx context.Context) {
|
||||||
defer wg.Done()
|
defer wg.Done()
|
||||||
s.log.Debug("syncing container trees...", zap.Stringer("cid", cnr))
|
s.log.Debug("syncing container trees...", zap.Stringer("cid", cnr))
|
||||||
|
|
||||||
err := s.SynchronizeAllTrees(ctx, cnr)
|
err := s.synchronizeAllTrees(ctx, cnr)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
s.log.Error("could not sync trees", zap.Stringer("cid", cnr), zap.Error(err))
|
s.log.Error("could not sync trees", zap.Stringer("cid", cnr), zap.Error(err))
|
||||||
return
|
return
|
||||||
|
|
Loading…
Reference in a new issue