Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit f3c9ec05 authored by David S. Miller's avatar David S. Miller
Browse files

Merge branch 'tipc-next' 



Erik Hugne says:

====================
tipc: fix handling of NETDEV_CHANGEADDR event

Aside from manual reconfiguration of the netdevice hwaddr, this can also
be changed automatically for an interface bond in active-backup mode
if fail_over_mac is enabled. This patchset fixes the handling of this
event in TIPC by properly updating the l2 media address for the bearer,
followed by a reinitialization of the node discovery mechanism.
====================

Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parents c8c3d7e2 16470111

net/tipc/bearer.c

+8 −1
Original line number Original line Diff line number Diff line
@@ -332,10 +332,11 @@ restart: 
	b_ptr->identity = bearer_id;

	b_ptr->identity = bearer_id;

	b_ptr->tolerance = m_ptr->tolerance;

	b_ptr->tolerance = m_ptr->tolerance;

	b_ptr->window = m_ptr->window;

	b_ptr->window = m_ptr->window;

	b_ptr->domain = disc_domain;

	b_ptr->net_plane = bearer_id + 'A';

	b_ptr->net_plane = bearer_id + 'A';

	b_ptr->priority = priority;

	b_ptr->priority = priority;





	res = tipc_disc_create(b_ptr, &b_ptr->bcast_addr, disc_domain);

	res = tipc_disc_create(b_ptr, &b_ptr->bcast_addr);

	if (res) {

	if (res) {

		bearer_disable(b_ptr, false);

		bearer_disable(b_ptr, false);

		pr_warn("Bearer <%s> rejected, discovery object creation failed\n",

		pr_warn("Bearer <%s> rejected, discovery object creation failed\n",
@@ -360,7 +361,9 @@ static int tipc_reset_bearer(struct tipc_bearer *b_ptr) 
{

{

	read_lock_bh(&tipc_net_lock);

	read_lock_bh(&tipc_net_lock);

	pr_info("Resetting bearer <%s>\n", b_ptr->name);

	pr_info("Resetting bearer <%s>\n", b_ptr->name);

	tipc_disc_delete(b_ptr->link_req);

	tipc_link_reset_list(b_ptr->identity);

	tipc_link_reset_list(b_ptr->identity);

	tipc_disc_create(b_ptr, &b_ptr->bcast_addr);

	read_unlock_bh(&tipc_net_lock);

	read_unlock_bh(&tipc_net_lock);

	return 0;

	return 0;

}

}
@@ -580,7 +583,11 @@ static int tipc_l2_device_event(struct notifier_block *nb, unsigned long evt, 
			break;

			break;

	case NETDEV_DOWN:

	case NETDEV_DOWN:

	case NETDEV_CHANGEMTU:

	case NETDEV_CHANGEMTU:

		tipc_reset_bearer(b_ptr);

		break;

	case NETDEV_CHANGEADDR:

	case NETDEV_CHANGEADDR:

		tipc_l2_media_addr_set(b_ptr, &b_ptr->addr,

				       (char *)dev->dev_addr);

		tipc_reset_bearer(b_ptr);

		tipc_reset_bearer(b_ptr);

		break;

		break;

	case NETDEV_UNREGISTER:

	case NETDEV_UNREGISTER:

net/tipc/bearer.h

+2 −0
Original line number Original line Diff line number Diff line
@@ -116,6 +116,7 @@ struct tipc_media { 
 * @priority: default link priority for bearer

 * @priority: default link priority for bearer

 * @window: default window size for bearer

 * @window: default window size for bearer

 * @tolerance: default link tolerance for bearer

 * @tolerance: default link tolerance for bearer

 * @domain: network domain to which links can be established

 * @identity: array index of this bearer within TIPC bearer array

 * @identity: array index of this bearer within TIPC bearer array

 * @link_req: ptr to (optional) structure making periodic link setup requests

 * @link_req: ptr to (optional) structure making periodic link setup requests

 * @net_plane: network plane ('A' through 'H') currently associated with bearer

 * @net_plane: network plane ('A' through 'H') currently associated with bearer
@@ -135,6 +136,7 @@ struct tipc_bearer { 
	u32 priority;

	u32 priority;

	u32 window;

	u32 window;

	u32 tolerance;

	u32 tolerance;

	u32 domain;

	u32 identity;

	u32 identity;

	struct tipc_link_req *link_req;

	struct tipc_link_req *link_req;

	char net_plane;

	char net_plane;

net/tipc/discover.c

+7 −12
Original line number Original line Diff line number Diff line
@@ -48,7 +48,6 @@ 
 * struct tipc_link_req - information about an ongoing link setup request

 * struct tipc_link_req - information about an ongoing link setup request

 * @bearer: bearer issuing requests

 * @bearer: bearer issuing requests

 * @dest: destination address for request messages

 * @dest: destination address for request messages

 * @domain: network domain to which links can be established

 * @num_nodes: number of nodes currently discovered (i.e. with an active link)

 * @num_nodes: number of nodes currently discovered (i.e. with an active link)

 * @lock: spinlock for controlling access to requests

 * @lock: spinlock for controlling access to requests

 * @buf: request message to be (repeatedly) sent

 * @buf: request message to be (repeatedly) sent
@@ -58,7 +57,6 @@ 
struct tipc_link_req {

struct tipc_link_req {

	struct tipc_bearer *bearer;

	struct tipc_bearer *bearer;

	struct tipc_media_addr dest;

	struct tipc_media_addr dest;

	u32 domain;

	int num_nodes;

	int num_nodes;

	spinlock_t lock;

	spinlock_t lock;

	struct sk_buff *buf;

	struct sk_buff *buf;
@@ -69,14 +67,13 @@ struct tipc_link_req { 
/**

/**

 * tipc_disc_init_msg - initialize a link setup message

 * tipc_disc_init_msg - initialize a link setup message

 * @type: message type (request or response)

 * @type: message type (request or response)

 * @dest_domain: network domain of node(s) which should respond to message

 * @b_ptr: ptr to bearer issuing message

 * @b_ptr: ptr to bearer issuing message

 */

 */

static struct sk_buff *tipc_disc_init_msg(u32 type, u32 dest_domain,

static struct sk_buff *tipc_disc_init_msg(u32 type, struct tipc_bearer *b_ptr)

					  struct tipc_bearer *b_ptr)

{

{

	struct sk_buff *buf = tipc_buf_acquire(INT_H_SIZE);

	struct sk_buff *buf = tipc_buf_acquire(INT_H_SIZE);

	struct tipc_msg *msg;

	struct tipc_msg *msg;

	u32 dest_domain = b_ptr->domain;





	if (buf) {

	if (buf) {

		msg = buf_msg(buf);

		msg = buf_msg(buf);
@@ -149,7 +146,7 @@ void tipc_disc_rcv(struct sk_buff *buf, struct tipc_bearer *b_ptr) 
	}

	}

	if (!tipc_in_scope(dest, tipc_own_addr))

	if (!tipc_in_scope(dest, tipc_own_addr))

		return;

		return;

	if (!tipc_in_scope(b_ptr->link_req->domain, orig))

	if (!tipc_in_scope(b_ptr->domain, orig))

		return;

		return;





	/* Locate structure corresponding to requesting node */

	/* Locate structure corresponding to requesting node */
@@ -242,7 +239,7 @@ void tipc_disc_rcv(struct sk_buff *buf, struct tipc_bearer *b_ptr) 
	link_fully_up = link_working_working(link);

	link_fully_up = link_working_working(link);





	if ((type == DSC_REQ_MSG) && !link_fully_up) {

	if ((type == DSC_REQ_MSG) && !link_fully_up) {

		rbuf = tipc_disc_init_msg(DSC_RESP_MSG, orig, b_ptr);

		rbuf = tipc_disc_init_msg(DSC_RESP_MSG, b_ptr);

		if (rbuf) {

		if (rbuf) {

			tipc_bearer_send(b_ptr, rbuf, &media_addr);

			tipc_bearer_send(b_ptr, rbuf, &media_addr);

			kfree_skb(rbuf);

			kfree_skb(rbuf);
@@ -306,7 +303,7 @@ static void disc_timeout(struct tipc_link_req *req) 
	spin_lock_bh(&req->lock);

	spin_lock_bh(&req->lock);





	/* Stop searching if only desired node has been found */

	/* Stop searching if only desired node has been found */

	if (tipc_node(req->domain) && req->num_nodes) {

	if (tipc_node(req->bearer->domain) && req->num_nodes) {

		req->timer_intv = TIPC_LINK_REQ_INACTIVE;

		req->timer_intv = TIPC_LINK_REQ_INACTIVE;

		goto exit;

		goto exit;

	}

	}
@@ -342,8 +339,7 @@ exit: 
 *

 *

 * Returns 0 if successful, otherwise -errno.

 * Returns 0 if successful, otherwise -errno.

 */

 */

int tipc_disc_create(struct tipc_bearer *b_ptr, struct tipc_media_addr *dest,

int tipc_disc_create(struct tipc_bearer *b_ptr, struct tipc_media_addr *dest)

		     u32 dest_domain)

{

{

	struct tipc_link_req *req;

	struct tipc_link_req *req;
@@ -351,7 +347,7 @@ int tipc_disc_create(struct tipc_bearer *b_ptr, struct tipc_media_addr *dest, 
	if (!req)

	if (!req)

		return -ENOMEM;

		return -ENOMEM;





	req->buf = tipc_disc_init_msg(DSC_REQ_MSG, dest_domain, b_ptr);

	req->buf = tipc_disc_init_msg(DSC_REQ_MSG, b_ptr);

	if (!req->buf) {

	if (!req->buf) {

		kfree(req);

		kfree(req);

		return -ENOMSG;

		return -ENOMSG;
@@ -359,7 +355,6 @@ int tipc_disc_create(struct tipc_bearer *b_ptr, struct tipc_media_addr *dest, 




	memcpy(&req->dest, dest, sizeof(*dest));

	memcpy(&req->dest, dest, sizeof(*dest));

	req->bearer = b_ptr;

	req->bearer = b_ptr;

	req->domain = dest_domain;

	req->num_nodes = 0;

	req->num_nodes = 0;

	req->timer_intv = TIPC_LINK_REQ_INIT;

	req->timer_intv = TIPC_LINK_REQ_INIT;

	spin_lock_init(&req->lock);

	spin_lock_init(&req->lock);

net/tipc/discover.h

+1 −2
Original line number Original line Diff line number Diff line
@@ -39,8 +39,7 @@ 




struct tipc_link_req;

struct tipc_link_req;





int tipc_disc_create(struct tipc_bearer *b_ptr, struct tipc_media_addr *dest,

int tipc_disc_create(struct tipc_bearer *b_ptr, struct tipc_media_addr *dest);

		     u32 dest_domain);

void tipc_disc_delete(struct tipc_link_req *req);

void tipc_disc_delete(struct tipc_link_req *req);

void tipc_disc_add_dest(struct tipc_link_req *req);

void tipc_disc_add_dest(struct tipc_link_req *req);

void tipc_disc_remove_dest(struct tipc_link_req *req);

void tipc_disc_remove_dest(struct tipc_link_req *req);