diff options
Diffstat (limited to 'hicn-light/src/hicn/core/listener_table.h')
| -rw-r--r-- | hicn-light/src/hicn/core/listener_table.h | 106 |
1 files changed, 106 insertions, 0 deletions
diff --git a/hicn-light/src/hicn/core/listener_table.h b/hicn-light/src/hicn/core/listener_table.h new file mode 100644 index 000000000..66959def4 --- /dev/null +++ b/hicn-light/src/hicn/core/listener_table.h @@ -0,0 +1,106 @@ +/* + * Copyright (c) 2020 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/** + * \file listener_table.h + * \brief hICN listener table + */ + +#ifndef HICN_LISTENER_TABLE_H +#define HICN_LISTENER_TABLE_H + +#include <hicn/core/address.h> +#include <hicn/base/common.h> +#include <hicn/base/hash.h> +#include <hicn/base/khash.h> +#include <hicn/core/listener.h> +#include <hicn/base/pool.h> + +#define _lt_var(x) _lt_var_##x + +#define key_hash(key) (hash(key, sizeof(listener_key_t))) +#define key_hash_eq(a, b) (key_hash(b) - key_hash(a)) + +KHASH_INIT(lt_name, const char *, unsigned, 0, str_hash, str_hash_eq); +KHASH_INIT(lt_key, listener_key_t *, unsigned, 0, key_hash, key_hash_eq); + +typedef struct { + kh_lt_key_t * id_by_key; + kh_lt_name_t * id_by_name; + listener_t * listeners; // pool +} listener_table_t; + +#define listener_table_allocate(TABLE, LISTENER, KEY, NAME) \ +do { \ + pool_get(table->listeners, (LISTENER)); \ + off_t _lt_var(id) = (LISTENER) - (TABLE)->listeners; \ + int _lt_var(res); \ + khiter_t _lt_var(k); \ + _lt_var(k) = kh_put_lt_name((TABLE)->id_by_name, (NAME), &_lt_var(res)); \ + kh_value((TABLE)->id_by_name, _lt_var(k)) = _lt_var(id); \ + \ + listener->type = (KEY)->type; \ + listener->address = (KEY)->address; \ + listener_key_t * _lt_var(key) = listener_get_key(LISTENER); \ + _lt_var(k) = kh_put_lt_key((TABLE)->id_by_key, _lt_var(key), &_lt_var(res));\ + kh_value((TABLE)->id_by_key, _lt_var(k)) = _lt_var(id); \ +} while(0) + +#define listener_table_deallocate(TABLE, LISTENER) \ +do { \ + const address_key_t * _lt_var(key) = listener_get_key(LISTENER); \ + khiter_t _lt_var(k); \ + _lt_var(k) = kh_get_ct_key((TABLE)->id_by_key, _lt_var(key)); \ + if (_lt_var(k) != kh_end((TABLE)>id_by_key)) \ + kh_del_ct_key((TABLE)->id_by_key, _lt_var(k)); \ + \ + const char * _lt_var(name) = listener_get_name(LISTENER); \ + _lt_var(k) = kh_get_ct_name((TABLE)->id_by_name, _lt_var(name)); \ + if (_lt_var(k) != kh_end((TABLE)->id_by_name)) \ + kh_del_ct_name((TABLE)->id_by_name, _lt_var(k)); \ + \ + pool_put((TABLE)->listeners, LISTENER); \ +} while(0) \ + + +#define listener_table_len(table) (pool_elts(table->listeners)) + +#define listener_table_validate_id(table, id) pool_validate_id(table->listeners, id) + +#define listener_table_at(table, id) ((table)->listeners + id) + +#define listener_table_get_by_id(table, id) \ + listener_table_validate_id(table, id) \ + ? listener_table_at(table, id) : NULL + +#define listener_table_get_listener_id(table, listener) (listener - table->listeners) + +#define listener_table_foreach(table, listener, BODY) \ + pool_foreach(table->listeners, listener, do { BODY } while(0) ) + +listener_table_t * listener_table_create(); +void listener_table_free(listener_table_t * table); + +listener_t * listener_table_get_by_address(listener_table_t * table, + face_type_t type, const address_t * address); + +listener_t * listener_table_get_by_name(listener_table_t * table, + const char *name); + +void listener_table_remove_by_id(listener_table_t * table, off_t id); + +unsigned listener_table_add(listener_table_t * table, listener_t * listener); + +#endif /* HICN_LISTENER_TABLE_H */ |