From: Justin Pettit Date: Fri, 11 Apr 2008 01:31:44 +0000 (-0700) Subject: Remove MAC table support. X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=6d188895dc80ef0b5ee620de7d61f6527b15cf53;p=openvswitch Remove MAC table support. --- diff --git a/ChangeLog b/ChangeLog index 056f51a9..97aa4474 100644 --- a/ChangeLog +++ b/ChangeLog @@ -1,3 +1,8 @@ +v0.2.2 - 13 Apr 2008 +-------------------- + - Removed MAC tables + - Various bug fixes and tweaks + v0.2.1 - 28 Mar 2008 -------------------- - Fixed build problem when SSL enabled diff --git a/datapath/Makefile.am b/datapath/Makefile.am index 3dda217a..64c5077a 100644 --- a/datapath/Makefile.am +++ b/datapath/Makefile.am @@ -8,7 +8,7 @@ endif EXTRA_DIST = linux-2.6 linux-2.4\ datapath.c snap.h chain.c crc32.c crc_t.c\ - flow.h forward.h table-hash.c table-mac.c\ + flow.h forward.h table-hash.c\ unit.c unit.h datapath.h chain.h crc32.h\ flow.c forward.c forward_t.c table.h\ table-linear.c table_t.c unit-exports.c\ diff --git a/datapath/chain.c b/datapath/chain.c index 2f8708e0..6d3784cc 100644 --- a/datapath/chain.c +++ b/datapath/chain.c @@ -35,9 +35,7 @@ struct sw_chain *chain_create(struct datapath *dp) return NULL; chain->dp = dp; - if (add_table(chain, table_mac_create(TABLE_MAC_NUM_BUCKETS, - TABLE_MAC_MAX_FLOWS)) - || add_table(chain, table_hash2_create(0x1EDC6F41, TABLE_HASH_MAX_FLOWS, + if (add_table(chain, table_hash2_create(0x1EDC6F41, TABLE_HASH_MAX_FLOWS, 0x741B8CD7, TABLE_HASH_MAX_FLOWS)) || add_table(chain, table_linear_create(TABLE_LINEAR_MAX_FLOWS))) { chain_destroy(chain); diff --git a/datapath/linux-2.4/Makefile.in b/datapath/linux-2.4/Makefile.in index 8e4ba5ba..c9308dca 100644 --- a/datapath/linux-2.4/Makefile.in +++ b/datapath/linux-2.4/Makefile.in @@ -6,7 +6,7 @@ export KVERSION = 2.4 export VMDIR = @VMDIR@ SHAREDFILES = ../chain.c ../crc32.c ../table-hash.c ../table-linear.c \ - ../table-mac.c ../forward.c ../flow.c ../unit-exports.c \ + ../forward.c ../flow.c ../unit-exports.c \ ../dp_dev.c ../datapath_t.c SIMLINKFILES = $(patsubst ../%,%, $(SHAREDFILES)) diff --git a/datapath/linux-2.6/Makefile.in b/datapath/linux-2.6/Makefile.in index 5a7cb55f..15402038 100644 --- a/datapath/linux-2.6/Makefile.in +++ b/datapath/linux-2.6/Makefile.in @@ -12,7 +12,7 @@ CFLAGS_EXTRA += -I $(srcdir)/.. -I $(srcdir)/datapath/ -I $(top_srcdir)/include # Files shared between 2.4 and 2.6 builds SHAREDFILES = ../chain.c ../crc32.c ../table-hash.c ../table-linear.c \ - ../table-mac.c ../forward.c ../flow.c ../unit-exports.c \ + ../forward.c ../flow.c ../unit-exports.c \ ../datapath_t.c ../dp_dev.c \ compat-2.6/genetlink.c \ compat-2.6/random32.c diff --git a/datapath/table-mac.c b/datapath/table-mac.c deleted file mode 100644 index 4e081ad2..00000000 --- a/datapath/table-mac.c +++ /dev/null @@ -1,272 +0,0 @@ -/* - * Distributed under the terms of the GNU GPL version 2. - * Copyright (c) 2007, 2008 The Board of Trustees of The Leland - * Stanford Junior University - */ - -#include "table.h" -#include "crc32.h" -#include "flow.h" -#include "openflow.h" -#include "datapath.h" - -#include - -struct sw_table_mac { - struct sw_table swt; - spinlock_t lock; - struct crc32 crc32; - atomic_t n_flows; - unsigned int max_flows; - unsigned int bucket_mask; /* Number of buckets minus 1. */ - struct hlist_head *buckets; -}; - -static struct hlist_head *find_bucket(struct sw_table *swt, - const struct sw_flow_key *key) -{ - struct sw_table_mac *tm = (struct sw_table_mac *) swt; - unsigned int crc = crc32_calculate(&tm->crc32, key, sizeof *key); - return &tm->buckets[crc & tm->bucket_mask]; -} - -static struct sw_flow *table_mac_lookup(struct sw_table *swt, - const struct sw_flow_key *key) -{ - struct hlist_head *bucket = find_bucket(swt, key); - struct hlist_node *pos; - struct sw_flow *flow; - hlist_for_each_entry_rcu (flow, pos, bucket, u.hnode) - if (!memcmp(key->dl_src, flow->key.dl_src, 6)) - return flow; - return NULL; -} - -static int table_mac_insert(struct sw_table *swt, struct sw_flow *flow) -{ - struct sw_table_mac *tm = (struct sw_table_mac *) swt; - struct hlist_head *bucket; - struct hlist_node *pos; - unsigned long int flags; - struct sw_flow *f; - - /* MAC table only handles flows that match on Ethernet - source address and wildcard everything else. */ - if (likely(flow->key.wildcards != (OFPFW_ALL & ~OFPFW_DL_SRC))) - return 0; - bucket = find_bucket(swt, &flow->key); - - spin_lock_irqsave(&tm->lock, flags); - hlist_for_each_entry_rcu (f, pos, bucket, u.hnode) { - if (!memcmp(f->key.dl_src, flow->key.dl_src, 6) - && flow_del(f)) { - hlist_replace_rcu(&f->u.hnode, &flow->u.hnode); - spin_unlock_irqrestore(&tm->lock, flags); - flow_deferred_free(f); - return 1; - } - } - - /* Table overflow? */ - if (atomic_read(&tm->n_flows) >= tm->max_flows) { - spin_unlock_irqrestore(&tm->lock, flags); - return 0; - } - atomic_inc(&tm->n_flows); - - hlist_add_head_rcu(&flow->u.hnode, bucket); - spin_unlock_irqrestore(&tm->lock, flags); - return 1; -} - -static int do_delete(struct sw_table *swt, struct sw_flow *flow) -{ - if (flow_del(flow)) { - hlist_del_rcu(&flow->u.hnode); - flow_deferred_free(flow); - return 1; - } - return 0; -} - -/* Returns number of deleted flows. */ -static int table_mac_delete(struct sw_table *swt, - const struct sw_flow_key *key, int strict) -{ - struct sw_table_mac *tm = (struct sw_table_mac *) swt; - - if (key->wildcards == (OFPFW_ALL & ~OFPFW_DL_SRC)) { - struct sw_flow *flow = table_mac_lookup(swt, key); - if (flow && do_delete(swt, flow)) { - atomic_dec(&tm->n_flows); - return 1; - } - return 0; - } else { - unsigned int i; - int count = 0; - for (i = 0; i <= tm->bucket_mask; i++) { - struct hlist_head *bucket = &tm->buckets[i]; - struct hlist_node *pos; - struct sw_flow *flow; - hlist_for_each_entry_rcu (flow, pos, bucket, u.hnode) - if (flow_del_matches(&flow->key, key, strict)) - count += do_delete(swt, flow); - } - if (count) - atomic_sub(count, &tm->n_flows); - return count; - } -} - -static int table_mac_timeout(struct datapath *dp, struct sw_table *swt) -{ - struct sw_table_mac *tm = (struct sw_table_mac *) swt; - unsigned int i; - int count = 0; - - for (i = 0; i <= tm->bucket_mask; i++) { - struct hlist_head *bucket = &tm->buckets[i]; - struct hlist_node *pos; - struct sw_flow *flow; - hlist_for_each_entry_rcu (flow, pos, bucket, u.hnode) { - if (flow_timeout(flow)) { - count += do_delete(swt, flow); - if (dp->hello_flags & OFP_CHELLO_SEND_FLOW_EXP) - dp_send_flow_expired(dp, flow); - } - } - } - if (count) - atomic_sub(count, &tm->n_flows); - return count; -} - -static void table_mac_destroy(struct sw_table *swt) -{ - struct sw_table_mac *tm = (struct sw_table_mac *) swt; - unsigned int i; - for (i = 0; i <= tm->bucket_mask; i++) { - struct hlist_head *hlist = &tm->buckets[i]; - while (!hlist_empty(hlist)) { - struct sw_flow *flow = hlist_entry(hlist->first, - struct sw_flow, u.hnode); - hlist_del(&flow->u.hnode); - flow_free(flow); - } - } - kfree(tm->buckets); - kfree(tm); -} - -struct swt_iterator_mac { - struct sw_table_mac *tm; - unsigned int bucket_i; -}; - -static struct sw_flow *next_head_flow(struct swt_iterator_mac *im) -{ - for (; im->bucket_i <= im->tm->bucket_mask; im->bucket_i++) { - struct hlist_node *first = im->tm->buckets[im->bucket_i].first; - if (first != NULL) { - struct sw_flow *f = hlist_entry(first, - struct sw_flow, - u.hnode); - return f; - } - } - return NULL; -} - -static int table_mac_iterator(struct sw_table *swt, - struct swt_iterator *swt_iter) -{ - struct swt_iterator_mac *im; - - swt_iter->private = im = kmalloc(sizeof *im, GFP_KERNEL); - if (im == NULL) - return 0; - - im->tm = (struct sw_table_mac *) swt; - - if (atomic_read(&im->tm->n_flows) == 0) - swt_iter->flow = NULL; - else { - im->bucket_i = 0; - swt_iter->flow = next_head_flow(im); - } - - return 1; -} - -static void table_mac_next(struct swt_iterator *swt_iter) -{ - struct swt_iterator_mac *im; - struct hlist_node *next; - - if (swt_iter->flow == NULL) - return; - - im = (struct swt_iterator_mac *) swt_iter->private; - - next = swt_iter->flow->u.hnode.next; - if (next != NULL) { - swt_iter->flow = hlist_entry(next, struct sw_flow, u.hnode); - } else { - im->bucket_i++; - swt_iter->flow = next_head_flow(im); - } -} - -static void table_mac_iterator_destroy(struct swt_iterator *swt_iter) -{ - kfree(swt_iter->private); -} - -static void table_mac_stats(struct sw_table *swt, struct sw_table_stats *stats) -{ - struct sw_table_mac *tm = (struct sw_table_mac *) swt; - stats->name = "mac"; - stats->n_flows = atomic_read(&tm->n_flows); - stats->max_flows = tm->max_flows; -} - -struct sw_table *table_mac_create(unsigned int n_buckets, - unsigned int max_flows) -{ - struct sw_table_mac *tm; - struct sw_table *swt; - - tm = kzalloc(sizeof *tm, GFP_KERNEL); - if (tm == NULL) - return NULL; - - BUG_ON(n_buckets & (n_buckets - 1)); - - tm->buckets = kzalloc(n_buckets * sizeof *tm->buckets, GFP_KERNEL); - if (tm->buckets == NULL) { - printk("failed to allocate %u buckets\n", n_buckets); - kfree(tm); - return NULL; - } - tm->bucket_mask = n_buckets - 1; - - swt = &tm->swt; - swt->lookup = table_mac_lookup; - swt->insert = table_mac_insert; - swt->delete = table_mac_delete; - swt->timeout = table_mac_timeout; - swt->destroy = table_mac_destroy; - swt->stats = table_mac_stats; - - swt->iterator = table_mac_iterator; - swt->iterator_next = table_mac_next; - swt->iterator_destroy = table_mac_iterator_destroy; - - crc32_init(&tm->crc32, 0x04C11DB7); /* Ethernet CRC. */ - atomic_set(&tm->n_flows, 0); - tm->max_flows = max_flows; - spin_lock_init(&tm->lock); - - return swt; -} diff --git a/datapath/table.h b/datapath/table.h index 9a303670..dcb72b9d 100644 --- a/datapath/table.h +++ b/datapath/table.h @@ -63,8 +63,6 @@ struct sw_table { void (*stats)(struct sw_table *table, struct sw_table_stats *stats); }; -struct sw_table *table_mac_create(unsigned int n_buckets, - unsigned int max_flows); struct sw_table *table_hash_create(unsigned int polynomial, unsigned int n_buckets); struct sw_table *table_hash2_create(unsigned int poly0, unsigned int buckets0, diff --git a/datapath/table_t.c b/datapath/table_t.c index 8ab0d583..42687cf2 100644 --- a/datapath/table_t.c +++ b/datapath/table_t.c @@ -755,30 +755,18 @@ complex_test_destr: void run_table_t(void) { - int mac_buckets, mac_max, linear_max, hash_buckets, hash2_buckets1; + int linear_max, hash_buckets, hash2_buckets1; int hash2_buckets2, num_flows, num_iterations; int i; struct sw_table *swt; /* Most basic operations. */ - simple_insert_delete(table_mac_create(2048, 65536), - OFPFW_ALL & ~OFPFW_DL_SRC); simple_insert_delete(table_linear_create(2048), 0); simple_insert_delete(table_hash_create(0x04C11DB7, 2048), 0); simple_insert_delete(table_hash2_create(0x04C11DB7, 2048, 0x1EDC6F41, 2048), 0); - /* MAC table operations. */ - multiple_insert_destroy(table_mac_create(2048, 65536), 1024, - OFPFW_ALL & ~OFPFW_DL_SRC, 0, 0); - multiple_insert_destroy(table_mac_create(2048, 65536), 2048, - OFPFW_ALL & ~OFPFW_DL_SRC, 0, 0); - multiple_insert_destroy(table_mac_create(2048, 65536), 65535, - OFPFW_ALL & ~OFPFW_DL_SRC, 0, 0); - multiple_insert_destroy(table_mac_create(2048, 65536), - 131072, OFPFW_ALL & ~OFPFW_DL_SRC, 65536, 65536); - /* Linear table operations. */ multiple_insert_destroy(table_linear_create(2048), 1024, 0, 0, 0); multiple_insert_destroy(table_linear_create(2048), 2048, 0, 0, 0); @@ -817,8 +805,6 @@ void run_table_t(void) multiple_insert_destroy(table_hash2_create(0x04C11DB7, 1<<20, 0x04C11DB7, 1<<20), 1<<16, 0, 0, 100); - mac_buckets = 1024; - mac_max = 2048; linear_max = 2048; hash_buckets = 2048; hash2_buckets1 = 1024; @@ -835,7 +821,7 @@ void run_table_t(void) printk(" complex_add_delete_test with %d flows and %d iterations\n\n", num_flows, num_iterations); - for (i = 0; i < 4; i++) { + for (i = 0; i < 3; i++) { unsigned int mask = i == 0 ? : 0; if (unit_failed()) @@ -844,16 +830,12 @@ void run_table_t(void) mask = 0; switch (i) { case 0: - swt = table_mac_create(mac_buckets, mac_max); - mask = OFPFW_ALL & ~OFPFW_DL_SRC; - break; - case 1: swt = table_linear_create(linear_max); break; - case 2: + case 1: swt = table_hash_create (0x04C11DB7, hash_buckets); break; - case 3: + case 2: swt = table_hash2_create(0x04C11DB7, hash2_buckets1, 0x1EDC6F41, hash2_buckets2); break; @@ -867,7 +849,7 @@ void run_table_t(void) return; } printk("Testing %s table with %d buckets and %d max flows...\n", - table_name(swt), mac_buckets, mac_max); + table_name(swt), hash_buckets, num_flows); iterator_test(swt, 0, mask); iterator_test(swt, num_flows, mask); add_test(swt, mask); diff --git a/datapath/unit-exports.c b/datapath/unit-exports.c index 9db5bdd3..0dc3fa0b 100644 --- a/datapath/unit-exports.c +++ b/datapath/unit-exports.c @@ -14,7 +14,6 @@ EXPORT_SYMBOL(flow_alloc); EXPORT_SYMBOL(flow_free); EXPORT_SYMBOL(flow_cache); -EXPORT_SYMBOL(table_mac_create); EXPORT_SYMBOL(table_hash_create); EXPORT_SYMBOL(table_hash2_create); EXPORT_SYMBOL(table_linear_create);