// Matrix Construct // // Copyright (C) Matrix Construct Developers, Authors & Contributors // Copyright (C) 2016-2018 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. using namespace ircd; mapi::header IRCD_MODULE { "Matrix state library; modular components." }; namespace ircd::m::state { extern "C" size_t ircd__m__state__gc(void); } size_t ircd::m::state::ircd__m__state__gc() { std::set heads; { const db::gopts opts{db::get::NO_CACHE}; //opts.readahead = 4_MiB; db::column &column{m::dbs::room_events}; for(auto it(column.begin(opts)); it; ++it) { const auto &root(it->second); id_buffer buf; copy(buf, root); heads.emplace(buf); } } std::set active; for(auto it(begin(heads)); it != end(heads); it = heads.erase(it)) { const auto &root(*it); std::cout << "root: " << string_view{root} << std::endl; state::for_each(root, state::iter_bool_closure{[&active] (const json::array &key, const string_view &val) { std::cout << "key: " << key << std::endl; std::cout << "val: " << val << std::endl; return true; }}); break; } /* static const db::gopts opts { db::get::NO_CACHE }; auto &column{m::dbs::state_node}; for(auto it(column.begin(opts)); it; ++it) { id_buffer buf; const auto &root(it->second); copy(buf, root); active.emplace(buf); } */ size_t ret(active.size()); return ret; }