/*
Copyright (c) 2014, 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_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;
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;
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);
return;
}
IPACM_LanToLan::~IPACM_LanToLan()
{
IPACMDBG_DMESG("WARNING: UNEXPECTEDLY KILL LAN2LAN CONTROLLER!\n");
return;
}
void IPACM_LanToLan::event_callback(ipa_cm_event_id event, void* param)
{
ipacm_event_eth_bridge *data = (ipacm_event_eth_bridge*)param;
IPACMDBG_H("Get %s event.\n", IPACM_Iface::ipacmcfg->getEventName(event));
switch(event)
{
case IPA_ETH_BRIDGE_IFACE_UP:
{
handle_iface_up(data);
break;
}
case IPA_ETH_BRIDGE_IFACE_DOWN:
{
handle_iface_down(data);
break;
}
case IPA_ETH_BRIDGE_CLIENT_ADD:
{
handle_client_add(data);
break;
}
case IPA_ETH_BRIDGE_CLIENT_DEL:
{
handle_client_del(data);
break;
}
case IPA_ETH_BRIDGE_WLAN_SCC_MCC_SWITCH:
{
handle_wlan_scc_mcc_switch(data);
break;
}
default:
break;
}
print_data_structure_info();
return;
}
void IPACM_LanToLan::handle_iface_up(ipacm_event_eth_bridge *data)
{
list<IPACM_LanToLan_Iface>::iterator it;
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();
/* 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;
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);
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;
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) //find the interface
{
IPACMDBG_H("Found the interface.\n");
it_iface->handle_client_add(data->mac_addr);
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;
}
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;
int i;
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++)
{
add_client_rt_rule(&peer, &(*it));
}
}
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;
}
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;
flt_rule_info new_flt_info;
ipa_ioc_get_rt_tbl rt_tbl;
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);
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");
it_flt->flt_rule_hdl[iptype] = flt_rule_hdl;
break;
}
}
if(it_flt == peer->flt_rule.end()) //the client is not in the flt info list
{
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;
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])
{
m_p_iface->eth_bridge_del_flt_rule(it_flt->flt_rule_hdl[IPA_IP_v4], IPA_IP_v4);
IPACMDBG_H("IPv4 flt rule %d is deleted.\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);
IPACMDBG_H("IPv6 flt rule %d is deleted.\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");
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;
}
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])
{
m_p_iface->eth_bridge_del_flt_rule(it->flt_rule_hdl[IPA_IP_v4], IPA_IP_v4);
IPACMDBG_H("IPv4 flt rule %d is deleted.\n", it->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_rule_hdl[IPA_IP_v6], IPA_IP_v6);
IPACMDBG_H("IPv6 flt rule %d is deleted.\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));
}
}
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)
{
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;
}
memcpy(new_client.mac_addr, mac, sizeof(new_client.mac_addr));
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 */
add_client_rt_rule(&(*it_peer_info), &front_client);
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));
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);
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);
}
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));
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]);
}
}
}
}
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]);
}
if(m_is_ip_addr_assigned[IPA_IP_v6])
{
IPACMDBG_H("IPv6 %d\n", it_flt->flt_rule_hdl[IPA_IP_v6]);
}
}
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;
}