X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer.c;h=c6fce97774f4888d22738d6661832fd90c6bb4e7;hb=d3dedf27c4a2ce0ea994d90f637eba9ed2f26776;hp=f8b25665f1df4ae83279a9801d8e54ca52b2eded;hpb=63e5638db6236d902c4ea909fc53e5842e5b71b6;p=deliverable%2Flttng-tools.git

diff --git a/src/common/consumer/consumer.c b/src/common/consumer/consumer.c
index f8b25665f..c6fce9777 100644
--- a/src/common/consumer/consumer.c
+++ b/src/common/consumer/consumer.c
@@ -4348,3 +4348,23 @@ int lttng_consumer_rotate_rename(char *current_path, char *new_path,
 		return rotate_rename_local(current_path, new_path, uid, gid);
 	}
 }
+
+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;
+	}
+
+	ret = relayd_rotate_pending(&relayd->control_sock, chunk_id);
+
+end:
+	return ret;
+
+}