From: Jesse Gross <jesse@nicira.com>
Date: Sat, 19 Nov 2011 21:25:43 +0000 (-0800)
Subject: datapath: Add genl_dereference() and use it.
X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=20d035b27559fe3823a09d72293c81281d3516c4;p=openvswitch

datapath: Add genl_dereference() and use it.

We currently use a specialized version of what amounts to
genl_dereference() to protect the flow table.  This prepares to
propose genl_dereference() upstream and uses it instead of our
version.

Signed-off-by: Jesse Gross <jesse@nicira.com>
Acked-by: Ben Pfaff <blp@nicira.com>
---

diff --git a/datapath/datapath.c b/datapath/datapath.c
index adfc76a4..93947ee0 100644
--- a/datapath/datapath.c
+++ b/datapath/datapath.c
@@ -112,12 +112,6 @@ static struct datapath *get_dp(int dp_ifindex)
 	return dp;
 }
 
-/* Must be called with genl_mutex. */
-static struct flow_table *get_table_protected(struct datapath *dp)
-{
-	return rcu_dereference_protected(dp->table, lockdep_genl_is_held());
-}
-
 /* Must be called with rcu_read_lock or RTNL lock. */
 static struct vport *get_vport_protected(struct datapath *dp, u16 port_no)
 {
@@ -505,7 +499,7 @@ static int flush_flows(int dp_ifindex)
 	if (!dp)
 		return -ENODEV;
 
-	old_table = get_table_protected(dp);
+	old_table = genl_dereference(dp->table);
 	new_table = flow_tbl_alloc(TBL_MIN_BUCKETS);
 	if (!new_table)
 		return -ENOMEM;
@@ -827,7 +821,7 @@ static struct genl_ops dp_packet_genl_ops[] = {
 static void get_dp_stats(struct datapath *dp, struct ovs_dp_stats *stats)
 {
 	int i;
-	struct flow_table *table = get_table_protected(dp);
+	struct flow_table *table = genl_dereference(dp->table);
 
 	stats->n_flows = flow_tbl_count(table);
 
@@ -1015,7 +1009,7 @@ static int ovs_flow_cmd_new_or_set(struct sk_buff *skb, struct genl_info *info)
 	if (!dp)
 		goto error;
 
-	table = get_table_protected(dp);
+	table = genl_dereference(dp->table);
 	flow = flow_tbl_lookup(table, &key, key_len);
 	if (!flow) {
 		struct sw_flow_actions *acts;
@@ -1033,7 +1027,7 @@ static int ovs_flow_cmd_new_or_set(struct sk_buff *skb, struct genl_info *info)
 			if (!IS_ERR(new_table)) {
 				rcu_assign_pointer(dp->table, new_table);
 				flow_tbl_deferred_destroy(table);
-				table = get_table_protected(dp);
+				table = genl_dereference(dp->table);
 			}
 		}
 
@@ -1142,7 +1136,7 @@ static int ovs_flow_cmd_get(struct sk_buff *skb, struct genl_info *info)
 	if (!dp)
 		return -ENODEV;
 
-	table = get_table_protected(dp);
+	table = genl_dereference(dp->table);
 	flow = flow_tbl_lookup(table, &key, key_len);
 	if (!flow)
 		return -ENOENT;
@@ -1177,7 +1171,7 @@ static int ovs_flow_cmd_del(struct sk_buff *skb, struct genl_info *info)
 	if (!dp)
 		return -ENODEV;
 
-	table = get_table_protected(dp);
+	table = genl_dereference(dp->table);
 	flow = flow_tbl_lookup(table, &key, key_len);
 	if (!flow)
 		return -ENOENT;
@@ -1203,18 +1197,21 @@ static int ovs_flow_cmd_dump(struct sk_buff *skb, struct netlink_callback *cb)
 {
 	struct ovs_header *ovs_header = genlmsg_data(nlmsg_data(cb->nlh));
 	struct datapath *dp;
+	struct flow_table *table;
 
 	dp = get_dp(ovs_header->dp_ifindex);
 	if (!dp)
 		return -ENODEV;
 
+	table = genl_dereference(dp->table);
+
 	for (;;) {
 		struct sw_flow *flow;
 		u32 bucket, obj;
 
 		bucket = cb->args[0];
 		obj = cb->args[1];
-		flow = flow_tbl_next(get_table_protected(dp), &bucket, &obj);
+		flow = flow_tbl_next(table, &bucket, &obj);
 		if (!flow)
 			break;
 
@@ -1428,7 +1425,7 @@ err_destroy_local_port:
 err_destroy_percpu:
 	free_percpu(dp->stats_percpu);
 err_destroy_table:
-	flow_tbl_destroy(get_table_protected(dp));
+	flow_tbl_destroy(genl_dereference(dp->table));
 err_free_dp:
 	kfree(dp);
 err_put_module:
diff --git a/datapath/linux/compat/include/linux/genetlink.h b/datapath/linux/compat/include/linux/genetlink.h
index e45d0854..f7b96d96 100644
--- a/datapath/linux/compat/include/linux/genetlink.h
+++ b/datapath/linux/compat/include/linux/genetlink.h
@@ -12,4 +12,12 @@ static inline int lockdep_genl_is_held(void)
 }
 #endif
 
+/* This is also not upstream yet. */
+#ifndef genl_dereference
+#include <linux/rcupdate.h>
+
+#define genl_dereference(p)					\
+	rcu_dereference_protected(p, lockdep_genl_is_held())
+#endif
+
 #endif /* linux/genetlink.h wrapper */