aboutsummaryrefslogtreecommitdiffstats
path: root/tests/vpp/perf/ip4/2n1l-10ge2p1x710-avf-ethip4-ip4scale20k-ndrpdr.robot
blob: 0423a28ee39e1e7149ab7458a9f48a0094ec0c8b (plain) 
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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133

# Copyright (c) 2019 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.

*** Settings ***
| Resource | resources/libraries/robot/shared/default.robot
| ...
| Force Tags | 2_NODE_SINGLE_LINK_TOPO | PERFTEST | HW_ENV | NDRPDR
| ... | NIC_Intel-X710 | ETH | IP4FWD | SCALE | FIB_20k | DRV_AVF
| ...
| Suite Setup | Setup suite single link | performance_avf
| Suite Teardown | Tear down suite | performance
| Test Setup | Setup test
| Test Teardown | Tear down test | performance
| ...
| Test Template | Local Template
| ...
| Documentation | *RFC2544: Pkt throughput IPv4 routing test cases*
| ...
| ... | *[Top] Network Topologies:* TG-DUT1-TG 2-node circular topology\
| ... | with single links between nodes.
| ... | *[Enc] Packet Encapsulations:* Eth-IPv4 for IPv4 routing.
| ... | *[Cfg] DUT configuration:* DUT1 is configured with IPv4 routing and\
| ... | 2x10k static IPv4 /32 route entries. DUT1 is tested with ${nic_name}\
| ... | with VF enabled.
| ... | *[Ver] TG verification:* TG finds and reports throughput NDR (Non Drop\
| ... | Rate) with zero packet loss tolerance and throughput PDR (Partial Drop\
| ... | Rate) with non-zero packet loss tolerance (LT) expressed in percentage\
| ... | of packets transmitted. NDR and PDR are discovered for different\
| ... | Ethernet L2 frame sizes using MLRsearch library.\
| ... | Test packets are generated by TG on links to DUT1. TG traffic profile\
| ... | contains two L3 flow-groups (flow-group per direction, 10k flows per\
| ... | flow-group) with all packets containing Ethernet header, IPv4 header\
| ... | with IP protocol=61 and static payload. MAC addresses are matching MAC\
| ... | addresses of the TG node interfaces.
| ... | *[Ref] Applicable standard specifications:* RFC2544.

*** Variables ***
| @{plugins_to_enable}= | avf_plugin.so
| ${crypto_type}= | ${None}
| ${nic_name}= | Intel-X710
| ${nic_driver}= | avf
| ${osi_layer}= | L3
| ${overhead}= | ${0}
| ${rts_per_flow}= | ${10000}
# Traffic profile:
| ${traffic_profile}= | trex-sl-2n-ethip4-ip4dst${rts_per_flow}

*** Keywords ***
| Local Template
| | ...
| | [Documentation]
| | ... | [Cfg] DUT runs IPv4 routing config.
| | ... | Each DUT uses ${phy_cores} physical core(s) for worker threads.
| | ... | [Ver] Measure NDR and PDR values using MLRsearch algorithm.\
| | ...
| | ... | *Arguments:*
| | ... | - frame_size - Framesize in Bytes in integer or string (IMIX_v4_1).
| | ... | Type: integer, string
| | ... | - phy_cores - Number of physical cores. Type: integer
| | ... | - rxq - Number of RX queues, default value: ${None}. Type: integer
| | ...
| | [Arguments] | ${frame_size} | ${phy_cores} | ${rxq}=${None}
| | ...
| | Set Test Variable | \${frame_size}
| | ...
| | Given Set Max Rate And Jumbo
| | And Add worker threads to all DUTs | ${phy_cores} | ${rxq}
| | And Pre-initialize layer driver | ${nic_driver}
| | And Apply startup configuration on all VPP DUTs
| | When Initialize layer driver | ${nic_driver}
| | And Initialize layer interface
| | And Initialize IPv4 forwarding with scaling in circular topology
| | ... | ${rts_per_flow}
| | Then Find NDR and PDR intervals using optimized search

*** Test Cases ***
| tc01-64B-1c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | 64B | 1C
| | frame_size=${64} | phy_cores=${1}

| tc02-64B-2c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | 64B | 2C
| | frame_size=${64} | phy_cores=${2}

| tc03-64B-4c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | 64B | 4C
| | frame_size=${64} | phy_cores=${4}

| tc04-1518B-1c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | 1518B | 1C
| | frame_size=${1518} | phy_cores=${1}

| tc05-1518B-2c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | 1518B | 2C
| | frame_size=${1518} | phy_cores=${2}

| tc06-1518B-4c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | 1518B | 4C
| | frame_size=${1518} | phy_cores=${4}

| tc07-9000B-1c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | 9000B | 1C
| | frame_size=${9000} | phy_cores=${1}

| tc08-9000B-2c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | 9000B | 2C
| | frame_size=${9000} | phy_cores=${2}

| tc09-9000B-4c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | 9000B | 4C
| | frame_size=${9000} | phy_cores=${4}

| tc10-IMIX-1c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | IMIX | 1C
| | frame_size=IMIX_v4_1 | phy_cores=${1}

| tc11-IMIX-2c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | IMIX | 2C
| | frame_size=IMIX_v4_1 | phy_cores=${2}

| tc12-IMIX-4c-avf-ethip4-ip4scale20k-ndrpdr
| | [Tags] | IMIX | 4C
| | frame_size=IMIX_v4_1 | phy_cores=${4}
"n">TCP_FLAGS_ACKSYN) == masked_flags) { return ACL_TIMEOUT_TCP_IDLE; } else { return ACL_TIMEOUT_TCP_TRANSIENT; } break; case IPPROTO_UDP: return ACL_TIMEOUT_UDP_IDLE; break; default: return ACL_TIMEOUT_UDP_IDLE; } } /* * Get the idle timeout of a session. */ always_inline u64 fa_session_get_timeout (acl_main_t * am, fa_session_t * sess) { u64 timeout = (am->vlib_main->clib_time.clocks_per_second); if (sess->link_list_id == ACL_TIMEOUT_PURGATORY) { timeout /= (1000000 / SESSION_PURGATORY_TIMEOUT_USEC); } else { int timeout_type = fa_session_get_timeout_type (am, sess); timeout *= am->session_timeout_sec[timeout_type]; } return timeout; } always_inline fa_session_t * get_session_ptr (acl_main_t * am, u16 thread_index, u32 session_index) { acl_fa_per_worker_data_t *pw = &am->per_worker_data[thread_index]; if (session_index > vec_len (pw->fa_sessions_pool)) { return 0; } fa_session_t *sess = (session_index > vec_len (pw->fa_sessions_pool)) ? 0 : pool_elt_at_index (pw->fa_sessions_pool, session_index); return sess; } always_inline int is_valid_session_ptr (acl_main_t * am, u16 thread_index, fa_session_t * sess) { acl_fa_per_worker_data_t *pw = &am->per_worker_data[thread_index]; return ((sess != 0) && ((sess - pw->fa_sessions_pool) < pool_len (pw->fa_sessions_pool))); } always_inline void acl_fa_conn_list_add_session (acl_main_t * am, fa_full_session_id_t sess_id, u64 now) { fa_session_t *sess = get_session_ptr (am, sess_id.thread_index, sess_id.session_index); u8 list_id = sess->deleted ? ACL_TIMEOUT_PURGATORY : fa_session_get_timeout_type (am, sess); uword thread_index = os_get_thread_index (); acl_fa_per_worker_data_t *pw = &am->per_worker_data[thread_index]; /* the retrieved session thread index must be necessarily the same as the one in the key */ ASSERT (sess->thread_index == sess_id.thread_index); /* the retrieved session thread index must be the same as current thread */ ASSERT (sess->thread_index == thread_index); sess->link_enqueue_time = now; sess->link_list_id = list_id; sess->link_next_idx = FA_SESSION_BOGUS_INDEX; sess->link_prev_idx = pw->fa_conn_list_tail[list_id]; if (FA_SESSION_BOGUS_INDEX != pw->fa_conn_list_tail[list_id]) { fa_session_t *prev_sess = get_session_ptr (am, thread_index, pw->fa_conn_list_tail[list_id]); prev_sess->link_next_idx = sess_id.session_index; /* We should never try to link with a session on another thread */ ASSERT (prev_sess->thread_index == sess->thread_index); } pw->fa_conn_list_tail[list_id] = sess_id.session_index; #ifdef FA_NODE_VERBOSE_DEBUG clib_warning ("FA-SESSION-DEBUG: add session id %d on thread %d sw_if_index %d", sess_id.session_index, thread_index, sess->sw_if_index); #endif pw->serviced_sw_if_index_bitmap = clib_bitmap_set (pw->serviced_sw_if_index_bitmap, sess->sw_if_index, 1); if (FA_SESSION_BOGUS_INDEX == pw->fa_conn_list_head[list_id]) { pw->fa_conn_list_head[list_id] = sess_id.session_index; /* set the head expiry time because it is the first element */ pw->fa_conn_list_head_expiry_time[list_id] = now + fa_session_get_timeout (am, sess); } } static int acl_fa_conn_list_delete_session (acl_main_t * am, fa_full_session_id_t sess_id, u64 now) { uword thread_index = os_get_thread_index (); acl_fa_per_worker_data_t *pw = &am->per_worker_data[thread_index]; if (thread_index != sess_id.thread_index) { /* If another thread attempts to delete the session, fail it. */ #ifdef FA_NODE_VERBOSE_DEBUG clib_warning ("thread id in key %d != curr thread index, not deleting"); #endif return 0; } fa_session_t *sess = get_session_ptr (am, sess_id.thread_index, sess_id.session_index); u64 next_expiry_time = ~0ULL; /* we should never try to delete the session with another thread index */ if (sess->thread_index != os_get_thread_index ()) { clib_error ("Attempting to delete session belonging to thread %d by thread %d", sess->thread_index, thread_index); } if (FA_SESSION_BOGUS_INDEX != sess->link_prev_idx) { fa_session_t *prev_sess = get_session_ptr (am, thread_index, sess->link_prev_idx); /* the previous session must be in the same list as this one */ ASSERT (prev_sess->link_list_id == sess->link_list_id); prev_sess->link_next_idx = sess->link_next_idx; } if (FA_SESSION_BOGUS_INDEX != sess->link_next_idx) { fa_session_t *next_sess = get_session_ptr (am, thread_index, sess->link_next_idx); /* The next session must be in the same list as the one we are deleting */ ASSERT (next_sess->link_list_id == sess->link_list_id); next_sess->link_prev_idx = sess->link_prev_idx; next_expiry_time = now + fa_session_get_timeout (am, next_sess); } if (pw->fa_conn_list_head[sess->link_list_id] == sess_id.session_index) { pw->fa_conn_list_head[sess->link_list_id] = sess->link_next_idx; pw->fa_conn_list_head_expiry_time[sess->link_list_id] = next_expiry_time; } if (pw->fa_conn_list_tail[sess->link_list_id] == sess_id.session_index) { pw->fa_conn_list_tail[sess->link_list_id] = sess->link_prev_idx; } return 1; } always_inline int acl_fa_restart_timer_for_session (acl_main_t * am, u64 now, fa_full_session_id_t sess_id) { if (acl_fa_conn_list_delete_session (am, sess_id, now)) { acl_fa_conn_list_add_session (am, sess_id, now); return 1; } else { /* * Our thread does not own this connection, so we can not delete * The session. To avoid the complicated signaling, we simply * pick the list waiting time to be the shortest of the timeouts. * This way we do not have to do anything special, and let * the regular requeue check take care of everything. */ return 0; } } always_inline int is_ip6_5tuple (fa_5tuple_t * p5t) { return (p5t->l3_zero_pad[0] | p5t-> l3_zero_pad[1] | p5t->l3_zero_pad[2] | p5t->l3_zero_pad[3] | p5t-> l3_zero_pad[4] | p5t->l3_zero_pad[5]) != 0; } always_inline u8 acl_fa_track_session (acl_main_t * am, int is_input, u32 sw_if_index, u64 now, fa_session_t * sess, fa_5tuple_t * pkt_5tuple) { sess->last_active_time = now; if (pkt_5tuple->pkt.tcp_flags_valid) { sess->tcp_flags_seen.as_u8[is_input] |= pkt_5tuple->pkt.tcp_flags; } return 3; } always_inline u64 reverse_l4_u64_fastpath (u64 l4, int is_ip6) { fa_session_l4_key_t l4i = {.as_u64 = l4 }; fa_session_l4_key_t l4o; l4o.port[1] = l4i.port[0]; l4o.port[0] = l4i.port[1]; l4o.non_port_l4_data = l4i.non_port_l4_data; l4o.is_input = 1 - l4i.is_input; return l4o.as_u64; } always_inline u64 reverse_l4_u64_slowpath (u64 l4, int is_ip6) { fa_session_l4_key_t l4i = {.as_u64 = l4 }; fa_session_l4_key_t l4o; if (l4i.proto == icmp_protos[is_ip6]) { static const u8 *icmp_invmap[] = { icmp4_invmap, icmp6_invmap }; static const u8 *icmp_valid_new[] = { icmp4_valid_new, icmp6_valid_new }; static const u8 icmp_invmap_size[] = { sizeof (icmp4_invmap), sizeof (icmp6_invmap) }; static const u8 icmp_valid_new_size[] = { sizeof (icmp4_valid_new), sizeof (icmp6_valid_new) }; int type = is_ip6 ? l4i.port[0] - 128 : l4i.port[0]; l4o.non_port_l4_data = l4i.non_port_l4_data; l4o.port[0] = l4i.port[0]; l4o.port[1] = l4i.port[1]; /* * ONLY ICMP messages defined in icmp4_valid_new/icmp6_valid_new table * are allowed to create stateful ACL. * The other messages will be forwarded without creating a reverse session. */ if (type >= 0 && (type <= icmp_valid_new_size[is_ip6]) && (icmp_valid_new[is_ip6][type]) && (type <= icmp_invmap_size[is_ip6]) && icmp_invmap[is_ip6][type]) { /* * we set the inverse direction and correct the port, * if it is okay to add the reverse session. * If not, then the same session will be added twice * to bihash, which is the same as adding just one session. */ l4o.is_input = 1 - l4i.is_input; l4o.port[0] = icmp_invmap[is_ip6][type] - 1; } return l4o.as_u64; } else return reverse_l4_u64_fastpath (l4, is_ip6); } always_inline u64 reverse_l4_u64 (u64 l4, int is_ip6) { fa_session_l4_key_t l4i = {.as_u64 = l4 }; if (PREDICT_FALSE (l4i.is_slowpath)) { return reverse_l4_u64_slowpath (l4, is_ip6); } else { return reverse_l4_u64_fastpath (l4, is_ip6); } } always_inline void reverse_session_add_del_ip6 (acl_main_t * am, clib_bihash_kv_40_8_t * pkv, int is_add) { clib_bihash_kv_40_8_t kv2; kv2.key[0] = pkv->key[2]; kv2.key[1] = pkv->key[3]; kv2.key[2] = pkv->key[0]; kv2.key[3] = pkv->key[1]; /* the last u64 needs special treatment (ports, etc.) */ kv2.key[4] = reverse_l4_u64 (pkv->key[4], 1); kv2.value = pkv->value; clib_bihash_add_del_40_8 (&am->fa_ip6_sessions_hash, &kv2, is_add); } always_inline void reverse_session_add_del_ip4 (acl_main_t * am, clib_bihash_kv_16_8_t * pkv, int is_add) { clib_bihash_kv_16_8_t kv2; kv2.key[0] = ((pkv->key[0] & 0xffffffff) << 32) | ((pkv->key[0] >> 32) & 0xffffffff); /* the last u64 needs special treatment (ports, etc.) */ kv2.key[1] = reverse_l4_u64 (pkv->key[1], 0); kv2.value = pkv->value; clib_bihash_add_del_16_8 (&am->fa_ip4_sessions_hash, &kv2, is_add); } always_inline void acl_fa_deactivate_session (acl_main_t * am, u32 sw_if_index, fa_full_session_id_t sess_id) { fa_session_t *sess = get_session_ptr (am, sess_id.thread_index, sess_id.session_index); ASSERT (sess->thread_index == os_get_thread_index ()); if (sess->is_ip6) { clib_bihash_add_del_40_8 (&am->fa_ip6_sessions_hash, &sess->info.kv_40_8, 0); reverse_session_add_del_ip6 (am, &sess->info.kv_40_8, 0); } else { clib_bihash_add_del_16_8 (&am->fa_ip4_sessions_hash, &sess->info.kv_16_8, 0); reverse_session_add_del_ip4 (am, &sess->info.kv_16_8, 0); } sess->deleted = 1; clib_smp_atomic_add (&am->fa_session_total_deactivations, 1); } always_inline void acl_fa_put_session (acl_main_t * am, u32 sw_if_index, fa_full_session_id_t sess_id) { if (sess_id.thread_index != os_get_thread_index ()) { clib_error ("Attempting to delete session belonging to thread %d by thread %d", sess_id.thread_index, os_get_thread_index ()); } void *oldheap = clib_mem_set_heap (am->acl_mheap); acl_fa_per_worker_data_t *pw = &am->per_worker_data[sess_id.thread_index]; pool_put_index (pw->fa_sessions_pool, sess_id.session_index); /* Deleting from timer structures not needed, as the caller must have dealt with the timers. */ vec_validate (pw->fa_session_dels_by_sw_if_index, sw_if_index); clib_mem_set_heap (oldheap); clib_smp_atomic_add (&pw->fa_session_dels_by_sw_if_index[sw_if_index], 1); clib_smp_atomic_add (&am->fa_session_total_dels, 1); } always_inline int acl_fa_two_stage_delete_session (acl_main_t * am, u32 sw_if_index, fa_full_session_id_t sess_id, u64 now) { fa_session_t *sess = get_session_ptr (am, sess_id.thread_index, sess_id.session_index); if (sess->deleted) { acl_fa_put_session (am, sw_if_index, sess_id); return 1; } else { acl_fa_deactivate_session (am, sw_if_index, sess_id); acl_fa_conn_list_add_session (am, sess_id, now); return 0; } } always_inline int acl_fa_can_add_session (acl_main_t * am, int is_input, u32 sw_if_index) { u64 curr_sess_count; curr_sess_count = am->fa_session_total_adds - am->fa_session_total_dels; return (curr_sess_count + vec_len (vlib_mains) < am->fa_conn_table_max_entries); } always_inline void acl_fa_try_recycle_session (acl_main_t * am, int is_input, u16 thread_index, u32 sw_if_index, u64 now) { /* try to recycle a TCP transient session */ acl_fa_per_worker_data_t *pw = &am->per_worker_data[thread_index]; fa_full_session_id_t volatile sess_id; int n_recycled = 0; /* clean up sessions from purgatory, if we can */ sess_id.session_index = pw->fa_conn_list_head[ACL_TIMEOUT_PURGATORY]; while ((FA_SESSION_BOGUS_INDEX != sess_id.session_index) && n_recycled < am->fa_max_deleted_sessions_per_interval) { sess_id.thread_index = thread_index; fa_session_t *sess = get_session_ptr (am, sess_id.thread_index, sess_id.session_index); if (sess->link_enqueue_time + fa_session_get_timeout (am, sess) < now) { acl_fa_conn_list_delete_session (am, sess_id, now); /* interface that needs the sessions may not be the interface of the session. */ acl_fa_put_session (am, sess->sw_if_index, sess_id); n_recycled++; } else break; /* too early to try to recycle from here, bail out */ sess_id.session_index = pw->fa_conn_list_head[ACL_TIMEOUT_PURGATORY]; } sess_id.session_index = pw->fa_conn_list_head[ACL_TIMEOUT_TCP_TRANSIENT]; if (FA_SESSION_BOGUS_INDEX != sess_id.session_index) { sess_id.thread_index = thread_index; acl_fa_conn_list_delete_session (am, sess_id, now); acl_fa_deactivate_session (am, sw_if_index, sess_id); /* this goes to purgatory list */ acl_fa_conn_list_add_session (am, sess_id, now); } } always_inline fa_session_t * acl_fa_add_session (acl_main_t * am, int is_input, int is_ip6, u32 sw_if_index, u64 now, fa_5tuple_t * p5tuple, u16 current_policy_epoch) { fa_full_session_id_t f_sess_id; uword thread_index = os_get_thread_index (); void *oldheap = clib_mem_set_heap (am->acl_mheap); acl_fa_per_worker_data_t *pw = &am->per_worker_data[thread_index]; f_sess_id.thread_index = thread_index; fa_session_t *sess; if (f_sess_id.as_u64 == ~0) { clib_error ("Adding session with invalid value"); } pool_get_aligned (pw->fa_sessions_pool, sess, CLIB_CACHE_LINE_BYTES); f_sess_id.session_index = sess - pw->fa_sessions_pool; f_sess_id.intf_policy_epoch = current_policy_epoch; if (is_ip6) { sess->info.kv_40_8.key[0] = p5tuple->kv_40_8.key[0]; sess->info.kv_40_8.key[1] = p5tuple->kv_40_8.key[1]; sess->info.kv_40_8.key[2] = p5tuple->kv_40_8.key[2]; sess->info.kv_40_8.key[3] = p5tuple->kv_40_8.key[3]; sess->info.kv_40_8.key[4] = p5tuple->kv_40_8.key[4]; sess->info.kv_40_8.value = f_sess_id.as_u64; } else { sess->info.kv_16_8.key[0] = p5tuple->kv_16_8.key[0]; sess->info.kv_16_8.key[1] = p5tuple->kv_16_8.key[1]; sess->info.kv_16_8.value = f_sess_id.as_u64; } sess->last_active_time = now; sess->sw_if_index = sw_if_index; sess->tcp_flags_seen.as_u16 = 0; sess->thread_index = thread_index; sess->link_list_id = ACL_TIMEOUT_UNUSED; sess->link_prev_idx = FA_SESSION_BOGUS_INDEX; sess->link_next_idx = FA_SESSION_BOGUS_INDEX; sess->deleted = 0; sess->is_ip6 = is_ip6; acl_fa_conn_list_add_session (am, f_sess_id, now); ASSERT (am->fa_sessions_hash_is_initialized == 1); if (is_ip6) { reverse_session_add_del_ip6 (am, &sess->info.kv_40_8, 1); clib_bihash_add_del_40_8 (&am->fa_ip6_sessions_hash, &sess->info.kv_40_8, 1); } else { reverse_session_add_del_ip4 (am, &sess->info.kv_16_8, 1); clib_bihash_add_del_16_8 (&am->fa_ip4_sessions_hash, &sess->info.kv_16_8, 1); } vec_validate (pw->fa_session_adds_by_sw_if_index, sw_if_index); clib_mem_set_heap (oldheap); clib_smp_atomic_add (&pw->fa_session_adds_by_sw_if_index[sw_if_index], 1); clib_smp_atomic_add (&am->fa_session_total_adds, 1); return sess; } always_inline int acl_fa_find_session (acl_main_t * am, int is_ip6, u32 sw_if_index0, fa_5tuple_t * p5tuple, u64 * pvalue_sess) { int res = 0; if (is_ip6) { clib_bihash_kv_40_8_t kv_result; res = (clib_bihash_search_inline_2_40_8 (&am->fa_ip6_sessions_hash, &p5tuple->kv_40_8, &kv_result) == 0); *pvalue_sess = kv_result.value; } else { clib_bihash_kv_16_8_t kv_result; res = (clib_bihash_search_inline_2_16_8 (&am->fa_ip4_sessions_hash, &p5tuple->kv_16_8, &kv_result) == 0); *pvalue_sess = kv_result.value; } return res; } /* * fd.io coding-style-patch-verification: ON * * Local Variables: * eval: (c-set-style "gnu") * End: */