diff options
author | Dimitri Staessens <[email protected]> | 2020-02-15 21:39:24 +0100 |
---|---|---|
committer | Sander Vrijders <[email protected]> | 2020-02-16 18:26:07 +0100 |
commit | b46ba7bb7405c3b5a85f4203f816e623a5edb2d7 (patch) | |
tree | c18930ab79341f982388082e1799fce537b0a64c /src/ipcpd/unicast/pol/simple_pff.c | |
parent | f78ab5787773fbda3be5581a3b48f43ec7acd9d3 (diff) | |
download | ouroboros-b46ba7bb7405c3b5a85f4203f816e623a5edb2d7.tar.gz ouroboros-b46ba7bb7405c3b5a85f4203f816e623a5edb2d7.zip |
ipcpd: Rename hashtable to pft
This makes the hashtable more tailored to a packet forwarding table
(PFT). In the end not much of a change was needed, but now it's clear
the pft maps a destination address to a list of (outgoing) fds.
Signed-off-by: Dimitri Staessens <[email protected]>
Signed-off-by: Sander Vrijders <[email protected]>
Diffstat (limited to 'src/ipcpd/unicast/pol/simple_pff.c')
-rw-r--r-- | src/ipcpd/unicast/pol/simple_pff.c | 49 |
1 files changed, 25 insertions, 24 deletions
diff --git a/src/ipcpd/unicast/pol/simple_pff.c b/src/ipcpd/unicast/pol/simple_pff.c index 3d294d90..c5780703 100644 --- a/src/ipcpd/unicast/pol/simple_pff.c +++ b/src/ipcpd/unicast/pol/simple_pff.c @@ -29,11 +29,11 @@ #include <assert.h> #include <pthread.h> -#include "hashtable.h" +#include "pft.h" #include "simple_pff.h" struct pff_i { - struct htable * table; + struct pft * pft; pthread_rwlock_t lock; }; @@ -63,8 +63,8 @@ struct pff_i * simple_pff_create(void) return NULL; } - tmp->table = htable_create(PFT_SIZE, false); - if (tmp->table == NULL) { + tmp->pft = pft_create(PFT_SIZE, false); + if (tmp->pft == NULL) { pthread_rwlock_destroy(&tmp->lock); free(tmp); return NULL; @@ -77,7 +77,7 @@ void simple_pff_destroy(struct pff_i * pff_i) { assert(pff_i); - htable_destroy(pff_i->table); + pft_destroy(pff_i->pft); pthread_rwlock_destroy(&pff_i->lock); free(pff_i); @@ -98,21 +98,21 @@ int simple_pff_add(struct pff_i * pff_i, int * fd, size_t len) { - int * val; + int * fds; assert(pff_i); assert(len > 0); (void) len; - val = malloc(sizeof(*val)); - if (val == NULL) + fds = malloc(sizeof(*fds)); + if (fds == NULL) return -ENOMEM; - *val = fd[0]; + *fds = *fd; - if (htable_insert(pff_i->table, addr, val, 1)) { - free(val); + if (pft_insert(pff_i->pft, addr, fds, 1)) { + free(fds); return -1; } @@ -124,25 +124,26 @@ int simple_pff_update(struct pff_i * pff_i, int * fd, size_t len) { - int * val; + int * fds; assert(pff_i); assert(len > 0); (void) len; - val = malloc(sizeof(*val)); - if (val == NULL) + fds = malloc(sizeof(*fds)); + if (fds == NULL) return -ENOMEM; - *val = fd[0]; - if (htable_delete(pff_i->table, addr)) { - free(val); + *fds = *fd; + + if (pft_delete(pff_i->pft, addr)) { + free(fds); return -1; } - if (htable_insert(pff_i->table, addr, val, 1)) { - free(val); + if (pft_insert(pff_i->pft, addr, fds, 1)) { + free(fds); return -1; } @@ -154,7 +155,7 @@ int simple_pff_del(struct pff_i * pff_i, { assert(pff_i); - if (htable_delete(pff_i->table, addr)) + if (pft_delete(pff_i->pft, addr)) return -1; return 0; @@ -164,13 +165,13 @@ void simple_pff_flush(struct pff_i * pff_i) { assert(pff_i); - htable_flush(pff_i->table); + pft_flush(pff_i->pft); } int simple_pff_nhop(struct pff_i * pff_i, uint64_t addr) { - void * j; + int * fds; size_t len; int fd = -1; @@ -178,8 +179,8 @@ int simple_pff_nhop(struct pff_i * pff_i, pthread_rwlock_rdlock(&pff_i->lock); - if (!htable_lookup(pff_i->table, addr, &j, &len)) - fd = *((int *) j); + if (pft_lookup(pff_i->pft, addr, &fds, &len) == 0) + fd = *fds; pthread_rwlock_unlock(&pff_i->lock); |