X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Frelayd%2Frelayd.c;h=ed788b993ffed5e27535e92b3e03323ef05a396b;hb=96b0ecff3ade3c7970d1cc5fb12a50a94c67ee67;hp=fb459699d32a68ddbf93d001df1829d93798181f;hpb=639ddf685b134bb075b92819f647f9f3c462df54;p=lttng-tools.git

diff --git a/src/common/relayd/relayd.c b/src/common/relayd/relayd.c
index fb459699d..ed788b993 100644
--- a/src/common/relayd/relayd.c
+++ b/src/common/relayd/relayd.c
@@ -1187,176 +1187,3 @@ error:
 	free(msg);
 	return ret;
 }
-
-int relayd_rotate_rename(struct lttcomm_relayd_sock *rsock,
-		const char *old_path, const char *new_path)
-{
-	int ret;
-	struct lttcomm_relayd_rotate_rename *msg = NULL;
-	struct lttcomm_relayd_generic_reply reply;
-	size_t old_path_length, new_path_length;
-	size_t msg_length;
-
-	/* Code flow error. Safety net. */
-	assert(rsock);
-
-	DBG("Relayd rename chunk %s to %s", old_path, new_path);
-
-	/* The two paths are sent with a '\0' delimiter between them. */
-	old_path_length = strlen(old_path) + 1;
-	new_path_length = strlen(new_path) + 1;
-
-	msg_length = sizeof(*msg) + old_path_length + new_path_length;
-	msg = zmalloc(msg_length);
-	if (!msg) {
-		PERROR("zmalloc rotate-rename command message");
-		ret = -1;
-		goto error;
-	}
-
-	assert(old_path_length <= UINT32_MAX);
-	msg->old_path_length = htobe32(old_path_length);
-
-	assert(new_path_length <= UINT32_MAX);
-	msg->new_path_length = htobe32(new_path_length);
-
-	strcpy(msg->paths, old_path);
-	strcpy(msg->paths + old_path_length, new_path);
-
-	/* Send command */
-	ret = send_command(rsock, RELAYD_ROTATE_RENAME, (const void *) msg,
-			msg_length, 0);
-	if (ret < 0) {
-		goto error;
-	}
-
-	/* Receive response */
-	ret = recv_reply(rsock, (void *) &reply, sizeof(reply));
-	if (ret < 0) {
-		goto error;
-	}
-
-	reply.ret_code = be32toh(reply.ret_code);
-
-	/* Return session id or negative ret code. */
-	if (reply.ret_code != LTTNG_OK) {
-		ret = -1;
-		ERR("Relayd rotate rename replied error %d", reply.ret_code);
-	} else {
-		/* Success */
-		ret = 0;
-	}
-
-	DBG("Relayd rotate rename completed successfully");
-
-error:
-	free(msg);
-	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;
-	struct lttcomm_relayd_mkdir *msg;
-	struct lttcomm_relayd_generic_reply reply;
-	size_t len;
-
-	/* Code flow error. Safety net. */
-	assert(rsock);
-
-	DBG("Relayd mkdir path %s", path);
-
-	len = strlen(path) + 1;
-	msg = zmalloc(sizeof(msg->length) + len);
-	if (!msg) {
-		PERROR("Alloc mkdir msg");
-		ret = -1;
-		goto error;
-	}
-	msg->length = htobe32((uint32_t) len);
-
-	if (lttng_strncpy(msg->path, path, len)) {
-		ret = -1;
-		goto error;
-	}
-
-	/* Send command */
-	ret = send_command(rsock, RELAYD_MKDIR, (void *) msg,
-			sizeof(msg->length) + len, 0);
-	if (ret < 0) {
-		goto error;
-	}
-
-	/* Receive response */
-	ret = recv_reply(rsock, (void *) &reply, sizeof(reply));
-	if (ret < 0) {
-		goto error;
-	}
-
-	reply.ret_code = be32toh(reply.ret_code);
-
-	/* Return session id or negative ret code. */
-	if (reply.ret_code != LTTNG_OK) {
-		ret = -1;
-		ERR("Relayd mkdir replied error %d", reply.ret_code);
-	} else {
-		/* Success */
-		ret = 0;
-	}
-
-	DBG("Relayd mkdir completed successfully");
-
-error:
-	free(msg);
-	return ret;
-}