nixos/nix
1
1
Fork 0
mirror of https://github.com/NixOS/nix.git synced 2025-11-15 06:52:43 +01:00
Code Activity

libstore: Fix makeCopyPathMessage after config getUri refactor

Browse source
This commit is contained in:
Sergei Zimmerman 2025-08-14 15:52:24 +03:00
parent cf7084a67c
commit e6f3a193d8
No known key found for this signature in database
1 changed files with 28 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

40
src/libstore/store-api.cc
View file

@ -785,12 +785,24 @@ const Store::Stats & Store::getStats()
return stats;
}
static std::string makeCopyPathMessage(std::string_view srcUri, std::string_view dstUri, std::string_view storePath)
static std::string
makeCopyPathMessage(const StoreReference & src, const StoreReference & dst, std::string_view storePath)
{
return srcUri == "local" || srcUri == "daemon" ? fmt("copying path '%s' to '%s'", storePath, dstUri)
: dstUri == "local" || dstUri == "daemon"
? fmt("copying path '%s' from '%s'", storePath, srcUri)
: fmt("copying path '%s' from '%s' to '%s'", storePath, srcUri, dstUri);
auto isShorthand = [](const StoreReference & ref) {
if (const auto * specified = std::get_if<StoreReference::Specified>(&ref.variant)) {
const auto & scheme = specified->scheme;
return (scheme == "local" || scheme == "unix") && specified->authority.empty() && ref.params.empty();
}
return false;
};
if (isShorthand(src))
return fmt("copying path '%s' to '%s'", storePath, dst.render());
if (isShorthand(dst))
return fmt("copying path '%s' from '%s'", storePath, src.render());
return fmt("copying path '%s' from '%s' to '%s'", storePath, src.render(), dst.render());
}
void copyStorePath(
@ -801,11 +813,15 @@ void copyStorePath(
if (!repair && dstStore.isValidPath(storePath))
return;
auto srcUri = srcStore.config.getUri();
auto dstUri = dstStore.config.getUri();
auto srcRef = srcStore.config.getReference();
auto dstRef = dstStore.config.getReference();
auto storePathS = srcStore.printStorePath(storePath);
Activity act(
*logger, lvlInfo, actCopyPath, makeCopyPathMessage(srcUri, dstUri, storePathS), {storePathS, srcUri, dstUri});
*logger,
lvlInfo,
actCopyPath,
makeCopyPathMessage(srcRef, dstRef, storePathS),
{storePathS, srcRef.render(), dstRef.render()});
PushActivity pact(act.id);
auto info = srcStore.queryPathInfo(storePath);
@ -957,15 +973,15 @@ std::map<StorePath, StorePath> copyPaths(
// We can reasonably assume that the copy will happen whenever we
// read the path, so log something about that at that point
uint64_t total = 0;
auto srcUri = srcStore.config.getUri();
auto dstUri = dstStore.config.getUri();
auto srcRef = srcStore.config.getReference();
auto dstRef = dstStore.config.getReference();
auto storePathS = srcStore.printStorePath(missingPath);
Activity act(
*logger,
lvlInfo,
actCopyPath,
makeCopyPathMessage(srcUri, dstUri, storePathS),
{storePathS, srcUri, dstUri});
makeCopyPathMessage(srcRef, dstRef, storePathS),
{storePathS, srcRef.render(), dstRef.render()});
PushActivity pact(act.id);
LambdaSink progressSink([&](std::string_view data) {