1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
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 */
|
