tipc: eliminate function tipc_link_activate()
The function tipc_link_activate() is redundant, since it mostly performs settings that have already been done in a preceding tipc_link_reset(). There are three exceptions to this: - The actual state change to TIPC_LINK_WORKING. This should anyway be done in the FSM, and not in a separate function. - Registration of the link with the bearer. This should be done by the node, since we don't want the link to have any knowledge about its specific bearer. - Call to tipc_node_link_up() for user access registration. With the new role distribution between link aggregation and link level this becomes the wrong call order; tipc_node_link_up() should instead be called directly as a result of a TIPC_LINK_UP event, hence by the node itself. This commit implements those changes. Tested-by: Ying Xue <ying.xue@windriver.com> Signed-off-by: Jon Maloy <jon.maloy@ericsson.com> Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
parent
29a3060aa7
commit
cbeb83ca68
|
@ -228,6 +228,8 @@ struct tipc_link *tipc_link_create(struct tipc_node *n_ptr,
|
||||||
l_ptr->peer_session = WILDCARD_SESSION;
|
l_ptr->peer_session = WILDCARD_SESSION;
|
||||||
l_ptr->bearer_id = b_ptr->identity;
|
l_ptr->bearer_id = b_ptr->identity;
|
||||||
l_ptr->tolerance = b_ptr->tolerance;
|
l_ptr->tolerance = b_ptr->tolerance;
|
||||||
|
l_ptr->snd_nxt = 1;
|
||||||
|
l_ptr->rcv_nxt = 1;
|
||||||
l_ptr->state = TIPC_LINK_RESETTING;
|
l_ptr->state = TIPC_LINK_RESETTING;
|
||||||
|
|
||||||
l_ptr->pmsg = (struct tipc_msg *)&l_ptr->proto_msg;
|
l_ptr->pmsg = (struct tipc_msg *)&l_ptr->proto_msg;
|
||||||
|
@ -376,6 +378,7 @@ static int tipc_link_fsm_evt(struct tipc_link *l, int evt,
|
||||||
pl = node_active_link(l->owner, 0);
|
pl = node_active_link(l->owner, 0);
|
||||||
if (pl && link_probing(pl))
|
if (pl && link_probing(pl))
|
||||||
break;
|
break;
|
||||||
|
l->state = TIPC_LINK_WORKING;
|
||||||
actions |= LINK_ACTIVATE;
|
actions |= LINK_ACTIVATE;
|
||||||
if (!l->owner->working_links)
|
if (!l->owner->working_links)
|
||||||
actions |= SND_BCAST_SYNC;
|
actions |= SND_BCAST_SYNC;
|
||||||
|
@ -398,6 +401,7 @@ static int tipc_link_fsm_evt(struct tipc_link *l, int evt,
|
||||||
pl = node_active_link(l->owner, 0);
|
pl = node_active_link(l->owner, 0);
|
||||||
if (pl && link_probing(pl))
|
if (pl && link_probing(pl))
|
||||||
break;
|
break;
|
||||||
|
l->state = TIPC_LINK_WORKING;
|
||||||
actions |= LINK_ACTIVATE;
|
actions |= LINK_ACTIVATE;
|
||||||
if (!l->owner->working_links)
|
if (!l->owner->working_links)
|
||||||
actions |= SND_BCAST_SYNC;
|
actions |= SND_BCAST_SYNC;
|
||||||
|
@ -639,19 +643,6 @@ void tipc_link_reset(struct tipc_link *l_ptr)
|
||||||
link_reset_statistics(l_ptr);
|
link_reset_statistics(l_ptr);
|
||||||
}
|
}
|
||||||
|
|
||||||
void tipc_link_activate(struct tipc_link *link)
|
|
||||||
{
|
|
||||||
struct tipc_node *node = link->owner;
|
|
||||||
|
|
||||||
link->rcv_nxt = 1;
|
|
||||||
link->stats.recv_info = 1;
|
|
||||||
link->silent_intv_cnt = 0;
|
|
||||||
link->state = TIPC_LINK_WORKING;
|
|
||||||
link->exec_mode = TIPC_LINK_OPEN;
|
|
||||||
tipc_node_link_up(node, link->bearer_id);
|
|
||||||
tipc_bearer_add_dest(node->net, link->bearer_id, link->addr);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* __tipc_link_xmit(): same as tipc_link_xmit, but destlink is known & locked
|
* __tipc_link_xmit(): same as tipc_link_xmit, but destlink is known & locked
|
||||||
* @link: link to use
|
* @link: link to use
|
||||||
|
|
|
@ -223,7 +223,6 @@ void tipc_link_purge_queues(struct tipc_link *l_ptr);
|
||||||
void tipc_link_purge_backlog(struct tipc_link *l);
|
void tipc_link_purge_backlog(struct tipc_link *l);
|
||||||
void tipc_link_reset_all(struct tipc_node *node);
|
void tipc_link_reset_all(struct tipc_node *node);
|
||||||
void tipc_link_reset(struct tipc_link *l_ptr);
|
void tipc_link_reset(struct tipc_link *l_ptr);
|
||||||
void tipc_link_activate(struct tipc_link *link);
|
|
||||||
int __tipc_link_xmit(struct net *net, struct tipc_link *link,
|
int __tipc_link_xmit(struct net *net, struct tipc_link *link,
|
||||||
struct sk_buff_head *list);
|
struct sk_buff_head *list);
|
||||||
int tipc_link_xmit(struct tipc_link *link, struct sk_buff_head *list,
|
int tipc_link_xmit(struct tipc_link *link, struct sk_buff_head *list,
|
||||||
|
|
|
@ -295,11 +295,13 @@ void tipc_node_link_up(struct tipc_node *n, int bearer_id)
|
||||||
n->action_flags |= TIPC_NOTIFY_LINK_UP;
|
n->action_flags |= TIPC_NOTIFY_LINK_UP;
|
||||||
n->link_id = l->peer_bearer_id << 16 | l->bearer_id;
|
n->link_id = l->peer_bearer_id << 16 | l->bearer_id;
|
||||||
|
|
||||||
|
tipc_bearer_add_dest(n->net, bearer_id, n->addr);
|
||||||
|
|
||||||
pr_debug("Established link <%s> on network plane %c\n",
|
pr_debug("Established link <%s> on network plane %c\n",
|
||||||
l->name, l->net_plane);
|
l->name, l->net_plane);
|
||||||
|
|
||||||
/* No active links ? => take both active slots */
|
/* No active links ? => take both active slots */
|
||||||
if (*slot0 < 0) {
|
if (!tipc_node_is_up(n)) {
|
||||||
*slot0 = bearer_id;
|
*slot0 = bearer_id;
|
||||||
*slot1 = bearer_id;
|
*slot1 = bearer_id;
|
||||||
node_established_contact(n);
|
node_established_contact(n);
|
||||||
|
@ -896,7 +898,7 @@ void tipc_rcv(struct net *net, struct sk_buff *skb, struct tipc_bearer *b)
|
||||||
rc = tipc_link_rcv(l, skb, &xmitq);
|
rc = tipc_link_rcv(l, skb, &xmitq);
|
||||||
|
|
||||||
if (unlikely(rc & TIPC_LINK_UP_EVT))
|
if (unlikely(rc & TIPC_LINK_UP_EVT))
|
||||||
tipc_link_activate(l);
|
tipc_node_link_up(n, bearer_id);
|
||||||
if (unlikely(rc & TIPC_LINK_DOWN_EVT))
|
if (unlikely(rc & TIPC_LINK_DOWN_EVT))
|
||||||
tipc_link_reset(l);
|
tipc_link_reset(l);
|
||||||
skb = NULL;
|
skb = NULL;
|
||||||
|
|
Loading…
Reference in New Issue