diff options
author | Bruno Martins <bgcngm@gmail.com> | 2018-01-08 12:51:07 +0000 |
---|---|---|
committer | Davide Garberi <dade.garberi@gmail.com> | 2018-01-20 09:30:21 +0100 |
commit | 1c67f47d4a205e12650dcb6255c00bafc0046082 (patch) | |
tree | 72bb48ca2152cb2295b0f8de39497490d8616f6f /data-ipa-cfg-mgr/ipacm/src/IPACM_LanToLan.cpp | |
parent | 6b0c862328f58e523e2a6efa667a2f4b3a609bf3 (diff) |
msm8996-common: Import IPACM back
* QC package: LA.UM.6.5.r1-05300-8x96.0
* Squashed with commits 08e2a5b9b, 055b183 and 8fcf57b
Change-Id: I2f7a792dc0155986e065d1bf79e1f08370c3d79c
Signed-off-by: Davide Garberi <dade.garberi@gmail.com>
Diffstat (limited to 'data-ipa-cfg-mgr/ipacm/src/IPACM_LanToLan.cpp')
-rw-r--r-- | data-ipa-cfg-mgr/ipacm/src/IPACM_LanToLan.cpp | 2081 |
1 files changed, 2081 insertions, 0 deletions
diff --git a/data-ipa-cfg-mgr/ipacm/src/IPACM_LanToLan.cpp b/data-ipa-cfg-mgr/ipacm/src/IPACM_LanToLan.cpp new file mode 100644 index 0000000..092af64 --- /dev/null +++ b/data-ipa-cfg-mgr/ipacm/src/IPACM_LanToLan.cpp @@ -0,0 +1,2081 @@ +/* +Copyright (c) 2014-2017, The Linux Foundation. All rights reserved. + +Redistribution and use in source and binary forms, with or without +modification, are permitted provided that the following conditions are +met: + * Redistributions of source code must retain the above copyright + notice, this list of conditions and the following disclaimer. + * Redistributions in binary form must reproduce the above + copyright notice, this list of conditions and the following + disclaimer in the documentation and/or other materials provided + with the distribution. + * Neither the name of The Linux Foundation nor the names of its + contributors may be used to endorse or promote products derived + from this software without specific prior written permission. + +THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED +WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF +MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT +ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS +BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR +CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF +SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR +BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, +WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE +OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN +IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. +*/ +/*! + @file + IPACM_LanToLan.cpp + + @brief + This file implements the functionality of offloading LAN to LAN traffic. + + @Author + Shihuan Liu + +*/ + +#include <stdlib.h> +#include "IPACM_LanToLan.h" +#include "IPACM_Wlan.h" + +#define __stringify(x...) #x + +const char *ipa_l2_hdr_type[] = { + __stringify(NONE), + __stringify(ETH_II), + __stringify(802_3), + __stringify(L2_MAX) +}; + +IPACM_LanToLan* IPACM_LanToLan::p_instance; + +IPACM_LanToLan_Iface::IPACM_LanToLan_Iface(IPACM_Lan *p_iface) +{ + int i; + + m_p_iface = p_iface; + memset(m_is_ip_addr_assigned, 0, sizeof(m_is_ip_addr_assigned)); + m_support_inter_iface_offload = true; + m_support_intra_iface_offload = false; + m_is_l2tp_iface = false; + for(i = 0; i < IPA_HDR_L2_MAX; i++) + { + ref_cnt_peer_l2_hdr_type[i] = 0; + hdr_proc_ctx_for_inter_interface[i] = 0; + } + hdr_proc_ctx_for_intra_interface = 0; + hdr_proc_ctx_for_l2tp = 0; + + if(p_iface->ipa_if_cate == WLAN_IF) + { + IPACMDBG_H("Interface %s is WLAN interface.\n", p_iface->dev_name); + m_support_intra_iface_offload = true; + if( ((IPACM_Wlan*)p_iface)->is_guest_ap() ) + { + IPACMDBG_H("Interface %s is guest AP.\n", p_iface->dev_name); + m_support_inter_iface_offload = false; + } + } + return; +} + +IPACM_LanToLan_Iface::~IPACM_LanToLan_Iface() +{ +} + +IPACM_LanToLan::IPACM_LanToLan() +{ + IPACM_EvtDispatcher::registr(IPA_ETH_BRIDGE_IFACE_UP, this); + IPACM_EvtDispatcher::registr(IPA_ETH_BRIDGE_IFACE_DOWN, this); + IPACM_EvtDispatcher::registr(IPA_ETH_BRIDGE_CLIENT_ADD, this); + IPACM_EvtDispatcher::registr(IPA_ETH_BRIDGE_CLIENT_DEL, this); + IPACM_EvtDispatcher::registr(IPA_ETH_BRIDGE_WLAN_SCC_MCC_SWITCH, this); +#ifdef FEATURE_L2TP + IPACM_EvtDispatcher::registr(IPA_ADD_VLAN_IFACE, this); + IPACM_EvtDispatcher::registr(IPA_DEL_VLAN_IFACE, this); + IPACM_EvtDispatcher::registr(IPA_ADD_L2TP_VLAN_MAPPING, this); + IPACM_EvtDispatcher::registr(IPA_DEL_L2TP_VLAN_MAPPING, this); + IPACM_EvtDispatcher::registr(IPA_HANDLE_VLAN_CLIENT_INFO, this); + IPACM_EvtDispatcher::registr(IPA_HANDLE_VLAN_IFACE_INFO, this); +#endif + m_has_l2tp_iface = false; + return; +} + +IPACM_LanToLan::~IPACM_LanToLan() +{ + IPACMDBG_DMESG("WARNING: UNEXPECTEDLY KILL LAN2LAN CONTROLLER!\n"); + return; +} + +IPACM_LanToLan* IPACM_LanToLan::get_instance() +{ + if(p_instance == NULL) + { + p_instance = new IPACM_LanToLan(); + IPACMDBG_H("Created LanToLan instance.\n"); + } + return p_instance; +} + +#ifdef FEATURE_L2TP +bool IPACM_LanToLan::has_l2tp_iface() +{ + list<IPACM_LanToLan_Iface>::iterator it; + bool has_l2tp_iface = false; + + for(it = m_iface.begin(); it != m_iface.end(); it++) + { + if(it->is_l2tp_iface() == true) + { + has_l2tp_iface = true; + break; + } + } + return has_l2tp_iface; +} +#endif + +void IPACM_LanToLan::event_callback(ipa_cm_event_id event, void* param) +{ + ipacm_event_eth_bridge *eth_bridge_data; + ipa_ioc_vlan_iface_info *vlan_iface_data; + +#ifdef FEATURE_L2TP + ipa_ioc_l2tp_vlan_mapping_info *l2tp_vlan_mapping_data; +#endif + ipacm_event_data_all *vlan_data; + + IPACMDBG_H("Get %s event.\n", IPACM_Iface::ipacmcfg->getEventName(event)); + + switch(event) + { + case IPA_ETH_BRIDGE_IFACE_UP: + { + eth_bridge_data = (ipacm_event_eth_bridge*)param; + handle_iface_up(eth_bridge_data); + break; + } + + case IPA_ETH_BRIDGE_IFACE_DOWN: + { + eth_bridge_data = (ipacm_event_eth_bridge*)param; + handle_iface_down(eth_bridge_data); + break; + } + + case IPA_ETH_BRIDGE_CLIENT_ADD: + { + eth_bridge_data = (ipacm_event_eth_bridge*)param; + handle_client_add(eth_bridge_data); + break; + } + + case IPA_ETH_BRIDGE_CLIENT_DEL: + { + eth_bridge_data = (ipacm_event_eth_bridge*)param; + handle_client_del(eth_bridge_data); + break; + } + + case IPA_ETH_BRIDGE_WLAN_SCC_MCC_SWITCH: + { + eth_bridge_data = (ipacm_event_eth_bridge*)param; + handle_wlan_scc_mcc_switch(eth_bridge_data); + break; + } + +#ifdef FEATURE_L2TP + case IPA_ADD_VLAN_IFACE: + { + vlan_iface_data = (ipa_ioc_vlan_iface_info*)param; + handle_add_vlan_iface(vlan_iface_data); + break; + } + + case IPA_DEL_VLAN_IFACE: + { + vlan_iface_data = (ipa_ioc_vlan_iface_info*)param; + handle_del_vlan_iface(vlan_iface_data); + break; + } + case IPA_ADD_L2TP_VLAN_MAPPING: + { + l2tp_vlan_mapping_data = (ipa_ioc_l2tp_vlan_mapping_info*)param; + handle_add_l2tp_vlan_mapping(l2tp_vlan_mapping_data); + break; + } + case IPA_DEL_L2TP_VLAN_MAPPING: + { + l2tp_vlan_mapping_data = (ipa_ioc_l2tp_vlan_mapping_info*)param; + handle_del_l2tp_vlan_mapping(l2tp_vlan_mapping_data); + break; + } + case IPA_HANDLE_VLAN_CLIENT_INFO: + { + vlan_data = (ipacm_event_data_all*)param; + handle_vlan_client_info(vlan_data); + break; + } + case IPA_HANDLE_VLAN_IFACE_INFO: + { + vlan_data = (ipacm_event_data_all*)param; + handle_vlan_iface_info(vlan_data); + break; + } +#endif + default: + break; + } + + print_data_structure_info(); + return; +} + +void IPACM_LanToLan::handle_iface_up(ipacm_event_eth_bridge *data) +{ + list<IPACM_LanToLan_Iface>::iterator it; + list<l2tp_vlan_mapping_info>::iterator it_mapping; + bool has_l2tp_iface = false; + + IPACMDBG_H("Interface name: %s IP type: %d\n", data->p_iface->dev_name, data->iptype); + for(it = m_iface.begin(); it != m_iface.end(); it++) + { + if(it->get_iface_pointer() == data->p_iface) + { + IPACMDBG_H("Found the interface.\n"); + if(it->get_m_is_ip_addr_assigned(data->iptype) == false) + { + IPACMDBG_H("IP type %d was not active before, activating it now.\n", data->iptype); + it->set_m_is_ip_addr_assigned(data->iptype, true); + + /* install inter-interface rules */ + if(it->get_m_support_inter_iface_offload()) + it->add_all_inter_interface_client_flt_rule(data->iptype); + + /* install intra-BSS rules */ + if(it->get_m_support_intra_iface_offload()) + it->add_all_intra_interface_client_flt_rule(data->iptype); + } + break; + } + } + + if(it == m_iface.end()) //If the interface has not been created before + { + if(m_iface.size() == MAX_NUM_IFACE) + { + IPACMERR("The number of interfaces has reached maximum %d.\n", MAX_NUM_IFACE); + return; + } + + if(!data->p_iface->tx_prop || !data->p_iface->rx_prop) + { + IPACMERR("The interface %s does not have tx_prop or rx_prop.\n", data->p_iface->dev_name); + return; + } + + if(data->p_iface->tx_prop->tx[0].hdr_l2_type == IPA_HDR_L2_NONE || data->p_iface->tx_prop->tx[0].hdr_l2_type == IPA_HDR_L2_MAX) + { + IPACMERR("Invalid l2 header type %s!\n", ipa_l2_hdr_type[data->p_iface->tx_prop->tx[0].hdr_l2_type]); + return; + } + + IPACMDBG_H("Does not find the interface, insert a new one.\n"); + IPACM_LanToLan_Iface new_iface(data->p_iface); + new_iface.set_m_is_ip_addr_assigned(data->iptype, true); + + m_iface.push_front(new_iface); + IPACMDBG_H("Now the total number of interfaces is %d.\n", m_iface.size()); + + IPACM_LanToLan_Iface &front_iface = m_iface.front(); +#ifdef FEATURE_L2TP + for(it_mapping = m_l2tp_vlan_mapping.begin(); it_mapping != m_l2tp_vlan_mapping.end(); it_mapping++) + { + if(front_iface.set_l2tp_iface(it_mapping->vlan_iface_name) == true) + { + has_l2tp_iface = true; + } + } + + if(m_has_l2tp_iface == false && has_l2tp_iface == true) + { + IPACMDBG_H("There is l2tp iface, add rt rules for l2tp iface.\n"); + m_has_l2tp_iface = true; + for(it = ++m_iface.begin(); it != m_iface.end(); it++) + { + if(it->is_l2tp_iface() == false) + { + it->handle_l2tp_enable(); + } + } + } +#endif + /* install inter-interface rules */ + if(front_iface.get_m_support_inter_iface_offload()) + { + for(it = ++m_iface.begin(); it != m_iface.end(); it++) + { + /* add peer info only when both interfaces support inter-interface communication */ + if(it->get_m_support_inter_iface_offload()) + { + /* populate hdr_proc_ctx and routing table handle */ + handle_new_iface_up(&front_iface, &(*it)); + + /* add client specific routing rule on existing interface */ + it->add_client_rt_rule_for_new_iface(); + } + } + + /* add client specific filtering rule on new interface */ + front_iface.add_all_inter_interface_client_flt_rule(data->iptype); + } + + /* populate the intra-interface information */ + if(front_iface.get_m_support_intra_iface_offload()) + { + front_iface.handle_intra_interface_info(); + } + + /* handle cached client add event */ + handle_cached_client_add_event(front_iface.get_iface_pointer()); + } + return; +} + +void IPACM_LanToLan::handle_iface_down(ipacm_event_eth_bridge *data) +{ + list<IPACM_LanToLan_Iface>::iterator it_target_iface; + bool has_l2tp_iface = false; + + IPACMDBG_H("Interface name: %s\n", data->p_iface->dev_name); + + for(it_target_iface = m_iface.begin(); it_target_iface != m_iface.end(); it_target_iface++) + { + if(it_target_iface->get_iface_pointer() == data->p_iface) + { + IPACMDBG_H("Found the interface.\n"); + break; + } + } + + if(it_target_iface == m_iface.end()) + { + IPACMDBG_H("The interface has not been found.\n"); + /* clear cached client add event for the unfound interface*/ + clear_cached_client_add_event(data->p_iface); + return; + } + + it_target_iface->handle_down_event(); + m_iface.erase(it_target_iface); +#ifdef FEATURE_L2TP + for(it_target_iface = m_iface.begin(); it_target_iface != m_iface.end(); it_target_iface++) + { + if(it_target_iface->is_l2tp_iface() == true) + { + has_l2tp_iface = true; + break; + } + } + if(m_has_l2tp_iface == true && has_l2tp_iface == false) + { + IPACMDBG_H("There is no l2tp iface now, delete rt rules for l2tp iface.\n"); + m_has_l2tp_iface = false; + for(it_target_iface = m_iface.begin(); it_target_iface != m_iface.end(); it_target_iface++) + { + if(it_target_iface->is_l2tp_iface() == false) + { + it_target_iface->handle_l2tp_disable(); + } + } + } +#endif + return; +} + +void IPACM_LanToLan::handle_new_iface_up(IPACM_LanToLan_Iface *new_iface, IPACM_LanToLan_Iface *exist_iface) +{ + char rt_tbl_name_for_flt[IPA_IP_MAX][IPA_RESOURCE_NAME_MAX]; + char rt_tbl_name_for_rt[IPA_IP_MAX][IPA_RESOURCE_NAME_MAX]; + + IPACMDBG_H("Populate peer info between: new_iface %s, existing iface %s\n", new_iface->get_iface_pointer()->dev_name, + exist_iface->get_iface_pointer()->dev_name); + + /* populate the routing table information */ + snprintf(rt_tbl_name_for_flt[IPA_IP_v4], IPA_RESOURCE_NAME_MAX, "eth_v4_%s_to_%s", + ipa_l2_hdr_type[exist_iface->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type], + ipa_l2_hdr_type[new_iface->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type]); + IPACMDBG_H("IPv4 routing table for flt name: %s\n", rt_tbl_name_for_flt[IPA_IP_v4]); + + snprintf(rt_tbl_name_for_flt[IPA_IP_v6], IPA_RESOURCE_NAME_MAX, "eth_v6_%s_to_%s", + ipa_l2_hdr_type[exist_iface->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type], + ipa_l2_hdr_type[new_iface->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type]); + IPACMDBG_H("IPv6 routing table for flt name: %s\n", rt_tbl_name_for_flt[IPA_IP_v6]); + + snprintf(rt_tbl_name_for_rt[IPA_IP_v4], IPA_RESOURCE_NAME_MAX, "eth_v4_%s_to_%s", + ipa_l2_hdr_type[new_iface->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type], + ipa_l2_hdr_type[exist_iface->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type]); + IPACMDBG_H("IPv4 routing table for rt name: %s\n", rt_tbl_name_for_rt[IPA_IP_v4]); + + snprintf(rt_tbl_name_for_rt[IPA_IP_v6], IPA_RESOURCE_NAME_MAX, "eth_v6_%s_to_%s", + ipa_l2_hdr_type[new_iface->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type], + ipa_l2_hdr_type[exist_iface->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type]); + IPACMDBG_H("IPv6 routing table for rt name: %s\n", rt_tbl_name_for_rt[IPA_IP_v6]); + + /* add new peer info in both new iface and existing iface */ + exist_iface->handle_new_iface_up(rt_tbl_name_for_flt, rt_tbl_name_for_rt, new_iface); + + new_iface->handle_new_iface_up(rt_tbl_name_for_rt, rt_tbl_name_for_flt, exist_iface); + + return; +} + +void IPACM_LanToLan::handle_client_add(ipacm_event_eth_bridge *data) +{ + list<IPACM_LanToLan_Iface>::iterator it_iface; + list<l2tp_vlan_mapping_info>::iterator it_mapping; + l2tp_vlan_mapping_info *mapping_info = NULL; + bool is_l2tp_client = false; + + IPACMDBG_H("Incoming client MAC: 0x%02x%02x%02x%02x%02x%02x, interface: %s\n", data->mac_addr[0], data->mac_addr[1], + data->mac_addr[2], data->mac_addr[3], data->mac_addr[4], data->mac_addr[5], data->p_iface->dev_name); +#ifdef FEATURE_L2TP + for(it_mapping = m_l2tp_vlan_mapping.begin(); it_mapping != m_l2tp_vlan_mapping.end(); it_mapping++) + { + if(strncmp(it_mapping->l2tp_iface_name, data->iface_name, + sizeof(it_mapping->l2tp_iface_name)) == 0) + { + IPACMDBG_H("Found l2tp iface %s with l2tp client MAC 0x%02x%02x%02x%02x%02x%02x\n", + it_mapping->l2tp_iface_name, it_mapping->l2tp_client_mac[0], it_mapping->l2tp_client_mac[1], + it_mapping->l2tp_client_mac[2], it_mapping->l2tp_client_mac[3], it_mapping->l2tp_client_mac[4], + it_mapping->l2tp_client_mac[5]); + memcpy(it_mapping->l2tp_client_mac, data->mac_addr, sizeof(it_mapping->l2tp_client_mac)); + mapping_info = &(*it_mapping); + is_l2tp_client = true; + break; + } + } +#endif + for(it_iface = m_iface.begin(); it_iface != m_iface.end(); it_iface++) + { + if(it_iface->get_iface_pointer() == data->p_iface) //find the interface + { + IPACMDBG_H("Found the interface.\n"); + it_iface->handle_client_add(data->mac_addr, is_l2tp_client, mapping_info); + break; + } + } + + /* if the iface was not found, cache the client add event */ + if(it_iface == m_iface.end()) + { + IPACMDBG_H("The interface is not found.\n"); + if(m_cached_client_add_event.size() < MAX_NUM_CACHED_CLIENT_ADD_EVENT) + { + IPACMDBG_H("Cached the client information.\n"); + m_cached_client_add_event.push_front(*data); + } + else + { + IPACMDBG_H("Cached client add event has reached maximum number.\n"); + } + } + return; +} + +void IPACM_LanToLan::handle_client_del(ipacm_event_eth_bridge *data) +{ + list<IPACM_LanToLan_Iface>::iterator it_iface; + + IPACMDBG_H("Incoming client MAC: 0x%02x%02x%02x%02x%02x%02x, interface: %s\n", data->mac_addr[0], data->mac_addr[1], + data->mac_addr[2], data->mac_addr[3], data->mac_addr[4], data->mac_addr[5], data->p_iface->dev_name); + + for(it_iface = m_iface.begin(); it_iface != m_iface.end(); it_iface++) + { + if(it_iface->get_iface_pointer() == data->p_iface) //found the interface + { + IPACMDBG_H("Found the interface.\n"); + it_iface->handle_client_del(data->mac_addr); + break; + } + } + + if(it_iface == m_iface.end()) + { + IPACMDBG_H("The interface is not found.\n"); + } + + return; +} + +void IPACM_LanToLan::handle_wlan_scc_mcc_switch(ipacm_event_eth_bridge *data) +{ + list<IPACM_LanToLan_Iface>::iterator it_iface; + + IPACMDBG_H("Incoming interface: %s\n", data->p_iface->dev_name); + for(it_iface = m_iface.begin(); it_iface != m_iface.end(); it_iface++) + { + if(it_iface->get_iface_pointer() == data->p_iface) + { + it_iface->handle_wlan_scc_mcc_switch(); + break; + } + } + return; +} + +#ifdef FEATURE_L2TP +void IPACM_LanToLan::handle_add_vlan_iface(ipa_ioc_vlan_iface_info *data) +{ + list<vlan_iface_info>::iterator it_vlan; + list<l2tp_vlan_mapping_info>::iterator it_mapping; + vlan_iface_info new_vlan_info; + + IPACMDBG_H("Vlan iface: %s vlan id: %d\n", data->name, data->vlan_id); + for(it_vlan = m_vlan_iface.begin(); it_vlan != m_vlan_iface.end(); it_vlan++) + { + if(strncmp(it_vlan->vlan_iface_name, data->name, sizeof(it_vlan->vlan_iface_name)) == 0) + { + IPACMERR("The vlan iface was added before with id %d\n", it_vlan->vlan_id); + return; + } + } + + for(it_mapping = m_l2tp_vlan_mapping.begin(); it_mapping != m_l2tp_vlan_mapping.end(); it_mapping++) + { + if(strncmp(data->name, it_mapping->vlan_iface_name, sizeof(data->name)) == 0) + { + IPACMDBG_H("Found a mapping: l2tp iface %s.\n", it_mapping->l2tp_iface_name); + it_mapping->vlan_id = data->vlan_id; + } + } + + memset(&new_vlan_info, 0 , sizeof(new_vlan_info)); + strlcpy(new_vlan_info.vlan_iface_name, data->name, sizeof(new_vlan_info.vlan_iface_name)); + new_vlan_info.vlan_id = data->vlan_id; + m_vlan_iface.push_front(new_vlan_info); + return; +} + +void IPACM_LanToLan::handle_del_vlan_iface(ipa_ioc_vlan_iface_info *data) +{ + list<vlan_iface_info>::iterator it_vlan; + list<l2tp_vlan_mapping_info>::iterator it_mapping; + + IPACMDBG_H("Vlan iface: %s vlan id: %d\n", data->name, data->vlan_id); + for(it_vlan = m_vlan_iface.begin(); it_vlan != m_vlan_iface.end(); it_vlan++) + { + if(strncmp(it_vlan->vlan_iface_name, data->name, sizeof(it_vlan->vlan_iface_name)) == 0) + { + IPACMDBG_H("Found the vlan interface\n"); + m_vlan_iface.erase(it_vlan); + break; + } + } + + it_mapping = m_l2tp_vlan_mapping.begin(); + while(it_mapping != m_l2tp_vlan_mapping.end()) + { + if(strncmp(data->name, it_mapping->vlan_iface_name, sizeof(data->name)) == 0) + { + IPACMDBG_H("Delete mapping with l2tp iface %s\n", it_mapping->l2tp_iface_name); + it_mapping = m_l2tp_vlan_mapping.erase(it_mapping); + } + else + { + it_mapping++; + } + } + return; +} +void IPACM_LanToLan::handle_add_l2tp_vlan_mapping(ipa_ioc_l2tp_vlan_mapping_info *data) +{ + list<l2tp_vlan_mapping_info>::iterator it_mapping; + list<vlan_iface_info>::iterator it_vlan; + list<IPACM_LanToLan_Iface>::iterator it_iface; + l2tp_vlan_mapping_info new_mapping; + bool has_l2tp_iface = false; + + IPACMDBG_H("L2tp iface: %s session id: %d vlan iface: %s \n", + data->l2tp_iface_name, data->l2tp_session_id, data->vlan_iface_name); + for(it_mapping = m_l2tp_vlan_mapping.begin(); it_mapping != m_l2tp_vlan_mapping.end(); it_mapping++) + { + if(strncmp(data->l2tp_iface_name, it_mapping->l2tp_iface_name, + sizeof(data->l2tp_iface_name)) == 0) + { + IPACMERR("L2tp mapping was added before mapped to vlan %s.\n", it_mapping->vlan_iface_name); + return; + } + } + memset(&new_mapping, 0, sizeof(new_mapping)); + strlcpy(new_mapping.l2tp_iface_name, data->l2tp_iface_name, + sizeof(new_mapping.l2tp_iface_name)); + strlcpy(new_mapping.vlan_iface_name, data->vlan_iface_name, + sizeof(new_mapping.vlan_iface_name)); + new_mapping.l2tp_session_id = data->l2tp_session_id; + + for(it_vlan = m_vlan_iface.begin(); it_vlan != m_vlan_iface.end(); it_vlan++) + { + if(strncmp(it_vlan->vlan_iface_name, data->vlan_iface_name, sizeof(it_vlan->vlan_iface_name)) == 0) + { + IPACMDBG_H("Found vlan iface with id %d\n", it_vlan->vlan_id); + new_mapping.vlan_id = it_vlan->vlan_id; + memcpy(new_mapping.vlan_iface_ipv6_addr, it_vlan->vlan_iface_ipv6_addr, + sizeof(new_mapping.vlan_iface_ipv6_addr)); + memcpy(new_mapping.vlan_client_mac, it_vlan->vlan_client_mac, + sizeof(new_mapping.vlan_client_mac)); + memcpy(new_mapping.vlan_client_ipv6_addr, it_vlan->vlan_client_ipv6_addr, + sizeof(new_mapping.vlan_client_ipv6_addr)); + break; + } + } + m_l2tp_vlan_mapping.push_front(new_mapping); + + for(it_iface = m_iface.begin(); it_iface != m_iface.end(); it_iface++) + { + if(it_iface->set_l2tp_iface(data->vlan_iface_name) == true) + { + has_l2tp_iface = true; + } + } + + if(m_has_l2tp_iface == false && has_l2tp_iface == true) + { + IPACMDBG_H("There is l2tp iface, add rt rules for l2tp iface.\n"); + m_has_l2tp_iface = true; + for(it_iface = m_iface.begin(); it_iface != m_iface.end(); it_iface++) + { + if(it_iface->is_l2tp_iface() == false) + { + it_iface->handle_l2tp_enable(); + } + } + } + return; +} + +void IPACM_LanToLan::handle_del_l2tp_vlan_mapping(ipa_ioc_l2tp_vlan_mapping_info *data) +{ + list<l2tp_vlan_mapping_info>::iterator it; + list<IPACM_LanToLan_Iface>::iterator it_iface; + + IPACMDBG_H("L2tp iface: %s session id: %d vlan iface: %s \n", + data->l2tp_iface_name, data->l2tp_session_id, data->vlan_iface_name); + for(it = m_l2tp_vlan_mapping.begin(); it != m_l2tp_vlan_mapping.end(); it++) + { + if(strncmp(data->l2tp_iface_name, it->l2tp_iface_name, + sizeof(data->l2tp_iface_name)) == 0) + { + IPACMDBG_H("Found l2tp iface mapped to vlan %s.\n", it->vlan_iface_name); + if(strncmp(data->vlan_iface_name, it->vlan_iface_name, + sizeof(data->vlan_iface_name)) == 0) + { + m_l2tp_vlan_mapping.erase(it); + } + else + { + IPACMERR("Incoming mapping is incorrect.\n"); + } + break; + } + } + return; +} +void IPACM_LanToLan::handle_vlan_client_info(ipacm_event_data_all *data) +{ + list<l2tp_vlan_mapping_info>::iterator it_mapping; + list<vlan_iface_info>::iterator it_vlan; + + IPACMDBG_H("Incoming vlan client iface: %s IPv6 address: 0x%08x%08x%08x%08x\n", data->iface_name, + data->ipv6_addr[0], data->ipv6_addr[1], data->ipv6_addr[2], data->ipv6_addr[3]); + IPACMDBG_H("MAC address: 0x%02x%02x%02x%02x%02x%02x\n", data->mac_addr[0], data->mac_addr[1], + data->mac_addr[2], data->mac_addr[3], data->mac_addr[4], data->mac_addr[5]); + + for(it_vlan = m_vlan_iface.begin(); it_vlan != m_vlan_iface.end(); it_vlan++) + { + if(strncmp(it_vlan->vlan_iface_name, data->iface_name, sizeof(it_vlan->vlan_iface_name)) == 0) + { + IPACMDBG_H("Found vlan iface in vlan list: %s\n", it_vlan->vlan_iface_name); + if(it_vlan->vlan_client_ipv6_addr[0] > 0 || it_vlan->vlan_client_ipv6_addr[1] > 0 || + it_vlan->vlan_client_ipv6_addr[2] > 0 || it_vlan->vlan_client_ipv6_addr[3] > 0) + { + IPACMDBG_H("Vlan client info has been populated before, return.\n"); + return; + } + memcpy(it_vlan->vlan_client_mac, data->mac_addr, sizeof(it_vlan->vlan_client_mac)); + memcpy(it_vlan->vlan_client_ipv6_addr, data->ipv6_addr, sizeof(it_vlan->vlan_client_ipv6_addr)); + } + } + + for(it_mapping = m_l2tp_vlan_mapping.begin(); it_mapping != m_l2tp_vlan_mapping.end(); it_mapping++) + { + if(strncmp(it_mapping->vlan_iface_name, data->iface_name, sizeof(it_mapping->vlan_iface_name)) == 0) + { + IPACMDBG_H("Found vlan iface in l2tp mapping list: %s, l2tp iface: %s\n", it_mapping->vlan_iface_name, + it_mapping->l2tp_iface_name); + memcpy(it_mapping->vlan_client_mac, data->mac_addr, sizeof(it_mapping->vlan_client_mac)); + memcpy(it_mapping->vlan_client_ipv6_addr, data->ipv6_addr, sizeof(it_mapping->vlan_client_ipv6_addr)); + } + } + return; +} + +void IPACM_LanToLan::handle_vlan_iface_info(ipacm_event_data_all *data) +{ + list<vlan_iface_info>::iterator it_vlan; + list<l2tp_vlan_mapping_info>::iterator it_mapping; + + IPACMDBG_H("Incoming vlan iface: %s IPv6 address: 0x%08x%08x%08x%08x\n", data->iface_name, + data->ipv6_addr[0], data->ipv6_addr[1], data->ipv6_addr[2], data->ipv6_addr[3]); + + for(it_vlan = m_vlan_iface.begin(); it_vlan != m_vlan_iface.end(); it_vlan++) + { + if(strncmp(it_vlan->vlan_iface_name, data->iface_name, + sizeof(it_vlan->vlan_iface_name)) == 0) + { + IPACMDBG_H("Found vlan iface: %s\n", it_vlan->vlan_iface_name); + memcpy(it_vlan->vlan_iface_ipv6_addr, data->ipv6_addr, + sizeof(it_vlan->vlan_iface_ipv6_addr)); + + for(it_mapping = m_l2tp_vlan_mapping.begin(); it_mapping != m_l2tp_vlan_mapping.end(); it_mapping++) + { + if(strncmp(it_mapping->vlan_iface_name, it_vlan->vlan_iface_name, + sizeof(it_mapping->vlan_iface_name)) == 0) + { + IPACMDBG_H("Found the l2tp-vlan mapping: l2tp %s\n", it_mapping->l2tp_iface_name); + memcpy(it_mapping->vlan_iface_ipv6_addr, data->ipv6_addr, + sizeof(it_mapping->vlan_iface_ipv6_addr)); + } + } + break; + } + } + + if(it_vlan == m_vlan_iface.end()) + { + IPACMDBG_H("Failed to find the vlan iface: %s\n", data->iface_name); + } + return; +} +#endif + +void IPACM_LanToLan::handle_cached_client_add_event(IPACM_Lan *p_iface) +{ + list<ipacm_event_eth_bridge>::iterator it; + + it = m_cached_client_add_event.begin(); + while(it != m_cached_client_add_event.end()) + { + if(it->p_iface == p_iface) + { + IPACMDBG_H("Found client with MAC: 0x%02x%02x%02x%02x%02x%02x\n", it->mac_addr[0], it->mac_addr[1], + it->mac_addr[2], it->mac_addr[3], it->mac_addr[4], it->mac_addr[5]); + handle_client_add(&(*it)); + it = m_cached_client_add_event.erase(it); + } + else + { + it++; + } + } + return; +} + +void IPACM_LanToLan::clear_cached_client_add_event(IPACM_Lan *p_iface) +{ + list<ipacm_event_eth_bridge>::iterator it; + + it = m_cached_client_add_event.begin(); + while(it != m_cached_client_add_event.end()) + { + if(it->p_iface == p_iface) + { + IPACMDBG_H("Found client with MAC: 0x%02x%02x%02x%02x%02x%02x\n", it->mac_addr[0], it->mac_addr[1], + it->mac_addr[2], it->mac_addr[3], it->mac_addr[4], it->mac_addr[5]); + it = m_cached_client_add_event.erase(it); + } + else + { + it++; + } + } + return; +} + +void IPACM_LanToLan::print_data_structure_info() +{ + list<IPACM_LanToLan_Iface>::iterator it; + list<ipacm_event_eth_bridge>::iterator it_event; + list<vlan_iface_info>::iterator it_vlan; + list<l2tp_vlan_mapping_info>::iterator it_mapping; + int i; + + IPACMDBG_H("Is there l2tp interface? %d\n", m_has_l2tp_iface); + +#ifdef FEATURE_L2TP + IPACMDBG_H("There are %d vlan interfaces.\n", m_vlan_iface.size()); + for(it_vlan = m_vlan_iface.begin(); it_vlan != m_vlan_iface.end(); it_vlan++) + { + IPACMDBG_H("Vlan iface: %s, id: %d, ipv6 addr: 0x%08x%08x%08x%08x\n", it_vlan->vlan_iface_name, + it_vlan->vlan_id, it_vlan->vlan_iface_ipv6_addr[0], it_vlan->vlan_iface_ipv6_addr[1], + it_vlan->vlan_iface_ipv6_addr[2], it_vlan->vlan_iface_ipv6_addr[3]); + IPACMDBG_H("Vlan client mac: 0x%02x%02x%02x%02x%02x%02x, ipv6 addr: 0x%08x%08x%08x%08x\n", + it_vlan->vlan_client_mac[0], it_vlan->vlan_client_mac[1], it_vlan->vlan_client_mac[2], + it_vlan->vlan_client_mac[3], it_vlan->vlan_client_mac[4], it_vlan->vlan_client_mac[5], + it_vlan->vlan_client_ipv6_addr[0], it_vlan->vlan_client_ipv6_addr[1], it_vlan->vlan_client_ipv6_addr[2], + it_vlan->vlan_client_ipv6_addr[3]); + } + + IPACMDBG_H("There are %d vlan-l2tp mapping.\n", m_l2tp_vlan_mapping.size()); + for(it_mapping = m_l2tp_vlan_mapping.begin(); it_mapping != m_l2tp_vlan_mapping.end(); it_mapping++) + { + IPACMDBG_H("L2tp iface: %s, session id: %d\n", it_mapping->l2tp_iface_name, it_mapping->l2tp_session_id); + IPACMDBG_H("Vlan iface: %s, id: %d, ipv6 addr: 0x%08x%08x%08x%08x\n", it_mapping->vlan_iface_name, + it_mapping->vlan_id, it_mapping->vlan_iface_ipv6_addr[0], it_mapping->vlan_iface_ipv6_addr[1], + it_mapping->vlan_iface_ipv6_addr[2], it_mapping->vlan_iface_ipv6_addr[3]); + IPACMDBG_H("Vlan client mac: 0x%02x%02x%02x%02x%02x%02x, ipv6 addr: 0x%08x%08x%08x%08x\n", + it_mapping->vlan_client_mac[0], it_mapping->vlan_client_mac[1], it_mapping->vlan_client_mac[2], + it_mapping->vlan_client_mac[3], it_mapping->vlan_client_mac[4], it_mapping->vlan_client_mac[5], + it_mapping->vlan_client_ipv6_addr[0], it_mapping->vlan_client_ipv6_addr[1], it_mapping->vlan_client_ipv6_addr[2], + it_mapping->vlan_client_ipv6_addr[3]); + IPACMDBG_H("L2tp client mac: 0x%02x%02x%02x%02x%02x%02x\n", it_mapping->l2tp_client_mac[0], it_mapping->l2tp_client_mac[1], + it_mapping->l2tp_client_mac[2], it_mapping->l2tp_client_mac[3], it_mapping->l2tp_client_mac[4], it_mapping->l2tp_client_mac[5]); + } +#endif + IPACMDBG_H("There are %d interfaces in total.\n", m_iface.size()); + for(it = m_iface.begin(); it != m_iface.end(); it++) + { + it->print_data_structure_info(); + } + + IPACMDBG_H("There are %d cached client add events in total.\n", m_cached_client_add_event.size()); + + i = 1; + for(it_event = m_cached_client_add_event.begin(); it_event != m_cached_client_add_event.end(); it_event++) + { + IPACMDBG_H("Client %d MAC: 0x%02x%02x%02x%02x%02x%02x, interface: %s\n", i, it_event->mac_addr[0], it_event->mac_addr[1], it_event->mac_addr[2], + it_event->mac_addr[3], it_event->mac_addr[4], it_event->mac_addr[5], it_event->p_iface->dev_name); + i++; + } + + return; +} + +void IPACM_LanToLan_Iface::add_client_rt_rule_for_new_iface() +{ + list<client_info>::iterator it; + ipa_hdr_l2_type peer_l2_type; + peer_iface_info &peer = m_peer_iface_info.front(); + + peer_l2_type = peer.peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type; + if(ref_cnt_peer_l2_hdr_type[peer_l2_type] == 1) + { + for(it = m_client_info.begin(); it != m_client_info.end(); it++) + { +#ifdef FEATURE_L2TP + if(it->is_l2tp_client == false) + { + add_client_rt_rule(&peer, &(*it)); + } + /* add l2tp rt rules */ + add_l2tp_client_rt_rule(&peer, &(*it)); +#else + add_client_rt_rule(&peer, &(*it)); +#endif + } + } + + return; +} + +void IPACM_LanToLan_Iface::add_client_rt_rule(peer_iface_info *peer_info, client_info *client) +{ + int i, num_rt_rule; + uint32_t rt_rule_hdl[MAX_NUM_PROP]; + ipa_hdr_l2_type peer_l2_hdr_type; + + peer_l2_hdr_type = peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type; + + /* if the peer info is not for intra interface communication */ + if(peer_info->peer != this) + { + IPACMDBG_H("This is for inter interface communication.\n"); + + m_p_iface->eth_bridge_add_rt_rule(client->mac_addr, peer_info->rt_tbl_name_for_rt[IPA_IP_v4], hdr_proc_ctx_for_inter_interface[peer_l2_hdr_type], + peer_l2_hdr_type, IPA_IP_v4, rt_rule_hdl, &num_rt_rule); + + client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v4] = num_rt_rule; + IPACMDBG_H("Number of IPv4 routing rule is %d.\n", num_rt_rule); + for(i=0; i<num_rt_rule; i++) + { + IPACMDBG_H("Routing rule %d handle %d\n", i, rt_rule_hdl[i]); + client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v4][i] = rt_rule_hdl[i]; + } + + m_p_iface->eth_bridge_add_rt_rule(client->mac_addr, peer_info->rt_tbl_name_for_rt[IPA_IP_v6], hdr_proc_ctx_for_inter_interface[peer_l2_hdr_type], + peer_l2_hdr_type, IPA_IP_v6, rt_rule_hdl, &num_rt_rule); + + client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v6] = num_rt_rule; + IPACMDBG_H("Number of IPv6 routing rule is %d.\n", num_rt_rule); + for(i=0; i<num_rt_rule; i++) + { + IPACMDBG_H("Routing rule %d handle %d\n", i, rt_rule_hdl[i]); + client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v6][i] = rt_rule_hdl[i]; + } + } + else + { + IPACMDBG_H("This is for intra interface communication.\n"); + m_p_iface->eth_bridge_add_rt_rule(client->mac_addr, peer_info->rt_tbl_name_for_rt[IPA_IP_v4], hdr_proc_ctx_for_intra_interface, + peer_l2_hdr_type, IPA_IP_v4, rt_rule_hdl, &num_rt_rule); + + client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v4] = num_rt_rule; + IPACMDBG_H("Number of IPv4 routing rule is %d.\n", num_rt_rule); + for(i=0; i<num_rt_rule; i++) + { + IPACMDBG_H("Routing rule %d handle %d\n", i, rt_rule_hdl[i]); + client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v4][i] = rt_rule_hdl[i]; + } + + m_p_iface->eth_bridge_add_rt_rule(client->mac_addr, peer_info->rt_tbl_name_for_rt[IPA_IP_v6], hdr_proc_ctx_for_intra_interface, + peer_l2_hdr_type, IPA_IP_v6, rt_rule_hdl, &num_rt_rule); + + client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v6] = num_rt_rule; + IPACMDBG_H("Number of IPv6 routing rule is %d.\n", num_rt_rule); + for(i=0; i<num_rt_rule; i++) + { + IPACMDBG_H("Routing rule %d handle %d\n", i, rt_rule_hdl[i]); + client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v6][i] = rt_rule_hdl[i]; + } + } + + return; +} + +#ifdef FEATURE_L2TP +void IPACM_LanToLan_Iface::add_l2tp_client_rt_rule(peer_iface_info *peer, client_info *client) +{ + ipa_hdr_l2_type peer_l2_hdr_type; + l2tp_vlan_mapping_info *mapping_info; + + peer_l2_hdr_type = peer->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type; + mapping_info = client->mapping_info; + if(client->is_l2tp_client) + { + m_p_iface->add_l2tp_rt_rule(IPA_IP_v4, client->mac_addr, peer_l2_hdr_type, mapping_info->l2tp_session_id, + mapping_info->vlan_id, mapping_info->vlan_client_mac, mapping_info->vlan_iface_ipv6_addr, + mapping_info->vlan_client_ipv6_addr, &client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_hdr_hdl, + &client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_hdr_proc_ctx_hdl[IPA_IP_v4], &client->l2tp_rt_rule_hdl[peer_l2_hdr_type].second_pass_hdr_hdl, + &client->l2tp_rt_rule_hdl[peer_l2_hdr_type].num_rt_hdl[IPA_IP_v4], client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_rt_rule_hdl[IPA_IP_v4], + client->l2tp_rt_rule_hdl[peer_l2_hdr_type].second_pass_rt_rule_hdl); + + m_p_iface->add_l2tp_rt_rule(IPA_IP_v6, client->mac_addr, peer_l2_hdr_type, mapping_info->l2tp_session_id, + mapping_info->vlan_id, mapping_info->vlan_client_mac, mapping_info->vlan_iface_ipv6_addr, + mapping_info->vlan_client_ipv6_addr, &client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_hdr_hdl, + &client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_hdr_proc_ctx_hdl[IPA_IP_v6], &client->l2tp_rt_rule_hdl[peer_l2_hdr_type].second_pass_hdr_hdl, + &client->l2tp_rt_rule_hdl[peer_l2_hdr_type].num_rt_hdl[IPA_IP_v6], client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_rt_rule_hdl[IPA_IP_v6], + client->l2tp_rt_rule_hdl[peer_l2_hdr_type].second_pass_rt_rule_hdl); + } + else + { + if(IPACM_LanToLan::get_instance()->has_l2tp_iface() == true) + { + m_p_iface->add_l2tp_rt_rule(IPA_IP_v6, client->mac_addr, &hdr_proc_ctx_for_l2tp, &client->l2tp_rt_rule_hdl[peer_l2_hdr_type].num_rt_hdl[IPA_IP_v6], + client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_rt_rule_hdl[IPA_IP_v6]); + } + } + return; +} +#endif + +void IPACM_LanToLan_Iface::add_all_inter_interface_client_flt_rule(ipa_ip_type iptype) +{ + list<peer_iface_info>::iterator it_iface; + list<client_info>::iterator it_client; + + for(it_iface = m_peer_iface_info.begin(); it_iface != m_peer_iface_info.end(); it_iface++) + { + IPACMDBG_H("Add flt rules for clients of interface %s.\n", it_iface->peer->get_iface_pointer()->dev_name); + for(it_client = it_iface->peer->m_client_info.begin(); it_client != it_iface->peer->m_client_info.end(); it_client++) + { + add_client_flt_rule(&(*it_iface), &(*it_client), iptype); + } + } + return; +} + +void IPACM_LanToLan_Iface::add_all_intra_interface_client_flt_rule(ipa_ip_type iptype) +{ + list<client_info>::iterator it_client; + + IPACMDBG_H("Add flt rules for own clients.\n"); + for(it_client = m_client_info.begin(); it_client != m_client_info.end(); it_client++) + { + add_client_flt_rule(&m_intra_interface_info, &(*it_client), iptype); + } + + return; +} + +void IPACM_LanToLan_Iface::add_one_client_flt_rule(IPACM_LanToLan_Iface *peer_iface, client_info *client) +{ + list<peer_iface_info>::iterator it; + + for(it = m_peer_iface_info.begin(); it != m_peer_iface_info.end(); it++) + { + if(it->peer == peer_iface) + { + IPACMDBG_H("Found the peer iface info.\n"); + if(m_is_ip_addr_assigned[IPA_IP_v4]) + { + add_client_flt_rule(&(*it), client, IPA_IP_v4); + } + if(m_is_ip_addr_assigned[IPA_IP_v6]) + { + add_client_flt_rule(&(*it), client, IPA_IP_v6); + } + + break; + } + } + return; +} + +void IPACM_LanToLan_Iface::add_client_flt_rule(peer_iface_info *peer, client_info *client, ipa_ip_type iptype) +{ + list<flt_rule_info>::iterator it_flt; + uint32_t flt_rule_hdl; + uint32_t l2tp_first_pass_flt_rule_hdl = 0, l2tp_second_pass_flt_rule_hdl = 0; + flt_rule_info new_flt_info; + ipa_ioc_get_rt_tbl rt_tbl; + + if(m_is_l2tp_iface && iptype == IPA_IP_v4) + { + IPACMDBG_H("No need to install IPv4 flt rule on l2tp interface.\n"); + return; + } + + for(it_flt = peer->flt_rule.begin(); it_flt != peer->flt_rule.end(); it_flt++) + { + if(it_flt->p_client == client) //the client is already in the flt info list + { + IPACMDBG_H("The client is found in flt info list.\n"); + break; + } + } + + if(it_flt != peer->flt_rule.end()) + { + l2tp_first_pass_flt_rule_hdl = it_flt->l2tp_first_pass_flt_rule_hdl[iptype]; + l2tp_second_pass_flt_rule_hdl = it_flt->l2tp_second_pass_flt_rule_hdl; + } + +#ifdef FEATURE_L2TP + if(m_is_l2tp_iface) + { + m_p_iface->add_l2tp_flt_rule(client->mac_addr, &l2tp_first_pass_flt_rule_hdl); + } + else +#endif + { +#ifdef FEATURE_L2TP + if(client->is_l2tp_client) + { + m_p_iface->add_l2tp_flt_rule(iptype, client->mac_addr, client->mapping_info->vlan_client_ipv6_addr, + &l2tp_first_pass_flt_rule_hdl, &l2tp_second_pass_flt_rule_hdl); + } + else +#endif + { + rt_tbl.ip = iptype; + memcpy(rt_tbl.name, peer->rt_tbl_name_for_flt[iptype], sizeof(rt_tbl.name)); + IPACMDBG_H("This flt rule points to rt tbl %s.\n", rt_tbl.name); + + if(IPACM_Iface::m_routing.GetRoutingTable(&rt_tbl) == false) + { + IPACMERR("Failed to get routing table.\n"); + return; + } + + m_p_iface->eth_bridge_add_flt_rule(client->mac_addr, rt_tbl.hdl, + iptype, &flt_rule_hdl); + IPACMDBG_H("Installed flt rule for IP type %d: handle %d\n", iptype, flt_rule_hdl); + } + } + + if(it_flt != peer->flt_rule.end()) + { + it_flt->flt_rule_hdl[iptype] = flt_rule_hdl; + it_flt->l2tp_first_pass_flt_rule_hdl[iptype] = l2tp_first_pass_flt_rule_hdl; + it_flt->l2tp_second_pass_flt_rule_hdl = l2tp_second_pass_flt_rule_hdl; + } + else + { + IPACMDBG_H("The client is not found in flt info list, insert a new one.\n"); + memset(&new_flt_info, 0, sizeof(new_flt_info)); + new_flt_info.p_client = client; + new_flt_info.flt_rule_hdl[iptype] = flt_rule_hdl; + new_flt_info.l2tp_first_pass_flt_rule_hdl[iptype] = l2tp_first_pass_flt_rule_hdl; + new_flt_info.l2tp_second_pass_flt_rule_hdl = l2tp_second_pass_flt_rule_hdl; + + peer->flt_rule.push_front(new_flt_info); + } + + return; +} + +void IPACM_LanToLan_Iface::del_one_client_flt_rule(IPACM_LanToLan_Iface *peer_iface, client_info *client) +{ + list<peer_iface_info>::iterator it; + + for(it = m_peer_iface_info.begin(); it != m_peer_iface_info.end(); it++) + { + if(it->peer == peer_iface) + { + IPACMDBG_H("Found the peer iface info.\n"); + del_client_flt_rule(&(*it), client); + break; + } + } + return; +} + +void IPACM_LanToLan_Iface::del_client_flt_rule(peer_iface_info *peer, client_info *client) +{ + list<flt_rule_info>::iterator it_flt; + + for(it_flt = peer->flt_rule.begin(); it_flt != peer->flt_rule.end(); it_flt++) + { + if(it_flt->p_client == client) //found the client in flt info list + { + IPACMDBG_H("Found the client in flt info list.\n"); + if(m_is_ip_addr_assigned[IPA_IP_v4]) + { + if(m_is_l2tp_iface) + { + IPACMDBG_H("No IPv4 client flt rule on l2tp iface.\n"); + } + else + { +#ifdef FEATURE_L2TP + if(client->is_l2tp_client) + { + m_p_iface->del_l2tp_flt_rule(IPA_IP_v4, it_flt->l2tp_first_pass_flt_rule_hdl[IPA_IP_v4], + it_flt->l2tp_second_pass_flt_rule_hdl); + it_flt->l2tp_second_pass_flt_rule_hdl = 0; + IPACMDBG_H("Deleted IPv4 first pass flt rule %d and second pass flt rule %d.\n", + it_flt->l2tp_first_pass_flt_rule_hdl[IPA_IP_v4], it_flt->l2tp_second_pass_flt_rule_hdl); + } + else +#endif + { + m_p_iface->eth_bridge_del_flt_rule(it_flt->flt_rule_hdl[IPA_IP_v4], IPA_IP_v4); + IPACMDBG_H("Deleted IPv4 flt rule %d.\n", it_flt->flt_rule_hdl[IPA_IP_v4]); + } + } + } + if(m_is_ip_addr_assigned[IPA_IP_v6]) + { +#ifdef FEATURE_L2TP + if(m_is_l2tp_iface) + { + m_p_iface->del_l2tp_flt_rule(it_flt->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6]); + IPACMDBG_H("Deleted IPv6 flt rule %d.\n", it_flt->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6]); + } + else +#endif + { +#ifdef FEATURE_L2TP + if(client->is_l2tp_client) + { + m_p_iface->del_l2tp_flt_rule(IPA_IP_v6, it_flt->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6], + it_flt->l2tp_second_pass_flt_rule_hdl); + IPACMDBG_H("Deleted IPv6 first pass flt rule %d and second pass flt rule %d.\n", + it_flt->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6], it_flt->l2tp_second_pass_flt_rule_hdl); + } + else +#endif + { + m_p_iface->eth_bridge_del_flt_rule(it_flt->flt_rule_hdl[IPA_IP_v6], IPA_IP_v6); + IPACMDBG_H("Deleted IPv6 flt rule %d.\n", it_flt->flt_rule_hdl[IPA_IP_v6]); + } + } + } + peer->flt_rule.erase(it_flt); + break; + } + } + return; +} + +void IPACM_LanToLan_Iface::del_client_rt_rule(peer_iface_info *peer, client_info *client) +{ + ipa_hdr_l2_type peer_l2_hdr_type; + int i, num_rules; + + peer_l2_hdr_type = peer->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type; + /* if the peer info is not for intra interface communication */ + if(peer->peer != this) + { + IPACMDBG_H("Delete routing rules for inter interface communication.\n"); + + if(client->is_l2tp_client == false) + { + num_rules = client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v4]; + for(i = 0; i < num_rules; i++) + { + m_p_iface->eth_bridge_del_rt_rule(client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v4][i], IPA_IP_v4); + IPACMDBG_H("IPv4 rt rule %d is deleted.\n", client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v4][i]); + } + client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v4] = 0; + + num_rules = client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v6]; + for(i = 0; i < num_rules; i++) + { + m_p_iface->eth_bridge_del_rt_rule(client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v6][i], IPA_IP_v6); + IPACMDBG_H("IPv6 rt rule %d is deleted.\n", client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v6][i]); + } + client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v6] = 0; +#ifdef FEATURE_L2TP + if(IPACM_LanToLan::get_instance()->has_l2tp_iface() == true) + { + m_p_iface->del_l2tp_rt_rule(IPA_IP_v6, client->l2tp_rt_rule_hdl[peer_l2_hdr_type].num_rt_hdl[IPA_IP_v6], + client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_rt_rule_hdl[IPA_IP_v6]); + } +#endif + } + else + { +#ifdef FEATURE_L2TP + m_p_iface->del_l2tp_rt_rule(IPA_IP_v4, client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_hdr_hdl, + client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_hdr_proc_ctx_hdl[IPA_IP_v4], client->l2tp_rt_rule_hdl[peer_l2_hdr_type].second_pass_hdr_hdl, + client->l2tp_rt_rule_hdl[peer_l2_hdr_type].num_rt_hdl[IPA_IP_v4], client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_rt_rule_hdl[IPA_IP_v4], + client->l2tp_rt_rule_hdl[peer_l2_hdr_type].second_pass_rt_rule_hdl); + + m_p_iface->del_l2tp_rt_rule(IPA_IP_v6, 0, client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_hdr_proc_ctx_hdl[IPA_IP_v6], + 0, client->l2tp_rt_rule_hdl[peer_l2_hdr_type].num_rt_hdl[IPA_IP_v6], client->l2tp_rt_rule_hdl[peer_l2_hdr_type].first_pass_rt_rule_hdl[IPA_IP_v6], + NULL); +#endif + } + } + else + { + IPACMDBG_H("Delete routing rules for intra interface communication.\n"); + num_rules = client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v4]; + for(i = 0; i < num_rules; i++) + { + m_p_iface->eth_bridge_del_rt_rule(client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v4][i], IPA_IP_v4); + IPACMDBG_H("IPv4 rt rule %d is deleted.\n", client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v4][i]); + } + client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v4] = 0; + + num_rules = client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v6]; + for(i = 0; i < num_rules; i++) + { + m_p_iface->eth_bridge_del_rt_rule(client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v6][i], IPA_IP_v6); + IPACMDBG_H("IPv6 rt rule %d is deleted.\n", client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v6][i]); + } + client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v6] = 0; + } + + return; +} + +void IPACM_LanToLan_Iface::handle_down_event() +{ + list<IPACM_LanToLan_Iface>::iterator it_other_iface; + list<peer_iface_info>::iterator it_own_peer_info, it_other_iface_peer_info; + IPACM_LanToLan_Iface *other_iface; + + /* clear inter-interface rules */ + if(m_support_inter_iface_offload) + { + for(it_own_peer_info = m_peer_iface_info.begin(); it_own_peer_info != m_peer_iface_info.end(); + it_own_peer_info++) + { + /* decrement reference count of peer l2 header type on both interfaces*/ + decrement_ref_cnt_peer_l2_hdr_type(it_own_peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type); + it_own_peer_info->peer->decrement_ref_cnt_peer_l2_hdr_type(m_p_iface->tx_prop->tx[0].hdr_l2_type); + + /* first clear all flt rule on target interface */ + IPACMDBG_H("Clear all flt rule on target interface.\n"); + clear_all_flt_rule_for_one_peer_iface(&(*it_own_peer_info)); + + other_iface = it_own_peer_info->peer; + /* then clear all flt/rt rule and hdr proc ctx for target interface on peer interfaces */ + IPACMDBG_H("Clear all flt/rt rules and hdr proc ctx for target interface on peer interfaces %s.\n", + it_own_peer_info->peer->get_iface_pointer()->dev_name); + for(it_other_iface_peer_info = other_iface->m_peer_iface_info.begin(); + it_other_iface_peer_info != other_iface->m_peer_iface_info.end(); + it_other_iface_peer_info++) + { + if(it_other_iface_peer_info->peer == this) //found myself in other iface's peer info list + { + IPACMDBG_H("Found the right peer info on other iface.\n"); + other_iface->clear_all_flt_rule_for_one_peer_iface(&(*it_other_iface_peer_info)); + other_iface->clear_all_rt_rule_for_one_peer_iface(&(*it_other_iface_peer_info)); + /* remove the peer info from the list */ + other_iface->m_peer_iface_info.erase(it_other_iface_peer_info); + other_iface->del_hdr_proc_ctx(m_p_iface->tx_prop->tx[0].hdr_l2_type); + break; + } + } + + /* then clear rt rule and hdr proc ctx and release rt table on target interface */ + IPACMDBG_H("Clear rt rules and hdr proc ctx and release rt table on target interface.\n"); + clear_all_rt_rule_for_one_peer_iface(&(*it_own_peer_info)); + del_hdr_proc_ctx(it_own_peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type); + } + m_peer_iface_info.clear(); + } + + /* clear intra interface rules */ + if(m_support_intra_iface_offload) + { + IPACMDBG_H("Clear intra interface flt/rt rules and hdr proc ctx, release rt tables.\n"); + clear_all_flt_rule_for_one_peer_iface(&m_intra_interface_info); + clear_all_rt_rule_for_one_peer_iface(&m_intra_interface_info); + m_p_iface->eth_bridge_del_hdr_proc_ctx(hdr_proc_ctx_for_intra_interface); + IPACMDBG_H("Hdr proc ctx with hdl %d is deleted.\n", hdr_proc_ctx_for_intra_interface); + } + + /* then clear the client info list */ + m_client_info.clear(); + + return; +} + +void IPACM_LanToLan_Iface::clear_all_flt_rule_for_one_peer_iface(peer_iface_info *peer) +{ + list<flt_rule_info>::iterator it; + + for(it = peer->flt_rule.begin(); it != peer->flt_rule.end(); it++) + { + if(m_is_ip_addr_assigned[IPA_IP_v4]) + { + if(m_is_l2tp_iface) + { + IPACMDBG_H("No IPv4 client flt rule on l2tp iface.\n"); + } + else + { +#ifdef FEATURE_L2TP + if(it->p_client->is_l2tp_client) + { + m_p_iface->del_l2tp_flt_rule(IPA_IP_v4, it->l2tp_first_pass_flt_rule_hdl[IPA_IP_v4], + it->l2tp_second_pass_flt_rule_hdl); + it->l2tp_second_pass_flt_rule_hdl = 0; + IPACMDBG_H("Deleted IPv4 first pass flt rule %d and second pass flt rule %d.\n", + it->l2tp_first_pass_flt_rule_hdl[IPA_IP_v4], it->l2tp_second_pass_flt_rule_hdl); + } + else +#endif + { + m_p_iface->eth_bridge_del_flt_rule(it->flt_rule_hdl[IPA_IP_v4], IPA_IP_v4); + IPACMDBG_H("Deleted IPv4 flt rule %d.\n", it->flt_rule_hdl[IPA_IP_v4]); + } + } + } + if(m_is_ip_addr_assigned[IPA_IP_v6]) + { +#ifdef FEATURE_L2TP + if(m_is_l2tp_iface) + { + m_p_iface->del_l2tp_flt_rule(it->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6]); + IPACMDBG_H("Deleted IPv6 flt rule %d.\n", it->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6]); + } + else +#endif + { +#ifdef FEATURE_L2TP + if(it->p_client->is_l2tp_client) + { + m_p_iface->del_l2tp_flt_rule(IPA_IP_v6, it->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6], + it->l2tp_second_pass_flt_rule_hdl); + IPACMDBG_H("Deleted IPv6 first pass flt rule %d and second pass flt rule %d.\n", + it->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6], it->l2tp_second_pass_flt_rule_hdl); + } + else +#endif + { + m_p_iface->eth_bridge_del_flt_rule(it->flt_rule_hdl[IPA_IP_v6], IPA_IP_v6); + IPACMDBG_H("Deleted IPv6 flt rule %d.\n", it->flt_rule_hdl[IPA_IP_v6]); + } + } + } + } + peer->flt_rule.clear(); + return; +} + +void IPACM_LanToLan_Iface::clear_all_rt_rule_for_one_peer_iface(peer_iface_info *peer) +{ + list<client_info>::iterator it; + ipa_hdr_l2_type peer_l2_type; + + peer_l2_type = peer->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type; + if(ref_cnt_peer_l2_hdr_type[peer_l2_type] == 0) + { + for(it = m_client_info.begin(); it != m_client_info.end(); it++) + { + del_client_rt_rule(peer, &(*it)); + } +#ifdef FEATURE_L2TP + if(IPACM_LanToLan::get_instance()->has_l2tp_iface() == true) + { + m_p_iface->eth_bridge_del_hdr_proc_ctx(hdr_proc_ctx_for_l2tp); + hdr_proc_ctx_for_l2tp = 0; + } +#endif + } + + return; +} + +void IPACM_LanToLan_Iface::handle_wlan_scc_mcc_switch() +{ + list<peer_iface_info>::iterator it_peer_info; + list<client_info>::iterator it_client; + ipa_hdr_l2_type peer_l2_hdr_type; + bool flag[IPA_HDR_L2_MAX]; + int i; + + /* modify inter-interface routing rules */ + if(m_support_inter_iface_offload) + { + IPACMDBG_H("Modify rt rules for peer interfaces.\n"); + memset(flag, 0, sizeof(flag)); + for(it_peer_info = m_peer_iface_info.begin(); it_peer_info != m_peer_iface_info.end(); it_peer_info++) + { + peer_l2_hdr_type = it_peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type; + if(flag[peer_l2_hdr_type] == false) + { + flag[peer_l2_hdr_type] = true; + for(it_client = m_client_info.begin(); it_client != m_client_info.end(); it_client++) + { + m_p_iface->eth_bridge_modify_rt_rule(it_client->mac_addr, hdr_proc_ctx_for_inter_interface[peer_l2_hdr_type], + peer_l2_hdr_type, IPA_IP_v4, it_client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v4], + it_client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v4]); + IPACMDBG_H("The following IPv4 routing rules are modified:\n"); + for(i = 0; i < it_client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v4]; i++) + { + IPACMDBG_H("%d\n", it_client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v4][i]); + } + + m_p_iface->eth_bridge_modify_rt_rule(it_client->mac_addr, hdr_proc_ctx_for_inter_interface[peer_l2_hdr_type], + peer_l2_hdr_type, IPA_IP_v6, it_client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v6], + it_client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v6]); + IPACMDBG_H("The following IPv6 routing rules are modified:\n"); + for(i = 0; i < it_client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].num_hdl[IPA_IP_v6]; i++) + { + IPACMDBG_H("%d\n", it_client->inter_iface_rt_rule_hdl[peer_l2_hdr_type].rule_hdl[IPA_IP_v6][i]); + } + } + } + } + } + + /* modify routing rules for intra-interface communication */ + IPACMDBG_H("Modify rt rules for intra-interface communication.\n"); + if(m_support_intra_iface_offload) + { + for(it_client = m_client_info.begin(); it_client != m_client_info.end(); it_client++) + { + m_p_iface->eth_bridge_modify_rt_rule(it_client->mac_addr, hdr_proc_ctx_for_intra_interface, + m_p_iface->tx_prop->tx[0].hdr_l2_type, IPA_IP_v4, it_client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v4], + it_client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v4]); + IPACMDBG_H("The following IPv4 routing rules are modified:\n"); + for(i = 0; i < it_client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v4]; i++) + { + IPACMDBG_H("%d\n", it_client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v4][i]); + } + + m_p_iface->eth_bridge_modify_rt_rule(it_client->mac_addr, hdr_proc_ctx_for_intra_interface, + m_p_iface->tx_prop->tx[0].hdr_l2_type, IPA_IP_v6, it_client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v6], + it_client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v6]); + IPACMDBG_H("The following IPv6 routing rules are modified:\n"); + for(i = 0; i < it_client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v6]; i++) + { + IPACMDBG_H("%d\n", it_client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v6][i]); + } + } + } + + return; +} + +void IPACM_LanToLan_Iface::handle_intra_interface_info() +{ + uint32_t hdr_proc_ctx_hdl; + + if(m_p_iface->tx_prop == NULL) + { + IPACMERR("No tx prop.\n"); + return; + } + + m_intra_interface_info.peer = this; + + snprintf(m_intra_interface_info.rt_tbl_name_for_flt[IPA_IP_v4], IPA_RESOURCE_NAME_MAX, + "eth_v4_intra_interface"); + IPACMDBG_H("IPv4 routing table for flt name: %s\n", m_intra_interface_info.rt_tbl_name_for_flt[IPA_IP_v4]); + snprintf(m_intra_interface_info.rt_tbl_name_for_flt[IPA_IP_v6], IPA_RESOURCE_NAME_MAX, + "eth_v6_intra_interface"); + IPACMDBG_H("IPv6 routing table for flt name: %s\n", m_intra_interface_info.rt_tbl_name_for_flt[IPA_IP_v6]); + + memcpy(m_intra_interface_info.rt_tbl_name_for_rt[IPA_IP_v4], m_intra_interface_info.rt_tbl_name_for_flt[IPA_IP_v4], + IPA_RESOURCE_NAME_MAX); + IPACMDBG_H("IPv4 routing table for rt name: %s\n", m_intra_interface_info.rt_tbl_name_for_rt[IPA_IP_v4]); + memcpy(m_intra_interface_info.rt_tbl_name_for_rt[IPA_IP_v6], m_intra_interface_info.rt_tbl_name_for_flt[IPA_IP_v6], + IPA_RESOURCE_NAME_MAX); + IPACMDBG_H("IPv6 routing table for rt name: %s\n", m_intra_interface_info.rt_tbl_name_for_rt[IPA_IP_v6]); + + m_p_iface->eth_bridge_add_hdr_proc_ctx(m_p_iface->tx_prop->tx[0].hdr_l2_type, + &hdr_proc_ctx_hdl); + hdr_proc_ctx_for_intra_interface = hdr_proc_ctx_hdl; + IPACMDBG_H("Hdr proc ctx for intra-interface communication: hdl %d\n", hdr_proc_ctx_hdl); + + return; +} + +void IPACM_LanToLan_Iface::handle_new_iface_up(char rt_tbl_name_for_flt[][IPA_RESOURCE_NAME_MAX], char rt_tbl_name_for_rt[][IPA_RESOURCE_NAME_MAX], + IPACM_LanToLan_Iface *peer_iface) +{ + peer_iface_info new_peer; + ipa_hdr_l2_type peer_l2_hdr_type; + + new_peer.peer = peer_iface; + memcpy(new_peer.rt_tbl_name_for_rt[IPA_IP_v4], rt_tbl_name_for_rt[IPA_IP_v4], IPA_RESOURCE_NAME_MAX); + memcpy(new_peer.rt_tbl_name_for_rt[IPA_IP_v6], rt_tbl_name_for_rt[IPA_IP_v6], IPA_RESOURCE_NAME_MAX); + memcpy(new_peer.rt_tbl_name_for_flt[IPA_IP_v4], rt_tbl_name_for_flt[IPA_IP_v4], IPA_RESOURCE_NAME_MAX); + memcpy(new_peer.rt_tbl_name_for_flt[IPA_IP_v6], rt_tbl_name_for_flt[IPA_IP_v6], IPA_RESOURCE_NAME_MAX); + + peer_l2_hdr_type = peer_iface->m_p_iface->tx_prop->tx[0].hdr_l2_type; + increment_ref_cnt_peer_l2_hdr_type(peer_l2_hdr_type); + add_hdr_proc_ctx(peer_l2_hdr_type); + + /* push the new peer_iface_info into the list */ + m_peer_iface_info.push_front(new_peer); + + return; +} + +void IPACM_LanToLan_Iface::handle_client_add(uint8_t *mac, bool is_l2tp_client, l2tp_vlan_mapping_info *mapping_info) +{ + list<client_info>::iterator it_client; + list<peer_iface_info>::iterator it_peer_info; + client_info new_client; + bool flag[IPA_HDR_L2_MAX]; + + for(it_client = m_client_info.begin(); it_client != m_client_info.end(); it_client++) + { + if(memcmp(it_client->mac_addr, mac, sizeof(it_client->mac_addr)) == 0) + { + IPACMDBG_H("This client has been added before.\n"); + return; + } + } + + if(m_client_info.size() == MAX_NUM_CLIENT) + { + IPACMDBG_H("The number of clients has reached maximum %d.\n", MAX_NUM_CLIENT); + return; + } + + IPACMDBG_H("is_l2tp_client: %d, mapping_info: %p\n", is_l2tp_client, mapping_info); + memset(&new_client, 0, sizeof(new_client)); + memcpy(new_client.mac_addr, mac, sizeof(new_client.mac_addr)); + new_client.is_l2tp_client = is_l2tp_client; + new_client.mapping_info = mapping_info; + m_client_info.push_front(new_client); + + client_info &front_client = m_client_info.front(); + + /* install inter-interface rules */ + if(m_support_inter_iface_offload) + { + memset(flag, 0, sizeof(flag)); + for(it_peer_info = m_peer_iface_info.begin(); it_peer_info != m_peer_iface_info.end(); it_peer_info++) + { + /* make sure add routing rule only once for each peer l2 header type */ + if(flag[it_peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type] == false) + { + /* add client routing rule for each peer interface */ + if(front_client.is_l2tp_client == false) + { + add_client_rt_rule(&(*it_peer_info), &front_client); + } +#ifdef FEATURE_L2TP + /* add l2tp rt rules */ + add_l2tp_client_rt_rule(&(*it_peer_info), &front_client); +#endif + flag[it_peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type] = true; + } + + /* add client filtering rule on peer interfaces */ + it_peer_info->peer->add_one_client_flt_rule(this, &front_client); + } + } + + /* install intra-interface rules */ + if(m_support_intra_iface_offload) + { + /* add routing rule first */ + add_client_rt_rule(&m_intra_interface_info, &front_client); + + /* add filtering rule */ + if(m_is_ip_addr_assigned[IPA_IP_v4]) + { + add_client_flt_rule(&m_intra_interface_info, &front_client, IPA_IP_v4); + } + if(m_is_ip_addr_assigned[IPA_IP_v6]) + { + add_client_flt_rule(&m_intra_interface_info, &front_client, IPA_IP_v6); + } + } + + return; +} + +void IPACM_LanToLan_Iface::handle_client_del(uint8_t *mac) +{ + list<client_info>::iterator it_client; + list<peer_iface_info>::iterator it_peer_info; + bool flag[IPA_HDR_L2_MAX]; + + for(it_client = m_client_info.begin(); it_client != m_client_info.end(); it_client++) + { + if(memcmp(it_client->mac_addr, mac, sizeof(it_client->mac_addr)) == 0) //found the client + { + IPACMDBG_H("Found the client.\n"); + break; + } + } + + if(it_client != m_client_info.end()) //if we found the client + { + /* uninstall inter-interface rules */ + if(m_support_inter_iface_offload) + { + memset(flag, 0, sizeof(flag)); + for(it_peer_info = m_peer_iface_info.begin(); it_peer_info != m_peer_iface_info.end(); + it_peer_info++) + { + IPACMDBG_H("Delete client filtering rule on peer interface.\n"); + it_peer_info->peer->del_one_client_flt_rule(this, &(*it_client)); + + /* make sure to delete routing rule only once for each peer l2 header type */ + if(flag[it_peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type] == false) + { + IPACMDBG_H("Delete client routing rule for peer interface.\n"); + del_client_rt_rule(&(*it_peer_info), &(*it_client)); +#ifdef FEATURE_L2TP + if(it_client->is_l2tp_client == false && IPACM_LanToLan::get_instance()->has_l2tp_iface() == true + && m_client_info.size() == 1) + { + m_p_iface->eth_bridge_del_hdr_proc_ctx(hdr_proc_ctx_for_l2tp); + hdr_proc_ctx_for_l2tp = 0; + } +#endif + flag[it_peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type] = true; + } + } + } + + /* uninstall intra-interface rules */ + if(m_support_intra_iface_offload) + { + /* delete filtering rule first */ + IPACMDBG_H("Delete client filtering rule for intra-interface communication.\n"); + del_client_flt_rule(&m_intra_interface_info, &(*it_client)); + + /* delete routing rule */ + IPACMDBG_H("Delete client routing rule for intra-interface communication.\n"); + del_client_rt_rule(&m_intra_interface_info, &(*it_client)); + } + + /* erase the client from client info list */ + m_client_info.erase(it_client); + } + else + { + IPACMDBG_H("The client is not found.\n"); + } + + return; +} + +void IPACM_LanToLan_Iface::add_hdr_proc_ctx(ipa_hdr_l2_type peer_l2_type) +{ + uint32_t hdr_proc_ctx_hdl; + + if(ref_cnt_peer_l2_hdr_type[peer_l2_type] == 1) + { + m_p_iface->eth_bridge_add_hdr_proc_ctx(peer_l2_type, &hdr_proc_ctx_hdl); + hdr_proc_ctx_for_inter_interface[peer_l2_type] = hdr_proc_ctx_hdl; + IPACMDBG_H("Installed inter-interface hdr proc ctx on iface %s: handle %d\n", m_p_iface->dev_name, hdr_proc_ctx_hdl); + } + return; +} + +void IPACM_LanToLan_Iface::del_hdr_proc_ctx(ipa_hdr_l2_type peer_l2_type) +{ + if(ref_cnt_peer_l2_hdr_type[peer_l2_type] == 0) + { + m_p_iface->eth_bridge_del_hdr_proc_ctx(hdr_proc_ctx_for_inter_interface[peer_l2_type]); + IPACMDBG_H("Hdr proc ctx with hdl %d is deleted.\n", hdr_proc_ctx_for_inter_interface[peer_l2_type]); + } + return; +} + +void IPACM_LanToLan_Iface::print_data_structure_info() +{ + list<peer_iface_info>::iterator it_peer; + list<client_info>::iterator it_client; + int i, j, k; + + IPACMDBG_H("\n"); + IPACMDBG_H("Interface %s:\n", m_p_iface->dev_name); + IPACMDBG_H("Is IPv4 addr assigned? %d\n", m_is_ip_addr_assigned[IPA_IP_v4]); + IPACMDBG_H("Is IPv6 addr assigned? %d\n", m_is_ip_addr_assigned[IPA_IP_v6]); + IPACMDBG_H("Support inter interface offload? %d\n", m_support_inter_iface_offload); + IPACMDBG_H("Support intra interface offload? %d\n", m_support_intra_iface_offload); + IPACMDBG_H("Is l2tp interface? %d\n", m_is_l2tp_iface); + + if(m_support_inter_iface_offload) + { + for(i = 0; i < IPA_HDR_L2_MAX; i++) + { + IPACMDBG_H("Ref_cnt of peer l2 type %s is %d.\n", ipa_l2_hdr_type[i], ref_cnt_peer_l2_hdr_type[i]); + if(ref_cnt_peer_l2_hdr_type[i] > 0) + { + IPACMDBG_H("Hdr proc ctx for peer l2 type %s: %d\n", ipa_l2_hdr_type[i], hdr_proc_ctx_for_inter_interface[i]); + } + } + } + + if(m_support_intra_iface_offload) + { + IPACMDBG_H("Hdr proc ctx for intra-interface: %d\n", hdr_proc_ctx_for_intra_interface); + } + + IPACMDBG_H("Hdr proc ctx for l2tp: %d\n", hdr_proc_ctx_for_l2tp); + + i = 1; + IPACMDBG_H("There are %d clients in total.\n", m_client_info.size()); + for(it_client = m_client_info.begin(); it_client != m_client_info.end(); it_client++) + { + IPACMDBG_H("Client %d MAC: 0x%02x%02x%02x%02x%02x%02x Pointer: 0x%08x\n", i, it_client->mac_addr[0], it_client->mac_addr[1], + it_client->mac_addr[2], it_client->mac_addr[3], it_client->mac_addr[4], it_client->mac_addr[5], &(*it_client)); + IPACMDBG_H("Is l2tp client? %d\n", it_client->is_l2tp_client); + if(it_client->is_l2tp_client && it_client->mapping_info) + { + IPACMDBG_H("Vlan iface associated with this client: %s\n", it_client->mapping_info->vlan_iface_name); + } + + if(m_support_inter_iface_offload) + { + for(j = 0; j < IPA_HDR_L2_MAX; j++) + { + if(ref_cnt_peer_l2_hdr_type[j] > 0) + { + IPACMDBG_H("Printing routing rule info for inter-interface communication for peer l2 type %s.\n", + ipa_l2_hdr_type[j]); + IPACMDBG_H("Number of IPv4 routing rules is %d, handles:\n", it_client->inter_iface_rt_rule_hdl[j].num_hdl[IPA_IP_v4]); + for(k = 0; k < it_client->inter_iface_rt_rule_hdl[j].num_hdl[IPA_IP_v4]; k++) + { + IPACMDBG_H("%d\n", it_client->inter_iface_rt_rule_hdl[j].rule_hdl[IPA_IP_v4][k]); + } + + IPACMDBG_H("Number of IPv6 routing rules is %d, handles:\n", it_client->inter_iface_rt_rule_hdl[j].num_hdl[IPA_IP_v6]); + for(k = 0; k < it_client->inter_iface_rt_rule_hdl[j].num_hdl[IPA_IP_v6]; k++) + { + IPACMDBG_H("%d\n", it_client->inter_iface_rt_rule_hdl[j].rule_hdl[IPA_IP_v6][k]); + } + +#ifdef FEATURE_L2TP + if(it_client->is_l2tp_client) + { + IPACMDBG_H("Printing l2tp hdr info for l2tp client.\n"); + IPACMDBG_H("First pass hdr hdl: %d, IPv4 hdr proc ctx hdl: IPv6 hdr proc ctx hdl: %d\n", + it_client->l2tp_rt_rule_hdl[j].first_pass_hdr_hdl, it_client->l2tp_rt_rule_hdl[j].first_pass_hdr_proc_ctx_hdl[IPA_IP_v4], + it_client->l2tp_rt_rule_hdl[j].first_pass_hdr_proc_ctx_hdl[IPA_IP_v6]); + IPACMDBG_H("Second pass hdr hdl: %d\n", it_client->l2tp_rt_rule_hdl[j].second_pass_hdr_hdl); + + IPACMDBG_H("Printing l2tp routing rule info for l2tp client.\n"); + IPACMDBG_H("Number of IPv4 routing rules is %d, first pass handles:\n", it_client->l2tp_rt_rule_hdl[j].num_rt_hdl[IPA_IP_v4]); + for(k = 0; k < it_client->l2tp_rt_rule_hdl[j].num_rt_hdl[IPA_IP_v4]; k++) + { + IPACMDBG_H("%d\n", it_client->l2tp_rt_rule_hdl[j].first_pass_rt_rule_hdl[IPA_IP_v4][k]); + } + IPACMDBG_H("Number of IPv6 routing rules is %d, first pass handles:\n", it_client->l2tp_rt_rule_hdl[j].num_rt_hdl[IPA_IP_v6]); + for(k = 0; k < it_client->l2tp_rt_rule_hdl[j].num_rt_hdl[IPA_IP_v6]; k++) + { + IPACMDBG_H("%d\n", it_client->l2tp_rt_rule_hdl[j].first_pass_rt_rule_hdl[IPA_IP_v6][k]); + } + IPACMDBG_H("Second pass handles:\n"); + for(k = 0; k < it_client->l2tp_rt_rule_hdl[j].num_rt_hdl[IPA_IP_v6]; k++) + { + IPACMDBG_H("%d\n", it_client->l2tp_rt_rule_hdl[j].second_pass_rt_rule_hdl[k]); + } + } + else + { + if(IPACM_LanToLan::get_instance()->has_l2tp_iface()) + { + IPACMDBG_H("Printing l2tp hdr info for non l2tp client.\n"); + IPACMDBG_H("Hdr hdl: %d, IPv4 hdr proc ctx hdl: IPv6 hdr proc ctx hdl: %d\n", + it_client->l2tp_rt_rule_hdl[j].first_pass_hdr_hdl, it_client->l2tp_rt_rule_hdl[j].first_pass_hdr_proc_ctx_hdl[IPA_IP_v4], + it_client->l2tp_rt_rule_hdl[j].first_pass_hdr_proc_ctx_hdl[IPA_IP_v6]); + + IPACMDBG_H("Printing l2tp routing rule info for non l2tp client.\n"); + IPACMDBG_H("Number of IPv4 routing rules is %d, handles:\n", it_client->l2tp_rt_rule_hdl[j].num_rt_hdl[IPA_IP_v4]); + for(k = 0; k < it_client->l2tp_rt_rule_hdl[j].num_rt_hdl[IPA_IP_v4]; k++) + { + IPACMDBG_H("%d\n", it_client->l2tp_rt_rule_hdl[j].first_pass_rt_rule_hdl[IPA_IP_v4][k]); + } + IPACMDBG_H("Number of IPv6 routing rules is %d, handles:\n", it_client->l2tp_rt_rule_hdl[j].num_rt_hdl[IPA_IP_v6]); + for(k = 0; k < it_client->l2tp_rt_rule_hdl[j].num_rt_hdl[IPA_IP_v6]; k++) + { + IPACMDBG_H("%d\n", it_client->l2tp_rt_rule_hdl[j].first_pass_rt_rule_hdl[IPA_IP_v6][k]); + } + } + } +#endif + } + } + } + + if(m_support_intra_iface_offload) + { + IPACMDBG_H("Printing routing rule info for intra-interface communication.\n"); + IPACMDBG_H("Number of IPv4 routing rules is %d, handles:\n", it_client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v4]); + for(j = 0; j < it_client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v4]; j++) + { + IPACMDBG_H("%d\n", it_client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v4][j]); + } + + IPACMDBG_H("Number of IPv6 routing rules is %d, handles:\n", it_client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v6]); + for(j = 0; j < it_client->intra_iface_rt_rule_hdl.num_hdl[IPA_IP_v6]; j++) + { + IPACMDBG_H("%d\n", it_client->intra_iface_rt_rule_hdl.rule_hdl[IPA_IP_v6][j]); + } + } + i++; + } + + IPACMDBG_H("There are %d peer interfaces in total.\n", m_peer_iface_info.size()); + for(it_peer = m_peer_iface_info.begin(); it_peer != m_peer_iface_info.end(); it_peer++) + { + print_peer_info(&(*it_peer)); + } + + if(m_support_intra_iface_offload) + { + IPACMDBG_H("This interface supports intra-interface communication, printing info:\n"); + print_peer_info(&m_intra_interface_info); + } + + return; +} + +void IPACM_LanToLan_Iface::print_peer_info(peer_iface_info *peer_info) +{ + list<flt_rule_info>::iterator it_flt; + list<rt_rule_info>::iterator it_rt; + + IPACMDBG_H("Printing peer info for iface %s:\n", peer_info->peer->m_p_iface->dev_name); + + IPACMDBG_H("There are %d flt info in total.\n", peer_info->flt_rule.size()); + for(it_flt = peer_info->flt_rule.begin(); it_flt != peer_info->flt_rule.end(); it_flt++) + { + IPACMDBG_H("Flt rule handle for client 0x%08x:\n", it_flt->p_client); + if(m_is_ip_addr_assigned[IPA_IP_v4]) + { + IPACMDBG_H("IPv4 %d\n", it_flt->flt_rule_hdl[IPA_IP_v4]); + IPACMDBG_H("IPv4 l2tp first pass flt rule: %d\n", it_flt->l2tp_first_pass_flt_rule_hdl[IPA_IP_v4]); + } + if(m_is_ip_addr_assigned[IPA_IP_v6]) + { + IPACMDBG_H("IPv6 %d\n", it_flt->flt_rule_hdl[IPA_IP_v6]); + IPACMDBG_H("IPv6 l2tp first pass flt rule: %d\n", it_flt->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6]); + } + IPACMDBG_H("L2tp second pass flt rule: %d\n", it_flt->l2tp_second_pass_flt_rule_hdl); + } + + return; +} + +IPACM_Lan* IPACM_LanToLan_Iface::get_iface_pointer() +{ + return m_p_iface; +} + +bool IPACM_LanToLan_Iface::get_m_is_ip_addr_assigned(ipa_ip_type iptype) +{ + IPACMDBG_H("Has IP address been assigned to interface %s for IP type %d? %d\n", + m_p_iface->dev_name, iptype, m_is_ip_addr_assigned[iptype]); + return m_is_ip_addr_assigned[iptype]; +} + +void IPACM_LanToLan_Iface::set_m_is_ip_addr_assigned(ipa_ip_type iptype, bool value) +{ + IPACMDBG_H("Is IP address of IP type %d assigned to interface %s? %d\n", iptype, + m_p_iface->dev_name, value); + m_is_ip_addr_assigned[iptype] = value; +} + +bool IPACM_LanToLan_Iface::get_m_support_inter_iface_offload() +{ + IPACMDBG_H("Support inter interface offload on %s? %d\n", m_p_iface->dev_name, + m_support_inter_iface_offload); + return m_support_inter_iface_offload; +} + +bool IPACM_LanToLan_Iface::get_m_support_intra_iface_offload() +{ + IPACMDBG_H("Support intra interface offload on %s? %d\n", m_p_iface->dev_name, + m_support_intra_iface_offload); + return m_support_intra_iface_offload; +} + +void IPACM_LanToLan_Iface::increment_ref_cnt_peer_l2_hdr_type(ipa_hdr_l2_type peer_l2_type) +{ + ref_cnt_peer_l2_hdr_type[peer_l2_type]++; + IPACMDBG_H("Now the ref_cnt of peer l2 hdr type %s is %d.\n", ipa_l2_hdr_type[peer_l2_type], + ref_cnt_peer_l2_hdr_type[peer_l2_type]); + + return; +} + +void IPACM_LanToLan_Iface::decrement_ref_cnt_peer_l2_hdr_type(ipa_hdr_l2_type peer_l2_type) +{ + ref_cnt_peer_l2_hdr_type[peer_l2_type]--; + IPACMDBG_H("Now the ref_cnt of peer l2 hdr type %s is %d.\n", ipa_l2_hdr_type[peer_l2_type], + ref_cnt_peer_l2_hdr_type[peer_l2_type]); + + return; +} + +#ifdef FEATURE_L2TP +bool IPACM_LanToLan_Iface::set_l2tp_iface(char *vlan_iface_name) +{ + IPACMDBG_H("Self iface %s, vlan iface %s\n", m_p_iface->dev_name, + vlan_iface_name); + + if(m_is_l2tp_iface == false) + { + if(strncmp(m_p_iface->dev_name, vlan_iface_name, strlen(m_p_iface->dev_name)) == 0) + { + IPACMDBG_H("This interface is l2tp interface.\n"); + m_is_l2tp_iface = true; + switch_to_l2tp_iface(); + } + } + return m_is_l2tp_iface; +} + +bool IPACM_LanToLan_Iface::is_l2tp_iface() +{ + return m_is_l2tp_iface; +} + +void IPACM_LanToLan_Iface::switch_to_l2tp_iface() +{ + list<peer_iface_info>::iterator it_peer; + list<flt_rule_info>::iterator it_flt; + + for(it_peer = m_peer_iface_info.begin(); it_peer != m_peer_iface_info.end(); it_peer++) + { + for(it_flt = it_peer->flt_rule.begin(); it_flt != it_peer->flt_rule.end(); it_flt++) + { + if(m_is_ip_addr_assigned[IPA_IP_v4]) + { + m_p_iface->eth_bridge_del_flt_rule(it_flt->flt_rule_hdl[IPA_IP_v4], IPA_IP_v4); + IPACMDBG_H("Deleted IPv4 flt rule %d.\n", it_flt->flt_rule_hdl[IPA_IP_v4]); + } + if(m_is_ip_addr_assigned[IPA_IP_v6]) + { + m_p_iface->eth_bridge_del_flt_rule(it_flt->flt_rule_hdl[IPA_IP_v6], IPA_IP_v6); + m_p_iface->add_l2tp_flt_rule(it_flt->p_client->mac_addr, &it_flt->l2tp_first_pass_flt_rule_hdl[IPA_IP_v6]); + IPACMDBG_H("Deleted IPv6 flt rule %d.\n", it_flt->flt_rule_hdl[IPA_IP_v6]); + } + } + } + return; +} +void IPACM_LanToLan_Iface::handle_l2tp_enable() +{ + int i; + ipa_hdr_l2_type peer_l2_hdr_type; + list<peer_iface_info>::iterator it_peer_info; + list<client_info>::iterator it_client; + bool flag[IPA_HDR_L2_MAX]; + + if(m_support_inter_iface_offload) + { + memset(flag, 0, sizeof(flag)); + for(it_peer_info = m_peer_iface_info.begin(); it_peer_info != m_peer_iface_info.end(); it_peer_info++) + { + if(it_peer_info->peer->is_l2tp_iface()) + { + peer_l2_hdr_type = it_peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type; + flag[peer_l2_hdr_type] = true; + } + } + + for(i = 0; i < IPA_HDR_L2_MAX; i++) + { + if(flag[i] == true) + { + IPACMDBG_H("Add rt rule for peer l2 type %s\n", ipa_l2_hdr_type[i]); + for(it_client = m_client_info.begin(); it_client != m_client_info.end(); it_client++) + { + m_p_iface->add_l2tp_rt_rule(IPA_IP_v6, it_client->mac_addr, &hdr_proc_ctx_for_l2tp, + &it_client->l2tp_rt_rule_hdl[i].num_rt_hdl[IPA_IP_v6], + it_client->l2tp_rt_rule_hdl[i].first_pass_rt_rule_hdl[IPA_IP_v6]); + } + } + } + } + return; +} + +void IPACM_LanToLan_Iface::handle_l2tp_disable() +{ + int i; + ipa_hdr_l2_type peer_l2_hdr_type; + list<peer_iface_info>::iterator it_peer_info; + list<client_info>::iterator it_client; + bool flag[IPA_HDR_L2_MAX]; + + if(m_support_inter_iface_offload) + { + memset(flag, 0, sizeof(flag)); + for(it_peer_info = m_peer_iface_info.begin(); it_peer_info != m_peer_iface_info.end(); it_peer_info++) + { + peer_l2_hdr_type = it_peer_info->peer->get_iface_pointer()->tx_prop->tx[0].hdr_l2_type; + flag[peer_l2_hdr_type] = true; + } + + for(i = 0; i < IPA_HDR_L2_MAX; i++) + { + if(flag[i] == true) + { + IPACMDBG_H("Delete rt rule for peer l2 type %s\n", ipa_l2_hdr_type[i]); + for(it_client = m_client_info.begin(); it_client != m_client_info.end(); it_client++) + { + m_p_iface->del_l2tp_rt_rule(IPA_IP_v6, it_client->l2tp_rt_rule_hdl[i].num_rt_hdl[IPA_IP_v6], + it_client->l2tp_rt_rule_hdl[i].first_pass_rt_rule_hdl[IPA_IP_v6]); + } + } + } + } + return; +} +#endif |