Skip to content

Commit

Permalink
clusterer: fix deadlock when broadcasting shtag state
Browse files Browse the repository at this point in the history
  • Loading branch information
rvlad-patrascu committed Jul 28, 2022
1 parent eb4a92c commit db99f9a
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion modules/clusterer/sharing_tags.c
Expand Up @@ -359,7 +359,8 @@ static int shtag_send_active_info(int c_id, str *tag_name, int node_id)
if (bin_push_str(&packet, tag_name) < 0)
return CLUSTERER_SEND_ERR;

if (cl_send_to(&packet, c_id, node_id) != CLUSTERER_SEND_SUCCESS) {
if (clusterer_send_msg(&packet, c_id, node_id, 1) !=
CLUSTERER_SEND_SUCCESS) {
bin_free_packet(&packet);
return CLUSTERER_SEND_ERR;
}
Expand Down

0 comments on commit db99f9a

Please sign in to comment.