X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer.c;h=3638273d0797d55f549d1047175f2087a3919c5f;hp=3ac00cb030bdebc60a3c864a91107873fb683f63;hb=d88744a44aa5f2ca90ab87946692b9eed3120641;hpb=5c408ad8ef08a226c018702aca969536f36ac4e5

diff --git a/src/common/consumer/consumer.c b/src/common/consumer/consumer.c
index 3ac00cb03..3638273d0 100644
--- a/src/common/consumer/consumer.c
+++ b/src/common/consumer/consumer.c
@@ -4389,6 +4389,27 @@ int lttng_consumer_rotate_rename(const char *old_path, const char *new_path,
 	}
 }
 
+int lttng_consumer_rotate_pending_relay(uint64_t session_id,
+		uint64_t relayd_id, uint64_t chunk_id)
+{
+	int ret;
+	struct consumer_relayd_sock_pair *relayd;
+
+	relayd = consumer_find_relayd(relayd_id);
+	if (!relayd) {
+		ERR("Failed to find relayd");
+		ret = -1;
+		goto end;
+	}
+
+	pthread_mutex_lock(&relayd->ctrl_sock_mutex);
+	ret = relayd_rotate_pending(&relayd->control_sock, chunk_id);
+	pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
+
+end:
+	return ret;
+}
+
 static
 int mkdir_local(const char *path, uid_t uid, gid_t gid)
 {