| /openthread-latest/src/core/api/ |
| D | message_api.cpp | 40 void otMessageFree(otMessage *aMessage) { AsCoreType(aMessage).Free(); } in otMessageFree() argument
42 uint16_t otMessageGetLength(const otMessage *aMessage) { return AsCoreType(aMessage).GetLength(); } in otMessageGetLength() argument
44 otError otMessageSetLength(otMessage *aMessage, uint16_t aLength) { return AsCoreType(aMessage).Set… in otMessageSetLength() argument
46 uint16_t otMessageGetOffset(const otMessage *aMessage) { return AsCoreType(aMessage).GetOffset(); } in otMessageGetOffset() argument
48 void otMessageSetOffset(otMessage *aMessage, uint16_t aOffset) { AsCoreType(aMessage).SetOffset(aOf… in otMessageSetOffset() argument
50 bool otMessageIsLinkSecurityEnabled(const otMessage *aMessage) { return AsCoreType(aMessage).IsLink… in otMessageIsLinkSecurityEnabled() argument
52 bool otMessageIsLoopbackToHostAllowed(const otMessage *aMessage) in otMessageIsLoopbackToHostAllowed() argument
54 return AsCoreType(aMessage).IsLoopbackToHostAllowed(); in otMessageIsLoopbackToHostAllowed()
57 void otMessageSetLoopbackToHostAllowed(otMessage *aMessage, bool aAllowLoopbackToHost) in otMessageSetLoopbackToHostAllowed() argument
59 return AsCoreType(aMessage).SetLoopbackToHostAllowed(aAllowLoopbackToHost); in otMessageSetLoopbackToHostAllowed()
[all …]
|
| D | coap_api.cpp | 47 void otCoapMessageInit(otMessage *aMessage, otCoapType aType, otCoapCode aCode) in otCoapMessageInit() argument
49 AsCoapMessage(aMessage).Init(MapEnum(aType), MapEnum(aCode)); in otCoapMessageInit()
63 otError otCoapMessageSetToken(otMessage *aMessage, const uint8_t *aToken, uint8_t aTokenLength) in otCoapMessageSetToken() argument
65 return AsCoapMessage(aMessage).SetToken(aToken, aTokenLength); in otCoapMessageSetToken()
68 void otCoapMessageGenerateToken(otMessage *aMessage, uint8_t aTokenLength) in otCoapMessageGenerateToken() argument
70 IgnoreError(AsCoapMessage(aMessage).GenerateRandomToken(aTokenLength)); in otCoapMessageGenerateToken()
73 otError otCoapMessageAppendContentFormatOption(otMessage *aMessage, otCoapOptionContentFormat aCont… in otCoapMessageAppendContentFormatOption() argument
75 return AsCoapMessage(aMessage).AppendContentFormatOption(aContentFormat); in otCoapMessageAppendContentFormatOption()
78 otError otCoapMessageAppendOption(otMessage *aMessage, uint16_t aNumber, uint16_t aLength, const vo… in otCoapMessageAppendOption() argument
80 return AsCoapMessage(aMessage).AppendOption(aNumber, aLength, aValue); in otCoapMessageAppendOption()
[all …]
|
| /openthread-latest/src/core/coap/ |
| D | coap.cpp | 140 Message *CoapBase::InitMessage(Message *aMessage, Type aType, Uri aUri) in InitMessage() argument
144 VerifyOrExit(aMessage != nullptr); in InitMessage()
146 SuccessOrExit(error = aMessage->Init(aType, kCodePost, aUri)); in InitMessage()
147 SuccessOrExit(error = aMessage->SetPayloadMarker()); in InitMessage()
150 FreeAndNullMessageOnError(aMessage, error); in InitMessage()
151 return aMessage; in InitMessage()
154 Message *CoapBase::InitResponse(Message *aMessage, const Message &aRequest) in InitResponse() argument
158 VerifyOrExit(aMessage != nullptr); in InitResponse()
160 SuccessOrExit(error = aMessage->SetDefaultResponseHeader(aRequest)); in InitResponse()
161 SuccessOrExit(error = aMessage->SetPayloadMarker()); in InitResponse()
[all …]
|
| D | coap.hpp | 167 void HandleRequest(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) const in HandleRequest() argument
169 mHandler(mContext, &aMessage, &aMessageInfo); in HandleRequest()
256 void HandleRequest(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) const in HandleRequest() argument
258 mHandler(mContext, &aMessage, &aMessageInfo); in HandleRequest()
288 …void EnqueueResponse(Message &aMessage, const Ip6::MessageInfo &aMessageInfo, const TxParameters &…
325 void DequeueResponse(Message &aMessage);
358 …typedef Error (*Interceptor)(const Message &aMessage, const Ip6::MessageInfo &aMessageInfo, void *…
535 Error SendMessage(Message &aMessage,
560 Error SendMessage(Message &aMessage,
579 …Error SendMessage(Message &aMessage, const Ip6::MessageInfo &aMessageInfo, const TxParameters &aTx…
[all …]
|
| /openthread-latest/src/core/common/ |
| 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() argument
63 return FindTlv(aMessage, aType, aMaxSize, aTlv, offset); in FindTlv()
66 Error Tlv::FindTlv(const Message &aMessage, uint8_t aType, uint16_t aMaxSize, Tlv &aTlv, uint16_t &… in FindTlv() argument
71 SuccessOrExit(error = info.FindIn(aMessage, aType)); in FindTlv()
74 aMessage.ReadBytes(info.mTlvOffsetRange, &aTlv); in FindTlv()
81 Error Tlv::FindTlvValueOffsetRange(const Message &aMessage, uint8_t aType, OffsetRange &aOffsetRang… in FindTlvValueOffsetRange() argument
86 SuccessOrExit(error = info.FindIn(aMessage, aType)); in FindTlvValueOffsetRange()
93 Error Tlv::ParsedInfo::ParseFrom(const Message &aMessage, uint16_t aOffset) in ParseFrom() argument
97 offsetRange.InitFromRange(aOffset, aMessage.GetLength()); in ParseFrom()
[all …]
|
| D | tlvs.hpp | 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() argument
321 return ReadTlvValue(aMessage, aOffset, &aValue, sizeof(aValue)); in Read()
337 …static Error Read(const Message &aMessage, uint16_t aOffset, typename UintTlvType::UintValueType &… in Read() argument
339 return ReadUintTlv(aMessage, aOffset, aValue); in Read()
355 …static Error Read(const Message &aMessage, uint16_t aOffset, typename StringTlvType::StringType &a… in Read() argument
[all …]
|
| D | message.cpp | 96 void MessagePool::Free(Message *aMessage) in Free() argument
98 OT_ASSERT(aMessage->Next() == nullptr && aMessage->Prev() == nullptr); in Free()
100 FreeBuffers(static_cast<Buffer *>(aMessage)); in Free()
390 Error Message::AppendBytesFromMessage(const Message &aMessage, const OffsetRange &aOffsetRange) in AppendBytesFromMessage() argument
392 return AppendBytesFromMessage(aMessage, aOffsetRange.GetOffset(), aOffsetRange.GetLength()); in AppendBytesFromMessage()
395 Error Message::AppendBytesFromMessage(const Message &aMessage, uint16_t aOffset, uint16_t aLength) in AppendBytesFromMessage() argument
401 VerifyOrExit(aMessage.GetLength() >= aOffset + aLength, error = kErrorParse); in AppendBytesFromMessage()
404 aMessage.GetFirstChunk(aOffset, aLength, chunk); in AppendBytesFromMessage()
410 aMessage.GetNextChunk(aLength, chunk); in AppendBytesFromMessage()
720 const Message &aMessage, in WriteBytesFromMessage() argument
[all …]
|
| D | message.hpp | 99 #define FreeMessage(aMessage) \ argument
102 if ((aMessage) != nullptr) \
104 (aMessage)->Free(); \
116 #define FreeMessageOnError(aMessage, aError) \ argument
119 if (((aError) != kErrorNone) && ((aMessage) != nullptr)) \
121 (aMessage)->Free(); \
131 #define FreeAndNullMessageOnError(aMessage, aError) \ argument
134 if (((aError) != kErrorNone) && ((aMessage) != nullptr)) \
136 (aMessage)->Free(); \
137 (aMessage) = nullptr; \
[all …]
|
| /openthread-latest/include/openthread/ |
| D | message.h | 121 void otMessageFree(otMessage *aMessage);
139 uint16_t otMessageGetLength(const otMessage *aMessage);
158 otError otMessageSetLength(otMessage *aMessage, uint16_t aLength);
175 uint16_t otMessageGetOffset(const otMessage *aMessage);
191 void otMessageSetOffset(otMessage *aMessage, uint16_t aOffset);
201 bool otMessageIsLinkSecurityEnabled(const otMessage *aMessage);
211 bool otMessageIsLoopbackToHostAllowed(const otMessage *aMessage);
219 void otMessageSetLoopbackToHostAllowed(otMessage *aMessage, bool aAllowLoopbackToHost);
231 bool otMessageIsMulticastLoopEnabled(otMessage *aMessage);
239 void otMessageSetMulticastLoopEnabled(otMessage *aMessage, bool aEnabled);
[all …]
|
| D | coap.h | 338 otMessage *aMessage,
349 typedef void (*otCoapRequestHandler)(void *aContext, otMessage *aMessage, const otMessageInfo *aMes…
475 void otCoapMessageInit(otMessage *aMessage, otCoapType aType, otCoapCode aCode);
502 otError otCoapMessageSetToken(otMessage *aMessage, const uint8_t *aToken, uint8_t aTokenLength);
510 void otCoapMessageGenerateToken(otMessage *aMessage, uint8_t aTokenLength);
530 otError otCoapMessageAppendContentFormatOption(otMessage *aMessage, otCoapOptionContentFormat aCont…
544 otError otCoapMessageAppendOption(otMessage *aMessage, uint16_t aNumber, uint16_t aLength, const vo…
560 otError otCoapMessageAppendUintOption(otMessage *aMessage, uint16_t aNumber, uint32_t aValue);
572 otError otCoapMessageAppendObserveOption(otMessage *aMessage, uint32_t aObserve);
584 otError otCoapMessageAppendUriPathOptions(otMessage *aMessage, const char *aUriPath);
[all …]
|
| /openthread-latest/src/core/net/ |
| D | checksum.cpp | 83 void Checksum::WriteToMessage(uint16_t aOffset, Message &aMessage) const in WriteToMessage()
94 aMessage.Write(aOffset, checksum); in WriteToMessage()
100 const Message &aMessage) in Calculate() argument
103 uint16_t length = aMessage.GetLength() - aMessage.GetOffset(); in Calculate()
114 aMessage.GetFirstChunk(aMessage.GetOffset(), length, chunk); in Calculate()
119 aMessage.GetNextChunk(length, chunk); in Calculate()
126 const Message &aMessage) in Calculate() argument
129 uint16_t length = aMessage.GetLength() - aMessage.GetOffset(); in Calculate()
143 aMessage.GetFirstChunk(aMessage.GetOffset(), length, chunk); in Calculate()
148 aMessage.GetNextChunk(length, chunk); in Calculate()
[all …]
|
| D | dhcp6_server.cpp | 171 void Server::HandleUdpReceive(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in HandleUdpReceive() argument
175 SuccessOrExit(aMessage.Read(aMessage.GetOffset(), header)); in HandleUdpReceive()
176 aMessage.MoveOffset(sizeof(header)); in HandleUdpReceive()
181 ProcessSolicit(aMessage, aMessageInfo.GetPeerAddr(), header.GetTransactionId()); in HandleUdpReceive()
187 void Server::ProcessSolicit(Message &aMessage, const Ip6::Address &aDst, const TransactionId &aTran… in ProcessSolicit() argument
192 uint16_t offset = aMessage.GetOffset(); in ProcessSolicit()
193 uint16_t length = aMessage.GetLength() - aMessage.GetOffset(); in ProcessSolicit()
196 … VerifyOrExit((optionOffset = FindOption(aMessage, offset, length, kOptionClientIdentifier)) > 0); in ProcessSolicit()
197 SuccessOrExit(ProcessClientIdentifier(aMessage, optionOffset, clientIdentifier)); in ProcessSolicit()
200 VerifyOrExit(FindOption(aMessage, offset, length, kOptionServerIdentifier) == 0); in ProcessSolicit()
[all …]
|
| D | dhcp6_client.cpp | 287 Error Client::AppendHeader(Message &aMessage) in AppendHeader() argument
294 return aMessage.Append(header); in AppendHeader()
297 Error Client::AppendElapsedTime(Message &aMessage) in AppendElapsedTime() argument
303 return aMessage.Append(option); in AppendElapsedTime()
306 Error Client::AppendClientIdentifier(Message &aMessage) in AppendClientIdentifier() argument
318 return aMessage.Append(option); in AppendClientIdentifier()
321 Error Client::AppendIaNa(Message &aMessage, uint16_t aRloc16) in AppendIaNa() argument
351 SuccessOrExit(error = aMessage.Append(option)); in AppendIaNa()
357 Error Client::AppendIaAddress(Message &aMessage, uint16_t aRloc16) in AppendIaAddress() argument
374 SuccessOrExit(error = aMessage.Append(option)); in AppendIaAddress()
[all …]
|
| D | dns_types.cpp | 161 Error Name::AppendTo(Message &aMessage) const in AppendTo()
167 error = AppendTerminator(aMessage); in AppendTo()
171 error = AppendName(GetAsCString(), aMessage); in AppendTo()
187 SuccessOrExit(error = iterator.AppendLabel(aMessage)); in AppendTo()
192 error = AppendTerminator(aMessage); in AppendTo()
206 Error Name::AppendLabel(const char *aLabel, Message &aMessage) in AppendLabel() argument
208 return AppendLabel(aLabel, static_cast<uint8_t>(StringLength(aLabel, kMaxLabelSize)), aMessage); in AppendLabel()
211 Error Name::AppendLabel(const char *aLabel, uint8_t aLength, Message &aMessage) in AppendLabel() argument
217 SuccessOrExit(error = aMessage.Append(aLength)); in AppendLabel()
218 error = aMessage.AppendBytes(aLabel, aLength); in AppendLabel()
[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 | ip6.cpp | 162 Error Ip6::AddMplOption(Message &aMessage, Header &aHeader) in AddMplOption() argument
176 SuccessOrExit(error = aMessage.PrependBytes(&padOption, padOption.GetSize())); in AddMplOption()
179 SuccessOrExit(error = aMessage.PrependBytes(&mplOption, mplOption.GetSize())); in AddMplOption()
180 SuccessOrExit(error = aMessage.Prepend(hbhHeader)); in AddMplOption()
188 Error Ip6::PrepareMulticastToLargerThanRealmLocal(Message &aMessage, const Header &aHeader) in PrepareMulticastToLargerThanRealmLocal() argument
198 Message *messageCopy = aMessage.Clone(); in PrepareMulticastToLargerThanRealmLocal()
223 SuccessOrExit(error = AddMplOption(aMessage, tunnelHeader)); in PrepareMulticastToLargerThanRealmLocal()
224 SuccessOrExit(error = aMessage.Prepend(tunnelHeader)); in PrepareMulticastToLargerThanRealmLocal()
230 Error Ip6::InsertMplOption(Message &aMessage, Header &aHeader) in InsertMplOption() argument
236 error = PrepareMulticastToLargerThanRealmLocal(aMessage, aHeader); in InsertMplOption()
[all …]
|
| D | dns_types.hpp | 514 Name(const Message &aMessage, uint16_t aOffset) in Name() argument
515 : Name(nullptr, &aMessage, aOffset) in Name()
569 void SetFromMessage(const Message &aMessage, uint16_t aOffset) in SetFromMessage() argument
572 mMessage = &aMessage; in SetFromMessage()
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);
[all …]
|
| /openthread-latest/src/core/thread/ |
| D | mesh_forwarder.cpp | 208 Error MeshForwarder::UpdateEcnOrDrop(Message &aMessage, bool aPreparingToSend) in UpdateEcnOrDrop() argument
222 uint32_t timeInQueue = TimerMilli::GetNow() - aMessage.GetTimestamp(); in UpdateEcnOrDrop()
226 VerifyOrExit(aMessage.IsDirectTransmission() && (aMessage.GetOffset() == 0)); in UpdateEcnOrDrop()
228 if (aMessage.GetType() == Message::kTypeIp6) in UpdateEcnOrDrop()
232 IgnoreError(aMessage.Read(0, ip6Header)); in UpdateEcnOrDrop()
250 aMessage.Write(0, ip6Header); in UpdateEcnOrDrop()
251 LogMessage(kMessageMarkEcn, aMessage); in UpdateEcnOrDrop()
261 else if (aMessage.GetType() == Message::kType6lowpan) in UpdateEcnOrDrop()
269 IgnoreError(meshHeader.ParseFrom(aMessage, headerLength)); in UpdateEcnOrDrop()
273 if (fragmentHeader.ParseFrom(aMessage, offset, headerLength) == kErrorNone) in UpdateEcnOrDrop()
[all …]
|
| D | network_diagnostic.cpp | 111 Error Server::AppendIp6AddressList(Message &aMessage) in AppendIp6AddressList() argument
128 SuccessOrExit(error = aMessage.Append(tlv)); in AppendIp6AddressList()
136 SuccessOrExit(error = aMessage.Append(extTlv)); in AppendIp6AddressList()
141 SuccessOrExit(error = aMessage.Append(addr.GetAddress())); in AppendIp6AddressList()
149 Error Server::AppendChildTable(Message &aMessage) in AppendChildTable() argument
164 SuccessOrExit(error = aMessage.Append(tlv)); in AppendChildTable()
172 SuccessOrExit(error = aMessage.Append(extTlv)); in AppendChildTable()
193 SuccessOrExit(error = aMessage.Append(entry)); in AppendChildTable()
201 Error Server::AppendMacCounters(Message &aMessage) in AppendMacCounters() argument
220 return tlv.AppendTo(aMessage); in AppendMacCounters()
[all …]
|
| D | lowpan.cpp | 203 Error Lowpan::Compress(Message &aMessage, const Mac::Addresses &aMacAddrs, FrameBuilder &aFrameBuil… in Compress() argument
212 error = Compress(aMessage, aMacAddrs, aFrameBuilder, headerDepth); in Compress()
227 Error Lowpan::Compress(Message &aMessage, in Compress() argument
233 uint16_t startOffset = aMessage.GetOffset(); in Compress()
245 SuccessOrExit(error = aMessage.Read(aMessage.GetOffset(), ip6Header)); in Compress()
378 aMessage.MoveOffset(sizeof(ip6Header)); in Compress()
387 SuccessOrExit(error = CompressExtensionHeader(aMessage, aFrameBuilder, nextHeader)); in Compress()
391 error = CompressUdp(aMessage, aFrameBuilder); in Compress()
398 error = Compress(aMessage, aMacAddrs, aFrameBuilder); in Compress()
418 aMessage.SetOffset(startOffset); in Compress()
[all …]
|
| /openthread-latest/src/core/utils/ |
| D | mesh_diag.cpp | 111 otMessage *aMessage, in HandleDiagGetResponse() argument
115 …static_cast<MeshDiag *>(aContext)->HandleDiagGetResponse(AsCoapMessagePtr(aMessage), AsCoreTypePtr… in HandleDiagGetResponse()
119 void MeshDiag::HandleDiagGetResponse(Coap::Message *aMessage, const Ip6::MessageInfo *aMessageInfo,… in HandleDiagGetResponse() argument
129 VerifyOrExit(aMessage != nullptr); in HandleDiagGetResponse()
132 SuccessOrExit(routerInfo.ParseFrom(*aMessage)); in HandleDiagGetResponse()
134 if (ip6AddrIterator.InitFrom(*aMessage) == kErrorNone) in HandleDiagGetResponse()
139 if (childIterator.InitFrom(*aMessage, routerInfo.mRloc16) == kErrorNone) in HandleDiagGetResponse()
235 bool MeshDiag::HandleDiagnosticGetAnswer(Coap::Message &aMessage, const Ip6::MessageInfo &aMessageI… in HandleDiagnosticGetAnswer() argument
242 didProcess = ProcessChildTableAnswer(aMessage, aMessageInfo); in HandleDiagnosticGetAnswer()
246 didProcess = ProcessChildrenIp6AddrsAnswer(aMessage, aMessageInfo); in HandleDiagnosticGetAnswer()
[all …]
|
| D | otns.cpp | 157 void Otns::EmitCoapSend(const Coap::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in EmitCoapSend() argument
162 SuccessOrExit(error = aMessage.ReadUriPathOptions(uriPath)); in EmitCoapSend()
164 …EmitStatus("coap=send,%d,%d,%d,%s,%s,%d", aMessage.GetMessageId(), aMessage.GetType(), aMessage.Ge… in EmitCoapSend()
171 void Otns::EmitCoapReceive(const Coap::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in EmitCoapReceive() argument
176 SuccessOrExit(error = aMessage.ReadUriPathOptions(uriPath)); in EmitCoapReceive()
178 …EmitStatus("coap=recv,%d,%d,%d,%s,%s,%d", aMessage.GetMessageId(), aMessage.GetType(), aMessage.Ge… in EmitCoapReceive()
184 void Otns::EmitCoapSendFailure(Error aError, Coap::Message &aMessage, const Ip6::MessageInfo &aMess… in EmitCoapSendFailure() argument
189 SuccessOrExit(error = aMessage.ReadUriPathOptions(uriPath)); in EmitCoapSendFailure()
191 …mitStatus("coap=send_error,%d,%d,%d,%s,%s,%d,%s", aMessage.GetMessageId(), aMessage.GetType(), aMe… in EmitCoapSendFailure()
|
| /openthread-latest/src/core/meshcop/ |
| D | border_agent.cpp | 335 void BorderAgent::HandleTmfCommissionerKeepAlive(Coap::Message &aMessage, const Ip6::MessageInfo &a… in HandleTmfCommissionerKeepAlive() argument
339 SuccessOrExit(ForwardToLeader(aMessage, aMessageInfo, kUriLeaderKeepAlive)); in HandleTmfCommissionerKeepAlive()
346 Error BorderAgent::ForwardToLeader(const Coap::Message &aMessage, const Ip6::MessageInfo &aMessageI… in ForwardToLeader() argument
374 SuccessOrExit(error = mCoapDtlsSession->SendAck(aMessage, aMessageInfo)); in ForwardToLeader()
377 …forwardContext.Reset(ForwardContext::AllocateAndInit(GetInstance(), aMessage, petition, separate)); in ForwardToLeader()
383 offsetRange.InitFromMessageOffsetToEnd(aMessage); in ForwardToLeader()
384 SuccessOrExit(error = message->AppendBytesFromMessage(aMessage, offsetRange)); in ForwardToLeader()
406 SendErrorMessage(aMessage, separate, error); in ForwardToLeader()
413 otMessage *aMessage, in HandleCoapResponse() argument
421 …>Get<BorderAgent>().HandleCoapResponse(*forwardContext.Get(), AsCoapMessagePtr(aMessage), aResult); in HandleCoapResponse()
[all …]
|
| /openthread-latest/examples/platforms/simulation/ |
| D | infra_if.c | 83 static uint16_t getMessageSize(const Message *aMessage) in getMessageSize() argument
85 return (uint16_t)(&aMessage->mData[aMessage->mDataLength] - (const uint8_t *)aMessage); in getMessageSize()
144 static void processMessage(otInstance *aInstance, Message *aMessage, uint16_t aLength) in processMessage() argument
149 otEXPECT(getMessageSize(aMessage) == aLength); in processMessage()
150 otEXPECT(aMessage->mDataLength > 0); in processMessage()
153 …otEXPECT(addressesMatch(&aMessage->mDst, &sIp6Address) || addressesMatch(&aMessage->mDst, &sLinkLo… in processMessage()
154 addressesMatch(&aMessage->mDst, &sLinkLocalAllRouters)); in processMessage()
156 if (aMessage->mData[0] == OT_ICMP6_TYPE_NEIGHBOR_SOLICIT) in processMessage()
159 sendNeighborAdvert(aMessage); in processMessage()
163 LOG("Received msg, len:%u", aMessage->mDataLength); in processMessage()
[all …]
|
