X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Frelayd%2Frelayd.c;h=995e4880197550575667d6e18ca613645b1916b5;hp=242abbedff15c5c2f079460cb8805dbc567268cd;hb=d88744a44aa5f2ca90ab87946692b9eed3120641;hpb=5c408ad8ef08a226c018702aca969536f36ac4e5

diff --git a/src/common/relayd/relayd.c b/src/common/relayd/relayd.c
index 242abbedf..995e48801 100644
--- a/src/common/relayd/relayd.c
+++ b/src/common/relayd/relayd.c
@@ -1086,6 +1086,56 @@ error:
 	return ret;
 }
 
+int relayd_rotate_pending(struct lttcomm_relayd_sock *rsock, uint64_t chunk_id)
+{
+	int ret;
+	struct lttcomm_relayd_rotate_pending msg;
+	struct lttcomm_relayd_rotate_pending_reply reply;
+
+	/* Code flow error. Safety net. */
+	assert(rsock);
+
+	DBG("Querying relayd for rotate pending with chunk_id %" PRIu64,
+			chunk_id);
+
+	memset(&msg, 0, sizeof(msg));
+	msg.chunk_id = htobe64(chunk_id);
+
+	/* Send command */
+	ret = send_command(rsock, RELAYD_ROTATE_PENDING, (void *) &msg,
+			sizeof(msg), 0);
+	if (ret < 0) {
+		goto error;
+	}
+
+	/* Receive response */
+	ret = recv_reply(rsock, (void *) &reply, sizeof(reply));
+	if (ret < 0) {
+		goto error;
+	}
+
+	reply.generic.ret_code = be32toh(reply.generic.ret_code);
+
+	/* Return session id or negative ret code. */
+	if (reply.generic.ret_code != LTTNG_OK) {
+		ret = -reply.generic.ret_code;
+		ERR("Relayd rotate pending replied with error %d", ret);
+		goto error;
+	} else {
+		/* No error, just rotate pending state */
+		if (reply.is_pending == 0 || reply.is_pending == 1) {
+			ret = reply.is_pending;
+			DBG("Relayd rotate pending command completed successfully with result \"%s\"",
+					ret ? "rotation pending" : "rotation NOT pending");
+		} else {
+			ret = -LTTNG_ERR_UNK;
+		}
+	}
+
+error:
+	return ret;
+}
+
 int relayd_mkdir(struct lttcomm_relayd_sock *rsock, const char *path)
 {
 	int ret;