Skip to content

Commit

Permalink
Changes #7 Fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
dgsudharsan committed Jun 22, 2021
1 parent c5766fe commit 594b136
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 5 deletions.
6 changes: 4 additions & 2 deletions orchagent/portsorch.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -4153,11 +4153,12 @@ bool PortsOrch::addVlanFloodGroups(Port &vlan, Port &port, string end_point_ip)
}
}
vlan.m_vlan_info.l2mc_group_id = l2mc_group_id;
m_portList[vlan.m_alias] = vlan;
}

vector<sai_attribute_t> attrs;
attr.id = SAI_L2MC_GROUP_MEMBER_ATTR_L2MC_GROUP_ID;
attr.value.oid = l2mc_group_id;
attr.value.oid = vlan.m_vlan_info.l2mc_group_id;
attrs.push_back(attr);

attr.id = SAI_L2MC_GROUP_MEMBER_ATTR_L2MC_OUTPUT_ID;
Expand All @@ -4184,13 +4185,14 @@ bool PortsOrch::addVlanFloodGroups(Port &vlan, Port &port, string end_point_ip)
status = sai_l2mc_group_api->create_l2mc_group_member(&l2mc_group_member, gSwitchId,
static_cast<uint32_t>(attrs.size()),
attrs.data());
if (status != SAI_STATUS_FAILURE)
if (status != SAI_STATUS_SUCCESS)
{
SWSS_LOG_ERROR("Failed to create l2mc group member for adding tunnel %s to vlan %hu",
end_point_ip.c_str(), vlan.m_vlan_info.vlan_id);
return false;
}
vlan.m_vlan_info.l2mc_members[end_point_ip] = l2mc_group_member;
m_portList[vlan.m_alias] = vlan;
return true;
}

Expand Down
8 changes: 5 additions & 3 deletions orchagent/vxlanorch.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1749,9 +1749,10 @@ bool VxlanTunnelMapOrch::addOperation(const Request& request)
TUNNELMAP_SET_VRF(mapper_list);
tunnel_obj->createTunnelHw(mapper_list,TUNNEL_MAP_USE_DEDICATED_ENCAP_DECAP);
Port tunPort;
if (!tunnel_orch->getTunnelPort(tunnel_name, tunPort, true))
auto src_vtep = tunnel_obj->getSrcIP().to_string();
if (!tunnel_orch->getTunnelPort(src_vtep, tunPort, true))
{
auto port_tunnel_name = tunnel_orch->getTunnelPortName(tunnel_name, true);
auto port_tunnel_name = tunnel_orch->getTunnelPortName(src_vtep, true);
gPortsOrch->addTunnel(port_tunnel_name, tunnel_obj->getTunnelId(), false);
gPortsOrch->getPort(port_tunnel_name,tunPort);
gPortsOrch->addBridgePort(tunPort);
Expand Down Expand Up @@ -1847,7 +1848,8 @@ bool VxlanTunnelMapOrch::delOperation(const Request& request)
if (tunnel_obj->getDipTunnelCnt() == 0)
{
Port tunnelPort;
auto port_tunnel_name = tunnel_orch->getTunnelPortName(tunnel_name, true);
auto src_vtep = tunnel_obj->getSrcIP().to_string();
auto port_tunnel_name = tunnel_orch->getTunnelPortName(src_vtep, true);
bool ret;

ret = gPortsOrch->getPort(port_tunnel_name,tunnelPort);
Expand Down

0 comments on commit 594b136

Please sign in to comment.