Blame rdma/rdma.c

Packit d3f73b
// SPDX-License-Identifier: GPL-2.0 OR Linux-OpenIB
Packit d3f73b
/*
Packit d3f73b
 * rdma.c	RDMA tool
Packit d3f73b
 * Authors:     Leon Romanovsky <leonro@mellanox.com>
Packit d3f73b
 */
Packit d3f73b
Packit d3f73b
#include "rdma.h"
Packit d3f73b
#include "SNAPSHOT.h"
Packit d3f73b
Packit d3f73b
static void help(char *name)
Packit d3f73b
{
Packit d3f73b
	pr_out("Usage: %s [ OPTIONS ] OBJECT { COMMAND | help }\n"
Packit d3f73b
	       "       %s [ -f[orce] ] -b[atch] filename\n"
Packit d3f73b
	       "where  OBJECT := { dev | link | resource | system | statistic | help }\n"
Packit d3f73b
	       "       OPTIONS := { -V[ersion] | -d[etails] | -j[son] | -p[retty]}\n", name, name);
Packit d3f73b
}
Packit d3f73b
Packit d3f73b
static int cmd_help(struct rd *rd)
Packit d3f73b
{
Packit d3f73b
	help(rd->filename);
Packit d3f73b
	return 0;
Packit d3f73b
}
Packit d3f73b
Packit d3f73b
static int rd_cmd(struct rd *rd, int argc, char **argv)
Packit d3f73b
{
Packit d3f73b
	const struct rd_cmd cmds[] = {
Packit d3f73b
		{ NULL,		cmd_help },
Packit d3f73b
		{ "help",	cmd_help },
Packit d3f73b
		{ "dev",	cmd_dev },
Packit d3f73b
		{ "link",	cmd_link },
Packit d3f73b
		{ "resource",	cmd_res },
Packit d3f73b
		{ "system",	cmd_sys },
Packit d3f73b
		{ "statistic",	cmd_stat },
Packit d3f73b
		{ 0 }
Packit d3f73b
	};
Packit d3f73b
Packit d3f73b
	rd->argc = argc;
Packit d3f73b
	rd->argv = argv;
Packit d3f73b
Packit d3f73b
	return rd_exec_cmd(rd, cmds, "object");
Packit d3f73b
}
Packit d3f73b
Packit d3f73b
static int rd_batch(struct rd *rd, const char *name, bool force)
Packit d3f73b
{
Packit d3f73b
	char *line = NULL;
Packit d3f73b
	size_t len = 0;
Packit d3f73b
	int ret = 0;
Packit d3f73b
Packit d3f73b
	if (name && strcmp(name, "-") != 0) {
Packit d3f73b
		if (!freopen(name, "r", stdin)) {
Packit d3f73b
			pr_err("Cannot open file \"%s\" for reading: %s\n",
Packit d3f73b
			       name, strerror(errno));
Packit d3f73b
			return errno;
Packit d3f73b
		}
Packit d3f73b
	}
Packit d3f73b
Packit d3f73b
	cmdlineno = 0;
Packit d3f73b
	while (getcmdline(&line, &len, stdin) != -1) {
Packit d3f73b
		char *largv[512];
Packit d3f73b
		int largc;
Packit d3f73b
Packit d3f73b
		largc = makeargs(line, largv, ARRAY_SIZE(largv));
Packit d3f73b
		if (!largc)
Packit d3f73b
			continue;	/* blank line */
Packit d3f73b
Packit d3f73b
		ret = rd_cmd(rd, largc, largv);
Packit d3f73b
		if (ret) {
Packit d3f73b
			pr_err("Command failed %s:%d\n", name, cmdlineno);
Packit d3f73b
			if (!force)
Packit d3f73b
				break;
Packit d3f73b
		}
Packit d3f73b
	}
Packit d3f73b
Packit d3f73b
	free(line);
Packit d3f73b
Packit d3f73b
	return ret;
Packit d3f73b
}
Packit d3f73b
Packit d3f73b
static int rd_init(struct rd *rd, char *filename)
Packit d3f73b
{
Packit d3f73b
	uint32_t seq;
Packit d3f73b
	int ret;
Packit d3f73b
Packit d3f73b
	rd->filename = filename;
Packit d3f73b
	INIT_LIST_HEAD(&rd->dev_map_list);
Packit d3f73b
	INIT_LIST_HEAD(&rd->filter_list);
Packit d3f73b
Packit d3f73b
	if (rd->json_output) {
Packit d3f73b
		rd->jw = jsonw_new(stdout);
Packit d3f73b
		if (!rd->jw) {
Packit d3f73b
			pr_err("Failed to create JSON writer\n");
Packit d3f73b
			return -ENOMEM;
Packit d3f73b
		}
Packit d3f73b
		jsonw_pretty(rd->jw, rd->pretty_output);
Packit d3f73b
	}
Packit d3f73b
Packit d3f73b
	rd->buff = malloc(MNL_SOCKET_BUFFER_SIZE);
Packit d3f73b
	if (!rd->buff)
Packit d3f73b
		return -ENOMEM;
Packit d3f73b
Packit d3f73b
	rd_prepare_msg(rd, RDMA_NLDEV_CMD_GET,
Packit d3f73b
		       &seq, (NLM_F_REQUEST | NLM_F_ACK | NLM_F_DUMP));
Packit d3f73b
	ret = rd_send_msg(rd);
Packit d3f73b
	if (ret)
Packit d3f73b
		return ret;
Packit d3f73b
Packit d3f73b
	return rd_recv_msg(rd, rd_dev_init_cb, rd, seq);
Packit d3f73b
}
Packit d3f73b
Packit d3f73b
static void rd_cleanup(struct rd *rd)
Packit d3f73b
{
Packit d3f73b
	if (rd->json_output)
Packit d3f73b
		jsonw_destroy(&rd->jw);
Packit d3f73b
	rd_free(rd);
Packit d3f73b
}
Packit d3f73b
Packit d3f73b
int main(int argc, char **argv)
Packit d3f73b
{
Packit d3f73b
	static const struct option long_options[] = {
Packit d3f73b
		{ "version",		no_argument,		NULL, 'V' },
Packit d3f73b
		{ "help",		no_argument,		NULL, 'h' },
Packit d3f73b
		{ "json",		no_argument,		NULL, 'j' },
Packit d3f73b
		{ "pretty",		no_argument,		NULL, 'p' },
Packit d3f73b
		{ "details",		no_argument,		NULL, 'd' },
Packit d3f73b
		{ "force",		no_argument,		NULL, 'f' },
Packit d3f73b
		{ "batch",		required_argument,	NULL, 'b' },
Packit d3f73b
		{ NULL, 0, NULL, 0 }
Packit d3f73b
	};
Packit d3f73b
	bool show_driver_details = false;
Packit d3f73b
	const char *batch_file = NULL;
Packit d3f73b
	bool pretty_output = false;
Packit d3f73b
	bool show_details = false;
Packit d3f73b
	bool json_output = false;
Packit d3f73b
	bool force = false;
Packit d3f73b
	struct rd rd = {};
Packit d3f73b
	char *filename;
Packit d3f73b
	int opt;
Packit d3f73b
	int err;
Packit d3f73b
Packit d3f73b
	filename = basename(argv[0]);
Packit d3f73b
Packit d3f73b
	while ((opt = getopt_long(argc, argv, ":Vhdpjfb:",
Packit d3f73b
				  long_options, NULL)) >= 0) {
Packit d3f73b
		switch (opt) {
Packit d3f73b
		case 'V':
Packit d3f73b
			printf("%s utility, iproute2-ss%s\n",
Packit d3f73b
			       filename, SNAPSHOT);
Packit d3f73b
			return EXIT_SUCCESS;
Packit d3f73b
		case 'p':
Packit d3f73b
			pretty_output = true;
Packit d3f73b
			break;
Packit d3f73b
		case 'd':
Packit d3f73b
			if (show_details)
Packit d3f73b
				show_driver_details = true;
Packit d3f73b
			else
Packit d3f73b
				show_details = true;
Packit d3f73b
			break;
Packit d3f73b
		case 'j':
Packit d3f73b
			json_output = true;
Packit d3f73b
			break;
Packit d3f73b
		case 'f':
Packit d3f73b
			force = true;
Packit d3f73b
			break;
Packit d3f73b
		case 'b':
Packit d3f73b
			batch_file = optarg;
Packit d3f73b
			break;
Packit d3f73b
		case 'h':
Packit d3f73b
			help(filename);
Packit d3f73b
			return EXIT_SUCCESS;
Packit d3f73b
		case ':':
Packit d3f73b
			pr_err("-%c option requires an argument\n", optopt);
Packit d3f73b
			return EXIT_FAILURE;
Packit d3f73b
		default:
Packit d3f73b
			pr_err("Unknown option.\n");
Packit d3f73b
			help(filename);
Packit d3f73b
			return EXIT_FAILURE;
Packit d3f73b
		}
Packit d3f73b
	}
Packit d3f73b
Packit d3f73b
	argc -= optind;
Packit d3f73b
	argv += optind;
Packit d3f73b
Packit d3f73b
	rd.show_details = show_details;
Packit d3f73b
	rd.show_driver_details = show_driver_details;
Packit d3f73b
	rd.json_output = json_output;
Packit d3f73b
	rd.pretty_output = pretty_output;
Packit d3f73b
Packit d3f73b
	err = rd_init(&rd, filename);
Packit d3f73b
	if (err)
Packit d3f73b
		goto out;
Packit d3f73b
Packit d3f73b
	if (batch_file)
Packit d3f73b
		err = rd_batch(&rd, batch_file, force);
Packit d3f73b
	else
Packit d3f73b
		err = rd_cmd(&rd, argc, argv);
Packit d3f73b
out:
Packit d3f73b
	/* Always cleanup */
Packit d3f73b
	rd_cleanup(&rd);
Packit d3f73b
	return err ? EXIT_FAILURE : EXIT_SUCCESS;
Packit d3f73b
}