From 57e2ce6be65503eabf283ea402bb5242dbbc1e04 Mon Sep 17 00:00:00 2001 From: "Lixia (Sylvia) Lei" Date: Wed, 16 Mar 2022 09:00:01 +0800 Subject: [PATCH] fix memory graph (#115) Signed-off-by: Sylvia Lei Signed-off-by: Billy Zha --- internal/graph/memory.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/internal/graph/memory.go b/internal/graph/memory.go index cd8686f7..f90825ab 100644 --- a/internal/graph/memory.go +++ b/internal/graph/memory.go @@ -57,7 +57,7 @@ func (m *Memory) IndexAll(ctx context.Context, fetcher content.Fetcher, node oci // prepare pre-handler preHandler := HandlerFunc(func(ctx context.Context, desc ocispec.Descriptor) ([]ocispec.Descriptor, error) { // skip the node if other go routine is working on it - done, committed := tracker.TryCommit(desc) + _, committed := tracker.TryCommit(desc) if !committed { return nil, ErrSkipDesc } @@ -66,8 +66,6 @@ func (m *Memory) IndexAll(ctx context.Context, fetcher content.Fetcher, node oci key := descriptor.FromOCI(desc) _, exists := m.indexed.Load(key) if exists { - // mark the node as done - close(done) return nil, ErrSkipDesc } @@ -80,8 +78,6 @@ func (m *Memory) IndexAll(ctx context.Context, fetcher content.Fetcher, node oci return nil, err } - // mark the node as done on success - close(done) return downEdges, nil })