From 57f10c9a1d4a05339a99680600f806c0ef576b37 Mon Sep 17 00:00:00 2001 From: Christian Kreibich Date: Thu, 10 Oct 2024 13:05:30 -0700 Subject: [PATCH] Provide reason when disconnecting a peer because they're slow --- libbroker/broker/internal/core_actor.cc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libbroker/broker/internal/core_actor.cc b/libbroker/broker/internal/core_actor.cc index 41b37cf7..89000b4e 100644 --- a/libbroker/broker/internal/core_actor.cc +++ b/libbroker/broker/internal/core_actor.cc @@ -873,7 +873,7 @@ caf::error core_actor_state::init_new_peer(endpoint_id peer_id, .on_backpressure_buffer(peer_buffer_size(), peer_overflow_policy()) .do_on_error([this, ptr, peer_id](const caf::error& what) { BROKER_INFO("remove peer" << peer_id << "due to:" << what); - ptr->force_disconnect(); + ptr->force_disconnect(to_string(what)); }) .as_observable()); // Push messages received from the peer into the central merge point.