Home
last modified time | relevance | path

Searched refs:message (Results 1 – 25 of 161) sorted by relevance

1234567

/openthread-latest/tests/unit/
Dtest_tlv.cpp44 Message *message; in TestTlv() local
54 VerifyOrQuit((message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6)) != nullptr); in TestTlv()
55 VerifyOrQuit(message != nullptr); in TestTlv()
57 VerifyOrQuit(message->GetOffset() == 0); in TestTlv()
58 VerifyOrQuit(message->GetLength() == 0); in TestTlv()
60 …VerifyOrQuit(Tlv::FindTlvValueOffsetRange(*message, /* aType */ 1, offsetRange) == kErrorNotFound); in TestTlv()
61 VerifyOrQuit(Tlv::ReadTlvValue(*message, 0, buffer, 1) == kErrorParse); in TestTlv()
65 offset = message->GetLength(); in TestTlv()
69 SuccessOrQuit(message->Append(tlv)); in TestTlv()
71 SuccessOrQuit(Tlv::FindTlvValueOffsetRange(*message, /* aType */ 1, offsetRange)); in TestTlv()
[all …]
Dtest_message.cpp51 Message *message; in TestMessage() local
69 VerifyOrQuit((message = messagePool->Allocate(Message::kTypeIp6)) != nullptr); in TestMessage()
70 message->SetLinkSecurityEnabled(kWithLinkSecurity); in TestMessage()
71 SuccessOrQuit(message->SetPriority(Message::Priority::kPriorityNet)); in TestMessage()
72 message->SetType(Message::Type::kType6lowpan); in TestMessage()
73 message->SetSubType(Message::SubType::kSubTypeJoinerEntrust); in TestMessage()
74 message->SetLoopbackToHostAllowed(true); in TestMessage()
75 message->SetOrigin(Message::kOriginHostUntrusted); in TestMessage()
76 SuccessOrQuit(message->SetLength(kMaxSize)); in TestMessage()
77 message->WriteBytes(0, writeBuffer, kMaxSize); in TestMessage()
[all …]
Dtest_dns.cpp70 Message *message; in TestDnsName() local
173 VerifyOrQuit((message = messagePool->Allocate(Message::kTypeIp6)) != nullptr); in TestDnsName()
175 message->SetOffset(0); in TestDnsName()
356 IgnoreError(message->SetLength(0)); in TestDnsName()
358 SuccessOrQuit(Dns::Name::AppendName(test.mName, *message)); in TestDnsName()
360 len = message->GetLength(); in TestDnsName()
361 SuccessOrQuit(message->Read(0, buffer, len)); in TestDnsName()
370 SuccessOrQuit(Dns::Name::ParseName(*message, offset)); in TestDnsName()
379 SuccessOrQuit(Dns::Name::ReadLabel(*message, offset, label, labelLength)); in TestDnsName()
388 VerifyOrQuit(Dns::Name::ReadLabel(*message, offset, label, labelLength) == kErrorNotFound, in TestDnsName()
[all …]
Dtest_message_queue.cpp53 Message *message; in VerifyMessageQueueContent() local
60 message = aMessageQueue.GetHead(); in VerifyMessageQueueContent()
61 VerifyOrQuit(message == nullptr, "not empty when expected len is zero."); in VerifyMessageQueueContent()
65 for (message = aMessageQueue.GetHead(); message != nullptr; message = message->GetNext()) in VerifyMessageQueueContent()
70 VerifyOrQuit(msgArg == message, "content does not match what is expected."); in VerifyMessageQueueContent()
82 message = aMessageQueue.GetHead(); in VerifyMessageQueueContent()
86 VerifyOrQuit(message == &msg, "`for` loop iteration does not match expected"); in VerifyMessageQueueContent()
87 message = message->GetNext(); in VerifyMessageQueueContent()
90 … VerifyOrQuit(message == nullptr, "`for` loop iteration resulted in fewer entries than expected"); in VerifyMessageQueueContent()
94 message = aMessageQueue.GetHead(); in VerifyMessageQueueContent()
[all …]
Dtest_checksum.cpp187 Message *message = instance->Get<Ip6::Ip6>().NewMessage(sizeof(Ip6::Udp::Header)); in TestUdpMessageChecksum() local
191 VerifyOrQuit(message != nullptr, "Ip6::NewMesssage() failed"); in TestUdpMessageChecksum()
192 SuccessOrQuit(message->SetLength(size)); in TestUdpMessageChecksum()
198 message->Write(0, udpHeader); in TestUdpMessageChecksum()
206 message->WriteBytes(sizeof(udpHeader), &buffer[0], payloadSize); in TestUdpMessageChecksum()
215 …Checksum::UpdateMessageChecksum(*message, messageInfo.GetSockAddr(), messageInfo.GetPeerAddr(), Ip… in TestUdpMessageChecksum()
217 SuccessOrQuit(message->Read(message->GetOffset(), udpHeader)); in TestUdpMessageChecksum()
223 *message) == 0xffff); in TestUdpMessageChecksum()
228 SuccessOrQuit(Checksum::VerifyMessageChecksum(*message, messageInfo, Ip6::kProtoUdp)); in TestUdpMessageChecksum()
232 CorruptMessage(*message); in TestUdpMessageChecksum()
[all …]
Dtest_aes.cpp128 Message *message; in TestMacCommandFrame() local
151 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestMacCommandFrame()
152 VerifyOrQuit(message != nullptr); in TestMacCommandFrame()
154 SuccessOrQuit(message->AppendBytes(test, kHeaderLength + kPayloadLength)); in TestMacCommandFrame()
159 aesCcm.Payload(*message, kHeaderLength, kPayloadLength, Crypto::AesCcm::kEncrypt); in TestMacCommandFrame()
162 SuccessOrQuit(message->Append(tag)); in TestMacCommandFrame()
163 VerifyOrQuit(message->GetLength() == sizeof(encrypted)); in TestMacCommandFrame()
164 VerifyOrQuit(message->Compare(0, encrypted)); in TestMacCommandFrame()
168 aesCcm.Payload(*message, kHeaderLength, kPayloadLength, Crypto::AesCcm::kDecrypt); in TestMacCommandFrame()
170 VerifyOrQuit(message->GetLength() == sizeof(encrypted)); in TestMacCommandFrame()
[all …]
Dtest_priority_queue.cpp49 Message *message; in VerifyPriorityQueueContent() local
63 message = aPriorityQueue.GetHead(); in VerifyPriorityQueueContent()
64 VerifyOrQuit(message == nullptr, "PriorityQueue is not empty when expected len is zero."); in VerifyPriorityQueueContent()
74 for (message = aPriorityQueue.GetHead(); message != nullptr; message = message->GetNext()) in VerifyPriorityQueueContent()
96 … VerifyOrQuit(msgArg == message, "PriorityQueue content does not match what is expected."); in VerifyPriorityQueueContent()
115 message = aPriorityQueue.GetHead(); in VerifyPriorityQueueContent()
119 VerifyOrQuit(message == &msg, "`for` loop iteration does not match expected"); in VerifyPriorityQueueContent()
120 message = message->GetNext(); in VerifyPriorityQueueContent()
123 … VerifyOrQuit(message == nullptr, "`for` loop iteration resulted in fewer entries than expected"); in VerifyPriorityQueueContent()
127 message = aPriorityQueue.GetHead(); in VerifyPriorityQueueContent()
[all …]
Dtest_heap_string.cpp209 Message *message; in TestHeapData() local
223 VerifyOrQuit((message = messagePool->Allocate(Message::kTypeIp6)) != nullptr); in TestHeapData()
225 message->SetOffset(0); in TestHeapData()
261 SuccessOrQuit(message->Append(kData2)); in TestHeapData()
262 SuccessOrQuit(data.SetFrom(*message)); in TestHeapData()
265 SuccessOrQuit(message->Append(kData3)); in TestHeapData()
266 SuccessOrQuit(data.SetFrom(*message)); in TestHeapData()
268 VerifyOrQuit(data.GetLength() == message->GetLength()); in TestHeapData()
270 message->SetOffset(sizeof(kData2)); in TestHeapData()
271 SuccessOrQuit(data.SetFrom(*message)); in TestHeapData()
[all …]
Dtest_hmac_sha256.cpp90 Message *message; in TestSha256() local
97 VerifyOrQuit((message = messagePool->Allocate(Message::kTypeIp6)) != nullptr); in TestSha256()
117 SuccessOrQuit(message->Append("Hello")); in TestSha256()
118 offsets[index++] = message->GetLength(); in TestSha256()
119 …SuccessOrQuit(message->AppendBytes(testCase.mData, static_cast<uint16_t>(strlen(testCase.mData)))); in TestSha256()
120 SuccessOrQuit(message->Append("There!")); in TestSha256()
131 sha256.Update(*message, offsets[index++], static_cast<uint16_t>(strlen(testCase.mData))); in TestSha256()
231 Message *message; in TestHmacSha256() local
240 VerifyOrQuit((message = messagePool->Allocate(Message::kTypeIp6)) != nullptr); in TestHmacSha256()
260 SuccessOrQuit(message->Append("Hello")); in TestHmacSha256()
[all …]
/openthread-latest/src/core/meshcop/
Djoiner_router.cpp120 Coap::Message *message = nullptr; in HandleUdpReceive() local
130 message = Get<Tmf::Agent>().NewPriorityNonConfirmablePostMessage(kUriRelayRx); in HandleUdpReceive()
131 VerifyOrExit(message != nullptr, error = kErrorNoBufs); in HandleUdpReceive()
133 SuccessOrExit(error = Tlv::Append<JoinerUdpPortTlv>(*message, aMessageInfo.GetPeerPort())); in HandleUdpReceive()
134 SuccessOrExit(error = Tlv::Append<JoinerIidTlv>(*message, aMessageInfo.GetPeerAddr().GetIid())); in HandleUdpReceive()
135 …SuccessOrExit(error = Tlv::Append<JoinerRouterLocatorTlv>(*message, Get<Mle::MleRouter>().GetRloc1… in HandleUdpReceive()
141 SuccessOrExit(error = message->Append(tlv)); in HandleUdpReceive()
142 SuccessOrExit(error = message->AppendBytesFromMessage(aMessage, offsetRange)); in HandleUdpReceive()
146 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in HandleUdpReceive()
151 FreeMessageOnError(message, error); in HandleUdpReceive()
[all …]
Dannounce_begin_client.cpp56 Coap::Message *message = nullptr; in SendRequest() local
59 … VerifyOrExit((message = Get<Tmf::Agent>().NewPriorityMessage()) != nullptr, error = kErrorNoBufs); in SendRequest()
61 SuccessOrExit(error = message->InitAsPost(aAddress, kUriAnnounceBegin)); in SendRequest()
62 SuccessOrExit(error = message->SetPayloadMarker()); in SendRequest()
65 …error = Tlv::Append<MeshCoP::CommissionerSessionIdTlv>(*message, Get<MeshCoP::Commissioner>().GetS… in SendRequest()
67 SuccessOrExit(error = MeshCoP::ChannelMaskTlv::AppendTo(*message, aChannelMask)); in SendRequest()
69 SuccessOrExit(error = Tlv::Append<MeshCoP::CountTlv>(*message, aCount)); in SendRequest()
70 SuccessOrExit(error = Tlv::Append<MeshCoP::PeriodTlv>(*message, aPeriod)); in SendRequest()
74 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendRequest()
79 FreeMessageOnError(message, error); in SendRequest()
Dmeshcop_leader.cpp92 Coap::Message *message; in SendPetitionResponse() local
94 message = Get<Tmf::Agent>().NewPriorityResponseMessage(aRequest); in SendPetitionResponse()
95 VerifyOrExit(message != nullptr, error = kErrorNoBufs); in SendPetitionResponse()
97 SuccessOrExit(error = Tlv::Append<StateTlv>(*message, aState)); in SendPetitionResponse()
101 SuccessOrExit(error = Tlv::Append<CommissionerIdTlv>(*message, mCommissionerId)); in SendPetitionResponse()
106 SuccessOrExit(error = Tlv::Append<CommissionerSessionIdTlv>(*message, mSessionId)); in SendPetitionResponse()
109 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, aMessageInfo)); in SendPetitionResponse()
114 FreeMessageOnError(message, error); in SendPetitionResponse()
169 Coap::Message *message; in SendKeepAliveResponse() local
171 message = Get<Tmf::Agent>().NewPriorityResponseMessage(aRequest); in SendKeepAliveResponse()
[all …]
Dborder_agent.cpp351 Coap::Message *message = nullptr; in ForwardToLeader() local
380 message = Get<Tmf::Agent>().NewPriorityConfirmablePostMessage(aUri); in ForwardToLeader()
381 VerifyOrExit(message != nullptr, error = kErrorNoBufs); in ForwardToLeader()
384 SuccessOrExit(error = message->AppendBytesFromMessage(aMessage, offsetRange)); in ForwardToLeader()
390 … Get<Tmf::Agent>().SendMessage(*message, messageInfo, HandleCoapResponse, forwardContext.Get())); in ForwardToLeader()
405 FreeMessage(message); in ForwardToLeader()
428 Coap::Message *message = nullptr; in HandleCoapResponse() local
433 … VerifyOrExit((message = mCoapDtlsSession->NewPriorityMessage()) != nullptr, error = kErrorNoBufs); in HandleCoapResponse()
472 SuccessOrExit(error = aForwardContext.ToHeader(*message, aResponse->GetCode())); in HandleCoapResponse()
476 SuccessOrExit(error = message->SetPayloadMarker()); in HandleCoapResponse()
[all …]
Denergy_scan_client.cpp59 Coap::Message *message = nullptr; in SendQuery() local
62 … VerifyOrExit((message = Get<Tmf::Agent>().NewPriorityMessage()) != nullptr, error = kErrorNoBufs); in SendQuery()
64 SuccessOrExit(error = message->InitAsPost(aAddress, kUriEnergyScan)); in SendQuery()
65 SuccessOrExit(error = message->SetPayloadMarker()); in SendQuery()
68 …error = Tlv::Append<MeshCoP::CommissionerSessionIdTlv>(*message, Get<MeshCoP::Commissioner>().GetS… in SendQuery()
70 SuccessOrExit(error = MeshCoP::ChannelMaskTlv::AppendTo(*message, aChannelMask)); in SendQuery()
72 SuccessOrExit(error = Tlv::Append<MeshCoP::CountTlv>(*message, aCount)); in SendQuery()
73 SuccessOrExit(error = Tlv::Append<MeshCoP::PeriodTlv>(*message, aPeriod)); in SendQuery()
74 SuccessOrExit(error = Tlv::Append<MeshCoP::ScanDurationTlv>(*message, aScanDuration)); in SendQuery()
77 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo)); in SendQuery()
[all …]
/openthread-latest/src/core/net/
Dsntp_client.cpp66 for (Message &message : mPendingQueries) in Stop()
70 queryMetadata.ReadFrom(message); in Stop()
71 FinalizeSntpTransaction(message, queryMetadata, 0, kErrorAbort); in Stop()
81 Message *message = nullptr; in Query() local
93 VerifyOrExit((message = NewMessage(header)) != nullptr, error = kErrorNoBufs); in Query()
105 …VerifyOrExit((messageCopy = CopyAndEnqueueMessage(*message, queryMetadata)) != nullptr, error = kE… in Query()
106 SuccessOrExit(error = SendMessage(*message, *messageInfo)); in Query()
112 if (message) in Query()
114 message->Free(); in Query()
128 Message *message = nullptr; in NewMessage() local
[all …]
/openthread-latest/src/core/thread/
Dmesh_forwarder_mtd.cpp42 Message &message = *aMessagePtr.Release(); in SendMessage() local
44 message.SetDirectTransmission(); in SendMessage()
45 message.SetOffset(0); in SendMessage()
46 message.SetDatagramTag(0); in SendMessage()
47 message.SetTimestampToNow(); in SendMessage()
49 mSendQueue.Enqueue(message); in SendMessage()
53 ApplyDirectTxQueueLimit(message); in SendMessage()
60 Message *message; in EvictMessage() local
67 VerifyOrExit((message = mSendQueue.GetTail()) != nullptr); in EvictMessage()
69 if (message->GetPriority() < static_cast<uint8_t>(aPriority)) in EvictMessage()
[all …]
Dmesh_forwarder_ftd.cpp46 Message &message = *aMessagePtr.Release(); in SendMessage() local
48 message.SetOffset(0); in SendMessage()
49 message.SetDatagramTag(0); in SendMessage()
50 message.SetTimestampToNow(); in SendMessage()
51 mSendQueue.Enqueue(message); in SendMessage()
53 switch (message.GetType()) in SendMessage()
60 IgnoreError(message.Read(0, ip6Header)); in SendMessage()
70 message.SetDirectTransmission(); in SendMessage()
73 if (message.GetSubType() != Message::kSubTypeMplRetransmission) in SendMessage()
87 mIndirectSender.AddMessageForSleepyChild(message, child); in SendMessage()
[all …]
Dindirect_sender.cpp142 for (Message &message : Get<MeshForwarder>().mSendQueue) in ClearAllMessagesForSleepyChild()
144 message.GetIndirectTxChildMask().Remove(Get<ChildTable>().GetChildIndex(aChild)); in ClearAllMessagesForSleepyChild()
146 Get<MeshForwarder>().RemoveMessageIfNoPendingTx(message); in ClearAllMessagesForSleepyChild()
166 for (const Message &message : Get<MeshForwarder>().mSendQueue) in FindQueuedMessageForSleepyChild() local
168 if (message.GetIndirectTxChildMask().Has(childIndex) && aChecker(message)) in FindQueuedMessageForSleepyChild()
170 match = &message; in FindQueuedMessageForSleepyChild()
202 for (Message &message : Get<MeshForwarder>().mSendQueue) in HandleChildModeChange()
204 if (message.GetIndirectTxChildMask().Has(childIndex)) in HandleChildModeChange()
206 message.GetIndirectTxChildMask().Remove(childIndex); in HandleChildModeChange()
207 message.SetDirectTransmission(); in HandleChildModeChange()
[all …]
Danycast_locator.cpp51 Coap::Message *message = nullptr; in Locate() local
57 message = Get<Tmf::Agent>().NewConfirmablePostMessage(kUriAnycastLocate); in Locate()
58 VerifyOrExit(message != nullptr, error = kErrorNoBufs); in Locate()
67 … SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*message, messageInfo, HandleResponse, this)); in Locate()
72 FreeMessageOnError(message, error); in Locate()
115 Coap::Message *message = nullptr; in HandleTmf() local
119 message = Get<Tmf::Agent>().NewResponseMessage(aMessage); in HandleTmf()
120 VerifyOrExit(message != nullptr); in HandleTmf()
122 …SuccessOrExit(Tlv::Append<ThreadMeshLocalEidTlv>(*message, Get<Mle::Mle>().GetMeshLocalEid().GetIi… in HandleTmf()
123 SuccessOrExit(Tlv::Append<ThreadRloc16Tlv>(*message, Get<Mle::Mle>().GetRloc16())); in HandleTmf()
[all …]
Dmle_router.cpp557 TxMessage *message = nullptr; in SendAdvertisement() local
574 VerifyOrExit((message = NewMleMessage(kCommandAdvertisement)) != nullptr, error = kErrorNoBufs); in SendAdvertisement()
575 SuccessOrExit(error = message->AppendSourceAddressTlv()); in SendAdvertisement()
576 SuccessOrExit(error = message->AppendLeaderDataTlv()); in SendAdvertisement()
585 SuccessOrExit(error = message->AppendRouteTlv()); in SendAdvertisement()
593 SuccessOrExit(error = message->SendTo(aDestination)); in SendAdvertisement()
598 FreeMessageOnError(message, error); in SendAdvertisement()
609 TxMessage *message = nullptr; in SendLinkRequest() local
614 VerifyOrExit((message = NewMleMessage(kCommandLinkRequest)) != nullptr, error = kErrorNoBufs); in SendLinkRequest()
615 SuccessOrExit(error = message->AppendVersionTlv()); in SendLinkRequest()
[all …]
/openthread-latest/examples/platforms/simulation/
Dinfra_if.c100 Message *message; in sendNeighborAdvert() local
105 message = &sPendingTx[sNumPendingTx++]; in sendNeighborAdvert()
107 message->mIfIndex = aNsMessage->mIfIndex; in sendNeighborAdvert()
108 message->mSrc = sIp6Address; in sendNeighborAdvert()
109 message->mDst = aNsMessage->mSrc; in sendNeighborAdvert()
130 memset(message->mData, 0, INFRA_IF_NEIGHBOR_ADVERT_SIZE); in sendNeighborAdvert()
132 message->mData[index++] = OT_ICMP6_TYPE_NEIGHBOR_ADVERT; // Type. in sendNeighborAdvert()
134 message->mData[index++] = 0xd0; // Flags, set R and S bits. in sendNeighborAdvert()
136 …memcpy(&message->mData[index], &sIp6Address, sizeof(sIp6Address)); // Set the target address field. in sendNeighborAdvert()
141 message->mDataLength = INFRA_IF_NEIGHBOR_ADVERT_SIZE; in sendNeighborAdvert()
[all …]
Dtrel.c142 Message *message; in sendBrowseMessage() local
145 message = &sPendingTx[sNumPendingTx++]; in sendBrowseMessage()
147 message->mType = TREL_DNSSD_BROWSE_MESSAGE; in sendBrowseMessage()
148 message->mDataLength = 0; in sendBrowseMessage()
157 Message *message; in sendServiceMessage() local
162 message = &sPendingTx[sNumPendingTx++]; in sendServiceMessage()
164 message->mType = aType; in sendServiceMessage()
165 message->mSockAddr = sSockAddr; in sendServiceMessage()
166 message->mDataLength = sServiceTxtLength; in sendServiceMessage()
167 memcpy(message->mData, sServiceTxtData, sServiceTxtLength); in sendServiceMessage()
[all …]
/openthread-latest/tests/scripts/thread-cert/
Dmessage.py378 message = self.next_message_of(MessageType.COMMAND, False)
379 if not message:
381 elif message.is_data_poll():
382 return message
385 message = None
400 message = m
404 assert (message is not None), "Could not find CoapMessage with code: {}".format(code)
406 return message
418 message = None
429 message = m
[all …]
/openthread-latest/tests/fuzz/
Dip6_send.cpp65 otMessage *message = nullptr; in LLVMFuzzerTestOneInput() local
85 message = otIp6NewMessage(instance, &settings); in LLVMFuzzerTestOneInput()
86 VerifyOrExit(message != nullptr, error = OT_ERROR_NO_BUFS); in LLVMFuzzerTestOneInput()
88 error = otMessageAppend(message, data + 1, static_cast<uint16_t>(size - 1)); in LLVMFuzzerTestOneInput()
91 error = otIp6Send(instance, message); in LLVMFuzzerTestOneInput()
93 message = nullptr; in LLVMFuzzerTestOneInput()
101 if (message != nullptr) in LLVMFuzzerTestOneInput()
103 otMessageFree(message); in LLVMFuzzerTestOneInput()
/openthread-latest/third_party/mbedtls/repo/tests/suites/
Dtest_suite_lms.data2 # This test uses a fixed message, and then generates a private key, signs the
3 # message, and verifies the signature.
6 LMS NULL-message sign-verify test
7 # This test uses a NULL zero-length message, and then generates a private key,
8 # signs the message, and verifies the signature.
21 # To produce another signature with this message and key (note that the actual
42 # To produce another signature with this message and key (note that the actual
51 LMS pyhsslms interop NULL-message test
61 # To produce another signature with this message and key (note that the actual
65 # * touch message.bin (create empty message file)
[all …]

1234567