2 * Copyright (c) 2009, 2010, 2011, 2012, 2013, 2014 Nicira, Inc.
3 * Copyright (c) 2013 Simon Horman
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at:
9 * http://www.apache.org/licenses/LICENSE-2.0
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
19 #include "odp-execute.h"
20 #include <linux/openvswitch.h>
29 #include "unaligned.h"
33 odp_eth_set_addrs(struct ofpbuf
*packet
,
34 const struct ovs_key_ethernet
*eth_key
)
36 struct eth_header
*eh
= ofpbuf_l2(packet
);
39 memcpy(eh
->eth_src
, eth_key
->eth_src
, sizeof eh
->eth_src
);
40 memcpy(eh
->eth_dst
, eth_key
->eth_dst
, sizeof eh
->eth_dst
);
45 odp_set_tunnel_action(const struct nlattr
*a
, struct flow_tnl
*tun_key
)
47 enum odp_key_fitness fitness
;
49 fitness
= odp_tun_key_from_attr(a
, tun_key
);
50 ovs_assert(fitness
!= ODP_FIT_ERROR
);
54 set_arp(struct ofpbuf
*packet
, const struct ovs_key_arp
*arp_key
)
56 struct arp_eth_header
*arp
= ofpbuf_l3(packet
);
58 arp
->ar_op
= arp_key
->arp_op
;
59 memcpy(arp
->ar_sha
, arp_key
->arp_sha
, ETH_ADDR_LEN
);
60 put_16aligned_be32(&arp
->ar_spa
, arp_key
->arp_sip
);
61 memcpy(arp
->ar_tha
, arp_key
->arp_tha
, ETH_ADDR_LEN
);
62 put_16aligned_be32(&arp
->ar_tpa
, arp_key
->arp_tip
);
66 odp_execute_set_action(struct ofpbuf
*packet
, const struct nlattr
*a
,
67 struct pkt_metadata
*md
)
69 enum ovs_key_attr type
= nl_attr_type(a
);
70 const struct ovs_key_ipv4
*ipv4_key
;
71 const struct ovs_key_ipv6
*ipv6_key
;
72 const struct ovs_key_tcp
*tcp_key
;
73 const struct ovs_key_udp
*udp_key
;
74 const struct ovs_key_sctp
*sctp_key
;
77 case OVS_KEY_ATTR_PRIORITY
:
78 md
->skb_priority
= nl_attr_get_u32(a
);
81 case OVS_KEY_ATTR_TUNNEL
:
82 odp_set_tunnel_action(a
, &md
->tunnel
);
85 case OVS_KEY_ATTR_SKB_MARK
:
86 md
->pkt_mark
= nl_attr_get_u32(a
);
89 case OVS_KEY_ATTR_ETHERNET
:
90 odp_eth_set_addrs(packet
,
91 nl_attr_get_unspec(a
, sizeof(struct ovs_key_ethernet
)));
94 case OVS_KEY_ATTR_IPV4
:
95 ipv4_key
= nl_attr_get_unspec(a
, sizeof(struct ovs_key_ipv4
));
96 packet_set_ipv4(packet
, ipv4_key
->ipv4_src
, ipv4_key
->ipv4_dst
,
97 ipv4_key
->ipv4_tos
, ipv4_key
->ipv4_ttl
);
100 case OVS_KEY_ATTR_IPV6
:
101 ipv6_key
= nl_attr_get_unspec(a
, sizeof(struct ovs_key_ipv6
));
102 packet_set_ipv6(packet
, ipv6_key
->ipv6_proto
, ipv6_key
->ipv6_src
,
103 ipv6_key
->ipv6_dst
, ipv6_key
->ipv6_tclass
,
104 ipv6_key
->ipv6_label
, ipv6_key
->ipv6_hlimit
);
107 case OVS_KEY_ATTR_TCP
:
108 tcp_key
= nl_attr_get_unspec(a
, sizeof(struct ovs_key_tcp
));
109 packet_set_tcp_port(packet
, tcp_key
->tcp_src
, tcp_key
->tcp_dst
);
112 case OVS_KEY_ATTR_UDP
:
113 udp_key
= nl_attr_get_unspec(a
, sizeof(struct ovs_key_udp
));
114 packet_set_udp_port(packet
, udp_key
->udp_src
, udp_key
->udp_dst
);
117 case OVS_KEY_ATTR_SCTP
:
118 sctp_key
= nl_attr_get_unspec(a
, sizeof(struct ovs_key_sctp
));
119 packet_set_sctp_port(packet
, sctp_key
->sctp_src
, sctp_key
->sctp_dst
);
122 case OVS_KEY_ATTR_MPLS
:
123 set_mpls_lse(packet
, nl_attr_get_be32(a
));
126 case OVS_KEY_ATTR_ARP
:
127 set_arp(packet
, nl_attr_get_unspec(a
, sizeof(struct ovs_key_arp
)));
130 case OVS_KEY_ATTR_DP_HASH
:
131 md
->dp_hash
= nl_attr_get_u32(a
);
134 case OVS_KEY_ATTR_RECIRC_ID
:
135 md
->recirc_id
= nl_attr_get_u32(a
);
138 case OVS_KEY_ATTR_UNSPEC
:
139 case OVS_KEY_ATTR_ENCAP
:
140 case OVS_KEY_ATTR_ETHERTYPE
:
141 case OVS_KEY_ATTR_IN_PORT
:
142 case OVS_KEY_ATTR_VLAN
:
143 case OVS_KEY_ATTR_ICMP
:
144 case OVS_KEY_ATTR_ICMPV6
:
145 case OVS_KEY_ATTR_ND
:
146 case OVS_KEY_ATTR_TCP_FLAGS
:
147 case __OVS_KEY_ATTR_MAX
:
154 odp_execute_actions__(void *dp
, struct ofpbuf
*packet
, bool steal
,
155 struct pkt_metadata
*,
156 const struct nlattr
*actions
, size_t actions_len
,
157 odp_execute_cb dp_execute_action
, bool more_actions
);
160 odp_execute_sample(void *dp
, struct ofpbuf
*packet
, bool steal
,
161 struct pkt_metadata
*md
, const struct nlattr
*action
,
162 odp_execute_cb dp_execute_action
, bool more_actions
)
164 const struct nlattr
*subactions
= NULL
;
165 const struct nlattr
*a
;
168 NL_NESTED_FOR_EACH_UNSAFE (a
, left
, action
) {
169 int type
= nl_attr_type(a
);
171 switch ((enum ovs_sample_attr
) type
) {
172 case OVS_SAMPLE_ATTR_PROBABILITY
:
173 if (random_uint32() >= nl_attr_get_u32(a
)) {
178 case OVS_SAMPLE_ATTR_ACTIONS
:
182 case OVS_SAMPLE_ATTR_UNSPEC
:
183 case __OVS_SAMPLE_ATTR_MAX
:
189 odp_execute_actions__(dp
, packet
, steal
, md
, nl_attr_get(subactions
),
190 nl_attr_get_size(subactions
), dp_execute_action
,
195 odp_execute_actions__(void *dp
, struct ofpbuf
*packet
, bool steal
,
196 struct pkt_metadata
*md
,
197 const struct nlattr
*actions
, size_t actions_len
,
198 odp_execute_cb dp_execute_action
, bool more_actions
)
200 const struct nlattr
*a
;
203 NL_ATTR_FOR_EACH_UNSAFE (a
, left
, actions
, actions_len
) {
204 int type
= nl_attr_type(a
);
206 switch ((enum ovs_action_attr
) type
) {
207 /* These only make sense in the context of a datapath. */
208 case OVS_ACTION_ATTR_OUTPUT
:
209 case OVS_ACTION_ATTR_USERSPACE
:
210 case OVS_ACTION_ATTR_RECIRC
:
211 if (dp_execute_action
) {
212 /* Allow 'dp_execute_action' to steal the packet data if we do
213 * not need it any more. */
214 bool may_steal
= steal
&& (!more_actions
215 && left
<= NLA_ALIGN(a
->nla_len
)
216 && type
!= OVS_ACTION_ATTR_RECIRC
);
217 dp_execute_action(dp
, packet
, md
, a
, may_steal
);
221 case OVS_ACTION_ATTR_PUSH_VLAN
: {
222 const struct ovs_action_push_vlan
*vlan
= nl_attr_get(a
);
223 eth_push_vlan(packet
, htons(ETH_TYPE_VLAN
), vlan
->vlan_tci
);
227 case OVS_ACTION_ATTR_POP_VLAN
:
228 eth_pop_vlan(packet
);
231 case OVS_ACTION_ATTR_PUSH_MPLS
: {
232 const struct ovs_action_push_mpls
*mpls
= nl_attr_get(a
);
233 push_mpls(packet
, mpls
->mpls_ethertype
, mpls
->mpls_lse
);
237 case OVS_ACTION_ATTR_POP_MPLS
:
238 pop_mpls(packet
, nl_attr_get_be16(a
));
241 case OVS_ACTION_ATTR_SET
:
242 odp_execute_set_action(packet
, nl_attr_get(a
), md
);
245 case OVS_ACTION_ATTR_SAMPLE
:
246 odp_execute_sample(dp
, packet
, steal
, md
, a
, dp_execute_action
,
247 more_actions
|| left
> NLA_ALIGN(a
->nla_len
));
250 case OVS_ACTION_ATTR_UNSPEC
:
251 case __OVS_ACTION_ATTR_MAX
:
258 odp_execute_actions(void *dp
, struct ofpbuf
*packet
, bool steal
,
259 struct pkt_metadata
*md
,
260 const struct nlattr
*actions
, size_t actions_len
,
261 odp_execute_cb dp_execute_action
)
263 odp_execute_actions__(dp
, packet
, steal
, md
, actions
, actions_len
,
264 dp_execute_action
, false);
266 if (!actions_len
&& steal
) {
268 ofpbuf_delete(packet
);