forked from mirrors/linux
		
	net: sched: extract common action counters update code into function
Currently, all implementations of tc_action_ops->stats_update() callback have almost exactly the same implementation of counters update code (besides gact which also updates drop counter). In order to simplify support for using both percpu-allocated and regular action counters depending on run-time flag in following patches, extract action counters update code into standalone function in act API. This commit doesn't change functionality. Signed-off-by: Vlad Buslov <vladbu@mellanox.com> Acked-by: Jiri Pirko <jiri@mellanox.com> Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
		
							parent
							
								
									21d8bd123a
								
							
						
					
					
						commit
						c8ecebd04c
					
				
					 7 changed files with 21 additions and 26 deletions
				
			
		|  | @ -186,6 +186,8 @@ int tcf_action_dump(struct sk_buff *skb, struct tc_action *actions[], int bind, | |||
| 		    int ref); | ||||
| int tcf_action_dump_old(struct sk_buff *skb, struct tc_action *a, int, int); | ||||
| int tcf_action_dump_1(struct sk_buff *skb, struct tc_action *a, int, int); | ||||
| void tcf_action_update_stats(struct tc_action *a, u64 bytes, u32 packets, | ||||
| 			     bool drop, bool hw); | ||||
| int tcf_action_copy_stats(struct sk_buff *, struct tc_action *, int); | ||||
| 
 | ||||
| int tcf_action_check_ctrlact(int action, struct tcf_proto *tp, | ||||
|  |  | |||
|  | @ -989,6 +989,20 @@ int tcf_action_init(struct net *net, struct tcf_proto *tp, struct nlattr *nla, | |||
| 	return err; | ||||
| } | ||||
| 
 | ||||
| void tcf_action_update_stats(struct tc_action *a, u64 bytes, u32 packets, | ||||
| 			     bool drop, bool hw) | ||||
| { | ||||
| 	_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats), bytes, packets); | ||||
| 
 | ||||
| 	if (drop) | ||||
| 		this_cpu_ptr(a->cpu_qstats)->drops += packets; | ||||
| 
 | ||||
| 	if (hw) | ||||
| 		_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats_hw), | ||||
| 				   bytes, packets); | ||||
| } | ||||
| EXPORT_SYMBOL(tcf_action_update_stats); | ||||
| 
 | ||||
| int tcf_action_copy_stats(struct sk_buff *skb, struct tc_action *p, | ||||
| 			  int compat_mode) | ||||
| { | ||||
|  |  | |||
|  | @ -905,11 +905,7 @@ static void tcf_stats_update(struct tc_action *a, u64 bytes, u32 packets, | |||
| { | ||||
| 	struct tcf_ct *c = to_ct(a); | ||||
| 
 | ||||
| 	_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats), bytes, packets); | ||||
| 
 | ||||
| 	if (hw) | ||||
| 		_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats_hw), | ||||
| 				   bytes, packets); | ||||
| 	tcf_action_update_stats(a, bytes, packets, false, hw); | ||||
| 	c->tcf_tm.lastuse = max_t(u64, c->tcf_tm.lastuse, lastuse); | ||||
| } | ||||
| 
 | ||||
|  |  | |||
|  | @ -177,15 +177,7 @@ static void tcf_gact_stats_update(struct tc_action *a, u64 bytes, u32 packets, | |||
| 	int action = READ_ONCE(gact->tcf_action); | ||||
| 	struct tcf_t *tm = &gact->tcf_tm; | ||||
| 
 | ||||
| 	_bstats_cpu_update(this_cpu_ptr(gact->common.cpu_bstats), bytes, | ||||
| 			   packets); | ||||
| 	if (action == TC_ACT_SHOT) | ||||
| 		this_cpu_ptr(gact->common.cpu_qstats)->drops += packets; | ||||
| 
 | ||||
| 	if (hw) | ||||
| 		_bstats_cpu_update(this_cpu_ptr(gact->common.cpu_bstats_hw), | ||||
| 				   bytes, packets); | ||||
| 
 | ||||
| 	tcf_action_update_stats(a, bytes, packets, action == TC_ACT_SHOT, hw); | ||||
| 	tm->lastuse = max_t(u64, tm->lastuse, lastuse); | ||||
| } | ||||
| 
 | ||||
|  |  | |||
|  | @ -318,10 +318,7 @@ static void tcf_stats_update(struct tc_action *a, u64 bytes, u32 packets, | |||
| 	struct tcf_mirred *m = to_mirred(a); | ||||
| 	struct tcf_t *tm = &m->tcf_tm; | ||||
| 
 | ||||
| 	_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats), bytes, packets); | ||||
| 	if (hw) | ||||
| 		_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats_hw), | ||||
| 				   bytes, packets); | ||||
| 	tcf_action_update_stats(a, bytes, packets, false, hw); | ||||
| 	tm->lastuse = max_t(u64, tm->lastuse, lastuse); | ||||
| } | ||||
| 
 | ||||
|  |  | |||
|  | @ -294,10 +294,7 @@ static void tcf_police_stats_update(struct tc_action *a, | |||
| 	struct tcf_police *police = to_police(a); | ||||
| 	struct tcf_t *tm = &police->tcf_tm; | ||||
| 
 | ||||
| 	_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats), bytes, packets); | ||||
| 	if (hw) | ||||
| 		_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats_hw), | ||||
| 				   bytes, packets); | ||||
| 	tcf_action_update_stats(a, bytes, packets, false, hw); | ||||
| 	tm->lastuse = max_t(u64, tm->lastuse, lastuse); | ||||
| } | ||||
| 
 | ||||
|  |  | |||
|  | @ -307,10 +307,7 @@ static void tcf_vlan_stats_update(struct tc_action *a, u64 bytes, u32 packets, | |||
| 	struct tcf_vlan *v = to_vlan(a); | ||||
| 	struct tcf_t *tm = &v->tcf_tm; | ||||
| 
 | ||||
| 	_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats), bytes, packets); | ||||
| 	if (hw) | ||||
| 		_bstats_cpu_update(this_cpu_ptr(a->cpu_bstats_hw), | ||||
| 				   bytes, packets); | ||||
| 	tcf_action_update_stats(a, bytes, packets, false, hw); | ||||
| 	tm->lastuse = max_t(u64, tm->lastuse, lastuse); | ||||
| } | ||||
| 
 | ||||
|  |  | |||
		Loading…
	
		Reference in a new issue