From 2f4a1dd6e03f3005e1f11dc98dda2d2d214b1f6f Mon Sep 17 00:00:00 2001 From: eldritch horrors Date: Sat, 27 Apr 2024 21:24:36 +0200 Subject: libstore: de-callback-ify Store::queryPathInfoUncached Change-Id: I23a156aaff5328f67ca16ccd85c0ea1711b21e35 --- src/libstore/remote-store.cc | 41 +++++++++++++++++------------------------ 1 file changed, 17 insertions(+), 24 deletions(-) (limited to 'src/libstore/remote-store.cc') diff --git a/src/libstore/remote-store.cc b/src/libstore/remote-store.cc index 20c1c50f2..94c426c02 100644 --- a/src/libstore/remote-store.cc +++ b/src/libstore/remote-store.cc @@ -304,32 +304,25 @@ void RemoteStore::querySubstitutablePathInfos(const StorePathCAMap & pathsMap, S } -void RemoteStore::queryPathInfoUncached(const StorePath & path, - Callback> callback) noexcept +std::shared_ptr RemoteStore::queryPathInfoUncached(const StorePath & path) { + auto conn(getConnection()); + conn->to << WorkerProto::Op::QueryPathInfo << printStorePath(path); try { - std::shared_ptr info; - { - auto conn(getConnection()); - conn->to << WorkerProto::Op::QueryPathInfo << printStorePath(path); - try { - conn.processStderr(); - } catch (Error & e) { - // Ugly backwards compatibility hack. - if (e.msg().find("is not valid") != std::string::npos) - throw InvalidPath(std::move(e.info())); - throw; - } - if (GET_PROTOCOL_MINOR(conn->daemonVersion) >= 17) { - bool valid; conn->from >> valid; - if (!valid) throw InvalidPath("path '%s' is not valid", printStorePath(path)); - } - info = std::make_shared( - StorePath{path}, - WorkerProto::Serialise::read(*this, *conn)); - } - callback(std::move(info)); - } catch (...) { callback.rethrow(); } + conn.processStderr(); + } catch (Error & e) { + // Ugly backwards compatibility hack. + if (e.msg().find("is not valid") != std::string::npos) + throw InvalidPath(std::move(e.info())); + throw; + } + if (GET_PROTOCOL_MINOR(conn->daemonVersion) >= 17) { + bool valid; conn->from >> valid; + if (!valid) throw InvalidPath("path '%s' is not valid", printStorePath(path)); + } + return std::make_shared( + StorePath{path}, + WorkerProto::Serialise::read(*this, *conn)); } -- cgit v1.2.3