neurocyte/thespian
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat: report sender in DEADSEND errors

Browse source
This commit is contained in:
CJ van den Berg 2024-08-29 14:37:35 +02:00
parent a3c595979f
commit 20339921cf
Signed by: neurocyte
GPG key ID: 8EB1E1BB660E3FB9
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/instance.cpp
View file

@ -186,7 +186,7 @@ template <typename... Ts>
return exit("UNEXPECTED_MESSAGE:" + b.to_json()); return exit("UNEXPECTED_MESSAGE:" + b.to_json());
} }
auto deadsend(const buffer &m) -> result; auto deadsend(const buffer &m, const ref &from) -> result;
const auto exit_normal_msg = array("exit", "normal"); const auto exit_normal_msg = array("exit", "normal");
const auto exit_noreceive_msg = array("exit", "noreceive"); const auto exit_noreceive_msg = array("exit", "noreceive");
const auto exit_nosyncreceive_msg = array("exit", "nosyncreceive"); const auto exit_nosyncreceive_msg = array("exit", "nosyncreceive");
@ -320,11 +320,11 @@ struct instance : std::enable_shared_from_this<instance> {
} }
[[nodiscard]] auto dispatch_sync_raw(buffer m) -> result { [[nodiscard]] auto dispatch_sync_raw(buffer m) -> result {
if (in_shutdown)
return deadsend(m);
ref from{}; ref from{};
if (current_instance) if (current_instance)
from = current_instance->lifetime_; from = current_instance->lifetime_;
if (in_shutdown)
return deadsend(m, from);
run(from, move(m)); run(from, move(m));
return ok(); return ok();
} }
@ -337,7 +337,7 @@ struct instance : std::enable_shared_from_this<instance> {
if ((not m.is_null()) and is_enabled(channel::send)) if ((not m.is_null()) and is_enabled(channel::send))
do_trace_raw(ref_m(from), "send", ref_m(this), m); do_trace_raw(ref_m(from), "send", ref_m(this), m);
if (in_shutdown) if (in_shutdown)
return deadsend(m); return deadsend(m, from);
auto run_m = [this, from{from}, m{move(m)}, lifelock{lifetime_}]() { auto run_m = [this, from{from}, m{move(m)}, lifelock{lifetime_}]() {
run(from, m); run(from, m);
@ -509,7 +509,7 @@ auto deadsend(const buffer &m) -> result {
if (auto p = ref_.lock()) { if (auto p = ref_.lock()) {
return p->send_raw(move(m)); return p->send_raw(move(m));
} }
return deadsend(m); return deadsend(m, ref_);
} }
auto operator==(const handle &a, const handle &b) -> bool { auto operator==(const handle &a, const handle &b) -> bool {