/openthread-latest/src/core/coap/ |
D | coap.hpp | 167 void HandleRequest(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) const in HandleRequest() 256 void HandleRequest(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) const in HandleRequest() 288 …void EnqueueResponse(Message &aMessage, const Ip6::MessageInfo &aMessageInfo, const TxParameters &… 306 …Error GetMatchedResponseCopy(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo, Messag… 318 struct ResponseMetadata : public Message::FooterData<ResponseMetadata> 324 …const Message *FindMatchedResponse(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) … 325 void DequeueResponse(Message &aMessage); 358 …typedef Error (*Interceptor)(const Message &aMessage, const Ip6::MessageInfo &aMessageInfo, void *… 417 Message *NewMessage(const Message::Settings &aSettings); 424 Message *NewMessage(void); [all …]
|
D | coap_message.hpp | 159 class Message : public ot::Message class 341 Error SetTokenFromMessage(const Message &aMessage); 361 bool IsTokenEqual(const Message &aMessage) const; 390 …Error AppendOptionFromMessage(uint16_t aNumber, uint16_t aLength, const Message &aMessage, uint16_… 605 Error SetDefaultResponseHeader(const Message &aRequest); 748 Message *Clone(uint16_t aLength) const; 759 Message *Clone(void) const { return Clone(GetLength()); } in Clone() 774 Message *GetNextCoapMessage(void) { return static_cast<Message *>(GetNext()); } in GetNextCoapMessage() 784 … const Message *GetNextCoapMessage(void) const { return static_cast<const Message *>(GetNext()); } in GetNextCoapMessage() 884 class ConstIterator : public ot::Message::ConstIterator [all …]
|
D | coap_message.cpp | 41 void Message::Init(void) in Init() 56 void Message::Init(Type aType, Code aCode) in Init() 63 Error Message::Init(Type aType, Code aCode, Uri aUri) in Init() 75 Error Message::InitAsPost(const Ip6::Address &aDestination, Uri aUri) in InitAsPost() 80 bool Message::IsConfirmablePostRequest(void) const { return IsConfirmable() && IsPostRequest(); } in IsConfirmablePostRequest() 82 bool Message::IsNonConfirmablePostRequest(void) const { return IsNonConfirmable() && IsPostRequest(… in IsNonConfirmablePostRequest() 84 void Message::Finish(void) in Finish() 99 uint8_t Message::WriteExtendedOptionField(uint16_t aValue, uint8_t *&aBuffer) in WriteExtendedOptionField() 141 Error Message::AppendOptionHeader(uint16_t aNumber, uint16_t aLength) in AppendOptionHeader() 173 Error Message::AppendOption(uint16_t aNumber, uint16_t aLength, const void *aValue) in AppendOption() [all …]
|
D | coap.cpp | 67 for (Message &message : mPendingRequests) in ClearRequests() 98 Message *CoapBase::NewMessage(const Message::Settings &aSettings) in NewMessage() 100 Message *message = nullptr; in NewMessage() 109 Message *CoapBase::NewMessage(void) { return NewMessage(Message::Settings::GetDefault()); } in NewMessage() 111 Message *CoapBase::NewPriorityMessage(void) in NewPriorityMessage() 113 return NewMessage(Message::Settings(kWithLinkSecurity, Message::kPriorityNet)); in NewPriorityMessage() 116 Message *CoapBase::NewPriorityConfirmablePostMessage(Uri aUri) in NewPriorityConfirmablePostMessage() 121 Message *CoapBase::NewConfirmablePostMessage(Uri aUri) { return InitMessage(NewMessage(), kTypeConf… in NewConfirmablePostMessage() 123 Message *CoapBase::NewPriorityNonConfirmablePostMessage(Uri aUri) in NewPriorityNonConfirmablePostMessage() 128 Message *CoapBase::NewNonConfirmablePostMessage(Uri aUri) in NewNonConfirmablePostMessage() [all …]
|
/openthread-latest/src/core/common/ |
D | message.hpp | 144 class Message; 164 friend class Message; 229 Message *mNext; // Next message in a doubly linked list. 230 Message *mPrev; // Previous message in a doubly linked list. 272 class Message : public otMessage, public Buffer, public GetProvider<Message> class 430 Error AppendTo(Message &aMessage) const { return aMessage.Append<DataType>(AsDataType()); } in AppendTo() 439 void ReadFrom(const Message &aMessage) in ReadFrom() 451 void UpdateIn(Message &aMessage) const in UpdateIn() 463 void RemoveFrom(Message &aMessage) const { aMessage.RemoveFooter(sizeof(DataType)); } in RemoveFrom() 490 Message *GetNext(void) const; [all …]
|
D | message.cpp | 61 Message *MessagePool::Allocate(Message::Type aType, uint16_t aReserveHeader, const Message::Setting… in Allocate() 64 Message *message; in Allocate() 66 VerifyOrExit((message = static_cast<Message *>(NewBuffer(aSettings.GetPriority()))) != nullptr); in Allocate() 74 message->SetOrigin(Message::kOriginHostTrusted); in Allocate() 89 Message *MessagePool::Allocate(Message::Type aType) { return Allocate(aType, 0, Message::Settings::… in Allocate() 91 Message *MessagePool::Allocate(Message::Type aType, uint16_t aReserveHeader) in Allocate() 93 return Allocate(aType, aReserveHeader, Message::Settings::GetDefault()); in Allocate() 96 void MessagePool::Free(Message *aMessage) in Free() 103 Buffer *MessagePool::NewBuffer(Message::Priority aPriority) in NewBuffer() 152 Error MessagePool::ReclaimBuffers(Message::Priority aPriority) { return Get<MeshForwarder>().EvictM… in ReclaimBuffers() [all …]
|
D | tlvs.hpp | 50 class Message; 162 Error AppendTo(Message &aMessage) const; 248 Error ParseFrom(const Message &aMessage, uint16_t aOffset); 262 Error ParseFrom(const Message &aMessage, const OffsetRange &aOffsetRange); 276 Error FindIn(const Message &aMessage, uint8_t aType); 304 …static Error ReadTlvValue(const Message &aMessage, uint16_t aOffset, void *aValue, uint8_t aMinLen… 319 …static Error Read(const Message &aMessage, uint16_t aOffset, typename SimpleTlvType::ValueType &aV… in Read() 337 …static Error Read(const Message &aMessage, uint16_t aOffset, typename UintTlvType::UintValueType &… in Read() 355 …static Error Read(const Message &aMessage, uint16_t aOffset, typename StringTlvType::StringType &a… in Read() 373 static Error FindTlv(const Message &aMessage, uint8_t aType, uint16_t aMaxSize, Tlv &aTlv); [all …]
|
D | tlvs.cpp | 57 Error Tlv::AppendTo(Message &aMessage) const { return aMessage.AppendBytes(this, static_cast<uint16… in AppendTo() 59 Error Tlv::FindTlv(const Message &aMessage, uint8_t aType, uint16_t aMaxSize, Tlv &aTlv) in FindTlv() 66 Error Tlv::FindTlv(const Message &aMessage, uint8_t aType, uint16_t aMaxSize, Tlv &aTlv, uint16_t &… in FindTlv() 81 Error Tlv::FindTlvValueOffsetRange(const Message &aMessage, uint8_t aType, OffsetRange &aOffsetRang… in FindTlvValueOffsetRange() 93 Error Tlv::ParsedInfo::ParseFrom(const Message &aMessage, uint16_t aOffset) in ParseFrom() 101 Error Tlv::ParsedInfo::ParseFrom(const Message &aMessage, const OffsetRange &aOffsetRange) in ParseFrom() 141 Error Tlv::ParsedInfo::FindIn(const Message &aMessage, uint8_t aType) in FindIn() 165 Error Tlv::ReadStringTlv(const Message &aMessage, uint16_t aOffset, uint8_t aMaxStringLength, char … in ReadStringTlv() 180 template <typename UintType> Error Tlv::ReadUintTlv(const Message &aMessage, uint16_t aOffset, Uint… in ReadUintTlv() 192 template Error Tlv::ReadUintTlv<uint8_t>(const Message &aMessage, uint16_t aOffset, uint8_t &aValue… [all …]
|
/openthread-latest/tests/unit/ |
D | test_priority_queue.cpp | 49 Message *message; in VerifyPriorityQueueContent() 50 Message *msgArg; in VerifyPriorityQueueContent() 51 int8_t curPriority = Message::kNumPriorities; in VerifyPriorityQueueContent() 66 VerifyOrQuit(aPriorityQueue.GetHeadForPriority(Message::kPriorityLow) == nullptr); in VerifyPriorityQueueContent() 67 VerifyOrQuit(aPriorityQueue.GetHeadForPriority(Message::kPriorityNormal) == nullptr); in VerifyPriorityQueueContent() 68 VerifyOrQuit(aPriorityQueue.GetHeadForPriority(Message::kPriorityHigh) == nullptr); in VerifyPriorityQueueContent() 69 VerifyOrQuit(aPriorityQueue.GetHeadForPriority(Message::kPriorityNet) == nullptr); in VerifyPriorityQueueContent() 78 msgArg = va_arg(args, Message *); in VerifyPriorityQueueContent() 86 … VerifyOrQuit(aPriorityQueue.GetHeadForPriority(static_cast<Message::Priority>(curPriority)) == in VerifyPriorityQueueContent() 92 …VerifyOrQuit(aPriorityQueue.GetHeadForPriority(static_cast<Message::Priority>(curPriority)) == msg… in VerifyPriorityQueueContent() [all …]
|
/openthread-latest/src/core/net/ |
D | ip6.hpp | 126 Message *NewMessage(void); 136 Message *NewMessage(uint16_t aReserved); 146 Message *NewMessage(uint16_t aReserved, const Message::Settings &aSettings); 161 …Message *NewMessageFromData(const uint8_t *aData, uint16_t aDataLength, const Message::Settings &a… 170 static Message::Priority DscpToPriority(uint8_t aDscp); 182 Error SendDatagram(Message &aMessage, MessageInfo &aMessageInfo, uint8_t aIpProto); 195 Error SendRaw(OwnedPtr<Message> aMessage); 208 Error HandleDatagram(OwnedPtr<Message> aMessagePtr, bool aIsReassembled = false); 345 static uint8_t PriorityToDscp(Message::Priority aPriority); 346 static Error TakeOrCopyMessagePtr(OwnedPtr<Message> &aTargetPtr, [all …]
|
D | dhcp6_client.hpp | 117 Error AppendHeader(Message &aMessage); 118 Error AppendClientIdentifier(Message &aMessage); 119 Error AppendIaNa(Message &aMessage, uint16_t aRloc16); 120 Error AppendIaAddress(Message &aMessage, uint16_t aRloc16); 121 Error AppendElapsedTime(Message &aMessage); 122 Error AppendRapidCommit(Message &aMessage); 124 void HandleUdpReceive(Message &aMessage, const Ip6::MessageInfo &aMessageInfo); 126 void ProcessReply(Message &aMessage); 127 uint16_t FindOption(Message &aMessage, uint16_t aOffset, uint16_t aLength, Code aCode); 128 Error ProcessServerIdentifier(Message &aMessage, uint16_t aOffset); [all …]
|
D | dhcp6_server.hpp | 173 Error AppendHeader(Message &aMessage, const TransactionId &aTransactionId); 174 Error AppendClientIdentifier(Message &aMessage, ClientIdentifier &aClientId); 175 Error AppendServerIdentifier(Message &aMessage); 176 Error AppendIaNa(Message &aMessage, IaNa &aIaNa); 177 Error AppendStatusCode(Message &aMessage, Status aStatusCode); 178 Error AppendIaAddress(Message &aMessage, ClientIdentifier &aClientId); 179 Error AppendRapidCommit(Message &aMessage); 180 Error AppendVendorSpecificInformation(Message &aMessage); 182 Error AddIaAddress(Message &aMessage, const Ip6::Address &aPrefix, ClientIdentifier &aClientId); 183 void HandleUdpReceive(Message &aMessage, const Ip6::MessageInfo &aMessageInfo); [all …]
|
D | sntp_client.cpp | 66 for (Message &message : mPendingQueries) in Stop() 81 Message *message = nullptr; in Query() 82 Message *messageCopy = nullptr; in Query() 126 Message *Client::NewMessage(const Header &aHeader) in NewMessage() 128 Message *message = nullptr; in NewMessage() 138 Message *Client::CopyAndEnqueueMessage(const Message &aMessage, const QueryMetadata &aQueryMetadata) in CopyAndEnqueueMessage() 141 Message *messageCopy = nullptr; in CopyAndEnqueueMessage() 157 void Client::DequeueMessage(Message &aMessage) in DequeueMessage() 168 Error Client::SendMessage(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in SendMessage() 173 void Client::SendCopy(const Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in SendCopy() [all …]
|
D | ip6.cpp | 69 Message *Ip6::NewMessage(void) { return NewMessage(0); } in NewMessage() 71 Message *Ip6::NewMessage(uint16_t aReserved) { return NewMessage(aReserved, Message::Settings::GetD… in NewMessage() 73 Message *Ip6::NewMessage(uint16_t aReserved, const Message::Settings &aSettings) in NewMessage() 76 …Message::kTypeIp6, sizeof(Header) + sizeof(HopByHopHeader) + sizeof(MplOption) + aReserved, aSetti… in NewMessage() 79 Message *Ip6::NewMessageFromData(const uint8_t *aData, uint16_t aDataLength, const Message::Setting… in NewMessageFromData() 81 Message *message = nullptr; in NewMessageFromData() 82 Message::Settings settings = aSettings; in NewMessageFromData() 93 message = Get<MessagePool>().Allocate(Message::kTypeIp6, /* aReserveHeader */ 0, settings); in NewMessageFromData() 107 Message::Priority Ip6::DscpToPriority(uint8_t aDscp) in DscpToPriority() 109 Message::Priority priority; in DscpToPriority() [all …]
|
D | udp6.hpp | 167 void HandleUdpReceive(Message &aMessage, const MessageInfo &aMessageInfo) in HandleUdpReceive() 195 Message *NewMessage(void); 204 Message *NewMessage(uint16_t aReserved); 214 Message *NewMessage(uint16_t aReserved, const Message::Settings &aSettings); 308 Error SendTo(Message &aMessage, const MessageInfo &aMessageInfo); 341 …template <typename Owner, void (Owner::*HandleUdpReceivePtr)(Message &aMessage, const MessageInfo … 385 bool HandleMessage(Message &aMessage, const MessageInfo &aMessageInfo) in HandleMessage() 560 Error SendTo(SocketHandle &aSocket, Message &aMessage, const MessageInfo &aMessageInfo); 574 Message *NewMessage(void); 583 Message *NewMessage(uint16_t aReserved); [all …]
|
D | dns_types.hpp | 514 Name(const Message &aMessage, uint16_t aOffset) in Name() 569 void SetFromMessage(const Message &aMessage, uint16_t aOffset) in SetFromMessage() 594 const Message &GetAsMessage(uint16_t &aOffset) const in GetAsMessage() 640 Error AppendTo(Message &aMessage) const; 658 static Error AppendLabel(const char *aLabel, Message &aMessage); 679 static Error AppendMultipleLabels(const char *aLabels, Message &aMessage); 691 static Error AppendTerminator(Message &aMessage); 705 static Error AppendPointerLabel(uint16_t aOffset, Message &aMessage); 723 static Error AppendName(const char *aName, Message &aMessage); 737 static Error ParseName(const Message &aMessage, uint16_t &aOffset); [all …]
|
/openthread-latest/src/core/thread/ |
D | network_diagnostic.hpp | 178 Message::Priority mPriority; 179 Coap::Message *mFirstAnswer; 188 Error AppendDiagTlv(uint8_t aTlvType, Message &aMessage); 189 Error AppendIp6AddressList(Message &aMessage); 190 Error AppendMacCounters(Message &aMessage); 191 Error AppendRequestedTlvs(const Message &aRequest, Message &aResponse); 195 void SendAnswer(const Ip6::Address &aDestination, const Message &aRequest); 197 Error AllocateAnswer(Coap::Message *&aAnswer, AnswerInfo &aInfo); 198 Error CheckAnswerLength(Coap::Message *&aAnswer, AnswerInfo &aInfo); 199 bool IsLastAnswer(const Coap::Message &aAnswer) const; [all …]
|
D | mesh_forwarder.hpp | 188 void SendMessage(OwnedPtr<Message> aMessagePtr); 251 Error EvictMessage(Message::Priority aPriority); 436 void Init(uint16_t aSrcRloc16, uint16_t aDatagramTag, Message::Priority aPriority); 446 … Message::Priority GetPriority(void) const { return static_cast<Message::Priority>(mPriority); } in GetPriority() 464 …static_assert(Message::kNumPriorities <= 4, "mPriority as a 2-bit does not fit all `Priority` valu… 477 void UpdateFor(const Message &aMessage); 489 void SendIcmpErrorIfDstUnreach(const Message &aMessage, const Mac::Addresses &aMacAddrs); 493 Error FrameToMessage(RxInfo &aRxInfo, uint16_t aDatagramSize, Message *&aMessage); 496 Message *PrepareNextDirectTransmission(void); 502 …epareMacHeaders(Mac::TxFrame &aTxFrame, Mac::TxFrame::Info &aTxFrameInfo, const Message *aMessage); [all …]
|
D | tmf.hpp | 57 …template <> void Type::HandleTmf<kUri>(Coap::Message & aMessage, const Ip6::MessageInfo &aMessageI… 61 typedef Coap::Message Message; ///< A TMF message. typedef 172 static uint8_t PriorityToDscp(Message::Priority aPriority); 181 static Message::Priority DscpToPriority(uint8_t aDscp); 184 template <Uri kUri> void HandleTmf(Message &aMessage, const Ip6::MessageInfo &aMessageInfo); 188 Message &aMessage, 190 …bool HandleResource(const char *aUriPath, Message &aMessage, const Ip6::MessageInfo &aMessa… 192 …static Error Filter(const Message &aMessage, const Ip6::MessageInfo &aMessageInfo, void *aContext); 217 Message &aMessage, 219 …bool HandleResource(const char *aUriPath, Message &aMessage, const Ip6::MessageInfo &aMessa…
|
D | indirect_sender.hpp | 104 Message *GetIndirectMessage(void) { return mIndirectMessage; } in GetIndirectMessage() 105 void SetIndirectMessage(Message *aMessage) { mIndirectMessage = aMessage; } in SetIndirectMessage() 128 Message *mIndirectMessage; // Current indirect message. 148 typedef bool (&MessageChecker)(const Message &aMessage); 176 void AddMessageForSleepyChild(Message &aMessage, Child &aChild); 187 Error RemoveMessageFromSleepyChild(Message &aMessage, Child &aChild); 207 Message *FindQueuedMessageForSleepyChild(const Child &aChild, MessageChecker aChecker) in FindQueuedMessageForSleepyChild() 223 …const Message *FindQueuedMessageForSleepyChild(const Child &aChild, MessageChecker aChecker) const; 278 uint16_t PrepareDataFrame(Mac::TxFrame &aFrame, Child &aChild, Message &aMessage); 282 static bool AcceptAnyMessage(const Message &aMessage); [all …]
|
D | tmf.cpp | 88 template <> void Agent::HandleTmf<kUriRelayRx>(Message &aMessage, const Ip6::MessageInfo &aMessageI… in HandleTmf() 103 Message &aMessage, in HandleResource() 109 bool Agent::HandleResource(const char *aUriPath, Message &aMessage, const Ip6::MessageInfo &aMessag… in HandleResource() 194 Error Agent::Filter(const Message &aMessage, const Ip6::MessageInfo &aMessageInfo, void *aContext) in Filter() 226 uint8_t Agent::PriorityToDscp(Message::Priority aPriority) in PriorityToDscp() 232 case Message::kPriorityNet: in PriorityToDscp() 236 case Message::kPriorityHigh: in PriorityToDscp() 237 case Message::kPriorityNormal: in PriorityToDscp() 240 case Message::kPriorityLow: in PriorityToDscp() 248 Message::Priority Agent::DscpToPriority(uint8_t aDscp) in DscpToPriority() [all …]
|
D | indirect_sender.cpp | 93 void IndirectSender::AddMessageForSleepyChild(Message &aMessage, Child &aChild) in AddMessageForSleepyChild() 105 if ((aMessage.GetType() != Message::kTypeSupervision) && (aChild.GetIndirectMessageCount() > 1)) in AddMessageForSleepyChild() 107 … Message *supervisionMessage = FindQueuedMessageForSleepyChild(aChild, AcceptSupervisionMessage); in AddMessageForSleepyChild() 122 Error IndirectSender::RemoveMessageFromSleepyChild(Message &aMessage, Child &aChild) in RemoveMessageFromSleepyChild() 142 for (Message &message : Get<MeshForwarder>().mSendQueue) in ClearAllMessagesForSleepyChild() 161 const Message *IndirectSender::FindQueuedMessageForSleepyChild(const Child &aChild, MessageChecker … in FindQueuedMessageForSleepyChild() 163 const Message *match = nullptr; in FindQueuedMessageForSleepyChild() 166 for (const Message &message : Get<MeshForwarder>().mSendQueue) in FindQueuedMessageForSleepyChild() 202 for (Message &message : Get<MeshForwarder>().mSendQueue) in HandleChildModeChange() 231 Message *curMessage = aChild.GetIndirectMessage(); in RequestMessageUpdate() [all …]
|
/openthread-latest/src/core/meshcop/ |
D | border_agent.hpp | 264 Coap::Message &aMessage, 266 …bool HandleResource(const char *aUriPath, Coap::Message &aMessage, const Ip6::MessageInfo &… 272 … Error Init(Instance &aInstance, const Coap::Message &aMessage, bool aPetition, bool aSeparate); 275 Error ToHeader(Coap::Message &aMessage, uint8_t aCode) const; 283 uint8_t mToken[Coap::Message::kMaxTokenLength]; // The CoAP Token of the original request. 292 …Error ForwardToLeader(const Coap::Message &aMessage, const Ip6::MessageInfo &aMessageInfo, Uri aUr… 293 Error ForwardToCommissioner(Coap::Message &aForwardMessage, const Message &aMessage); 295 void SendErrorMessage(const Coap::Message &aRequest, bool aSeparate, Error aError); 296 …void HandleTmfCommissionerKeepAlive(Coap::Message &aMessage, const Ip6::MessageInfo &aMessageInfo… 297 void HandleTmfRelayTx(Coap::Message &aMessage, const Ip6::MessageInfo &aMessageInfo); [all …]
|
D | tcat_agent.hpp | 340 Error HandleSingleTlv(const Message &aIncomingMessage, Message &aOutgoingMessage); 341 …Error HandleSetActiveOperationalDataset(const Message &aIncomingMessage, uint16_t aOffset, uint16_… 343 Error HandlePing(const Message &aIncomingMessage, 344 Message &aOutgoingMessage, 348 Error HandleGetNetworkName(Message &aOutgoingMessage, bool &aResponse); 349 Error HandleGetDeviceId(Message &aOutgoingMessage, bool &aResponse); 350 Error HandleGetExtPanId(Message &aOutgoingMessage, bool &aResponse); 351 Error HandleGetProvisioningUrl(Message &aOutgoingMessage, bool &aResponse); 352 … Error HandlePresentPskdHash(const Message &aIncomingMessage, uint16_t aOffset, uint16_t aLength); 353 … Error HandlePresentPskcHash(const Message &aIncomingMessage, uint16_t aOffset, uint16_t aLength); [all …]
|
/openthread-latest/src/core/utils/ |
D | mesh_diag.hpp | 102 Error InitFrom(const Message &aMessage); 104 const Message *mMessage; 116 Error ParseFrom(const Message &aMessage); 145 Error InitFrom(const Message &aMessage, uint16_t aParentRloc16); 147 const Message *mMessage; 283 bool HandleDiagnosticGetAnswer(Coap::Message &aMessage, const Ip6::MessageInfo &aMessageInfo); 284 …Error ProcessMessage(Coap::Message &aMessage, const Ip6::MessageInfo &aMessageInfo, uint16_t aSend… 285 bool ProcessChildTableAnswer(Coap::Message &aMessage, const Ip6::MessageInfo &aMessageInfo); 286 …bool ProcessChildrenIp6AddrsAnswer(Coap::Message &aMessage, const Ip6::MessageInfo &aMessageInfo); 287 …bool ProcessRouterNeighborTableAnswer(Coap::Message &aMessage, const Ip6::MessageInfo &aMessageIn… [all …]
|