Skip to content
This repository has been archived by the owner on Sep 9, 2020. It is now read-only.

Commit

Permalink
runProjectStatus: Optimizations to avoid redundant computation
Browse files Browse the repository at this point in the history
  • Loading branch information
darkowlzz committed Nov 17, 2017
1 parent 50ea2fb commit e0098dc
Showing 1 changed file with 46 additions and 37 deletions.
83 changes: 46 additions & 37 deletions cmd/dep/status.go
Original file line number Diff line number Diff line change
Expand Up @@ -715,6 +715,34 @@ func runProjectStatus(ctx *dep.Ctx, args []string, p *dep.Project, sm gps.Source
// Collect all the constraints.
cc := collectConstraints(ptree, p, sm)

// Collect list of packages in target projects.
pkgs := make(map[gps.ProjectRoot][]string)

// Collect reachmap of all the locked projects.
reachmaps := make(map[string]pkgtree.ReachMap)

// Collect and store all the necessary data from pkgtree(s).
// TODO: Make this concurrent.
for _, pl := range p.Lock.Projects() {
pkgtree, err := sm.ListPackages(pl.Ident(), pl.Version())
if err != nil {
return err
}

// Collect reachmaps.
prm, _ := pkgtree.ToReachMap(true, true, false, p.Manifest.IgnoredPackages())
reachmaps[string(pl.Ident().ProjectRoot)] = prm

// Collect list of packages if it's one of the target projects.
for _, pr := range prs {
if pr == pl.Ident().ProjectRoot {
for pkg := range pkgtree.Packages {
pkgs[pr] = append(pkgs[pr], pkg)
}
}
}
}

for _, pr := range prs {
// Create projectStatus and add project name and source.
projStatus := projectStatus{
Expand All @@ -723,27 +751,12 @@ func runProjectStatus(ctx *dep.Ctx, args []string, p *dep.Project, sm gps.Source
}
resultStatus = append(resultStatus, &projStatus)

for _, pl := range p.Lock.Projects() {
// Get the corresponding locked project for the target project.
if pr != pl.Ident().ProjectRoot {
// PROJECT IMPORTERS & PACKAGE IMPORTERS
// Since this project is not the target project, we should
// check if this project imports the target project.
// Get the Package List and check for existence of target
// project's import paths in the list.
// Add the Project to PROJECT IMPORTERS and package to PACKAGE
// IMPORTERS if they import the target project.
pkgtree, err := sm.ListPackages(pl.Ident(), pl.Version())
if err != nil {
return err
}

proot := string(pl.Ident().ProjectRoot)

// Get the PackageTree reachmap. Reachmap contains package name
// and imports of the package.
prm, _ := pkgtree.ToReachMap(true, true, false, p.Manifest.IgnoredPackages())
for pkg, ie := range prm {
// Gather PROJECT IMPORTERS & PACKAGE IMPORTERS data.
for projectroot, rmap := range reachmaps {
// If it's not the target project, check if it imports the target
// project.
if string(pr) != projectroot {
for pkg, ie := range rmap {
// Iterate through the external imports and check if they
// import any package from the target project.
for _, p := range ie.External {
Expand All @@ -753,27 +766,31 @@ func runProjectStatus(ctx *dep.Ctx, args []string, p *dep.Project, sm gps.Source
projStatus.ProjectImporters = make(map[string]bool)
}
// Add to ProjectImporters if it doesn't exists.
if _, ok := projStatus.ProjectImporters[proot]; !ok {
projStatus.ProjectImporters[proot] = true
if _, ok := projStatus.ProjectImporters[projectroot]; !ok {
projStatus.ProjectImporters[projectroot] = true
}
// Initialize PackageImporters map if it's the first entry.
if len(projStatus.PackageImporters[proot]) == 0 {
if len(projStatus.PackageImporters[projectroot]) == 0 {
projStatus.PackageImporters = make(map[string][]string)
}
// List Packages that import packages from target project.
projStatus.PackageImporters[p] = append(projStatus.PackageImporters[p], pkg)
}
}
}
}
}

// Gather data from the locked project.
for _, pl := range p.Lock.Projects() {
if pr != pl.Ident().ProjectRoot {
continue
}

// VERSION
projStatus.Version = pl.Version().String()
// ALT SOURCE
projStatus.AltSource = pl.Ident().Source

// REVISION
projStatus.Revision, _, _ = gps.VersionComponentStrings(pl.Version())

Expand Down Expand Up @@ -805,15 +822,8 @@ func runProjectStatus(ctx *dep.Ctx, args []string, p *dep.Project, sm gps.Source
}
}

pkgtree, err := sm.ListPackages(pl.Ident(), pl.Version())
if err != nil {
return err
}

// PACKAGES
for pkgPath := range pkgtree.Packages {
projStatus.Packages = append(projStatus.Packages, pkgPath)
}
projStatus.Packages = pkgs[pr]

// PUB VERSION
var semvers, branches, nonsemvers []string
Expand Down Expand Up @@ -852,15 +862,14 @@ func runProjectStatus(ctx *dep.Ctx, args []string, p *dep.Project, sm gps.Source
return err
}

// Add all the projects in params.ToChange.
for _, rs := range resultStatus {
params.ToChange = append(params.ToChange, gps.ProjectRoot(rs.Project))
}
// Add all the target projects in params.ToChange.
params.ToChange = append(params.ToChange, prs...)

solver, err := gps.Prepare(params, sm)
if err != nil {
return err
}

solution, err := solver.Solve(context.TODO())
if err != nil {
return err
Expand Down

0 comments on commit e0098dc

Please sign in to comment.