// Matrix Construct // // Copyright (C) Matrix Construct Developers, Authors & Contributors // Copyright (C) 2016-2019 Jason Volk // // Permission to use, copy, modify, and/or distribute this software for any // purpose with or without fee is hereby granted, provided that the above // copyright notice and this permission notice is present in all copies. The // full license for this software is available in the LICENSE file. #pragma once #define HAVE_IRCD_M_QUERY_H namespace ircd::m { template R query(std::nothrow_t, const pair &, const string_view &key, R&& def, F&&); template R query(std::nothrow_t, const event::idx &, const string_view &key, R&& def, F&&); template auto query(std::nothrow_t, const pair &, const string_view &key, F&&); template auto query(std::nothrow_t, const event::idx &, const string_view &key, F&&); template R query(const pair &, const string_view &key, R&& def, F&&); template R query(const event::idx &, const string_view &key, R&& def, F&&); template auto query(const pair &, const string_view &key, F&&); template auto query(const event::idx &, const string_view &key, F&&); } /// Like m::get(), but the closure returns a value which will then be returned /// by these functions. This elides the pattern of returning a result through /// the lambda capture when one simply wants to condition on the fetched value /// rather than make further use of it. /// template inline auto ircd::m::query(const event::idx &event_idx, const string_view &key, F&& closure) { using R = typename std::invoke_result::type; R ret; m::get(event_idx, key, [&ret, &closure] (const string_view &value) noexcept(std::is_nothrow_invocable()) { ret = closure(value); }); return ret; } template inline auto ircd::m::query(const pair &event_idx, const string_view &key, F&& closure) { using R = typename std::invoke_result::type; R ret; const event::idx idx[2] { event_idx.first, event_idx.second }; m::get(idx, key, [&ret, &closure] (const vector_view res) noexcept(std::is_nothrow_invocable()) { ret = closure(res[0], res[1]); }); return ret; } template inline R ircd::m::query(const event::idx &event_idx, const string_view &key, R&& r, F&& f) { return query(std::nothrow, event_idx, key, std::forward(r), std::forward(f)); } template inline R ircd::m::query(const pair &event_idx, const string_view &key, R&& r, F&& f) { return query(std::nothrow, event_idx, key, std::forward(r), std::forward(f)); } /// See other overload documentation first. This overload implements /// non-throwing behavior when the event_idx/key(column) is not found by /// calling the closure with a default-constructed string so the closure can /// return a default value. /// template inline auto ircd::m::query(std::nothrow_t, const event::idx &event_idx, const string_view &key, F&& closure) { using R = typename std::invoke_result::type; R ret; const auto assign { [&ret, &closure](const string_view &value) noexcept(std::is_nothrow_invocable()) { ret = closure(value); } }; if(unlikely(!m::get(std::nothrow, event_idx, key, assign))) assign(string_view{}); return ret; } template inline auto ircd::m::query(std::nothrow_t, const pair &event_idx, const string_view &key, F&& closure) { using R = typename std::invoke_result::type; R ret; const auto compare { [&ret, &closure](const vector_view res) noexcept(std::is_nothrow_invocable()) { ret = closure(res[0], res[1]); } }; const event::idx idx[2] { event_idx.first, event_idx.second }; const auto mask { m::get(std::nothrow, idx, key, compare) }; const auto got { __builtin_popcountl(mask) }; return ret; } /// See other overload documentation first. This overload implements /// non-throwing behavior when the event_idx/key(column) is not found by /// returning a default value supplied by the caller. /// template inline R ircd::m::query(std::nothrow_t, const event::idx &event_idx, const string_view &key, R&& default_, F&& closure) { R ret { std::forward(default_) }; m::get(std::nothrow, event_idx, key, [&ret, &closure] (const string_view &value) noexcept(std::is_nothrow_invocable()) { ret = closure(value); }); return ret; } template inline R ircd::m::query(std::nothrow_t, const pair &event_idx, const string_view &key, R&& default_, F&& closure) { R ret { std::forward(default_) }; const event::idx idx[2] { event_idx.first, event_idx.second }; m::get(std::nothrow, idx, key, [&ret, &closure] (const vector_view &res) noexcept(std::is_nothrow_invocable()) { ret = closure(res[0], res[1]); }); return ret; }