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

Forward multicast datagrams when operating in NCP mode. (#243)

Browse Source
This commit is contained in:
Jonathan Hui
2016-07-07 08:41:25 -07:00
committed by GitHub
parent ab28c3a063
commit d6107c5f53
2 changed files with 31 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/net/ip6.cpp
+27 -5
View File
@@ -304,6 +304,29 @@ exit:
return error;
}
void Ip6::ProcessReceiveCallback(Message &aMessage)
{
ThreadError error = kThreadError_None;
Message *messageCopy;
VerifyOrExit(sReceiveIp6DatagramCallback != NULL, ;);
// make a copy of the datagram to pass to host
VerifyOrExit((messageCopy = NewMessage(0)) != NULL, ;);
SuccessOrExit(error = messageCopy->SetLength(aMessage.GetLength()));
VerifyOrExit(aMessage.CopyTo(0, 0, aMessage.GetLength(), *messageCopy) == aMessage.GetLength(),
error = kThreadError_Drop);
sReceiveIp6DatagramCallback(messageCopy);
exit:
if (error != kThreadError_None && messageCopy != NULL)
{
Message::Free(*messageCopy);
}
}
ThreadError Ip6::HandleDatagram(Message &message, Netif *netif, uint8_t interfaceId, const void *linkMessageInfo,
bool fromLocalHost)
{
@@ -383,13 +406,12 @@ ThreadError Ip6::HandleDatagram(Message &message, Netif *netif, uint8_t interfac
// process IPv6 Payload
if (receive)
{
SuccessOrExit(HandlePayload(message, messageInfo, nextHeader));
if (sReceiveIp6DatagramCallback != NULL && fromLocalHost == false)
if (fromLocalHost == false)
{
sReceiveIp6DatagramCallback(&message);
ExitNow(error = kThreadError_None);
ProcessReceiveCallback(message);
}
SuccessOrExit(HandlePayload(message, messageInfo, nextHeader));
}
if (forward)
src/core/net/ip6.hpp
+4 -3
View File
@@ -530,7 +530,6 @@ public:
*/
static uint16_t UpdateChecksum(uint16_t aChecksum, uint16_t aValue);
/**
* This static method updates a checksum.
*
@@ -571,12 +570,14 @@ public:
/**
* This function registers a callback to provide received raw IPv6 datagrams.
*
* @param[in] aCallback A pointer to a function that is called when an IPv6 datagram is received or NULL to disable
* the callback.
* @param[in] aCallback A pointer to a function that is called when an IPv6 datagram is received or NULL to
* disable the callback.
*
*/
static void SetReceiveDatagramCallback(otReceiveIp6DatagramCallback aCallback);
private:
static void ProcessReceiveCallback(Message &aMessage);
};
/**