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.
24 #include "dpif-netdev.h"
25 #include "dynamic-string.h"
29 #include "ovs-thread.h"
31 #include "poll-loop.h"
34 #include "tnl-arp-cache.h"
35 #include "unaligned.h"
38 #include "openvswitch/vlog.h"
42 #define ARP_ENTRY_DEFAULT_IDLE_TIME (15 * 60)
44 struct tnl_arp_entry {
45 struct cmap_node cmap_node;
47 uint8_t mac[ETH_ADDR_LEN];
48 time_t expires; /* Expiration time. */
49 char br_name[IFNAMSIZ];
52 static struct cmap table;
53 static struct ovs_mutex mutex = OVS_MUTEX_INITIALIZER;
55 static struct tnl_arp_entry *
56 tnl_arp_lookup__(const char br_name[IFNAMSIZ], ovs_be32 dst)
58 struct tnl_arp_entry *arp;
60 CMAP_FOR_EACH_WITH_HASH (arp, cmap_node, (OVS_FORCE uint32_t) dst, &table) {
61 if (arp->ip == dst && !strcmp(arp->br_name, br_name)) {
62 arp->expires = time_now() + ARP_ENTRY_DEFAULT_IDLE_TIME;
70 tnl_arp_lookup(const char br_name[IFNAMSIZ], ovs_be32 dst,
71 uint8_t mac[ETH_ADDR_LEN])
73 struct tnl_arp_entry *arp;
76 arp = tnl_arp_lookup__(br_name, dst);
78 memcpy(mac, arp->mac, ETH_ADDR_LEN);
86 arp_entry_free(struct tnl_arp_entry *arp)
92 tnl_arp_delete(struct tnl_arp_entry *arp)
94 cmap_remove(&table, &arp->cmap_node, (OVS_FORCE uint32_t) arp->ip);
95 ovsrcu_postpone(arp_entry_free, arp);
99 tnl_arp_snoop(const struct flow *flow, struct flow_wildcards *wc,
100 const char name[IFNAMSIZ])
102 struct tnl_arp_entry *arp;
104 if (flow->dl_type != htons(ETH_TYPE_ARP)) {
108 /* Exact Match on all ARP flows. */
109 memset(&wc->masks.nw_proto, 0xff, sizeof wc->masks.nw_proto);
110 memset(&wc->masks.nw_src, 0xff, sizeof wc->masks.nw_src);
111 memset(&wc->masks.arp_sha, 0xff, sizeof wc->masks.arp_sha);
113 ovs_mutex_lock(&mutex);
114 arp = tnl_arp_lookup__(name, flow->nw_src);
116 if (!memcmp(arp->mac, flow->arp_sha, ETH_ADDR_LEN)) {
117 arp->expires = time_now() + ARP_ENTRY_DEFAULT_IDLE_TIME;
118 ovs_mutex_unlock(&mutex);
122 seq_change(tnl_conf_seq);
125 arp = xmalloc(sizeof *arp);
127 arp->ip = flow->nw_src;
128 memcpy(arp->mac, flow->arp_sha, ETH_ADDR_LEN);
129 arp->expires = time_now() + ARP_ENTRY_DEFAULT_IDLE_TIME;
130 ovs_strlcpy(arp->br_name, name, sizeof arp->br_name);
131 cmap_insert(&table, &arp->cmap_node, (OVS_FORCE uint32_t) arp->ip);
132 ovs_mutex_unlock(&mutex);
137 tnl_arp_cache_run(void)
139 struct tnl_arp_entry *arp;
140 bool changed = false;
142 ovs_mutex_lock(&mutex);
143 CMAP_FOR_EACH(arp, cmap_node, &table) {
144 if (arp->expires <= time_now()) {
149 ovs_mutex_unlock(&mutex);
152 seq_change(tnl_conf_seq);
157 tnl_arp_cache_flush(struct unixctl_conn *conn OVS_UNUSED, int argc OVS_UNUSED,
158 const char *argv[] OVS_UNUSED, void *aux OVS_UNUSED)
160 struct tnl_arp_entry *arp;
161 bool changed = false;
163 ovs_mutex_lock(&mutex);
164 CMAP_FOR_EACH(arp, cmap_node, &table) {
168 ovs_mutex_unlock(&mutex);
170 seq_change(tnl_conf_seq);
172 unixctl_command_reply(conn, "OK");
175 #define MAX_IP_ADDR_LEN 17
178 tnl_arp_cache_show(struct unixctl_conn *conn, int argc OVS_UNUSED,
179 const char *argv[] OVS_UNUSED, void *aux OVS_UNUSED)
181 struct ds ds = DS_EMPTY_INITIALIZER;
182 struct tnl_arp_entry *arp;
184 ds_put_cstr(&ds, "IP MAC Bridge\n");
185 ds_put_cstr(&ds, "=============================================\n");
186 ovs_mutex_lock(&mutex);
187 CMAP_FOR_EACH(arp, cmap_node, &table) {
188 int start_len, need_ws;
190 start_len = ds.length;
191 ds_put_format(&ds, IP_FMT, IP_ARGS(arp->ip));
193 need_ws = MAX_IP_ADDR_LEN - (ds.length - start_len);
194 ds_put_char_multiple(&ds, ' ', need_ws);
196 ds_put_format(&ds, ETH_ADDR_FMT" %s\n",
197 ETH_ADDR_ARGS(arp->mac), arp->br_name);
200 ovs_mutex_unlock(&mutex);
201 unixctl_command_reply(conn, ds_cstr(&ds));
206 tnl_arp_cache_init(void)
210 unixctl_command_register("tnl/arp/show", "", 0, 0, tnl_arp_cache_show, NULL);
211 unixctl_command_register("tnl/arp/flush", "", 0, 0, tnl_arp_cache_flush, NULL);