aboutsummaryrefslogtreecommitdiff
path: root/src/nix/progress-bar.cc
diff options
context:
space:
mode:
authorEelco Dolstra <edolstra@gmail.com>2017-08-14 22:12:36 +0200
committerEelco Dolstra <edolstra@gmail.com>2017-08-16 20:56:03 +0200
commit0e0dcf2c7ec054f1b30629e275f53f56039b8257 (patch)
tree10dc034fe2ff6a5860f74eae3b22673e08d1191e /src/nix/progress-bar.cc
parentc36467ad2e2e27d04e681144e0e10417c53c10c1 (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.cc70
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);
}
};