mirror of
https://github.com/matrix-construct/construct
synced 2024-08-22 01:24:53 +02:00
949 lines
20 KiB
C++
949 lines
20 KiB
C++
// Matrix Construct
|
|
//
|
|
// Copyright (C) Matrix Construct Developers, Authors & Contributors
|
|
// Copyright (C) 2016-2018 Jason Volk <jason@zemos.net>
|
|
//
|
|
// 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.
|
|
|
|
namespace ircd::m::vm
|
|
{
|
|
template<class... args> static fault handle_error(const opts &, const fault &, const string_view &fmt, args&&... a);
|
|
template<class T> static void call_hook(hook::site<T> &, eval &, const event &, T&& data);
|
|
static size_t calc_txn_reserve(const opts &, const event &);
|
|
static void write_commit(eval &);
|
|
static void write_append(eval &, const event &);
|
|
static void write_prepare(eval &, const event &);
|
|
static fault execute_edu(eval &, const event &);
|
|
static fault execute_pdu(eval &, const event &);
|
|
fault execute(eval &, const event &);
|
|
fault inject(eval &, json::iov &, const json::iov &);
|
|
fault inject(eval &, const room &, json::iov &, const json::iov &);
|
|
static void fini();
|
|
static void init();
|
|
|
|
extern hook::site<eval &> issue_hook; ///< Called when this server is issuing event
|
|
extern hook::site<eval &> conform_hook; ///< Called for static evaluations of event
|
|
extern hook::site<eval &> access_hook; ///< Called for access control checking
|
|
extern hook::site<eval &> fetch_hook; ///< Called to resolve dependencies
|
|
extern hook::site<eval &> eval_hook; ///< Called for final event evaluation
|
|
extern hook::site<eval &> post_hook; ///< Called to apply effects pre-notify
|
|
extern hook::site<eval &> notify_hook; ///< Called to broadcast successful eval
|
|
extern hook::site<eval &> effect_hook; ///< Called to apply effects post-notify
|
|
|
|
extern conf::item<bool> log_commit_debug;
|
|
extern conf::item<bool> log_accept_debug;
|
|
extern conf::item<bool> log_accept_info;
|
|
}
|
|
|
|
ircd::mapi::header
|
|
IRCD_MODULE
|
|
{
|
|
"Matrix Virtual Machine",
|
|
ircd::m::vm::init, ircd::m::vm::fini
|
|
};
|
|
|
|
decltype(ircd::m::vm::log_commit_debug)
|
|
ircd::m::vm::log_commit_debug
|
|
{
|
|
{ "name", "ircd.m.vm.log.commit.debug" },
|
|
{ "default", true },
|
|
};
|
|
|
|
decltype(ircd::m::vm::log_accept_debug)
|
|
ircd::m::vm::log_accept_debug
|
|
{
|
|
{ "name", "ircd.m.vm.log.accept.debug" },
|
|
{ "default", false },
|
|
};
|
|
|
|
decltype(ircd::m::vm::log_accept_info)
|
|
ircd::m::vm::log_accept_info
|
|
{
|
|
{ "name", "ircd.m.vm.log.accept.info" },
|
|
{ "default", false },
|
|
};
|
|
|
|
decltype(ircd::m::vm::issue_hook)
|
|
ircd::m::vm::issue_hook
|
|
{
|
|
{ "name", "vm.issue" }
|
|
};
|
|
|
|
decltype(ircd::m::vm::conform_hook)
|
|
ircd::m::vm::conform_hook
|
|
{
|
|
{ "name", "vm.conform" }
|
|
};
|
|
|
|
decltype(ircd::m::vm::access_hook)
|
|
ircd::m::vm::access_hook
|
|
{
|
|
{ "name", "vm.access" }
|
|
};
|
|
|
|
decltype(ircd::m::vm::fetch_hook)
|
|
ircd::m::vm::fetch_hook
|
|
{
|
|
{ "name", "vm.fetch" }
|
|
};
|
|
|
|
decltype(ircd::m::vm::eval_hook)
|
|
ircd::m::vm::eval_hook
|
|
{
|
|
{ "name", "vm.eval" }
|
|
};
|
|
|
|
decltype(ircd::m::vm::post_hook)
|
|
ircd::m::vm::post_hook
|
|
{
|
|
{ "name", "vm.post" }
|
|
};
|
|
|
|
decltype(ircd::m::vm::notify_hook)
|
|
ircd::m::vm::notify_hook
|
|
{
|
|
{ "name", "vm.notify" }
|
|
};
|
|
|
|
decltype(ircd::m::vm::effect_hook)
|
|
ircd::m::vm::effect_hook
|
|
{
|
|
{ "name", "vm.effect" }
|
|
};
|
|
|
|
//
|
|
// init
|
|
//
|
|
|
|
void
|
|
ircd::m::vm::init()
|
|
{
|
|
id::event::buf event_id;
|
|
sequence::retired = sequence::get(event_id);
|
|
sequence::committed = sequence::retired;
|
|
sequence::uncommitted = sequence::committed;
|
|
|
|
vm::ready = true;
|
|
vm::dock.notify_all();
|
|
|
|
log::info
|
|
{
|
|
log, "BOOT %s @%lu [%s]",
|
|
string_view{m::my_node.node_id},
|
|
sequence::retired,
|
|
sequence::retired? string_view{event_id} : "NO EVENTS"_sv
|
|
};
|
|
}
|
|
|
|
void
|
|
ircd::m::vm::fini()
|
|
{
|
|
vm::ready = false;
|
|
|
|
if(!eval::list.empty())
|
|
log::warning
|
|
{
|
|
log, "Waiting for %zu evals (exec:%zu inject:%zu room:%zu pending:%zu)",
|
|
eval::list.size(),
|
|
eval::executing,
|
|
eval::injecting,
|
|
eval::injecting_room,
|
|
sequence::pending,
|
|
};
|
|
|
|
vm::dock.wait([]
|
|
{
|
|
return !eval::executing && !eval::injecting && !eval::injecting_room;
|
|
});
|
|
|
|
assert(!sequence::pending);
|
|
|
|
event::id::buf event_id;
|
|
const auto retired
|
|
{
|
|
sequence::get(event_id)
|
|
};
|
|
|
|
log::info
|
|
{
|
|
log, "HLT '%s' @%lu [%s] %lu:%lu:%lu",
|
|
string_view{m::my_node.node_id},
|
|
retired,
|
|
retired? string_view{event_id} : "NO EVENTS"_sv,
|
|
sequence::retired,
|
|
sequence::committed,
|
|
sequence::uncommitted
|
|
};
|
|
|
|
assert(retired == sequence::retired);
|
|
}
|
|
|
|
//
|
|
// eval
|
|
//
|
|
|
|
enum ircd::m::vm::fault
|
|
IRCD_MODULE_EXPORT
|
|
ircd::m::vm::inject(eval &eval,
|
|
const room &room,
|
|
json::iov &event,
|
|
const json::iov &contents)
|
|
{
|
|
// m::vm bookkeeping that someone entered this function
|
|
const scope_count injecting_room{eval::injecting_room};
|
|
const scope_notify notify{vm::dock};
|
|
|
|
// This eval entry point is only used for injections. We try to find the
|
|
// commit opts the user supplied directly to this eval or with the room.
|
|
if(!eval.copts)
|
|
eval.copts = room.copts;
|
|
|
|
if(!eval.copts)
|
|
eval.copts = &vm::default_copts;
|
|
|
|
// Note that the regular opts is unconditionally overridden because the
|
|
// user should have provided copts instead.
|
|
assert(!eval.opts || eval.opts == eval.copts);
|
|
eval.opts = eval.copts;
|
|
|
|
// Set a member pointer to the json::iov currently being composed. This
|
|
// allows other parallel evals to have deep access to exactly what this
|
|
// eval is attempting to do.
|
|
const scope_restore eval_issue
|
|
{
|
|
eval.issue, &event
|
|
};
|
|
|
|
const scope_restore eval_room_id
|
|
{
|
|
eval.room_id, room.room_id
|
|
};
|
|
|
|
assert(eval.issue);
|
|
assert(eval.room_id);
|
|
assert(eval.copts);
|
|
assert(eval.opts);
|
|
assert(room.room_id);
|
|
|
|
const auto &opts
|
|
{
|
|
*eval.copts
|
|
};
|
|
|
|
const json::iov::push room_id
|
|
{
|
|
event, { "room_id", room.room_id }
|
|
};
|
|
|
|
const m::room::head head
|
|
{
|
|
room
|
|
};
|
|
|
|
const bool need_tophead{event.at("type") != "m.room.create"};
|
|
const unique_buffer<mutable_buffer> prev_buf{8192};
|
|
static const size_t prev_limit{16};
|
|
const auto prev
|
|
{
|
|
head.make_refs(prev_buf, prev_limit, need_tophead)
|
|
};
|
|
|
|
const auto &prev_events{prev.first};
|
|
const auto &depth{prev.second};
|
|
const json::iov::set depth_
|
|
{
|
|
event, !event.has("depth"),
|
|
{
|
|
"depth", [&depth]
|
|
{
|
|
return json::value
|
|
{
|
|
depth == std::numeric_limits<int64_t>::max()? depth : depth + 1
|
|
};
|
|
}
|
|
}
|
|
};
|
|
|
|
const m::room::auth auth
|
|
{
|
|
room
|
|
};
|
|
|
|
char ae_buf[1024];
|
|
json::array auth_events{json::empty_array};
|
|
if(depth != -1 && event.at("type") != "m.room.create" && opts.add_auth_events)
|
|
auth_events = auth.make_refs(ae_buf, m::event{event});
|
|
|
|
const json::iov::add auth_events_
|
|
{
|
|
event, opts.add_auth_events,
|
|
{
|
|
"auth_events", [&auth_events]() -> json::value
|
|
{
|
|
return auth_events;
|
|
}
|
|
}
|
|
};
|
|
|
|
const json::iov::add prev_events_
|
|
{
|
|
event, opts.add_prev_events,
|
|
{
|
|
"prev_events", [&prev_events]() -> json::value
|
|
{
|
|
return prev_events;
|
|
}
|
|
}
|
|
};
|
|
|
|
return inject(eval, event, contents);
|
|
}
|
|
|
|
enum ircd::m::vm::fault
|
|
IRCD_MODULE_EXPORT
|
|
ircd::m::vm::inject(eval &eval,
|
|
json::iov &event,
|
|
const json::iov &contents)
|
|
{
|
|
// m::vm bookkeeping that someone entered this function
|
|
const scope_count injecting{eval::injecting};
|
|
const scope_notify notify{vm::dock};
|
|
|
|
// This eval entry point is only used for commits. If the user did not
|
|
// supply commit opts we supply the default ones here.
|
|
if(!eval.copts)
|
|
eval.copts = &vm::default_copts;
|
|
|
|
// Note that the regular opts is unconditionally overridden because the
|
|
// user should have provided copts instead.
|
|
assert(!eval.opts || eval.opts == eval.copts);
|
|
eval.opts = eval.copts;
|
|
|
|
// Set a member pointer to the json::iov currently being composed. This
|
|
// allows other parallel evals to have deep access to exactly what this
|
|
// eval is attempting to do.
|
|
assert(!eval.room_id || eval.issue == &event);
|
|
if(!eval.room_id)
|
|
eval.issue = &event;
|
|
|
|
const unwind deissue{[&eval]
|
|
{
|
|
// issue is untouched when room_id is set; that indicates it was set
|
|
// and will be unset by another eval function (i.e above).
|
|
if(!eval.room_id)
|
|
eval.issue = nullptr;
|
|
}};
|
|
|
|
assert(eval.issue);
|
|
assert(eval.copts);
|
|
assert(eval.opts);
|
|
assert(eval.copts);
|
|
|
|
const auto &opts
|
|
{
|
|
*eval.copts
|
|
};
|
|
|
|
const json::iov::add origin_
|
|
{
|
|
event, opts.add_origin,
|
|
{
|
|
"origin", []() -> json::value
|
|
{
|
|
return my_host();
|
|
}
|
|
}
|
|
};
|
|
|
|
const json::iov::add origin_server_ts_
|
|
{
|
|
event, opts.add_origin_server_ts,
|
|
{
|
|
"origin_server_ts", []
|
|
{
|
|
return json::value{ircd::time<milliseconds>()};
|
|
}
|
|
}
|
|
};
|
|
|
|
const json::strung content
|
|
{
|
|
contents
|
|
};
|
|
|
|
// hashes
|
|
|
|
char hashes_buf[384];
|
|
const string_view hashes
|
|
{
|
|
opts.add_hash && eval.room_version != "1"?
|
|
m::event::hashes(hashes_buf, event, content):
|
|
string_view{}
|
|
};
|
|
|
|
const json::iov::add hashes_
|
|
{
|
|
event, opts.add_hash && eval.room_version != "1",
|
|
{
|
|
"hashes", [&hashes]() -> json::value
|
|
{
|
|
return hashes;
|
|
}
|
|
}
|
|
};
|
|
|
|
// event_id
|
|
|
|
char room_version_buf[32];
|
|
const scope_restore eval_room_version
|
|
{
|
|
eval.room_version,
|
|
eval.opts->room_version?:
|
|
m::version(room_version_buf, room{eval.room_id}, std::nothrow)
|
|
};
|
|
|
|
assert(eval.room_version);
|
|
const event::id &event_id_v1
|
|
{
|
|
opts.add_event_id && (eval.room_version == "1" || eval.room_version == "2")?
|
|
make_id(m::event{event}, eval.room_version, eval.event_id):
|
|
event::id{}
|
|
};
|
|
|
|
const json::iov::add event_id_
|
|
{
|
|
event, !empty(event_id_v1),
|
|
{
|
|
"event_id", [&event_id_v1]() -> json::value
|
|
{
|
|
return event_id_v1;
|
|
}
|
|
}
|
|
};
|
|
|
|
// hashes
|
|
|
|
const string_view hashes__
|
|
{
|
|
opts.add_hash && eval.room_version == "1"?
|
|
m::event::hashes(hashes_buf, event, content):
|
|
string_view{}
|
|
};
|
|
|
|
const json::iov::set hashes___
|
|
{
|
|
event, opts.add_hash && eval.room_version == "1",
|
|
{
|
|
"hashes", [&hashes__]() -> json::value
|
|
{
|
|
return hashes__;
|
|
}
|
|
}
|
|
};
|
|
|
|
// sigs
|
|
|
|
char sigs_buf[384];
|
|
const string_view sigs
|
|
{
|
|
opts.add_sig?
|
|
m::event::signatures(sigs_buf, event, contents):
|
|
string_view{}
|
|
};
|
|
|
|
const json::iov::add sigs_
|
|
{
|
|
event, opts.add_sig,
|
|
{
|
|
"signatures", [&sigs]() -> json::value
|
|
{
|
|
return sigs;
|
|
}
|
|
}
|
|
};
|
|
|
|
const json::iov::push content_
|
|
{
|
|
event, { "content", content },
|
|
};
|
|
|
|
const event::id &event_id
|
|
{
|
|
event_id_v1?
|
|
event_id_v1:
|
|
opts.add_event_id?
|
|
make_id(m::event{event}, eval.room_version, eval.event_id):
|
|
event::id{}
|
|
};
|
|
|
|
const m::event event_tuple
|
|
{
|
|
event, event_id
|
|
};
|
|
|
|
if(opts.debuglog_precommit)
|
|
log::debug
|
|
{
|
|
log, "Issuing: %s", pretty_oneline(event_tuple)
|
|
};
|
|
|
|
return execute(eval, event_tuple);
|
|
}
|
|
|
|
enum ircd::m::vm::fault
|
|
IRCD_MODULE_EXPORT
|
|
ircd::m::vm::execute(eval &eval,
|
|
const event &event)
|
|
try
|
|
{
|
|
// m::vm bookkeeping that someone entered this function
|
|
const scope_count executing{eval::executing};
|
|
const scope_notify notify{vm::dock};
|
|
|
|
// Set a member pointer to the event currently being evaluated. This
|
|
// allows other parallel evals to have deep access to this eval.
|
|
assert(!eval.event_);
|
|
const scope_restore eval_event
|
|
{
|
|
eval.event_, &event
|
|
};
|
|
|
|
const scope_restore eval_room_id
|
|
{
|
|
eval.room_id,
|
|
eval.room_id?
|
|
eval.room_id:
|
|
string_view(json::get<"room_id"_>(event))
|
|
};
|
|
|
|
char room_version_buf[32];
|
|
const scope_restore eval_room_version
|
|
{
|
|
eval.room_version,
|
|
eval.opts->room_version?
|
|
eval.opts->room_version:
|
|
eval.room_id?
|
|
m::version(room_version_buf, room{eval.room_id}, std::nothrow):
|
|
string_view{}
|
|
};
|
|
|
|
assert(eval.opts);
|
|
assert(eval.event_);
|
|
assert(eval.id);
|
|
assert(eval.ctx);
|
|
const auto &opts
|
|
{
|
|
*eval.opts
|
|
};
|
|
|
|
if(eval.copts && eval.copts->issue)
|
|
call_hook(issue_hook, eval, event, eval);
|
|
|
|
if(opts.conform)
|
|
call_hook(conform_hook, eval, event, eval);
|
|
|
|
const fault ret
|
|
{
|
|
event.event_id?
|
|
execute_pdu(eval, event):
|
|
execute_edu(eval, event)
|
|
};
|
|
|
|
if(ret != fault::ACCEPT)
|
|
return ret;
|
|
|
|
if(opts.notify)
|
|
call_hook(notify_hook, eval, event, eval);
|
|
|
|
if(opts.effects)
|
|
call_hook(effect_hook, eval, event, eval);
|
|
|
|
if(opts.debuglog_accept || bool(log_accept_debug))
|
|
log::debug
|
|
{
|
|
log, "%s", pretty_oneline(event)
|
|
};
|
|
|
|
if(opts.infolog_accept || bool(log_accept_info))
|
|
log::info
|
|
{
|
|
log, "%s", pretty_oneline(event)
|
|
};
|
|
|
|
return ret;
|
|
}
|
|
catch(const error &e) // VM FAULT CODE
|
|
{
|
|
return handle_error
|
|
(
|
|
*eval.opts, e.code,
|
|
"eval %s :%s",
|
|
event.event_id? string_view{event.event_id}: "<edu>"_sv,
|
|
unquote(json::object(e.content).get("error"))
|
|
);
|
|
}
|
|
catch(const m::error &e) // GENERAL MATRIX ERROR
|
|
{
|
|
return handle_error
|
|
(
|
|
*eval.opts, fault::GENERAL,
|
|
"eval %s (General Protection): %s %s :%s",
|
|
event.event_id? string_view{event.event_id}: "<edu>"_sv,
|
|
e.what(),
|
|
unquote(json::object(e.content).get("errcode")),
|
|
unquote(json::object(e.content).get("error"))
|
|
);
|
|
}
|
|
catch(const ctx::interrupted &e) // INTERRUPTION
|
|
{
|
|
return handle_error
|
|
(
|
|
*eval.opts, fault::INTERRUPT,
|
|
"eval %s :%s",
|
|
event.event_id? string_view{event.event_id}: "<edu>"_sv,
|
|
e.what()
|
|
);
|
|
}
|
|
catch(const std::exception &e) // ALL OTHER ERRORS
|
|
{
|
|
return handle_error
|
|
(
|
|
*eval.opts, fault::GENERAL,
|
|
"eval %s (General Protection): %s",
|
|
event.event_id? string_view{event.event_id}: "<edu>"_sv,
|
|
e.what()
|
|
);
|
|
}
|
|
|
|
enum ircd::m::vm::fault
|
|
ircd::m::vm::execute_edu(eval &eval,
|
|
const event &event)
|
|
{
|
|
if(eval.opts->eval)
|
|
call_hook(eval_hook, eval, event, eval);
|
|
|
|
if(eval.opts->post)
|
|
call_hook(post_hook, eval, event, eval);
|
|
|
|
return fault::ACCEPT;
|
|
}
|
|
|
|
enum ircd::m::vm::fault
|
|
ircd::m::vm::execute_pdu(eval &eval,
|
|
const event &event)
|
|
{
|
|
const scope_count pending
|
|
{
|
|
sequence::pending
|
|
};
|
|
|
|
const scope_restore remove_txn
|
|
{
|
|
eval.txn, std::shared_ptr<db::txn>{}
|
|
};
|
|
|
|
assert(eval.opts);
|
|
const auto &opts
|
|
{
|
|
*eval.opts
|
|
};
|
|
|
|
const m::event::id &event_id
|
|
{
|
|
event.event_id
|
|
};
|
|
|
|
const m::room::id &room_id
|
|
{
|
|
at<"room_id"_>(event)
|
|
};
|
|
|
|
const string_view &type
|
|
{
|
|
at<"type"_>(event)
|
|
};
|
|
|
|
const bool already_exists
|
|
{
|
|
exists(event_id)
|
|
};
|
|
|
|
//TODO: ABA
|
|
if(already_exists && !opts.replays)
|
|
throw error
|
|
{
|
|
fault::EXISTS, "Event has already been evaluated."
|
|
};
|
|
|
|
if(opts.access)
|
|
call_hook(access_hook, eval, event, eval);
|
|
|
|
if(opts.verify && !verify(event))
|
|
throw m::BAD_SIGNATURE
|
|
{
|
|
"Signature verification failed"
|
|
};
|
|
|
|
// Fetch dependencies
|
|
if(opts.fetch)
|
|
call_hook(fetch_hook, eval, event, eval);
|
|
|
|
// Obtain sequence number here.
|
|
const auto *const &top(eval::seqmax());
|
|
eval.sequence_shared[0] = 0;
|
|
eval.sequence_shared[1] = 0;
|
|
eval.sequence = 0;
|
|
eval.sequence =
|
|
{
|
|
top?
|
|
std::max(sequence::get(*top) + 1, sequence::committed + 1):
|
|
sequence::committed + 1
|
|
};
|
|
|
|
log::debug
|
|
{
|
|
log, "%s | acquire", loghead(eval)
|
|
};
|
|
|
|
assert(eval.sequence != 0);
|
|
assert(sequence::uncommitted <= sequence::get(eval));
|
|
assert(sequence::committed < sequence::get(eval));
|
|
assert(sequence::retired < sequence::get(eval));
|
|
assert(eval::sequnique(sequence::get(eval)));
|
|
sequence::uncommitted = sequence::get(eval);
|
|
|
|
// Evaluation by module hooks
|
|
if(opts.eval)
|
|
call_hook(eval_hook, eval, event, eval);
|
|
|
|
// Wait until this is the lowest sequence number
|
|
sequence::dock.wait([&eval]
|
|
{
|
|
return eval::seqnext(sequence::committed) == &eval;
|
|
});
|
|
|
|
log::debug
|
|
{
|
|
log, "%s | commit", loghead(eval)
|
|
};
|
|
|
|
assert(sequence::committed < sequence::get(eval));
|
|
assert(sequence::retired < sequence::get(eval));
|
|
sequence::committed = sequence::get(eval);
|
|
sequence::dock.notify_all();
|
|
|
|
if(opts.write)
|
|
write_prepare(eval, event);
|
|
|
|
if(opts.write)
|
|
write_append(eval, event);
|
|
|
|
// Generate post-eval/pre-notify effects. This function may conduct
|
|
// an entire eval of several more events recursively before returning.
|
|
if(opts.post)
|
|
call_hook(post_hook, eval, event, eval);
|
|
|
|
// Commit the transaction to database iff this eval is at the stack base.
|
|
if(opts.write && !eval.sequence_shared[0])
|
|
write_commit(eval);
|
|
|
|
// Wait for sequencing only if this is the stack base, otherwise we'll
|
|
// never return back to that stack base.
|
|
if(!eval.sequence_shared[0])
|
|
{
|
|
sequence::dock.wait([&eval]
|
|
{
|
|
return eval::seqnext(sequence::retired) == &eval;
|
|
});
|
|
|
|
log::debug
|
|
{
|
|
log, "%s | retire %lu:%lu",
|
|
loghead(eval),
|
|
sequence::get(eval),
|
|
eval.sequence_shared[1],
|
|
};
|
|
|
|
assert(sequence::retired < sequence::get(eval));
|
|
sequence::retired = std::max(eval.sequence_shared[1], sequence::get(eval));
|
|
sequence::dock.notify_all();
|
|
}
|
|
|
|
return fault::ACCEPT;
|
|
}
|
|
|
|
void
|
|
ircd::m::vm::write_prepare(eval &eval,
|
|
const event &event)
|
|
|
|
{
|
|
assert(eval.opts);
|
|
const auto &opts{*eval.opts};
|
|
|
|
// Share a transaction with any other unretired evals on this stack. This
|
|
// should mean the bottom-most/lowest-sequence eval on this ctx.
|
|
const auto get_other_txn{[&eval]
|
|
(auto &other)
|
|
{
|
|
if(&other == &eval)
|
|
return true;
|
|
|
|
if(!other.txn)
|
|
return true;
|
|
|
|
if(sequence::get(other) <= sequence::retired)
|
|
return true;
|
|
|
|
other.sequence_shared[1] = std::max(other.sequence_shared[1], sequence::get(eval));
|
|
eval.sequence_shared[0] = sequence::get(other);
|
|
eval.txn = other.txn;
|
|
return false;
|
|
}};
|
|
|
|
// If we broke from the iteration then this eval is sharing a transaction
|
|
// from another eval on this stack.
|
|
if(!eval.for_each(eval.ctx, get_other_txn))
|
|
return;
|
|
|
|
eval.txn = std::make_shared<db::txn>
|
|
(
|
|
*dbs::events, db::txn::opts
|
|
{
|
|
calc_txn_reserve(opts, event), // reserve_bytes
|
|
0, // max_bytes (no max)
|
|
}
|
|
);
|
|
}
|
|
|
|
void
|
|
ircd::m::vm::write_append(eval &eval,
|
|
const event &event)
|
|
|
|
{
|
|
assert(eval.opts);
|
|
assert(eval.txn);
|
|
|
|
const auto &opts{*eval.opts};
|
|
auto &txn{*eval.txn};
|
|
|
|
log::debug
|
|
{
|
|
log, "%s | append", loghead(eval)
|
|
};
|
|
|
|
// Preliminary write_opts
|
|
m::dbs::write_opts wopts(opts.wopts);
|
|
wopts.appendix.set(dbs::appendix::ROOM_STATE, opts.present);
|
|
wopts.appendix.set(dbs::appendix::ROOM_JOINED, opts.present);
|
|
wopts.appendix.set(dbs::appendix::ROOM_STATE_SPACE, opts.history);
|
|
wopts.appendix.set(dbs::appendix::ROOM_HEAD, opts.room_head);
|
|
wopts.appendix.set(dbs::appendix::ROOM_HEAD_RESOLVE, opts.room_head_resolve);
|
|
wopts.json_source = opts.json_source;
|
|
wopts.event_idx = eval.sequence;
|
|
dbs::write(*eval.txn, event, wopts);
|
|
}
|
|
|
|
void
|
|
ircd::m::vm::write_commit(eval &eval)
|
|
{
|
|
assert(eval.txn);
|
|
assert(eval.txn.use_count() == 1);
|
|
assert(eval.sequence_shared[0] == 0);
|
|
auto &txn(*eval.txn);
|
|
|
|
#ifdef RB_DEBUG
|
|
const auto db_seq_before(db::sequence(*m::dbs::events));
|
|
#endif
|
|
|
|
txn();
|
|
|
|
#ifdef RB_DEBUG
|
|
const auto db_seq_after(db::sequence(*m::dbs::events));
|
|
|
|
log::debug
|
|
{
|
|
log, "%s | wrote %lu:%lu | db seq %lu:%lu %zu cells in %zu bytes to events database ...",
|
|
loghead(eval),
|
|
sequence::get(eval),
|
|
eval.sequence_shared[1],
|
|
db_seq_before,
|
|
db_seq_after,
|
|
txn.size(),
|
|
txn.bytes()
|
|
};
|
|
#endif
|
|
}
|
|
|
|
size_t
|
|
ircd::m::vm::calc_txn_reserve(const opts &opts,
|
|
const event &event)
|
|
{
|
|
const size_t reserve_event
|
|
{
|
|
opts.reserve_bytes == size_t(-1)?
|
|
size_t(json::serialized(event) * 1.66):
|
|
opts.reserve_bytes
|
|
};
|
|
|
|
return reserve_event + opts.reserve_index;
|
|
}
|
|
|
|
template<class T>
|
|
void
|
|
ircd::m::vm::call_hook(hook::site<T> &hook,
|
|
eval &eval,
|
|
const event &event,
|
|
T&& data)
|
|
try
|
|
{
|
|
hook(event, std::forward<T>(data));
|
|
}
|
|
catch(const std::exception &e)
|
|
{
|
|
log::derror
|
|
{
|
|
"%s | phase:%s :%s",
|
|
loghead(eval),
|
|
unquote(hook.feature.get("name")),
|
|
e.what(),
|
|
};
|
|
|
|
throw;
|
|
}
|
|
|
|
template<class... args>
|
|
ircd::m::vm::fault
|
|
ircd::m::vm::handle_error(const vm::opts &opts,
|
|
const vm::fault &code,
|
|
const string_view &fmt,
|
|
args&&... a)
|
|
{
|
|
if(opts.errorlog & code)
|
|
log::error
|
|
{
|
|
log, fmt, std::forward<args>(a)...
|
|
};
|
|
else if(~opts.warnlog & code)
|
|
log::derror
|
|
{
|
|
log, fmt, std::forward<args>(a)...
|
|
};
|
|
|
|
if(opts.warnlog & code)
|
|
log::warning
|
|
{
|
|
log, fmt, std::forward<args>(a)...
|
|
};
|
|
|
|
if(~opts.nothrows & code)
|
|
throw error
|
|
{
|
|
code, fmt, std::forward<args>(a)...
|
|
};
|
|
|
|
return code;
|
|
}
|