Commit 2b4f8c8b authored by Dominik Charousset's avatar Dominik Charousset

Rename set_unexpected_handler convenience funs

parent 77db78aa
......@@ -87,12 +87,13 @@ struct make_response_promise_helper<response_promise> {
/// @relates local_actor
/// Default handler function for unexpected messages
/// that sends the message back to the sender.
result<message> mirror_unexpected(local_actor*, const type_erased_tuple*);
result<message> reflect_unexpected(local_actor*, const type_erased_tuple*);
/// @relates local_actor
/// Default handler function for unexpected messages
/// that sends the message back to the sender and then quits.
result<message> mirror_unexpected_once(local_actor*, const type_erased_tuple*);
result<message> reflect_unexpected_and_quit(local_actor*,
const type_erased_tuple*);
/// @relates local_actor
/// Default handler function for unexpected messages that
......@@ -109,8 +110,7 @@ result<message> print_and_drop_unexpected(local_actor*,
/// @relates local_actor
/// Default handler function for unexpected messages that
/// drops unexpected messages without printing them.
result<message> silently_drop_unexpected(local_actor*,
const type_erased_tuple*);
result<message> drop_unexpected(local_actor*, const type_erased_tuple*);
/// Base class for actors running on this node, either
/// living in an own thread or cooperatively scheduled.
......
......@@ -39,14 +39,14 @@
namespace caf {
result<message> mirror_unexpected(local_actor*, const type_erased_tuple* x) {
result<message> reflect_unexpected(local_actor*, const type_erased_tuple* x) {
return message::from(x);
}
result<message> mirror_unexpected_once(local_actor* self,
result<message> reflect_unexpected_and_quit(local_actor* self,
const type_erased_tuple* x) {
self->quit();
return mirror_unexpected(self, x);
return reflect_unexpected(self, x);
}
result<message> skip_unexpected(local_actor*, const type_erased_tuple*) {
......@@ -61,7 +61,7 @@ result<message> print_and_drop_unexpected(local_actor* self,
return sec::unexpected_message;
}
result<message> silently_drop_unexpected(local_actor*,
result<message> drop_unexpected(local_actor*,
const type_erased_tuple*) {
return sec::unexpected_message;
}
......
......@@ -211,7 +211,7 @@ public:
}
behavior make_behavior() override {
set_unexpected_handler(mirror_unexpected);
set_unexpected_handler(reflect_unexpected);
return {
[] {
// nop
......@@ -231,7 +231,7 @@ public:
}
behavior make_behavior() override {
set_unexpected_handler(mirror_unexpected);
set_unexpected_handler(reflect_unexpected);
return {
[] {
// nop
......
......@@ -49,7 +49,7 @@ struct sync_mirror : event_based_actor {
}
behavior make_behavior() override {
set_unexpected_handler(mirror_unexpected);
set_unexpected_handler(reflect_unexpected);
return {
[] {
// nop
......@@ -82,7 +82,7 @@ public:
: event_based_actor(cfg),
buddy_(buddy_arg) {
// don't pollute unit test output with (provoked) warnings
set_unexpected_handler(silently_drop_unexpected);
set_unexpected_handler(drop_unexpected);
}
inline const actor& buddy() const {
......@@ -145,7 +145,7 @@ class C : public event_based_actor {
public:
C(actor_config& cfg) : event_based_actor(cfg) {
// don't pollute unit test output with (provoked) warnings
set_unexpected_handler(silently_drop_unexpected);
set_unexpected_handler(drop_unexpected);
}
behavior make_behavior() override {
......@@ -261,7 +261,7 @@ CAF_TEST(test_void_res) {
CAF_TEST(pending_quit) {
auto mirror = system.spawn([](event_based_actor* self) -> behavior {
self->set_unexpected_handler(mirror_unexpected);
self->set_unexpected_handler(reflect_unexpected);
return {
[] {
// nop
......
......@@ -42,7 +42,7 @@ using sub4_atom = atom_constant<atom("sub4")>;
CAF_TEST(test_serial_reply) {
actor_system system;
auto mirror_behavior = [=](event_based_actor* self) -> behavior {
self->set_unexpected_handler(mirror_unexpected);
self->set_unexpected_handler(reflect_unexpected);
return {
[] {
// nop
......
......@@ -644,7 +644,7 @@ CAF_TEST(remote_actor_and_send) {
CAF_TEST(actor_serialize_and_deserialize) {
auto testee_impl = [](event_based_actor* testee_self) -> behavior {
testee_self->set_unexpected_handler(mirror_unexpected_once);
testee_self->set_unexpected_handler(reflect_unexpected_and_quit);
return {
[] {
// nop
......
......@@ -49,7 +49,7 @@ struct fixture {
};
behavior make_reflector_behavior(event_based_actor* self) {
self->set_unexpected_handler(mirror_unexpected_once);
self->set_unexpected_handler(reflect_unexpected_and_quit);
return {
[] {
// nop
......
......@@ -37,7 +37,7 @@ using namespace caf;
namespace {
behavior mirror(event_based_actor* self) {
self->set_unexpected_handler(mirror_unexpected);
self->set_unexpected_handler(reflect_unexpected);
return {
[] {
// nop
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment