Home
last modified time | relevance | path

Searched refs:Message (Results 1 – 25 of 194) sorted by relevance

12345678

/openthread-latest/src/core/coap/
Dcoap.hpp167 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 …]
Dcoap_message.hpp159 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 …]
Dcoap_message.cpp41 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 …]
Dcoap.cpp67 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/
Dmessage.hpp144 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 …]
Dmessage.cpp61 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 …]
Dtlvs.hpp50 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 …]
Dtlvs.cpp57 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/
Dtest_priority_queue.cpp49 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/
Dip6.hpp126 Message *NewMessage(void);
136 Message *NewMessage(uint16_t aReserved);
146 Message *NewMessage(uint16_t aReserved, const Message::Settings &aSettings);
161Message *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 …]
Ddhcp6_client.hpp117 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 …]
Ddhcp6_server.hpp173 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 …]
Dsntp_client.cpp66 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 …]
Dip6.cpp69 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()
76Message::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 …]
Dudp6.hpp167 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 …]
Ddns_types.hpp514 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/
Dnetwork_diagnostic.hpp178 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 …]
Dmesh_forwarder.hpp188 void SendMessage(OwnedPtr<Message> aMessagePtr);
251 Error EvictMessage(Message::Priority aPriority);
436 void Init(uint16_t aSrcRloc16, uint16_t aDatagramTag, Message::Priority aPriority);
446Message::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 …]
Dtmf.hpp57 …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…
Dindirect_sender.hpp104 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 …]
Dtmf.cpp88 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 …]
Dindirect_sender.cpp93 void IndirectSender::AddMessageForSleepyChild(Message &aMessage, Child &aChild) in AddMessageForSleepyChild()
105 if ((aMessage.GetType() != Message::kTypeSupervision) && (aChild.GetIndirectMessageCount() > 1)) in AddMessageForSleepyChild()
107Message *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/
Dborder_agent.hpp264 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 …]
Dtcat_agent.hpp340 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/
Dmesh_diag.hpp102 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 …]

12345678