Home
last modified time | relevance | path

Searched refs:MessagePool (Results 1 – 25 of 32) sorted by relevance

12

/openthread-latest/tests/unit/
Dtest_hmac_sha256.cpp89 MessagePool *messagePool; in TestSha256()
96 messagePool = &instance->Get<MessagePool>(); in TestSha256()
230 MessagePool *messagePool; in TestHmacSha256()
239 messagePool = &instance->Get<MessagePool>(); in TestHmacSha256()
Dtest_aes.cpp151 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestMacCommandFrame()
205 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestInPlaceAesCcmProcessing()
Dtest_heap_string.cpp208 MessagePool *messagePool; in TestHeapData()
222 messagePool = &instance->Get<MessagePool>(); in TestHeapData()
Dtest_message_queue.cpp46 static MessagePool *sMessagePool;
114 sMessagePool = &sInstance->Get<MessagePool>(); in TestMessageQueue()
Dtest_message.cpp50 MessagePool *messagePool; in TestMessage()
65 messagePool = &instance->Get<MessagePool>(); in TestMessage()
384 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestAppender()
Dtest_priority_queue.cpp173 MessagePool *messagePool; in TestPriorityQueue()
184 messagePool = &instance->Get<MessagePool>(); in TestPriorityQueue()
Dtest_dns.cpp69 MessagePool *messagePool; in TestDnsName()
172 messagePool = &instance->Get<MessagePool>(); in TestDnsName()
641 MessagePool *messagePool; in TestDnsCompressedName()
664 messagePool = &instance->Get<MessagePool>(); in TestDnsCompressedName()
1150 MessagePool *messagePool; in TestHeaderAndResourceRecords()
1180 messagePool = &instance->Get<MessagePool>(); in TestHeaderAndResourceRecords()
1608 MessagePool *messagePool; in TestDnsTxtEntry()
1623 messagePool = &instance->Get<MessagePool>(); in TestDnsTxtEntry()
Dtest_offset_range.cpp147 message = instance->Get<MessagePool>().Allocate(Message::kTypeOther); in TestOffsetRange()
Dtest_tlv.cpp54 VerifyOrQuit((message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6)) != nullptr); in TestTlv()
Dtest_frame_builder.cpp58 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestFrameBuilder()
Dtest_spinel_buffer.cpp61 static MessagePool *sMessagePool;
344 sMessagePool = &sInstance->Get<MessagePool>(); in TestBuffer()
966 sMessagePool = &sInstance->Get<MessagePool>(); in TestFuzzBuffer()
Dtest_lowpan.cpp125 Message *message = sInstance->Get<MessagePool>().Allocate(Message::kTypeIp6); in Init()
181 … VerifyOrQuit((message = sInstance->Get<MessagePool>().Allocate(Message::kTypeIp6)) != nullptr); in Test()
204 …VerifyOrQuit((compressedMsg = sInstance->Get<MessagePool>().Allocate(Message::kTypeIp6)) != nullpt… in Test()
228 … VerifyOrQuit((message = sInstance->Get<MessagePool>().Allocate(Message::kTypeIp6)) != nullptr); in Test()
Dtest_dns_client.cpp233 VerifyOrQuit(sInstance->Get<MessagePool>().GetFreeBufferCount() == in FinalizeTest()
234 sInstance->Get<MessagePool>().GetTotalBufferCount()); in FinalizeTest()
Dtest_mdns.cpp1101 message = sInstance->Get<MessagePool>().Allocate(Message::kTypeOther); in SendQuery()
1143 message = sInstance->Get<MessagePool>().Allocate(Message::kTypeOther); in SendQueryForTwo()
1173 message = sInstance->Get<MessagePool>().Allocate(Message::kTypeOther); in SendPtrResponse()
1220 message = sInstance->Get<MessagePool>().Allocate(Message::kTypeOther); in SendSrvResponse()
1268 message = sInstance->Get<MessagePool>().Allocate(Message::kTypeOther); in SendTxtResponse()
1313 message = sInstance->Get<MessagePool>().Allocate(Message::kTypeOther); in SendHostAddrResponse()
1365 message = sInstance->Get<MessagePool>().Allocate(Message::kTypeOther); in SendResponseWithEmptyKey()
1411 message = sInstance->Get<MessagePool>().Allocate(Message::kTypeOther); in SendPtrQueryWithKnownAnswers()
1453 message = sInstance->Get<MessagePool>().Allocate(Message::kTypeOther); in SendEmtryPtrQueryWithKnownAnswers()
/openthread-latest/src/core/common/
Dmessage.cpp51 MessagePool::MessagePool(Instance &aInstance) in MessagePool() function in ot::MessagePool
61 Message *MessagePool::Allocate(Message::Type aType, uint16_t aReserveHeader, const Message::Setting… 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()
96 void MessagePool::Free(Message *aMessage) in Free()
103 Buffer *MessagePool::NewBuffer(Message::Priority aPriority) in NewBuffer()
134 void MessagePool::FreeBuffers(Buffer *aBuffer) in FreeBuffers()
152 Error MessagePool::ReclaimBuffers(Message::Priority aPriority) { return Get<MeshForwarder>().EvictM… in ReclaimBuffers()
154 uint16_t MessagePool::GetFreeBufferCount(void) const in GetFreeBufferCount()
173 uint16_t MessagePool::GetTotalBufferCount(void) const in GetTotalBufferCount()
Dmessage.hpp145 class MessagePool;
231 MessagePool *mMessagePool; // Message pool for this message.
278 friend class MessagePool;
1545 MessagePool *GetMessagePool(void) const { return GetMetadata().mMessagePool; } in GetMessagePool()
1546 …void SetMessagePool(MessagePool *aMessagePool) { GetMetadata().mMessagePool = aMessagePool… in SetMessagePool()
1675 friend class MessagePool;
1805 class MessagePool : public InstanceLocator, private NonCopyable class
1815 explicit MessagePool(Instance &aInstance);
/openthread-latest/src/core/instance/
Dinstance.cpp480 aInfo.mTotalBuffers = Get<MessagePool>().GetTotalBufferCount(); in GetBufferInfo()
481 aInfo.mFreeBuffers = Get<MessagePool>().GetFreeBufferCount(); in GetBufferInfo()
482 aInfo.mMaxUsedBuffers = Get<MessagePool>().GetMaxUsedBufferCount(); in GetBufferInfo()
508 void Instance::ResetBufferInfo(void) { Get<MessagePool>().ResetMaxUsedBufferCount(); } in ResetBufferInfo()
Dinstance.hpp489 MessagePool mMessagePool;
1025 template <> inline MessagePool &Instance::Get(void) { return mMessagePool; } in Get()
/openthread-latest/src/core/radio/
Dble_secure.cpp183 mSendMessage = Get<MessagePool>().Allocate(Message::kTypeBle); in SendMessage()
201 mSendMessage = Get<MessagePool>().Allocate(Message::kTypeBle); in Send()
257 if ((message = Get<MessagePool>().Allocate(Message::kTypeBle, 0)) == nullptr) in HandleBleReceive()
323 mReceivedMessage = Get<MessagePool>().Allocate(Message::kTypeBle); in HandleTlsConnectEvent()
425 message = Get<MessagePool>().Allocate(Message::kTypeBle); in HandleTlsReceive()
/openthread-latest/src/core/coap/
Dcoap_secure.cpp128 …VerifyOrExit((message = Get<MessagePool>().Allocate(Message::kTypeIp6, Message::GetHelpDataReserve… in HandleDtlsReceive()
/openthread-latest/src/core/thread/
Dchild_supervision.cpp70 messagePtr.Reset(Get<MessagePool>().Allocate(Message::kTypeSupervision, sizeof(uint8_t))); in SendMessage()
/openthread-latest/src/core/meshcop/
Ddataset_updater.cpp105 message = Get<MessagePool>().Allocate(Message::kTypeOther); in RequestUpdate()
Djoiner_router.cpp199 Message *message = Get<MessagePool>().Allocate(Message::kTypeOther); in DelaySendingJoinerEntrust()
/openthread-latest/src/core/net/
Dip6.cpp75 return Get<MessagePool>().Allocate( in NewMessage()
93 message = Get<MessagePool>().Allocate(Message::kTypeIp6, /* aReserveHeader */ 0, settings); in NewMessageFromData()
/openthread-latest/tests/nexus/
Dtest_dtls.cpp120 Message *message = aNode.Get<MessagePool>().Allocate(Message::kTypeOther); in PrepareMessage()

12