diff options
author | Eelco Dolstra <edolstra@gmail.com> | 2017-08-14 22:12:36 +0200 |
---|---|---|
committer | Eelco Dolstra <edolstra@gmail.com> | 2017-08-16 20:56:03 +0200 |
commit | 0e0dcf2c7ec054f1b30629e275f53f56039b8257 (patch) | |
tree | 10dc034fe2ff6a5860f74eae3b22673e08d1191e /src/nix/progress-bar.cc | |
parent | c36467ad2e2e27d04e681144e0e10417c53c10c1 (diff) |
Progress indicator: Unify "copying" and "substituting"
They're the same thing after all.
Example:
$ nix build --store local?root=/tmp/nix nixpkgs.firefox-unwrapped
[0/1 built, 49/98 copied, 16.3/92.8 MiB DL, 55.8/309.2 MiB copied] downloading 'https://cache.nixos.org/nar/0pl9li1jigcj2dany47hpmn0r3r48wc4nz48v5mqhh426lgz3bz6.nar.xz'
Diffstat (limited to 'src/nix/progress-bar.cc')
-rw-r--r-- | src/nix/progress-bar.cc | 70 |
1 files changed, 5 insertions, 65 deletions
diff --git a/src/nix/progress-bar.cc b/src/nix/progress-bar.cc index 736eb5ede..21d89e477 100644 --- a/src/nix/progress-bar.cc +++ b/src/nix/progress-bar.cc @@ -25,13 +25,6 @@ private: std::map<ActivityType, uint64_t> expectedByType; }; - struct CopyInfo - { - uint64_t expected = 0; - uint64_t copied = 0; - uint64_t done = 0; - }; - struct ActivitiesByType { std::map<Activity::t, std::list<ActInfo>::iterator> its; @@ -46,12 +39,6 @@ private: uint64_t succeededBuilds = 0; uint64_t failedBuilds = 0; - std::map<Activity::t, Path> substitutions; - std::set<Activity::t> runningSubstitutions; - uint64_t succeededSubstitutions = 0; - - std::map<Activity::t, CopyInfo> runningCopies; - std::list<ActInfo> activities; std::map<Activity::t, std::list<ActInfo>::iterator> its; @@ -185,25 +172,7 @@ public: state.succeededBuilds, state.succeededBuilds + state.builds.size()); } - if (!state.substitutions.empty() || state.succeededSubstitutions) { - if (!res.empty()) res += ", "; - if (!state.runningSubstitutions.empty()) - res += fmt(ANSI_BLUE "%d" "/" ANSI_NORMAL, state.runningSubstitutions.size()); - res += fmt(ANSI_GREEN "%d/%d fetched" ANSI_NORMAL, - state.succeededSubstitutions, - state.succeededSubstitutions + state.substitutions.size()); - } - - if (!state.runningCopies.empty()) { - uint64_t copied = 0, expected = 0; - for (auto & i : state.runningCopies) { - copied += i.second.copied; - expected += i.second.expected - (i.second.done - i.second.copied); - } - add(fmt("%d/%d copied", copied, expected)); - } - - auto showActivity = [&](ActivityType type, const std::string & f) { + auto showActivity = [&](ActivityType type, const std::string & f, double unit) { auto & act = state.activitiesByType[type]; uint64_t done = act.done, expected = act.done; for (auto & j : act.its) { @@ -214,11 +183,12 @@ public: expected = std::max(expected, act.expected); if (done || expected) - add(fmt(f, done / MiB, expected / MiB)); + add(fmt(f, done / unit, expected / unit)); }; - showActivity(actDownload, "%1$.1f/%2$.1f MiB DL"); - showActivity(actCopyPath, "%1$.1f/%2$.1f MiB copied"); + showActivity(actCopyPaths, ANSI_GREEN "%d" ANSI_NORMAL "/%d copied", 1); + showActivity(actDownload, "%1$.1f/%2$.1f MiB DL", MiB); + showActivity(actCopyPath, "%1$.1f/%2$.1f MiB copied", MiB); return res; } @@ -287,36 +257,6 @@ public: updateActivity(*state, act, ev.getS(1)); } - if (ev.type == evSubstitutionCreated) { - state->substitutions[ev.getI(0)] = ev.getS(1); - } - - if (ev.type == evSubstitutionStarted) { - Activity::t act = ev.getI(0); - state->runningSubstitutions.insert(act); - auto name = storePathToName(state->substitutions[act]); - createActivity(*state, act, fmt("fetching " ANSI_BOLD "%s" ANSI_NORMAL, name)); - } - - if (ev.type == evSubstitutionFinished) { - Activity::t act = ev.getI(0); - if (ev.getI(1)) { - if (state->runningSubstitutions.count(act)) - state->succeededSubstitutions++; - } - state->runningSubstitutions.erase(act); - state->substitutions.erase(act); - deleteActivity(*state, act); - } - - if (ev.type == evCopyProgress) { - Activity::t act = ev.getI(0); - auto & i = state->runningCopies[act]; - i.expected = ev.getI(1); - i.copied = ev.getI(2); - i.done = ev.getI(3); - } - update(*state); } }; |