Commit ec8a2e56 authored by Jon Paul Maloy's avatar Jon Paul Maloy Committed by David S. Miller
Browse files

tipc: same receive code path for connection protocol and data messages 



As a preparation to eliminate port_lock we need to bring reception
of connection protocol messages under proper protection of bh_lock_sock
or socket owner.

We fix this by letting those messages follow the same code path as
incoming data messages.

As a side effect of this change, the last reference to the function
net_route_msg() disappears, and we can eliminate that function.

Signed-off-by: default avatarJon Maloy <jon.maloy@ericsson.com>
Reviewed-by: default avatarErik Hugne <erik.hugne@ericsson.com>
Reviewed-by: default avatarYing Xue <ying.xue@windriver.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent b786e2b0

net/tipc/link.c

+12 −6
Original line number Diff line number Diff line
@@ -1479,6 +1479,7 @@ void tipc_rcv(struct sk_buff *head, struct tipc_bearer *b_ptr) 
		case TIPC_MEDIUM_IMPORTANCE:

		case TIPC_HIGH_IMPORTANCE:

		case TIPC_CRITICAL_IMPORTANCE:

		case CONN_MANAGER:

			tipc_node_unlock(n_ptr);

			tipc_sk_rcv(buf);

			continue;
@@ -1493,10 +1494,6 @@ void tipc_rcv(struct sk_buff *head, struct tipc_bearer *b_ptr) 
			tipc_node_unlock(n_ptr);

			tipc_named_rcv(buf);

			continue;

		case CONN_MANAGER:

			tipc_node_unlock(n_ptr);

			tipc_port_proto_rcv(buf);

			continue;

		case BCAST_PROTOCOL:

			tipc_link_sync_rcv(n_ptr, buf);

			break;
@@ -2106,6 +2103,7 @@ void tipc_link_bundle_rcv(struct sk_buff *buf) 
	u32 msgcount = msg_msgcnt(buf_msg(buf));

	u32 pos = INT_H_SIZE;

	struct sk_buff *obuf;

	struct tipc_msg *omsg;



	while (msgcount--) {

		obuf = buf_extract(buf, pos);
@@ -2113,8 +2111,16 @@ void tipc_link_bundle_rcv(struct sk_buff *buf) 
			pr_warn("Link unable to unbundle message(s)\n");

			break;

		}

		pos += align(msg_size(buf_msg(obuf)));

		tipc_net_route_msg(obuf);

		omsg = buf_msg(obuf);

		pos += align(msg_size(omsg));

		if (msg_isdata(omsg) || (msg_user(omsg) == CONN_MANAGER)) {

			tipc_sk_rcv(obuf);

		} else if (msg_user(omsg) == NAME_DISTRIBUTOR) {

			tipc_named_rcv(obuf);

		} else {

			pr_warn("Illegal bundled msg: %u\n", msg_user(omsg));

			kfree_skb(obuf);

		}

	}

	kfree_skb(buf);

}

net/tipc/net.c

+0 −40
Original line number Diff line number Diff line
@@ -103,46 +103,6 @@ 
 *       This is always used within the scope of a tipc_nametbl_lock(read).

 *     - A local spin_lock protecting the queue of subscriber events.

*/

void tipc_net_route_msg(struct sk_buff *buf)

{

	struct tipc_msg *msg;

	u32 dnode;



	if (!buf)

		return;

	msg = buf_msg(buf);



	/* Handle message for this node */

	dnode = msg_short(msg) ? tipc_own_addr : msg_destnode(msg);

	if (tipc_in_scope(dnode, tipc_own_addr)) {

		if (msg_isdata(msg)) {

			if (msg_mcast(msg))

				tipc_port_mcast_rcv(buf, NULL);

			else if (msg_destport(msg)) {

				tipc_sk_rcv(buf);

			} else {

				pr_warn("Cannot route msg; no destination\n");

				kfree_skb(buf);

			}

			return;

		}

		switch (msg_user(msg)) {

		case NAME_DISTRIBUTOR:

			tipc_named_rcv(buf);

			break;

		case CONN_MANAGER:

			tipc_port_proto_rcv(buf);

			break;

		default:

			kfree_skb(buf);

		}

		return;

	}



	/* Handle message for another node */

	skb_trim(buf, msg_size(msg));

	tipc_link_xmit(buf, dnode, msg_link_selector(msg));

}



int tipc_net_start(u32 addr)

{

net/tipc/net.h

+0 −2
Original line number Diff line number Diff line
@@ -37,8 +37,6 @@ 
#ifndef _TIPC_NET_H

#define _TIPC_NET_H



void tipc_net_route_msg(struct sk_buff *buf);



int tipc_net_start(u32 addr);

void tipc_net_stop(void);

net/tipc/port.c

+1 −6
Original line number Diff line number Diff line
@@ -365,16 +365,14 @@ static struct sk_buff *port_build_peer_abort_msg(struct tipc_port *p_ptr, u32 er 
	return buf;

}



void tipc_port_proto_rcv(struct sk_buff *buf)

void tipc_port_proto_rcv(struct tipc_port *p_ptr, struct sk_buff *buf)

{

	struct tipc_msg *msg = buf_msg(buf);

	struct tipc_port *p_ptr;

	struct sk_buff *r_buf = NULL;

	u32 destport = msg_destport(msg);

	int wakeable;



	/* Validate connection */

	p_ptr = tipc_port_lock(destport);

	if (!p_ptr || !p_ptr->connected || !tipc_port_peer_msg(p_ptr, msg)) {

		r_buf = tipc_buf_acquire(BASIC_H_SIZE);

		if (r_buf) {
@@ -385,8 +383,6 @@ void tipc_port_proto_rcv(struct sk_buff *buf) 
			msg_set_origport(msg, destport);

			msg_set_destport(msg, msg_origport(msg));

		}

		if (p_ptr)

			tipc_port_unlock(p_ptr);

		goto exit;

	}
@@ -409,7 +405,6 @@ void tipc_port_proto_rcv(struct sk_buff *buf) 
		break;

	}

	p_ptr->probing_state = CONFIRMED;

	tipc_port_unlock(p_ptr);

exit:

	tipc_link_xmit2(r_buf, msg_destnode(msg), msg_link_selector(msg));

	kfree_skb(buf);

net/tipc/port.h

+1 −1
Original line number Diff line number Diff line
@@ -140,7 +140,7 @@ int tipc_port_mcast_xmit(struct tipc_port *port, 
			 unsigned int len);



struct sk_buff *tipc_port_get_ports(void);

void tipc_port_proto_rcv(struct sk_buff *buf);

void tipc_port_proto_rcv(struct tipc_port *port, struct sk_buff *buf);

void tipc_port_mcast_rcv(struct sk_buff *buf, struct tipc_port_list *dp);

void tipc_port_reinit(void);

CRA Git | Maintained and supported by SUSTech CRA and CCSE