squash this is also moving ctxg

Author: Brian Tiger Chow

core/core.go

@@ -101,6 +101,12 @@ type ConfigOption func(ctx context.Context) (*IpfsNode, error)
 func NewIPFSNode(parent context.Context, option ConfigOption) (*IpfsNode, error) {
 	ctxg := ctxgroup.WithContext(parent)
 	ctx := ctxg.Context()
+	success := false // flip to true after all sub-system inits succeed
+	defer func() {
+		if !success {
+			ctxg.Close()
+		}
+	}()
 
 	node, err := option(ctx)
 	if err != nil {
@@ -126,6 +132,7 @@ func NewIPFSNode(parent context.Context, option ConfigOption) (*IpfsNode, error)
 		node.Pinning = pin.NewPinner(node.Repo.Datastore(), node.DAG)
 	}
 	node.Resolver = &path.Resolver{DAG: node.DAG}
+	success = true
 	return node, nil
 }
 
@@ -141,13 +148,6 @@ func Online(r repo.Repo) ConfigOption {
 func Standard(r repo.Repo, online bool) ConfigOption {
 	return func(ctx context.Context) (n *IpfsNode, err error) {
 
-		success := false // flip to true after all sub-system inits succeed
-		defer func() {
-			if !success && n != nil {
-				n.Close()
-			}
-		}()
-
 		if r == nil {
 			return nil, debugerror.Errorf("repo required")
 		}
@@ -183,7 +183,6 @@ func Standard(r repo.Repo, online bool) ConfigOption {
 			n.Exchange = offline.Exchange(n.Blockstore)
 		}
 
-		success = true
 		return n, nil
 	}
 }