aboutsummaryrefslogtreecommitdiff
path: root/data-ipa-cfg-mgr/ipacm/src/IPACM_LanToLan.cpp
diff options
context:
space:
mode:
authorBruno Martins <bgcngm@gmail.com>2018-01-08 12:51:07 +0000
committerDavide Garberi <dade.garberi@gmail.com>2018-01-20 09:30:21 +0100
commit1c67f47d4a205e12650dcb6255c00bafc0046082 (patch)
tree72bb48ca2152cb2295b0f8de39497490d8616f6f /data-ipa-cfg-mgr/ipacm/src/IPACM_LanToLan.cpp
parent6b0c862328f58e523e2a6efa667a2f4b3a609bf3 (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.cpp2081
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