48 u32 transport_proto = va_arg (*args,
u32);
49 switch (transport_proto)
64 u32 transport_proto = va_arg (*args,
u32);
65 switch (transport_proto)
80 u32 *proto = va_arg (*args,
u32 *);
96 ip46_address_t * ip,
u16 port)
101 kv.
key[0] = ip->as_u64[0];
102 kv.
key[1] = ip->as_u64[1];
103 kv.
key[2] = (
u64) port << 8 | (
u64) proto;
105 rv = clib_bihash_search_inline_24_8 (ht, &kv);
118 kv.
key[0] = te->ip.as_u64[0];
119 kv.
key[1] = te->ip.as_u64[1];
120 kv.
key[2] = (
u64) te->port << 8 | (
u64) proto;
123 clib_bihash_add_del_24_8 (ht, &kv, 1);
132 kv.
key[0] = te->ip.as_u64[0];
133 kv.
key[1] = te->ip.as_u64[1];
134 kv.
key[2] = (
u64) te->port << 8 | (
u64) proto;
136 clib_bihash_add_del_24_8 (ht, &kv, 0);
156 tp_vfts[transport_proto] = *vft;
171 return &
tp_vfts[transport_proto];
174 #define PORT_MASK ((1 << 16)- 1) 200 clib_net_to_host_u16 (port));
218 u16 min = 1024, max = 65535;
227 for (tries = 0; tries < limit; tries++)
260 ip46_address_t * lcl_addr,
u16 * lcl_port)
274 prefix.
fp_len = rmt->is_ip4 ? 32 : 128;
286 sw_if_index = rmt->sw_if_index;
293 &rmt->ip, (rmt->is_ip4 == 0) + 1);
297 memset (lcl_addr, 0,
sizeof (*lcl_addr));
303 lcl_addr->ip4.as_u32 = ip4->
as_u32;
336 if (vft->update_time)
337 (vft->update_time) (time_now, thread_index);
348 (vft->enable) (vm, is_en);
359 if (smm->local_endpoints_table_buckets == 0)
360 smm->local_endpoints_table_buckets = 250000;
361 if (smm->local_endpoints_table_memory == 0)
362 smm->local_endpoints_table_memory = 512 << 20;
368 smm->local_endpoints_table_buckets,
369 smm->local_endpoints_table_memory);
#define vec_validate(V, I)
Make sure vector is long enough for given index (no header, unspecified alignment) ...
fib_protocol_t fp_proto
protocol type
u32 transport_endpoint_lookup(transport_endpoint_table_t *ht, u8 proto, ip46_address_t *ip, u16 port)
u8 * format_transport_proto_short(u8 *s, va_list *args)
vnet_main_t * vnet_get_main(void)
void transport_endpoint_table_add(transport_endpoint_table_t *ht, u8 proto, transport_endpoint_t *te, u32 value)
static transport_endpoint_table_t local_endpoints_table
static_always_inline void clib_spinlock_unlock_if_init(clib_spinlock_t *p)
struct _transport_proto_vft transport_proto_vft_t
static u64 clib_cpu_time_now(void)
void * ip_interface_get_first_ip(u32 sw_if_index, u8 is_ip4)
#define pool_get(P, E)
Allocate an object E from a pool P (unspecified alignment).
void transport_endpoint_del(u32 tepi)
format_function_t format_vnet_sw_if_index_name
void transport_update_time(f64 time_now, u8 thread_index)
enum fib_protocol_t_ fib_protocol_t
Protocol Type.
Aggregrate type for a prefix.
u16 fp_len
The mask length.
static clib_spinlock_t local_endpoints_lock
fib_node_index_t fib_table_lookup(u32 fib_index, const fib_prefix_t *prefix)
Perfom a longest prefix match in the non-forwarding table.
static void clib_spinlock_init(clib_spinlock_t *p)
transport_proto_vft_t * transport_protocol_get_vft(transport_proto_t transport_proto)
Get transport virtual function table.
static session_manager_main_t * vnet_get_session_manager_main()
#define pool_elt_at_index(p, i)
Returns pointer to element at given index.
void transport_endpoint_table_del(transport_endpoint_table_t *ht, u8 proto, transport_endpoint_t *te)
ip46_address_t fp_addr
The address type is not deriveable from the fp_addr member.
static transport_endpoint_t * local_endpoints
transport_proto_vft_t * tp_vfts
Per-type vector of transport protocol virtual function tables.
struct _session_manager_main session_manager_main_t
u32 fib_entry_get_resolving_interface(fib_node_index_t entry_index)
void transport_init(void)
static_always_inline uword vlib_get_thread_index(void)
clib_bihash_24_8_t transport_endpoint_table_t
#define ENDPOINT_INVALID_INDEX
#define clib_warning(format, args...)
#define clib_memcpy(a, b, c)
u32 fib_node_index_t
A typedef of a node index.
void transport_enable_disable(vlib_main_t *vm, u8 is_en)
void transport_endpoint_cleanup(u8 proto, ip46_address_t *lcl_ip, u16 port)
void transport_register_protocol(transport_proto_t transport_proto, const transport_proto_vft_t *vft, fib_protocol_t fib_proto, u32 output_node)
Register transport virtual function table.
#define pool_put_index(p, i)
Free pool element with given index.
uword unformat_transport_proto(unformat_input_t *input, va_list *args)
static transport_endpoint_t * transport_endpoint_new(void)
static u32 port_allocator_seed
#define FIB_NODE_INDEX_INVALID
enum _transport_proto transport_proto_t
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
struct _transport_endpoint transport_endpoint_t
static u32 random_u32(u32 *seed)
32-bit random number generator
static vlib_thread_main_t * vlib_get_thread_main()
#define vec_foreach(var, vec)
Vector iterator.
int transport_alloc_local_endpoint(u8 proto, transport_endpoint_t *rmt, ip46_address_t *lcl_addr, u16 *lcl_port)
int transport_alloc_local_port(u8 proto, ip46_address_t *ip)
Allocate local port and add if successful add entry to local endpoint table to mark the pair as used...
void session_register_transport(transport_proto_t transport_proto, const transport_proto_vft_t *vft, u8 is_ip4, u32 output_node)
Initialize session layer for given transport proto and ip version.
static_always_inline void clib_spinlock_lock_if_init(clib_spinlock_t *p)
u8 * format_transport_proto(u8 *s, va_list *args)