]>
git.proxmox.com Git - ovs.git/blob - lib/tnl-ports.c
2 * Copyright (c) 2014, 2015 Nicira, Inc.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at:
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
21 #include "classifier.h"
22 #include "dynamic-string.h"
25 #include "ovs-thread.h"
27 #include "tnl-arp-cache.h"
28 #include "tnl-ports.h"
29 #include "ovs-thread.h"
33 static struct ovs_mutex mutex
= OVS_MUTEX_INITIALIZER
;
34 static struct classifier cls
; /* Tunnel ports. */
39 struct ovs_refcount ref_cnt
;
40 char dev_name
[IFNAMSIZ
];
43 static struct tnl_port_in
*
44 tnl_port_cast(const struct cls_rule
*cr
)
46 BUILD_ASSERT_DECL(offsetof(struct tnl_port_in
, cr
) == 0);
48 return CONTAINER_OF(cr
, struct tnl_port_in
, cr
);
52 tnl_port_free(struct tnl_port_in
*p
)
54 cls_rule_destroy(&p
->cr
);
59 tnl_port_init_flow(struct flow
*flow
, ovs_be32 ip_dst
, ovs_be16 udp_port
)
61 memset(flow
, 0, sizeof *flow
);
62 flow
->dl_type
= htons(ETH_TYPE_IP
);
64 flow
->nw_proto
= IPPROTO_UDP
;
66 flow
->nw_proto
= IPPROTO_GRE
;
68 flow
->tp_dst
= udp_port
;
69 /* When matching on incoming flow from remove tnl end point,
70 * our dst ip address is source ip for them. */
71 flow
->nw_src
= ip_dst
;
75 tnl_port_map_insert(odp_port_t port
, ovs_be32 ip_dst
, ovs_be16 udp_port
,
76 const char dev_name
[])
78 const struct cls_rule
*cr
;
79 struct tnl_port_in
*p
;
82 memset(&match
, 0, sizeof match
);
83 tnl_port_init_flow(&match
.flow
, ip_dst
, udp_port
);
85 ovs_mutex_lock(&mutex
);
87 cr
= classifier_lookup(&cls
, &match
.flow
, NULL
);
88 p
= tnl_port_cast(cr
);
89 /* Try again if the rule was released before we get the reference. */
90 } while (p
&& !ovs_refcount_try_ref_rcu(&p
->ref_cnt
));
93 p
= xzalloc(sizeof *p
);
96 match
.wc
.masks
.dl_type
= OVS_BE16_MAX
;
97 match
.wc
.masks
.nw_proto
= 0xff;
98 match
.wc
.masks
.nw_frag
= 0xff; /* XXX: No fragments support. */
99 match
.wc
.masks
.tp_dst
= OVS_BE16_MAX
;
100 match
.wc
.masks
.nw_src
= OVS_BE32_MAX
;
102 cls_rule_init(&p
->cr
, &match
, 0); /* Priority == 0. */
103 ovs_refcount_init(&p
->ref_cnt
);
104 strncpy(p
->dev_name
, dev_name
, IFNAMSIZ
);
106 classifier_insert(&cls
, &p
->cr
, NULL
, 0);
108 ovs_mutex_unlock(&mutex
);
112 tnl_port_unref(const struct cls_rule
*cr
)
114 struct tnl_port_in
*p
= tnl_port_cast(cr
);
116 if (cr
&& ovs_refcount_unref_relaxed(&p
->ref_cnt
) == 1) {
117 ovs_mutex_lock(&mutex
);
118 if (classifier_remove(&cls
, cr
)) {
119 ovsrcu_postpone(tnl_port_free
, p
);
121 ovs_mutex_unlock(&mutex
);
126 tnl_port_map_delete(ovs_be32 ip_dst
, ovs_be16 udp_port
)
128 const struct cls_rule
*cr
;
131 tnl_port_init_flow(&flow
, ip_dst
, udp_port
);
133 cr
= classifier_lookup(&cls
, &flow
, NULL
);
137 /* 'flow' is non-const to allow for temporary modifications during the lookup.
138 * Any changes are restored before returning. */
140 tnl_port_map_lookup(struct flow
*flow
, struct flow_wildcards
*wc
)
142 const struct cls_rule
*cr
= classifier_lookup(&cls
, flow
, wc
);
144 return (cr
) ? tnl_port_cast(cr
)->portno
: ODPP_NONE
;
148 tnl_port_show(struct unixctl_conn
*conn
, int argc OVS_UNUSED
,
149 const char *argv
[] OVS_UNUSED
, void *aux OVS_UNUSED
)
151 struct ds ds
= DS_EMPTY_INITIALIZER
;
152 const struct tnl_port_in
*p
;
154 ds_put_format(&ds
, "Listening ports:\n");
155 CLS_FOR_EACH(p
, cr
, &cls
) {
156 struct odputil_keybuf keybuf
;
157 struct odputil_keybuf maskbuf
;
159 const struct nlattr
*key
, *mask
;
160 size_t key_len
, mask_len
;
161 struct flow_wildcards wc
;
164 ds_put_format(&ds
, "%s (%"PRIu32
") : ", p
->dev_name
, p
->portno
);
165 minimask_expand(&p
->cr
.match
.mask
, &wc
);
166 miniflow_expand(&p
->cr
.match
.flow
, &flow
);
169 ofpbuf_use_stack(&buf
, &keybuf
, sizeof keybuf
);
170 odp_flow_key_from_flow(&buf
, &flow
, &wc
.masks
,
171 flow
.in_port
.odp_port
, true);
172 key
= ofpbuf_data(&buf
);
173 key_len
= ofpbuf_size(&buf
);
175 ofpbuf_use_stack(&buf
, &maskbuf
, sizeof maskbuf
);
176 odp_flow_key_from_mask(&buf
, &wc
.masks
, &flow
,
177 odp_to_u32(wc
.masks
.in_port
.odp_port
),
179 mask
= ofpbuf_data(&buf
);
180 mask_len
= ofpbuf_size(&buf
);
183 odp_flow_format(key
, key_len
, mask
, mask_len
, NULL
, &ds
, false);
184 ds_put_format(&ds
, "\n");
186 unixctl_command_reply(conn
, ds_cstr(&ds
));
191 tnl_port_map_init(void)
193 classifier_init(&cls
, flow_segment_u64s
);
194 unixctl_command_register("tnl/ports/show", "", 0, 0, tnl_port_show
, NULL
);