Blame tipc/bearer.c

Packit Service 3880ab
/*
Packit Service 3880ab
 * bearer.c	TIPC bearer functionality.
Packit Service 3880ab
 *
Packit Service 3880ab
 *		This program is free software; you can redistribute it and/or
Packit Service 3880ab
 *		modify it under the terms of the GNU General Public License
Packit Service 3880ab
 *		as published by the Free Software Foundation; either version
Packit Service 3880ab
 *		2 of the License, or (at your option) any later version.
Packit Service 3880ab
 *
Packit Service 3880ab
 * Authors:	Richard Alpe <richard.alpe@ericsson.com>
Packit Service 3880ab
 */
Packit Service 3880ab
Packit Service 3880ab
#include <stdio.h>
Packit Service 3880ab
#include <stdlib.h>
Packit Service 3880ab
#include <string.h>
Packit Service 3880ab
#include <netdb.h>
Packit Service 3880ab
#include <errno.h>
Packit Service 3880ab
#include <arpa/inet.h>
Packit Service 3880ab
Packit Service 3880ab
#include <linux/tipc_netlink.h>
Packit Service 3880ab
#include <linux/tipc.h>
Packit Service 3880ab
#include <linux/genetlink.h>
Packit Service 3880ab
#include <linux/if.h>
Packit Service 3880ab
Packit Service 3880ab
#include <libmnl/libmnl.h>
Packit Service 3880ab
#include <sys/socket.h>
Packit Service 3880ab
Packit Service 3880ab
#include "utils.h"
Packit Service 3880ab
#include "cmdl.h"
Packit Service 3880ab
#include "msg.h"
Packit Service 3880ab
#include "bearer.h"
Packit Service 3880ab
Packit Service 3880ab
#define UDP_PROP_IP 1
Packit Service 3880ab
#define UDP_PROP_PORT 2
Packit Service 3880ab
Packit Service 3880ab
struct cb_data {
Packit Service 3880ab
	int attr;
Packit Service 3880ab
	int prop;
Packit Service 3880ab
	struct nlmsghdr *nlh;
Packit Service 3880ab
};
Packit Service 3880ab
Packit Service 3880ab
static void _print_bearer_opts(void)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr,
Packit Service 3880ab
		"OPTIONS\n"
Packit Service 3880ab
		" priority		- Bearer link priority\n"
Packit Service 3880ab
		" tolerance		- Bearer link tolerance\n"
Packit Service 3880ab
		" window		- Bearer link window\n"
Packit Service 3880ab
		" mtu			- Bearer link mtu\n");
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
void print_bearer_media(void)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr,
Packit Service 3880ab
		"\nMEDIA\n"
Packit Service 3880ab
		" udp			- User Datagram Protocol\n"
Packit Service 3880ab
		" ib			- Infiniband\n"
Packit Service 3880ab
		" eth			- Ethernet\n");
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_enable_l2_help(struct cmdl *cmdl, char *media)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr,
Packit Service 3880ab
		"Usage: %s bearer enable media %s device DEVICE [OPTIONS]\n"
Packit Service 3880ab
		"\nOPTIONS\n"
Packit Service 3880ab
		" domain DOMAIN		- Discovery domain\n"
Packit Service 3880ab
		" priority PRIORITY	- Bearer priority\n",
Packit Service 3880ab
		cmdl->argv[0], media);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_enable_udp_help(struct cmdl *cmdl, char *media)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr,
Packit Service 3880ab
		"Usage: %s bearer enable [OPTIONS] media %s name NAME [localip IP|device DEVICE] [UDP OPTIONS]\n\n"
Packit Service 3880ab
		"OPTIONS\n"
Packit Service 3880ab
		" domain DOMAIN		- Discovery domain\n"
Packit Service 3880ab
		" priority PRIORITY	- Bearer priority\n\n"
Packit Service 3880ab
		"UDP OPTIONS\n"
Packit Service 3880ab
		" localport PORT	- Local UDP port (default 6118)\n"
Packit Service 3880ab
		" remoteip IP		- Remote IP address\n"
Packit Service 3880ab
		" remoteport PORT	- Remote UDP port (default 6118)\n",
Packit Service 3880ab
		cmdl->argv[0], media);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int get_netid_cb(const struct nlmsghdr *nlh, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	struct genlmsghdr *genl = mnl_nlmsg_get_payload(nlh);
Packit Service 3880ab
	struct nlattr *info[TIPC_NLA_MAX + 1] = {};
Packit Service 3880ab
	struct nlattr *attrs[TIPC_NLA_NET_MAX + 1] = {};
Packit Service 3880ab
	int *netid = (int*)data;
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse(nlh, sizeof(*genl), parse_attrs, info);
Packit Service 3880ab
	if (!info[TIPC_NLA_NET])
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
	mnl_attr_parse_nested(info[TIPC_NLA_NET], parse_attrs, attrs);
Packit Service 3880ab
	if (!attrs[TIPC_NLA_NET_ID])
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
	*netid = mnl_attr_get_u32(attrs[TIPC_NLA_NET_ID]);
Packit Service 3880ab
Packit Service 3880ab
	return MNL_CB_OK;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int generate_multicast(short af, char *buf, int bufsize)
Packit Service 3880ab
{
Packit Service 3880ab
	int netid;
Packit Service 3880ab
	char mnl_msg[MNL_SOCKET_BUFFER_SIZE];
Packit Service 3880ab
	struct nlmsghdr *nlh;
Packit Service 3880ab
Packit Service 3880ab
	if (!(nlh = msg_init(mnl_msg, TIPC_NL_NET_GET))) {
Packit Service 3880ab
		fprintf(stderr, "error, message initialization failed\n");
Packit Service 3880ab
		return -1;
Packit Service 3880ab
	}
Packit Service 3880ab
	if (msg_dumpit(nlh, get_netid_cb, &netid)) {
Packit Service 3880ab
		fprintf(stderr, "error, failed to fetch TIPC network id from kernel\n");
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
	if (af == AF_INET)
Packit Service 3880ab
		snprintf(buf, bufsize, "228.0.%u.%u", (netid>>8) & 0xFF, netid & 0xFF);
Packit Service 3880ab
	else
Packit Service 3880ab
		snprintf(buf, bufsize, "ff02::%u", netid);
Packit Service 3880ab
Packit Service 3880ab
	return 0;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static struct ifreq ifr;
Packit Service 3880ab
static int nl_dump_req_filter(struct nlmsghdr *nlh, int reqlen)
Packit Service 3880ab
{
Packit Service 3880ab
	struct ifaddrmsg *ifa = NLMSG_DATA(nlh);
Packit Service 3880ab
Packit Service 3880ab
	ifa->ifa_index = ifr.ifr_ifindex;
Packit Service 3880ab
Packit Service 3880ab
	return 0;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int nl_dump_addr_filter(struct nlmsghdr *nlh, void *arg)
Packit Service 3880ab
{
Packit Service 3880ab
	struct ifaddrmsg *ifa = NLMSG_DATA(nlh);
Packit Service 3880ab
	char *r_addr = (char *)arg;
Packit Service 3880ab
	int len = nlh->nlmsg_len;
Packit Service 3880ab
	struct rtattr *addr_attr;
Packit Service 3880ab
Packit Service 3880ab
	if (ifr.ifr_ifindex != ifa->ifa_index)
Packit Service 3880ab
		return 0;
Packit Service 3880ab
Packit Service 3880ab
	if (strlen(r_addr) > 0)
Packit Service 3880ab
		return 0;
Packit Service 3880ab
Packit Service 3880ab
	addr_attr = parse_rtattr_one(IFA_ADDRESS, IFA_RTA(ifa),
Packit Service 3880ab
				     len - NLMSG_LENGTH(sizeof(*ifa)));
Packit Service 3880ab
	if (!addr_attr)
Packit Service 3880ab
		return 0;
Packit Service 3880ab
Packit Service 3880ab
	if (ifa->ifa_family == AF_INET) {
Packit Service 3880ab
		struct sockaddr_in ip4addr;
Packit Service 3880ab
		memcpy(&ip4addr.sin_addr, RTA_DATA(addr_attr),
Packit Service 3880ab
		       sizeof(struct in_addr));
Packit Service 3880ab
		inet_ntop(AF_INET, &ip4addr.sin_addr, r_addr,
Packit Service 3880ab
			  INET_ADDRSTRLEN);
Packit Service 3880ab
	} else if (ifa->ifa_family == AF_INET6) {
Packit Service 3880ab
		struct sockaddr_in6 ip6addr;
Packit Service 3880ab
		memcpy(&ip6addr.sin6_addr, RTA_DATA(addr_attr),
Packit Service 3880ab
		       sizeof(struct in6_addr));
Packit Service 3880ab
		inet_ntop(AF_INET6, &ip6addr.sin6_addr, r_addr,
Packit Service 3880ab
			  INET6_ADDRSTRLEN);
Packit Service 3880ab
	}
Packit Service 3880ab
	return 0;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_validate_and_get_addr(const char *name, char *r_addr)
Packit Service 3880ab
{
Packit Service 3880ab
	struct rtnl_handle rth = { .fd = -1 };
Packit Service 3880ab
	int err = -1;
Packit Service 3880ab
Packit Service 3880ab
	memset(&ifr, 0, sizeof(ifr));
Packit Service 3880ab
	if (!name || !r_addr || get_ifname(ifr.ifr_name, name))
Packit Service 3880ab
		return err;
Packit Service 3880ab
Packit Service 3880ab
	ifr.ifr_ifindex = ll_name_to_index(ifr.ifr_name);
Packit Service 3880ab
	if (!ifr.ifr_ifindex)
Packit Service 3880ab
		return err;
Packit Service 3880ab
Packit Service 3880ab
	/* remove from cache */
Packit Service 3880ab
	ll_drop_by_index(ifr.ifr_ifindex);
Packit Service 3880ab
Packit Service 3880ab
	if ((err = rtnl_open(&rth, 0)) < 0)
Packit Service 3880ab
		return err;
Packit Service 3880ab
Packit Service 3880ab
	if ((err = rtnl_addrdump_req(&rth, AF_UNSPEC, nl_dump_req_filter)) > 0)
Packit Service 3880ab
		err = rtnl_dump_filter(&rth, nl_dump_addr_filter, r_addr);
Packit Service 3880ab
Packit Service 3880ab
	rtnl_close(&rth);
Packit Service 3880ab
	return err;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int nl_add_udp_enable_opts(struct nlmsghdr *nlh, struct opt *opts,
Packit Service 3880ab
				  struct cmdl *cmdl)
Packit Service 3880ab
{
Packit Service 3880ab
	int err;
Packit Service 3880ab
	struct opt *opt;
Packit Service 3880ab
	struct nlattr *nest;
Packit Service 3880ab
	char buf[INET6_ADDRSTRLEN];
Packit Service 3880ab
	char *locport = "6118";
Packit Service 3880ab
	char *remport = "6118";
Packit Service 3880ab
	char *locip = NULL;
Packit Service 3880ab
	char *remip = NULL;
Packit Service 3880ab
	struct addrinfo *loc = NULL;
Packit Service 3880ab
	struct addrinfo *rem = NULL;
Packit Service 3880ab
	struct addrinfo hints = {
Packit Service 3880ab
		.ai_family = AF_UNSPEC,
Packit Service 3880ab
		.ai_socktype = SOCK_DGRAM
Packit Service 3880ab
	};
Packit Service 3880ab
	char addr[INET6_ADDRSTRLEN] = {0};
Packit Service 3880ab
Packit Service 3880ab
	opt = get_opt(opts, "device");
Packit Service 3880ab
	if (opt && cmd_bearer_validate_and_get_addr(opt->val, addr) < 0) {
Packit Service 3880ab
		fprintf(stderr, "error, no device name available\n");
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (strlen(addr) > 0) {
Packit Service 3880ab
		locip = addr;
Packit Service 3880ab
	} else {
Packit Service 3880ab
		opt = get_opt(opts, "localip");
Packit Service 3880ab
		if (!opt) {
Packit Service 3880ab
			fprintf(stderr, "error, udp bearer localip/device missing\n");
Packit Service 3880ab
			cmd_bearer_enable_udp_help(cmdl, "udp");
Packit Service 3880ab
			return -EINVAL;
Packit Service 3880ab
		}
Packit Service 3880ab
		locip = opt->val;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if ((opt = get_opt(opts, "remoteip")))
Packit Service 3880ab
		remip = opt->val;
Packit Service 3880ab
Packit Service 3880ab
	if ((opt = get_opt(opts, "localport")))
Packit Service 3880ab
		locport = opt->val;
Packit Service 3880ab
Packit Service 3880ab
	if ((opt = get_opt(opts, "remoteport")))
Packit Service 3880ab
		remport = opt->val;
Packit Service 3880ab
Packit Service 3880ab
	if ((err = getaddrinfo(locip, locport, &hints, &loc))) {
Packit Service 3880ab
		fprintf(stderr, "UDP local address error: %s\n",
Packit Service 3880ab
			gai_strerror(err));
Packit Service 3880ab
		return err;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (!remip) {
Packit Service 3880ab
		if (generate_multicast(loc->ai_family, buf, sizeof(buf))) {
Packit Service 3880ab
			fprintf(stderr, "Failed to generate multicast address\n");
Packit Service 3880ab
			freeaddrinfo(loc);
Packit Service 3880ab
			return -EINVAL;
Packit Service 3880ab
		}
Packit Service 3880ab
		remip = buf;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if ((err = getaddrinfo(remip, remport, &hints, &rem))) {
Packit Service 3880ab
		fprintf(stderr, "UDP remote address error: %s\n",
Packit Service 3880ab
			gai_strerror(err));
Packit Service 3880ab
		freeaddrinfo(loc);
Packit Service 3880ab
		return err;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (rem->ai_family != loc->ai_family) {
Packit Service 3880ab
		fprintf(stderr, "UDP local and remote AF mismatch\n");
Packit Service 3880ab
		freeaddrinfo(rem);
Packit Service 3880ab
		freeaddrinfo(loc);
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	nest = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER_UDP_OPTS);
Packit Service 3880ab
	mnl_attr_put(nlh, TIPC_NLA_UDP_LOCAL, loc->ai_addrlen, loc->ai_addr);
Packit Service 3880ab
	mnl_attr_put(nlh, TIPC_NLA_UDP_REMOTE, rem->ai_addrlen, rem->ai_addr);
Packit Service 3880ab
	mnl_attr_nest_end(nlh, nest);
Packit Service 3880ab
Packit Service 3880ab
	freeaddrinfo(rem);
Packit Service 3880ab
	freeaddrinfo(loc);
Packit Service 3880ab
Packit Service 3880ab
	return 0;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static char *cmd_get_media_type(const struct cmd *cmd, struct cmdl *cmdl,
Packit Service 3880ab
				struct opt *opts)
Packit Service 3880ab
{
Packit Service 3880ab
	struct opt *opt = get_opt(opts, "media");
Packit Service 3880ab
Packit Service 3880ab
	if (!opt) {
Packit Service 3880ab
		if (help_flag)
Packit Service 3880ab
			(cmd->help)(cmdl);
Packit Service 3880ab
		else
Packit Service 3880ab
			fprintf(stderr, "error, missing bearer media\n");
Packit Service 3880ab
		return NULL;
Packit Service 3880ab
	}
Packit Service 3880ab
	return opt->val;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int nl_add_bearer_name(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
			      struct cmdl *cmdl, struct opt *opts,
Packit Service 3880ab
			      const struct tipc_sup_media *sup_media)
Packit Service 3880ab
{
Packit Service 3880ab
	char bname[TIPC_MAX_BEARER_NAME];
Packit Service 3880ab
	int err;
Packit Service 3880ab
Packit Service 3880ab
	if ((err = cmd_get_unique_bearer_name(cmd, cmdl, opts, bname, sup_media)))
Packit Service 3880ab
		return err;
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_put_strz(nlh, TIPC_NLA_BEARER_NAME, bname);
Packit Service 3880ab
	return 0;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
int cmd_get_unique_bearer_name(const struct cmd *cmd, struct cmdl *cmdl,
Packit Service 3880ab
			       struct opt *opts, char *bname,
Packit Service 3880ab
			       const struct tipc_sup_media *sup_media)
Packit Service 3880ab
{
Packit Service 3880ab
	char *media;
Packit Service 3880ab
	char *identifier;
Packit Service 3880ab
	struct opt *opt;
Packit Service 3880ab
	const struct tipc_sup_media *entry;
Packit Service 3880ab
Packit Service 3880ab
	if (!(media = cmd_get_media_type(cmd, cmdl, opts)))
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
Packit Service 3880ab
	for (entry = sup_media; entry->media; entry++) {
Packit Service 3880ab
		if (strcmp(entry->media, media))
Packit Service 3880ab
			continue;
Packit Service 3880ab
Packit Service 3880ab
		if (!(opt = get_opt(opts, entry->identifier))) {
Packit Service 3880ab
			if (help_flag)
Packit Service 3880ab
				(entry->help)(cmdl, media);
Packit Service 3880ab
			else
Packit Service 3880ab
				fprintf(stderr, "error, missing bearer %s\n",
Packit Service 3880ab
					entry->identifier);
Packit Service 3880ab
			return -EINVAL;
Packit Service 3880ab
		}
Packit Service 3880ab
Packit Service 3880ab
		identifier = opt->val;
Packit Service 3880ab
		snprintf(bname, TIPC_MAX_BEARER_NAME, "%s:%s", media, identifier);
Packit Service 3880ab
Packit Service 3880ab
		return 0;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	fprintf(stderr, "error, invalid media type %s\n", media);
Packit Service 3880ab
Packit Service 3880ab
	return -EINVAL;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_add_udp_help(struct cmdl *cmdl, char *media)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr, "Usage: %s bearer add media %s name NAME remoteip REMOTEIP\n\n",
Packit Service 3880ab
		cmdl->argv[0], media);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_add_help(struct cmdl *cmdl)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr, "Usage: %s bearer add media udp name NAME remoteip REMOTEIP\n",
Packit Service 3880ab
		cmdl->argv[0]);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int udp_bearer_add(struct nlmsghdr *nlh, struct opt *opts,
Packit Service 3880ab
			  struct cmdl *cmdl)
Packit Service 3880ab
{
Packit Service 3880ab
	int err;
Packit Service 3880ab
	struct opt *opt;
Packit Service 3880ab
	struct nlattr *opts_nest;
Packit Service 3880ab
	char *remport = "6118";
Packit Service 3880ab
Packit Service 3880ab
	opts_nest = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER_UDP_OPTS);
Packit Service 3880ab
Packit Service 3880ab
	if ((opt = get_opt(opts, "remoteport")))
Packit Service 3880ab
		remport = opt->val;
Packit Service 3880ab
Packit Service 3880ab
	if ((opt = get_opt(opts, "remoteip"))) {
Packit Service 3880ab
		char *ip = opt->val;
Packit Service 3880ab
		struct addrinfo *addr = NULL;
Packit Service 3880ab
		struct addrinfo hints = {
Packit Service 3880ab
			.ai_family = AF_UNSPEC,
Packit Service 3880ab
			.ai_socktype = SOCK_DGRAM
Packit Service 3880ab
		};
Packit Service 3880ab
Packit Service 3880ab
		if ((err = getaddrinfo(ip, remport, &hints, &addr))) {
Packit Service 3880ab
			fprintf(stderr, "UDP address error: %s\n",
Packit Service 3880ab
				gai_strerror(err));
Packit Service 3880ab
			freeaddrinfo(addr);
Packit Service 3880ab
			return err;
Packit Service 3880ab
		}
Packit Service 3880ab
Packit Service 3880ab
		mnl_attr_put(nlh, TIPC_NLA_UDP_REMOTE, addr->ai_addrlen,
Packit Service 3880ab
			     addr->ai_addr);
Packit Service 3880ab
		freeaddrinfo(addr);
Packit Service 3880ab
	} else {
Packit Service 3880ab
		fprintf(stderr, "error, missing remoteip\n");
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
	mnl_attr_nest_end(nlh, opts_nest);
Packit Service 3880ab
Packit Service 3880ab
	return 0;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_add_media(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
				struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	int err;
Packit Service 3880ab
	char *media;
Packit Service 3880ab
	char buf[MNL_SOCKET_BUFFER_SIZE];
Packit Service 3880ab
	struct opt *opt;
Packit Service 3880ab
	struct nlattr *attrs;
Packit Service 3880ab
	struct opt opts[] = {
Packit Service 3880ab
		{ "remoteip",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "remoteport",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "name",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "media",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
	const struct tipc_sup_media sup_media[] = {
Packit Service 3880ab
		{ "udp",	"name",		cmd_bearer_add_udp_help},
Packit Service 3880ab
		{ NULL, },
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	/* Rewind optind to include media in the option list */
Packit Service 3880ab
	cmdl->optind--;
Packit Service 3880ab
	if (parse_opts(opts, cmdl) < 0)
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
Packit Service 3880ab
	if (!(opt = get_opt(opts, "media"))) {
Packit Service 3880ab
		fprintf(stderr, "error, missing media value\n");
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
	media = opt->val;
Packit Service 3880ab
Packit Service 3880ab
	if (strcmp(media, "udp") != 0) {
Packit Service 3880ab
		fprintf(stderr, "error, no \"%s\" media specific options available\n",
Packit Service 3880ab
			media);
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
	if (!(opt = get_opt(opts, "name"))) {
Packit Service 3880ab
		fprintf(stderr, "error, missing media name\n");
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (!(nlh = msg_init(buf, TIPC_NL_BEARER_ADD))) {
Packit Service 3880ab
		fprintf(stderr, "error, message initialisation failed\n");
Packit Service 3880ab
		return -1;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	attrs = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER);
Packit Service 3880ab
	err = nl_add_bearer_name(nlh, cmd, cmdl, opts, sup_media);
Packit Service 3880ab
	if (err)
Packit Service 3880ab
		return err;
Packit Service 3880ab
Packit Service 3880ab
	err = udp_bearer_add(nlh, opts, cmdl);
Packit Service 3880ab
	if (err)
Packit Service 3880ab
		return err;
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_nest_end(nlh, attrs);
Packit Service 3880ab
Packit Service 3880ab
	return msg_doit(nlh, NULL, NULL);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_add(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
			  struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	const struct cmd cmds[] = {
Packit Service 3880ab
		{ "media",	cmd_bearer_add_media,	cmd_bearer_add_help },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	return run_cmd(nlh, cmd, cmds, cmdl, NULL);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_enable_help(struct cmdl *cmdl)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr,
Packit Service 3880ab
		"Usage: %s bearer enable [OPTIONS] media MEDIA ARGS...\n\n"
Packit Service 3880ab
		"OPTIONS\n"
Packit Service 3880ab
		" domain DOMAIN         - Discovery domain\n"
Packit Service 3880ab
		" priority PRIORITY     - Bearer priority\n",
Packit Service 3880ab
		cmdl->argv[0]);
Packit Service 3880ab
	print_bearer_media();
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_enable(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
			     struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	int err;
Packit Service 3880ab
	struct opt *opt;
Packit Service 3880ab
	struct nlattr *nest;
Packit Service 3880ab
	char buf[MNL_SOCKET_BUFFER_SIZE];
Packit Service 3880ab
	struct opt opts[] = {
Packit Service 3880ab
		{ "device",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "domain",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "localip",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "localport",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "media",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "name",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "priority",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "remoteip",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "remoteport",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
	struct tipc_sup_media sup_media[] = {
Packit Service 3880ab
		{ "udp",        "name",         cmd_bearer_enable_udp_help},
Packit Service 3880ab
		{ "eth",        "device",       cmd_bearer_enable_l2_help },
Packit Service 3880ab
		{ "ib",         "device",       cmd_bearer_enable_l2_help },
Packit Service 3880ab
		{ NULL, },
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	if (parse_opts(opts, cmdl) < 0) {
Packit Service 3880ab
		if (help_flag)
Packit Service 3880ab
			(cmd->help)(cmdl);
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (!(nlh = msg_init(buf, TIPC_NL_BEARER_ENABLE))) {
Packit Service 3880ab
		fprintf(stderr, "error: message initialisation failed\n");
Packit Service 3880ab
		return -1;
Packit Service 3880ab
	}
Packit Service 3880ab
	nest = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER);
Packit Service 3880ab
Packit Service 3880ab
	if ((opt = get_opt(opts, "domain")))
Packit Service 3880ab
		mnl_attr_put_u32(nlh, TIPC_NLA_BEARER_DOMAIN, atoi(opt->val));
Packit Service 3880ab
Packit Service 3880ab
	if ((opt = get_opt(opts, "priority"))) {
Packit Service 3880ab
		struct nlattr *props;
Packit Service 3880ab
Packit Service 3880ab
		props = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER_PROP);
Packit Service 3880ab
		mnl_attr_put_u32(nlh, TIPC_NLA_PROP_PRIO, atoi(opt->val));
Packit Service 3880ab
		mnl_attr_nest_end(nlh, props);
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	err = nl_add_bearer_name(nlh, cmd, cmdl, opts, sup_media);
Packit Service 3880ab
	if (err)
Packit Service 3880ab
		return err;
Packit Service 3880ab
Packit Service 3880ab
	opt = get_opt(opts, "media");
Packit Service 3880ab
	if (opt && strcmp(opt->val, "udp") == 0) {
Packit Service 3880ab
		err = nl_add_udp_enable_opts(nlh, opts, cmdl);
Packit Service 3880ab
		if (err)
Packit Service 3880ab
			return err;
Packit Service 3880ab
	}
Packit Service 3880ab
	mnl_attr_nest_end(nlh, nest);
Packit Service 3880ab
Packit Service 3880ab
	return msg_doit(nlh, NULL, NULL);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_disable_l2_help(struct cmdl *cmdl, char *media)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr, "Usage: %s bearer disable media %s device DEVICE\n",
Packit Service 3880ab
		cmdl->argv[0], media);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_disable_udp_help(struct cmdl *cmdl, char *media)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr, "Usage: %s bearer disable media %s name NAME\n",
Packit Service 3880ab
		cmdl->argv[0], media);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_disable_help(struct cmdl *cmdl)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr, "Usage: %s bearer disable media MEDIA ARGS...\n",
Packit Service 3880ab
		cmdl->argv[0]);
Packit Service 3880ab
	print_bearer_media();
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_disable(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
			      struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	int err;
Packit Service 3880ab
	char buf[MNL_SOCKET_BUFFER_SIZE];
Packit Service 3880ab
	struct nlattr *nest;
Packit Service 3880ab
	struct opt opts[] = {
Packit Service 3880ab
		{ "device",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "name",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "media",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
	struct tipc_sup_media sup_media[] = {
Packit Service 3880ab
		{ "udp",        "name",         cmd_bearer_disable_udp_help},
Packit Service 3880ab
		{ "eth",        "device",       cmd_bearer_disable_l2_help },
Packit Service 3880ab
		{ "ib",         "device",       cmd_bearer_disable_l2_help },
Packit Service 3880ab
		{ NULL, },
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	if (parse_opts(opts, cmdl) < 0) {
Packit Service 3880ab
		if (help_flag)
Packit Service 3880ab
			(cmd->help)(cmdl);
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (!(nlh = msg_init(buf, TIPC_NL_BEARER_DISABLE))) {
Packit Service 3880ab
		fprintf(stderr, "error, message initialisation failed\n");
Packit Service 3880ab
		return -1;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	nest = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER);
Packit Service 3880ab
	err = nl_add_bearer_name(nlh, cmd, cmdl, opts, sup_media);
Packit Service 3880ab
	if (err)
Packit Service 3880ab
		return err;
Packit Service 3880ab
	mnl_attr_nest_end(nlh, nest);
Packit Service 3880ab
Packit Service 3880ab
	return msg_doit(nlh, NULL, NULL);
Packit Service 3880ab
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_set_help(struct cmdl *cmdl)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr, "Usage: %s bearer set OPTION media MEDIA ARGS...\n",
Packit Service 3880ab
		cmdl->argv[0]);
Packit Service 3880ab
	_print_bearer_opts();
Packit Service 3880ab
	print_bearer_media();
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_set_udp_help(struct cmdl *cmdl, char *media)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr, "Usage: %s bearer set OPTION media %s name NAME\n\n",
Packit Service 3880ab
		cmdl->argv[0], media);
Packit Service 3880ab
	_print_bearer_opts();
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_set_l2_help(struct cmdl *cmdl, char *media)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr,
Packit Service 3880ab
		"Usage: %s bearer set [OPTION]... media %s device DEVICE\n",
Packit Service 3880ab
		cmdl->argv[0], media);
Packit Service 3880ab
	_print_bearer_opts();
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_set_prop(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
			       struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	int err;
Packit Service 3880ab
	int val;
Packit Service 3880ab
	int prop;
Packit Service 3880ab
	char buf[MNL_SOCKET_BUFFER_SIZE];
Packit Service 3880ab
	struct nlattr *props;
Packit Service 3880ab
	struct nlattr *attrs;
Packit Service 3880ab
	struct opt opts[] = {
Packit Service 3880ab
		{ "device",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "media",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "name",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
	struct tipc_sup_media sup_media[] = {
Packit Service 3880ab
		{ "udp",        "name",         cmd_bearer_set_udp_help},
Packit Service 3880ab
		{ "eth",        "device",       cmd_bearer_set_l2_help },
Packit Service 3880ab
		{ "ib",         "device",       cmd_bearer_set_l2_help },
Packit Service 3880ab
		{ NULL, },
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	if (strcmp(cmd->cmd, "priority") == 0)
Packit Service 3880ab
		prop = TIPC_NLA_PROP_PRIO;
Packit Service 3880ab
	else if ((strcmp(cmd->cmd, "tolerance") == 0))
Packit Service 3880ab
		prop = TIPC_NLA_PROP_TOL;
Packit Service 3880ab
	else if ((strcmp(cmd->cmd, "window") == 0))
Packit Service 3880ab
		prop = TIPC_NLA_PROP_WIN;
Packit Service 3880ab
	else if ((strcmp(cmd->cmd, "mtu") == 0))
Packit Service 3880ab
		prop = TIPC_NLA_PROP_MTU;
Packit Service 3880ab
	else
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
Packit Service 3880ab
	if (cmdl->optind >= cmdl->argc) {
Packit Service 3880ab
		fprintf(stderr, "error, missing value\n");
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
	val = atoi(shift_cmdl(cmdl));
Packit Service 3880ab
Packit Service 3880ab
	if (parse_opts(opts, cmdl) < 0)
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
Packit Service 3880ab
	if (prop == TIPC_NLA_PROP_MTU) {
Packit Service 3880ab
		char *media = cmd_get_media_type(cmd, cmdl, opts);
Packit Service 3880ab
Packit Service 3880ab
		if (!media)
Packit Service 3880ab
			return -EINVAL;
Packit Service 3880ab
		else if (strcmp(media, "udp")) {
Packit Service 3880ab
			fprintf(stderr, "error, not supported for media\n");
Packit Service 3880ab
			return -EINVAL;
Packit Service 3880ab
		}
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (!(nlh = msg_init(buf, TIPC_NL_BEARER_SET))) {
Packit Service 3880ab
		fprintf(stderr, "error, message initialisation failed\n");
Packit Service 3880ab
		return -1;
Packit Service 3880ab
	}
Packit Service 3880ab
	attrs = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER);
Packit Service 3880ab
Packit Service 3880ab
	props = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER_PROP);
Packit Service 3880ab
	mnl_attr_put_u32(nlh, prop, val);
Packit Service 3880ab
	mnl_attr_nest_end(nlh, props);
Packit Service 3880ab
Packit Service 3880ab
	err = nl_add_bearer_name(nlh, cmd, cmdl, opts, sup_media);
Packit Service 3880ab
	if (err)
Packit Service 3880ab
		return err;
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_nest_end(nlh, attrs);
Packit Service 3880ab
Packit Service 3880ab
	return msg_doit(nlh, NULL, NULL);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_set(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
			  struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	const struct cmd cmds[] = {
Packit Service 3880ab
		{ "priority",	cmd_bearer_set_prop,	cmd_bearer_set_help },
Packit Service 3880ab
		{ "tolerance",	cmd_bearer_set_prop,	cmd_bearer_set_help },
Packit Service 3880ab
		{ "window",	cmd_bearer_set_prop,	cmd_bearer_set_help },
Packit Service 3880ab
		{ "mtu",	cmd_bearer_set_prop,	cmd_bearer_set_help },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	return run_cmd(nlh, cmd, cmds, cmdl, NULL);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_get_help(struct cmdl *cmdl)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr, "Usage: %s bearer get [OPTION] media MEDIA ARGS...\n",
Packit Service 3880ab
		cmdl->argv[0]);
Packit Service 3880ab
	_print_bearer_opts();
Packit Service 3880ab
	print_bearer_media();
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_get_udp_help(struct cmdl *cmdl, char *media)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr, "Usage: %s bearer get [OPTION] media %s name NAME [UDP OPTIONS]\n\n",
Packit Service 3880ab
		cmdl->argv[0], media);
Packit Service 3880ab
	fprintf(stderr,
Packit Service 3880ab
		"UDP OPTIONS\n"
Packit Service 3880ab
		" remoteip              - Remote ip address\n"
Packit Service 3880ab
		" remoteport            - Remote port\n"
Packit Service 3880ab
		" localip               - Local ip address\n"
Packit Service 3880ab
		" localport             - Local port\n\n");
Packit Service 3880ab
	_print_bearer_opts();
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static void cmd_bearer_get_l2_help(struct cmdl *cmdl, char *media)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr,
Packit Service 3880ab
		"Usage: %s bearer get OPTION media %s device DEVICE\n",
Packit Service 3880ab
		cmdl->argv[0], media);
Packit Service 3880ab
	_print_bearer_opts();
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
Packit Service 3880ab
static int bearer_dump_udp_cb(const struct nlmsghdr *nlh, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	struct sockaddr_storage *addr;
Packit Service 3880ab
	struct genlmsghdr *genl = mnl_nlmsg_get_payload(nlh);
Packit Service 3880ab
	struct nlattr *info[TIPC_NLA_UDP_MAX + 1] = {};
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse(nlh, sizeof(*genl), parse_attrs, info);
Packit Service 3880ab
Packit Service 3880ab
	if (!info[TIPC_NLA_UDP_REMOTE])
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
Packit Service 3880ab
	addr = mnl_attr_get_payload(info[TIPC_NLA_UDP_REMOTE]);
Packit Service 3880ab
Packit Service 3880ab
	if (addr->ss_family == AF_INET) {
Packit Service 3880ab
		struct sockaddr_in *ipv4 = (struct sockaddr_in *) addr;
Packit Service 3880ab
Packit Service 3880ab
		printf("%s\n", inet_ntoa(ipv4->sin_addr));
Packit Service 3880ab
	} else if (addr->ss_family == AF_INET6) {
Packit Service 3880ab
		char straddr[INET6_ADDRSTRLEN];
Packit Service 3880ab
		struct sockaddr_in6 *ipv6 = (struct sockaddr_in6 *) addr;
Packit Service 3880ab
Packit Service 3880ab
		if (!inet_ntop(AF_INET6, &ipv6->sin6_addr, straddr,
Packit Service 3880ab
			       sizeof(straddr))) {
Packit Service 3880ab
			fprintf(stderr, "error, parsing IPv6 addr\n");
Packit Service 3880ab
			return MNL_CB_ERROR;
Packit Service 3880ab
		}
Packit Service 3880ab
		printf("%s\n", straddr);
Packit Service 3880ab
Packit Service 3880ab
	} else {
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	return MNL_CB_OK;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int bearer_get_udp_cb(const struct nlmsghdr *nlh, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	struct cb_data *cb_data = (struct cb_data *) data;
Packit Service 3880ab
	struct sockaddr_storage *addr;
Packit Service 3880ab
	struct genlmsghdr *genl = mnl_nlmsg_get_payload(nlh);
Packit Service 3880ab
	struct nlattr *info[TIPC_NLA_MAX + 1] = {};
Packit Service 3880ab
	struct nlattr *attrs[TIPC_NLA_BEARER_MAX + 1] = {};
Packit Service 3880ab
	struct nlattr *opts[TIPC_NLA_UDP_MAX + 1] = {};
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse(nlh, sizeof(*genl), parse_attrs, info);
Packit Service 3880ab
	if (!info[TIPC_NLA_BEARER])
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse_nested(info[TIPC_NLA_BEARER], parse_attrs, attrs);
Packit Service 3880ab
	if (!attrs[TIPC_NLA_BEARER_UDP_OPTS])
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse_nested(attrs[TIPC_NLA_BEARER_UDP_OPTS], parse_attrs, opts);
Packit Service 3880ab
	if (!opts[TIPC_NLA_UDP_LOCAL])
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
Packit Service 3880ab
	if ((cb_data->attr == TIPC_NLA_UDP_REMOTE) &&
Packit Service 3880ab
	    (cb_data->prop == UDP_PROP_IP) &&
Packit Service 3880ab
	    opts[TIPC_NLA_UDP_MULTI_REMOTEIP]) {
Packit Service 3880ab
		struct genlmsghdr *genl = mnl_nlmsg_get_payload(cb_data->nlh);
Packit Service 3880ab
Packit Service 3880ab
		genl->cmd = TIPC_NL_UDP_GET_REMOTEIP;
Packit Service 3880ab
		return msg_dumpit(cb_data->nlh, bearer_dump_udp_cb, NULL);
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	addr = mnl_attr_get_payload(opts[cb_data->attr]);
Packit Service 3880ab
Packit Service 3880ab
	if (addr->ss_family == AF_INET) {
Packit Service 3880ab
		struct sockaddr_in *ipv4 = (struct sockaddr_in *) addr;
Packit Service 3880ab
Packit Service 3880ab
		switch (cb_data->prop) {
Packit Service 3880ab
		case UDP_PROP_IP:
Packit Service 3880ab
			printf("%s\n", inet_ntoa(ipv4->sin_addr));
Packit Service 3880ab
			break;
Packit Service 3880ab
		case UDP_PROP_PORT:
Packit Service 3880ab
			printf("%u\n", ntohs(ipv4->sin_port));
Packit Service 3880ab
			break;
Packit Service 3880ab
		default:
Packit Service 3880ab
			return MNL_CB_ERROR;
Packit Service 3880ab
		}
Packit Service 3880ab
Packit Service 3880ab
	} else if (addr->ss_family == AF_INET6) {
Packit Service 3880ab
		char straddr[INET6_ADDRSTRLEN];
Packit Service 3880ab
		struct sockaddr_in6 *ipv6 = (struct sockaddr_in6 *) addr;
Packit Service 3880ab
Packit Service 3880ab
		switch (cb_data->prop) {
Packit Service 3880ab
		case UDP_PROP_IP:
Packit Service 3880ab
			if (!inet_ntop(AF_INET6, &ipv6->sin6_addr, straddr,
Packit Service 3880ab
				       sizeof(straddr))) {
Packit Service 3880ab
				fprintf(stderr, "error, parsing IPv6 addr\n");
Packit Service 3880ab
				return MNL_CB_ERROR;
Packit Service 3880ab
			}
Packit Service 3880ab
			printf("%s\n", straddr);
Packit Service 3880ab
			break;
Packit Service 3880ab
		case UDP_PROP_PORT:
Packit Service 3880ab
			printf("%u\n", ntohs(ipv6->sin6_port));
Packit Service 3880ab
			break;
Packit Service 3880ab
		default:
Packit Service 3880ab
			return MNL_CB_ERROR;
Packit Service 3880ab
		}
Packit Service 3880ab
Packit Service 3880ab
	} else {
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	return MNL_CB_OK;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int bearer_get_cb(const struct nlmsghdr *nlh, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	int *prop = data;
Packit Service 3880ab
	struct genlmsghdr *genl = mnl_nlmsg_get_payload(nlh);
Packit Service 3880ab
	struct nlattr *info[TIPC_NLA_MAX + 1] = {};
Packit Service 3880ab
	struct nlattr *attrs[TIPC_NLA_BEARER_MAX + 1] = {};
Packit Service 3880ab
	struct nlattr *props[TIPC_NLA_PROP_MAX + 1] = {};
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse(nlh, sizeof(*genl), parse_attrs, info);
Packit Service 3880ab
	if (!info[TIPC_NLA_BEARER])
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse_nested(info[TIPC_NLA_BEARER], parse_attrs, attrs);
Packit Service 3880ab
	if (!attrs[TIPC_NLA_BEARER_PROP])
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse_nested(attrs[TIPC_NLA_BEARER_PROP], parse_attrs, props);
Packit Service 3880ab
	if (!props[*prop])
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
Packit Service 3880ab
	printf("%u\n", mnl_attr_get_u32(props[*prop]));
Packit Service 3880ab
Packit Service 3880ab
	return MNL_CB_OK;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_get_media(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
				struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	int err;
Packit Service 3880ab
	char *media;
Packit Service 3880ab
	char buf[MNL_SOCKET_BUFFER_SIZE];
Packit Service 3880ab
	struct opt *opt;
Packit Service 3880ab
	struct cb_data cb_data = {0};
Packit Service 3880ab
	struct nlattr *attrs;
Packit Service 3880ab
	struct opt opts[] = {
Packit Service 3880ab
		{ "localip",		OPT_KEY,	NULL },
Packit Service 3880ab
		{ "localport",		OPT_KEY,	NULL },
Packit Service 3880ab
		{ "remoteip",		OPT_KEY,	NULL },
Packit Service 3880ab
		{ "remoteport",		OPT_KEY,	NULL },
Packit Service 3880ab
		{ "name",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "media",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
	struct tipc_sup_media sup_media[] = {
Packit Service 3880ab
		{ "udp",        "name",         cmd_bearer_get_udp_help},
Packit Service 3880ab
		{ NULL, },
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	/* Rewind optind to include media in the option list */
Packit Service 3880ab
	cmdl->optind--;
Packit Service 3880ab
	if (parse_opts(opts, cmdl) < 0)
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
Packit Service 3880ab
	if (!(opt = get_opt(opts, "media"))) {
Packit Service 3880ab
		fprintf(stderr, "error, missing media value\n");
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
	media = opt->val;
Packit Service 3880ab
Packit Service 3880ab
	if (help_flag) {
Packit Service 3880ab
		cmd_bearer_get_udp_help(cmdl, media);
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
	if (strcmp(media, "udp") != 0) {
Packit Service 3880ab
		fprintf(stderr, "error, no \"%s\" media specific options\n", media);
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
	if (!(opt = get_opt(opts, "name"))) {
Packit Service 3880ab
		fprintf(stderr, "error, missing media name\n");
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (!(nlh = msg_init(buf, TIPC_NL_BEARER_GET))) {
Packit Service 3880ab
		fprintf(stderr, "error, message initialisation failed\n");
Packit Service 3880ab
		return -1;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	attrs = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER);
Packit Service 3880ab
	err = nl_add_bearer_name(nlh, cmd, cmdl, opts, sup_media);
Packit Service 3880ab
	if (err)
Packit Service 3880ab
		return err;
Packit Service 3880ab
	mnl_attr_nest_end(nlh, attrs);
Packit Service 3880ab
	cb_data.nlh = nlh;
Packit Service 3880ab
Packit Service 3880ab
	if (has_opt(opts, "localip")) {
Packit Service 3880ab
		cb_data.attr = TIPC_NLA_UDP_LOCAL;
Packit Service 3880ab
		cb_data.prop = UDP_PROP_IP;
Packit Service 3880ab
		return msg_doit(nlh, bearer_get_udp_cb, &cb_data);
Packit Service 3880ab
	} else if (has_opt(opts, "localport")) {
Packit Service 3880ab
		cb_data.attr = TIPC_NLA_UDP_LOCAL;
Packit Service 3880ab
		cb_data.prop = UDP_PROP_PORT;
Packit Service 3880ab
		return msg_doit(nlh, bearer_get_udp_cb, &cb_data);
Packit Service 3880ab
	} else if (has_opt(opts, "remoteip")) {
Packit Service 3880ab
		cb_data.attr = TIPC_NLA_UDP_REMOTE;
Packit Service 3880ab
		cb_data.prop = UDP_PROP_IP;
Packit Service 3880ab
		return msg_doit(nlh, bearer_get_udp_cb, &cb_data);
Packit Service 3880ab
	} else if (has_opt(opts, "remoteport")) {
Packit Service 3880ab
		cb_data.attr = TIPC_NLA_UDP_REMOTE;
Packit Service 3880ab
		cb_data.prop = UDP_PROP_PORT;
Packit Service 3880ab
		return msg_doit(nlh, bearer_get_udp_cb, &cb_data);
Packit Service 3880ab
	}
Packit Service 3880ab
	fprintf(stderr, "error, missing UDP option\n");
Packit Service 3880ab
	return -EINVAL;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_get_prop(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
			       struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	int err;
Packit Service 3880ab
	int prop;
Packit Service 3880ab
	char buf[MNL_SOCKET_BUFFER_SIZE];
Packit Service 3880ab
	struct nlattr *attrs;
Packit Service 3880ab
	struct opt opts[] = {
Packit Service 3880ab
		{ "device",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "media",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ "name",		OPT_KEYVAL,	NULL },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
	struct tipc_sup_media sup_media[] = {
Packit Service 3880ab
		{ "udp",        "name",         cmd_bearer_get_udp_help},
Packit Service 3880ab
		{ "eth",        "device",       cmd_bearer_get_l2_help },
Packit Service 3880ab
		{ "ib",         "device",       cmd_bearer_get_l2_help },
Packit Service 3880ab
		{ NULL, },
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	if (help_flag) {
Packit Service 3880ab
		(cmd->help)(cmdl);
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (strcmp(cmd->cmd, "priority") == 0)
Packit Service 3880ab
		prop = TIPC_NLA_PROP_PRIO;
Packit Service 3880ab
	else if ((strcmp(cmd->cmd, "tolerance") == 0))
Packit Service 3880ab
		prop = TIPC_NLA_PROP_TOL;
Packit Service 3880ab
	else if ((strcmp(cmd->cmd, "window") == 0))
Packit Service 3880ab
		prop = TIPC_NLA_PROP_WIN;
Packit Service 3880ab
	else if ((strcmp(cmd->cmd, "mtu") == 0))
Packit Service 3880ab
		prop = TIPC_NLA_PROP_MTU;
Packit Service 3880ab
	else
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
Packit Service 3880ab
	if (parse_opts(opts, cmdl) < 0)
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
Packit Service 3880ab
	if (prop == TIPC_NLA_PROP_MTU) {
Packit Service 3880ab
		char *media = cmd_get_media_type(cmd, cmdl, opts);
Packit Service 3880ab
Packit Service 3880ab
		if (!media)
Packit Service 3880ab
			return -EINVAL;
Packit Service 3880ab
		else if (strcmp(media, "udp")) {
Packit Service 3880ab
			fprintf(stderr, "error, not supported for media\n");
Packit Service 3880ab
			return -EINVAL;
Packit Service 3880ab
		}
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (!(nlh = msg_init(buf, TIPC_NL_BEARER_GET))) {
Packit Service 3880ab
		fprintf(stderr, "error, message initialisation failed\n");
Packit Service 3880ab
		return -1;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	attrs = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER);
Packit Service 3880ab
	err = nl_add_bearer_name(nlh, cmd, cmdl, opts, sup_media);
Packit Service 3880ab
	if (err)
Packit Service 3880ab
		return err;
Packit Service 3880ab
	mnl_attr_nest_end(nlh, attrs);
Packit Service 3880ab
Packit Service 3880ab
	return msg_doit(nlh, bearer_get_cb, &prop);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_get(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
			  struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	const struct cmd cmds[] = {
Packit Service 3880ab
		{ "priority",	cmd_bearer_get_prop,	cmd_bearer_get_help },
Packit Service 3880ab
		{ "tolerance",	cmd_bearer_get_prop,	cmd_bearer_get_help },
Packit Service 3880ab
		{ "window",	cmd_bearer_get_prop,	cmd_bearer_get_help },
Packit Service 3880ab
		{ "mtu",	cmd_bearer_get_prop,	cmd_bearer_get_help },
Packit Service 3880ab
		{ "media",	cmd_bearer_get_media,	cmd_bearer_get_help },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	return run_cmd(nlh, cmd, cmds, cmdl, NULL);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int bearer_list_cb(const struct nlmsghdr *nlh, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	struct genlmsghdr *genl = mnl_nlmsg_get_payload(nlh);
Packit Service 3880ab
	struct nlattr *info[TIPC_NLA_MAX + 1] = {};
Packit Service 3880ab
	struct nlattr *attrs[TIPC_NLA_BEARER_MAX + 1] = {};
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse(nlh, sizeof(*genl), parse_attrs, info);
Packit Service 3880ab
	if (!info[TIPC_NLA_BEARER]) {
Packit Service 3880ab
		fprintf(stderr, "No bearer in netlink response\n");
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	mnl_attr_parse_nested(info[TIPC_NLA_BEARER], parse_attrs, attrs);
Packit Service 3880ab
	if (!attrs[TIPC_NLA_BEARER_NAME]) {
Packit Service 3880ab
		fprintf(stderr, "Bearer name missing in netlink response\n");
Packit Service 3880ab
		return MNL_CB_ERROR;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	printf("%s\n", mnl_attr_get_str(attrs[TIPC_NLA_BEARER_NAME]));
Packit Service 3880ab
Packit Service 3880ab
	return MNL_CB_OK;
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
static int cmd_bearer_list(struct nlmsghdr *nlh, const struct cmd *cmd,
Packit Service 3880ab
			   struct cmdl *cmdl, void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	char buf[MNL_SOCKET_BUFFER_SIZE];
Packit Service 3880ab
Packit Service 3880ab
	if (help_flag) {
Packit Service 3880ab
		fprintf(stderr, "Usage: %s bearer list\n", cmdl->argv[0]);
Packit Service 3880ab
		return -EINVAL;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	if (!(nlh = msg_init(buf, TIPC_NL_BEARER_GET))) {
Packit Service 3880ab
		fprintf(stderr, "error, message initialisation failed\n");
Packit Service 3880ab
		return -1;
Packit Service 3880ab
	}
Packit Service 3880ab
Packit Service 3880ab
	return msg_dumpit(nlh, bearer_list_cb, NULL);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
void cmd_bearer_help(struct cmdl *cmdl)
Packit Service 3880ab
{
Packit Service 3880ab
	fprintf(stderr,
Packit Service 3880ab
		"Usage: %s bearer COMMAND [ARGS] ...\n"
Packit Service 3880ab
		"\n"
Packit Service 3880ab
		"COMMANDS\n"
Packit Service 3880ab
		" add			- Add data to existing bearer\n"
Packit Service 3880ab
		" enable		- Enable a bearer\n"
Packit Service 3880ab
		" disable		- Disable a bearer\n"
Packit Service 3880ab
		" set			- Set various bearer properties\n"
Packit Service 3880ab
		" get			- Get various bearer properties\n"
Packit Service 3880ab
		" list			- List bearers\n", cmdl->argv[0]);
Packit Service 3880ab
}
Packit Service 3880ab
Packit Service 3880ab
int cmd_bearer(struct nlmsghdr *nlh, const struct cmd *cmd, struct cmdl *cmdl,
Packit Service 3880ab
	       void *data)
Packit Service 3880ab
{
Packit Service 3880ab
	const struct cmd cmds[] = {
Packit Service 3880ab
		{ "add",	cmd_bearer_add,		cmd_bearer_add_help },
Packit Service 3880ab
		{ "disable",	cmd_bearer_disable,	cmd_bearer_disable_help },
Packit Service 3880ab
		{ "enable",	cmd_bearer_enable,	cmd_bearer_enable_help },
Packit Service 3880ab
		{ "get",	cmd_bearer_get,		cmd_bearer_get_help },
Packit Service 3880ab
		{ "list",	cmd_bearer_list,	NULL },
Packit Service 3880ab
		{ "set",	cmd_bearer_set,		cmd_bearer_set_help },
Packit Service 3880ab
		{ NULL }
Packit Service 3880ab
	};
Packit Service 3880ab
Packit Service 3880ab
	return run_cmd(nlh, cmd, cmds, cmdl, NULL);
Packit Service 3880ab
}