Skip to content

Commit

Permalink
Provide reason when disconnecting a peer because they're slow
Browse files Browse the repository at this point in the history
  • Loading branch information
ckreibich committed Dec 3, 2024
1 parent f6d10e1 commit 57f10c9
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion libbroker/broker/internal/core_actor.cc
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down

0 comments on commit 57f10c9

Please sign in to comment.