proxmox-mirrors/mirror_iproute2
1
0
Fork 0
mirror of https://git.proxmox.com/git/mirror_iproute2 synced 2026-01-04 17:19:43 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

tipc: introduce bearer add for remoteip

Browse Source 
Introduce the ability to add remote IP addresses to an existing UDP
bearer. On the kernel side, adding a "remoteip" to an existing bearer
puts the bearer in "replicast" mode where TIPC multicast messages are
send out to each configured remoteip using unicast. This is required
for TIPC UDP bearers to work in environments where IP multicast is
disabled.

Signed-off-by: Richard Alpe <richard.alpe@ericsson.com>
Reviewed-by: Parthasarathy Bhuvaragan <parthasarathy.bhuvaragan@ericsson.com>
Acked-by: Jon Maloy <jon.maloy@ericsson.com>
This commit is contained in:
Richard Alpe 2016-08-30 10:36:59 +02:00 committed by Stephen Hemminger
parent 3cc0b954b0
commit f1f40cf77d
2 changed files with 149 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
man/man8/tipc-bearer.8
View File

@ -10,6 +10,11 @@ tipc-bearer \- show or modify TIPC bearers
.ad l
.in +8
.ti -8
.B tipc bearer add media udp name
.IB "NAME " "remoteip " REMOTEIP
.br
.ti -8
.B tipc bearer enable
.RB "[ " domain
@ -196,6 +201,25 @@ IP is specified the
.B udp
bearer runs in point-to-point mode.
Multiple
.B remoteip
addresses can be added via the
.B bearer add
command. Adding one or more unicast
.B remoteip
addresses to an existing
.B udp
bearer puts the bearer in replicast mode where IP
multicast is emulated by sending multiple unicast messages to each configured
.B remoteip.
When a peer sees a TIPC discovery message from an unknown peer the peer address
is automatically added to the
.B remoteip
(replicast) list, thus only one side of
a link needs to be manually configured. A
.B remoteip
address cannot be added to a multicast bearer.
.TP
.BI "remoteport " REMOTEPORT
.br

125
tipc/bearer.c
View File

@ -222,6 +222,129 @@ static int nl_add_bearer_name(struct nlmsghdr *nlh, const struct cmd *cmd,
return -EINVAL;
}
static void cmd_bearer_add_udp_help(struct cmdl *cmdl, char *media)
{
fprintf(stderr, "Usage: %s bearer add media %s name NAME remoteip REMOTEIP\n\n",
cmdl->argv[0], media);
}
static void cmd_bearer_add_help(struct cmdl *cmdl)
{
fprintf(stderr, "Usage: %s bearer add media udp name NAME remoteip REMOTEIP\n",
cmdl->argv[0]);
}
static int udp_bearer_add(struct nlmsghdr *nlh, struct opt *opts,
struct cmdl *cmdl)
{
int err;
struct opt *opt;
struct nlattr *opts_nest;
char *remport = "6118";
opts_nest = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER_UDP_OPTS);
if ((opt = get_opt(opts, "remoteport")))
remport = opt->val;
if ((opt = get_opt(opts, "remoteip"))) {
char *ip = opt->val;
struct addrinfo *addr = NULL;
struct addrinfo hints = {
.ai_family = AF_UNSPEC,
.ai_socktype = SOCK_DGRAM
};
if ((err = getaddrinfo(ip, remport, &hints, &addr))) {
fprintf(stderr, "UDP address error: %s\n",
gai_strerror(err));
freeaddrinfo(addr);
return err;
}
mnl_attr_put(nlh, TIPC_NLA_UDP_REMOTE, addr->ai_addrlen,
addr->ai_addr);
freeaddrinfo(addr);
} else {
fprintf(stderr, "error, missing remoteip\n");
return -EINVAL;
}
mnl_attr_nest_end(nlh, opts_nest);
return 0;
}
static int cmd_bearer_add_media(struct nlmsghdr *nlh, const struct cmd *cmd,
struct cmdl *cmdl, void *data)
{
int err;
char *media;
char buf[MNL_SOCKET_BUFFER_SIZE];
struct opt *opt;
struct nlattr *attrs;
struct opt opts[] = {
{ "remoteip", NULL },
{ "remoteport", NULL },
{ "name", NULL },
{ "media", NULL },
{ NULL }
};
struct tipc_sup_media sup_media[] = {
{ "udp", "name", cmd_bearer_add_udp_help},
{ NULL, },
};
/* Rewind optind to include media in the option list */
cmdl->optind--;
if (parse_opts(opts, cmdl) < 0)
return -EINVAL;
if (!(opt = get_opt(opts, "media"))) {
fprintf(stderr, "error, missing media value\n");
return -EINVAL;
}
media = opt->val;
if (strcmp(media, "udp") != 0) {
fprintf(stderr, "error, no \"%s\" media specific options available\n",
media);
return -EINVAL;
}
if (!(opt = get_opt(opts, "name"))) {
fprintf(stderr, "error, missing media name\n");
return -EINVAL;
}
if (!(nlh = msg_init(buf, TIPC_NL_BEARER_ADD))) {
fprintf(stderr, "error, message initialisation failed\n");
return -1;
}
attrs = mnl_attr_nest_start(nlh, TIPC_NLA_BEARER);
err = nl_add_bearer_name(nlh, cmd, cmdl, opts, sup_media);
if (err)
return err;
err = udp_bearer_add(nlh, opts, cmdl);
if (err)
return err;
mnl_attr_nest_end(nlh, attrs);
return msg_doit(nlh, NULL, NULL);
}
static int cmd_bearer_add(struct nlmsghdr *nlh, const struct cmd *cmd,
struct cmdl *cmdl, void *data)
{
const struct cmd cmds[] = {
{ "media", cmd_bearer_add_media, cmd_bearer_add_help },
{ NULL }
};
return run_cmd(nlh, cmd, cmds, cmdl, NULL);
}
static void cmd_bearer_enable_help(struct cmdl *cmdl)
{
fprintf(stderr,
@ -605,6 +728,7 @@ void cmd_bearer_help(struct cmdl *cmdl)
"Usage: %s bearer COMMAND [ARGS] ...\n"
"\n"
"COMMANDS\n"
" add - Add data to existing bearer\n"
" enable - Enable a bearer\n"
" disable - Disable a bearer\n"
" set - Set various bearer properties\n"
@ -616,6 +740,7 @@ int cmd_bearer(struct nlmsghdr *nlh, const struct cmd *cmd, struct cmdl *cmdl,
void *data)
{
const struct cmd cmds[] = {
{ "add", cmd_bearer_add, cmd_bearer_add_help },
{ "disable", cmd_bearer_disable, cmd_bearer_disable_help },
{ "enable", cmd_bearer_enable, cmd_bearer_enable_help },
{ "get", cmd_bearer_get, cmd_bearer_get_help },