X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer.c;h=2c82836558287418a171f7e312c45d1fe362f459;hp=63a2ab288c865e338582485199a7a268064bb4af;hb=45f1d9a160baa4e8245124fe9ebb3295376e07b8;hpb=9276e5c88e693249bd31197baecf58310df8167e

diff --git a/src/common/consumer/consumer.c b/src/common/consumer/consumer.c
index 63a2ab288..2c8283655 100644
--- a/src/common/consumer/consumer.c
+++ b/src/common/consumer/consumer.c
@@ -4216,6 +4216,10 @@ int rotate_relay_stream(struct lttng_consumer_local_data *ctx,
 			stream->chan->current_chunk_id,
 			stream->last_sequence_number);
 	pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
+	if (ret < 0) {
+		ERR("Relayd rotate stream failed. Cleaning up relayd %" PRIu64".", relayd->net_seq_idx);
+		lttng_consumer_cleanup_relayd(relayd);
+	}
 	if (ret) {
 		ERR("Rotate relay stream");
 	}
@@ -4389,6 +4393,10 @@ int rotate_rename_relay(const char *old_path, const char *new_path,
 
 	pthread_mutex_lock(&relayd->ctrl_sock_mutex);
 	ret = relayd_rotate_rename(&relayd->control_sock, old_path, new_path);
+	if (ret < 0) {
+		ERR("Relayd rotate rename failed. Cleaning up relayd %" PRIu64".", relayd->net_seq_idx);
+		lttng_consumer_cleanup_relayd(relayd);
+	}
 	pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
 end:
 	return ret;
@@ -4419,6 +4427,10 @@ int lttng_consumer_rotate_pending_relay(uint64_t session_id,
 
 	pthread_mutex_lock(&relayd->ctrl_sock_mutex);
 	ret = relayd_rotate_pending(&relayd->control_sock, chunk_id);
+	if (ret < 0) {
+		ERR("Relayd rotate pending failed. Cleaning up relayd %" PRIu64".", relayd->net_seq_idx);
+		lttng_consumer_cleanup_relayd(relayd);
+	}
 	pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
 
 end:
@@ -4456,6 +4468,10 @@ int mkdir_relay(const char *path, uint64_t relayd_id)
 
 	pthread_mutex_lock(&relayd->ctrl_sock_mutex);
 	ret = relayd_mkdir(&relayd->control_sock, path);
+	if (ret < 0) {
+		ERR("Relayd mkdir failed. Cleaning up relayd %" PRIu64".", relayd->net_seq_idx);
+		lttng_consumer_cleanup_relayd(relayd);
+	}
 	pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
 
 end: