mirror of
https://github.com/espressif/openthread.git
synced 2026-10-05 07:17:39 +00:00
Use Leader ALOC if it is commissioner (#836)
* Use Leader ALOC if it is commissioner
This commit is contained in:
@@ -254,6 +254,11 @@ uint16_t Commissioner::GetSessionId(void) const
|
|||||||
return mSessionId;
|
return mSessionId;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
uint8_t Commissioner::GetState(void) const
|
||||||
|
{
|
||||||
|
return mState;
|
||||||
|
}
|
||||||
|
|
||||||
void Commissioner::HandleTimer(void *aContext)
|
void Commissioner::HandleTimer(void *aContext)
|
||||||
{
|
{
|
||||||
static_cast<Commissioner *>(aContext)->HandleTimer();
|
static_cast<Commissioner *>(aContext)->HandleTimer();
|
||||||
|
|||||||
@@ -127,6 +127,25 @@ public:
|
|||||||
*/
|
*/
|
||||||
uint16_t GetSessionId(void) const;
|
uint16_t GetSessionId(void) const;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Commissioner State.
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
enum
|
||||||
|
{
|
||||||
|
kStateDisabled = 0,
|
||||||
|
kStatePetition = 1,
|
||||||
|
kStateActive = 2,
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* This method returns the Commissioner State.
|
||||||
|
*
|
||||||
|
* @returns The Commissioner State.
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
uint8_t GetState(void) const;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This method sends MGMT_COMMISSIONER_GET.
|
* This method sends MGMT_COMMISSIONER_GET.
|
||||||
*
|
*
|
||||||
@@ -197,12 +216,6 @@ private:
|
|||||||
ThreadError SendPetition(void);
|
ThreadError SendPetition(void);
|
||||||
ThreadError SendKeepAlive(void);
|
ThreadError SendKeepAlive(void);
|
||||||
|
|
||||||
enum
|
|
||||||
{
|
|
||||||
kStateDisabled = 0,
|
|
||||||
kStatePetition = 1,
|
|
||||||
kStateActive = 2,
|
|
||||||
};
|
|
||||||
uint8_t mState;
|
uint8_t mState;
|
||||||
|
|
||||||
struct Joiner
|
struct Joiner
|
||||||
|
|||||||
@@ -194,7 +194,7 @@ ThreadError DatasetManager::Register(void)
|
|||||||
SuccessOrExit(error = message->Append(header.GetBytes(), header.GetLength()));
|
SuccessOrExit(error = message->Append(header.GetBytes(), header.GetLength()));
|
||||||
SuccessOrExit(error = message->Append(mLocal.GetBytes(), mLocal.GetSize()));
|
SuccessOrExit(error = message->Append(mLocal.GetBytes(), mLocal.GetSize()));
|
||||||
|
|
||||||
mMle.GetLeaderAddress(leader);
|
mMle.GetLeaderAloc(leader);
|
||||||
|
|
||||||
memset(&messageInfo, 0, sizeof(messageInfo));
|
memset(&messageInfo, 0, sizeof(messageInfo));
|
||||||
memcpy(&messageInfo.mPeerAddr, &leader, sizeof(messageInfo.mPeerAddr));
|
memcpy(&messageInfo.mPeerAddr, &leader, sizeof(messageInfo.mPeerAddr));
|
||||||
@@ -552,7 +552,7 @@ ThreadError DatasetManager::SendSetRequest(const otOperationalDataset &aDataset,
|
|||||||
}
|
}
|
||||||
|
|
||||||
memset(&messageInfo, 0, sizeof(messageInfo));
|
memset(&messageInfo, 0, sizeof(messageInfo));
|
||||||
mMle.GetLeaderAddress(messageInfo.GetPeerAddr());
|
mMle.GetLeaderAloc(messageInfo.GetPeerAddr());
|
||||||
messageInfo.mPeerPort = kCoapUdpPort;
|
messageInfo.mPeerPort = kCoapUdpPort;
|
||||||
SuccessOrExit(error = mSocket.SendTo(*message, messageInfo));
|
SuccessOrExit(error = mSocket.SendTo(*message, messageInfo));
|
||||||
|
|
||||||
@@ -603,7 +603,7 @@ ThreadError DatasetManager::SendGetRequest(const uint8_t *aTlvTypes, const uint8
|
|||||||
}
|
}
|
||||||
|
|
||||||
memset(&messageInfo, 0, sizeof(messageInfo));
|
memset(&messageInfo, 0, sizeof(messageInfo));
|
||||||
mMle.GetLeaderAddress(messageInfo.GetPeerAddr());
|
mMle.GetLeaderAloc(messageInfo.GetPeerAddr());
|
||||||
messageInfo.mPeerPort = kCoapUdpPort;
|
messageInfo.mPeerPort = kCoapUdpPort;
|
||||||
SuccessOrExit(error = mSocket.SendTo(*message, messageInfo));
|
SuccessOrExit(error = mSocket.SendTo(*message, messageInfo));
|
||||||
|
|
||||||
|
|||||||
@@ -636,7 +636,7 @@ ThreadError NetworkData::SendServerDataNotification(uint16_t aRloc16)
|
|||||||
}
|
}
|
||||||
|
|
||||||
memset(&messageInfo, 0, sizeof(messageInfo));
|
memset(&messageInfo, 0, sizeof(messageInfo));
|
||||||
mMle.GetLeaderAddress(messageInfo.GetPeerAddr());
|
mMle.GetLeaderAloc(messageInfo.GetPeerAddr());
|
||||||
messageInfo.mPeerPort = kCoapUdpPort;
|
messageInfo.mPeerPort = kCoapUdpPort;
|
||||||
SuccessOrExit(error = mSocket.SendTo(*message, messageInfo));
|
SuccessOrExit(error = mSocket.SendTo(*message, messageInfo));
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user