espressif/openthread
1
0
Fork 0
mirror of https://github.com/espressif/openthread.git synced 2026-08-02 17:17:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Filter out ICMP Echo Requests when ICMP offload is enabled. (#447)

Browse Source
This commit is contained in:
Jonathan Hui
2016-08-22 21:19:49 -07:00
committed by GitHub
parent 0de5f59090
commit f52efd73e6
4 changed files with 33 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/net/ip6.cpp
+30 -11
View File
@@ -334,7 +334,7 @@ exit:
return error;
}
void Ip6::ProcessReceiveCallback(Message &aMessage)
void Ip6::ProcessReceiveCallback(const Message &aMessage, const MessageInfo &messageInfo, uint8_t aIpProto)
{
ThreadError error = kThreadError_None;
Message *messageCopy = NULL;
@@ -343,19 +343,38 @@ void Ip6::ProcessReceiveCallback(Message &aMessage)
if (sIsReceiveIp6FilterEnabled)
{
Header ip6;
aMessage.Read(0, sizeof(ip6), &ip6);
// do not pass messages sent to/from an RLOC
VerifyOrExit(!ip6.GetSource().IsRoutingLocator() && !ip6.GetDestination().IsRoutingLocator(), ;);
VerifyOrExit(!messageInfo.GetSockAddr().IsRoutingLocator() &&
!messageInfo.GetPeerAddr().IsRoutingLocator(), ;);
if (ip6.GetSource().IsLinkLocal() && ip6.GetNextHeader() == kProtoUdp)
switch (aIpProto)
{
UdpHeader udp;
aMessage.Read(sizeof(ip6), sizeof(udp), &udp);
case kProtoIcmp6:
if (Icmp::IsEchoEnabled())
{
IcmpHeader icmp;
aMessage.Read(aMessage.GetOffset(), sizeof(icmp), &icmp);
// do not pass MLE messages
VerifyOrExit(udp.GetDestinationPort() != Mle::kUdpPort, ;);
// do not pass ICMP Echo Request messages
VerifyOrExit(icmp.GetType() != IcmpHeader::kTypeEchoRequest, ;);
}
break;
case kProtoUdp:
if (messageInfo.GetSockAddr().IsLinkLocal())
{
UdpHeader udp;
aMessage.Read(aMessage.GetOffset(), sizeof(udp), &udp);
// do not pass MLE messages
VerifyOrExit(udp.GetDestinationPort() != Mle::kUdpPort, ;);
}
break;
default:
break;
}
}
@@ -460,7 +479,7 @@ ThreadError Ip6::HandleDatagram(Message &message, Netif *netif, int8_t interface
{
if (fromLocalHost == false)
{
ProcessReceiveCallback(message);
ProcessReceiveCallback(message, messageInfo, nextHeader);
}
SuccessOrExit(error = HandlePayload(message, messageInfo, nextHeader));