net/openvswitch/actions.c

155 static int clone_execute(struct datapath *dp, struct sk_buff *skb,
161 static int do_execute_actions(struct datapath *dp, struct sk_buff *skb,
923 static void do_output(struct datapath *dp, struct sk_buff *skb, int out_port,
926 	struct vport *vport = ovs_vport_rcu(dp, out_port);
949 			struct net *net = read_pnet(&dp->net);
960 static int output_userspace(struct datapath *dp, struct sk_buff *skb,
981 			if (dp->user_features &
984 				  ovs_dp_get_upcall_portid(dp,
994 			vport = ovs_vport_rcu(dp, nla_get_u32(a));
1016 	return ovs_dp_upcall(dp, skb, key, &upcall, cutlen);
1019 static int dec_ttl_exception_handler(struct datapath *dp, struct sk_buff *skb,
1027 		return clone_execute(dp, skb, key, 0, nla_data(actions),
1038 static int sample(struct datapath *dp, struct sk_buff *skb,
1061 	return clone_execute(dp, skb, key, 0, actions, rem, last,
1069 static int clone(struct datapath *dp, struct sk_buff *skb,
1083 	return clone_execute(dp, skb, key, 0, actions, rem, last,
1205 static int execute_recirc(struct datapath *dp, struct sk_buff *skb,
1221 	return clone_execute(dp, skb, key, recirc_id, NULL, 0, last, true);
1224 static int execute_check_pkt_len(struct datapath *dp, struct sk_buff *skb,
1259 	return clone_execute(dp, skb, key, 0, nla_data(actions),
1303 static int do_execute_actions(struct datapath *dp, struct sk_buff *skb,
1315 			trace_ovs_do_execute_action(dp, skb, key, a, rem);
1330 				do_output(dp, skb, port, key);
1338 				do_output(dp, clone, port, key);
1352 			output_userspace(dp, skb, key, a, attr,
1398 			err = execute_recirc(dp, skb, key, a, last);
1421 			err = sample(dp, skb, key, a, last);
1435 			err = ovs_ct_execute(ovs_dp_get_net(dp), skb, key,
1464 			if (ovs_meter_execute(dp, skb, key, nla_get_u32(a))) {
1473 			err = clone(dp, skb, key, a, last);
1483 			err = execute_check_pkt_len(dp, skb, key, a, last);
1493 				return dec_ttl_exception_handler(dp, skb,
1523 static int clone_execute(struct datapath *dp, struct sk_buff *skb,
1552 			err = do_execute_actions(dp, skb, clone,
1580 					ovs_dp_name(dp));
1583 					ovs_dp_name(dp), recirc_id);
1590 static void process_deferred_actions(struct datapath *dp)
1607 			do_execute_actions(dp, skb, key, actions, actions_len);
1617 int ovs_execute_actions(struct datapath *dp, struct sk_buff *skb,
1626 				     ovs_dp_name(dp));
1633 	err = do_execute_actions(dp, skb, key,
1637 		process_deferred_actions(dp);