MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-12-27 07:54:05 +01:00
Code Issues Releases Wiki Activity

ircd:Ⓜ️:state: Adjust interface for event insertions from m::dbs.

Browse source
This commit is contained in:
Jason Volk 2018-02-04 19:33:10 -08:00
parent b97f6bf7a9
commit 42bd702d8f
2 changed files with 27 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
include/ircd/m/state.h
View file

@ -49,11 +49,11 @@ namespace ircd::m::state
string_view get_head(db::column &, const mutable_buffer &out, const id::room &);
string_view get_head(const mutable_buffer &out, const id::room &);
void set_head(db::txn &txn, const id::room &, const string_view &head);
string_view set_head(db::txn &txn, const id::room &, const string_view &head);
void insert(db::txn &txn, const id::room &, const json::array &key, const id::event &);
void insert(db::txn &txn, const id::room &, const string_view &type, const string_view &state_key, const id::event &);
void append_nodes(db::txn &, const event &);
string_view insert(db::txn &, const mutable_buffer &head, const id::room &, const json::array &key, const id::event &);
string_view insert(db::txn &, const mutable_buffer &head, const id::room &, const string_view &type, const string_view &state_key, const id::event &);
string_view insert(db::txn &, const mutable_buffer &head, const event &);
using search_closure = std::function<bool (const json::array &, const string_view &, const uint &, const uint &)>;
bool dfs(db::column &, const string_view &node_id, const search_closure &);

37
ircd/m/state.cc
View file

@ -157,8 +157,11 @@ namespace ircd::m::state
static string_view _insert(int8_t &height, db::txn &txn, const json::array &key, const string_view &val, const node &node, const mutable_buffer &idbuf, node::rep &push);
}
void
ircd::m::state::append_nodes(db::txn &txn,
/// State update from an event. (NOTE: sets the room head atm)
/// Leaves the root node ID in the head buffer; returns view.
ircd::string_view
ircd::m::state::insert(db::txn &txn,
const mutable_buffer &head,
const event &event)
{
const auto &type{at<"type"_>(event)};
@ -173,7 +176,6 @@ ircd::m::state::append_nodes(db::txn &txn,
// remain off-stack.
const critical_assertion ca;
thread_local char key[KEY_MAX_SZ];
thread_local char head[ID_MAX_SZ];
thread_local char node[NODE_MAX_SZ];
node::rep rep;
@ -184,15 +186,18 @@ ircd::m::state::append_nodes(db::txn &txn,
rep.chld[0] = string_view{};
rep.cn = 1;
set_head(txn, room_id, set_node(txn, head, rep.write(node)));
return;
return set_head(txn, room_id, set_node(txn, head, rep.write(node)));
}
state::insert(txn, room_id, type, state_key, event_id);
return insert(txn, head, room_id, type, state_key, event_id);
}
void
/// State update for room_id inserting (type,state_key) = event_id into the
/// tree. Leaves the root node ID in the head buffer; returns view.
/// (NOTE: sets the room head in the txn right now).
ircd::string_view
ircd::m::state::insert(db::txn &txn,
const mutable_buffer &head,
const id::room &room_id,
const string_view &type,
const string_view &state_key,
@ -201,11 +206,12 @@ ircd::m::state::insert(db::txn &txn,
// The insertion process reads from the DB and will yield this ircd::ctx
// so the key buffer must stay on this stack.
char key[KEY_MAX_SZ];
return insert(txn, room_id, make_key(key, type, state_key), event_id);
return insert(txn, head, room_id, make_key(key, type, state_key), event_id);
}
void
ircd::string_view
ircd::m::state::insert(db::txn &txn,
const mutable_buffer &headbuf,
const id::room &room_id,
const json::array &key,
const id::event &event_id)
@ -213,23 +219,22 @@ ircd::m::state::insert(db::txn &txn,
db::column heads{*event::events, "state_head"};
db::column nodes{*event::events, "state_node"};
char idbuf[ID_MAX_SZ];
string_view head
{
get_head(heads, idbuf, room_id)
get_head(heads, headbuf, room_id)
};
node::rep push;
int8_t height{0};
get_node(head, [&](const node &node)
{
head = _insert(height, txn, key, event_id, node, idbuf, push);
head = _insert(height, txn, key, event_id, node, headbuf, push);
});
if(push.kn)
head = push.write(txn, idbuf);
head = push.write(txn, headbuf);
set_head(txn, room_id, head);
return set_head(txn, room_id, head);
}
ircd::string_view
@ -471,7 +476,7 @@ ircd::m::state::_getbuffer(const uint8_t &height)
}
/// Set the root node ID for a room in this db transaction.
void
ircd::string_view
ircd::m::state::set_head(db::txn &iov,
const id::room &room_id,
const string_view &head_id)
@ -485,6 +490,8 @@ ircd::m::state::set_head(db::txn &iov,
head_id, // val
}
};
return head_id;
}
/// Copy a room's root node ID into buffer.