| /openthread-3.4.0/tests/unit/ |
| D | test_hmac_sha256.cpp | 89 MessagePool *messagePool; in TestSha256()
96 messagePool = &instance->Get<MessagePool>(); in TestSha256()
230 MessagePool *messagePool; in TestHmacSha256()
239 messagePool = &instance->Get<MessagePool>(); in TestHmacSha256()
|
| D | test_aes.cpp | 149 message = instance->Get<ot::MessagePool>().Allocate(ot::Message::kTypeIp6); in TestMacCommandFrame()
204 message = instance->Get<ot::MessagePool>().Allocate(ot::Message::kTypeIp6); in TestInPlaceAesCcmProcessing()
|
| D | test_heap_string.cpp | 200 MessagePool *messagePool; in TestHeapData()
214 messagePool = &instance->Get<MessagePool>(); in TestHeapData()
|
| D | test_message.cpp | 50 MessagePool *messagePool; in TestMessage()
64 messagePool = &instance->Get<MessagePool>(); in TestMessage()
331 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestAppender()
|
| D | test_message_queue.cpp | 44 static ot::MessagePool *sMessagePool;
112 sMessagePool = &sInstance->Get<ot::MessagePool>(); in TestMessageQueue()
|
| D | test_dns.cpp | 60 MessagePool *messagePool; in TestDnsName()
146 messagePool = &instance->Get<MessagePool>(); in TestDnsName()
485 MessagePool *messagePool; in TestDnsCompressedName()
508 messagePool = &instance->Get<MessagePool>(); in TestDnsCompressedName()
840 MessagePool *messagePool; in TestHeaderAndResourceRecords()
870 messagePool = &instance->Get<MessagePool>(); in TestHeaderAndResourceRecords()
1281 MessagePool *messagePool; in TestDnsTxtEntry()
1296 messagePool = &instance->Get<MessagePool>(); in TestDnsTxtEntry()
|
| D | test_priority_queue.cpp | 172 ot::MessagePool *messagePool; in TestPriorityQueue()
183 messagePool = &instance->Get<ot::MessagePool>(); in TestPriorityQueue()
|
| D | test_tlv.cpp | 54 VerifyOrQuit((message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6)) != nullptr); in TestTlv()
|
| D | test_frame_builder.cpp | 58 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestFrameBuilder()
|
| D | test_spinel_buffer.cpp | 61 static MessagePool *sMessagePool;
344 sMessagePool = &sInstance->Get<MessagePool>(); in TestBuffer()
967 sMessagePool = &sInstance->Get<MessagePool>(); in TestFuzzBuffer()
|
| D | test_lowpan.cpp | 127 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()
|
| D | test_dns_client.cpp | 219 VerifyOrQuit(sInstance->Get<MessagePool>().GetFreeBufferCount() == in FinalizeTest()
220 sInstance->Get<MessagePool>().GetTotalBufferCount()); in FinalizeTest()
|
| /openthread-3.4.0/src/core/common/ |
| D | message.cpp | 65 MessagePool::MessagePool(Instance &aInstance) in MessagePool() function in ot::MessagePool
75 Message *MessagePool::Allocate(Message::Type aType, uint16_t aReserveHeader, const Message::Setting… in Allocate()
101 Message *MessagePool::Allocate(Message::Type aType) { return Allocate(aType, 0, Message::Settings::… in Allocate()
103 Message *MessagePool::Allocate(Message::Type aType, uint16_t aReserveHeader) in Allocate()
108 void MessagePool::Free(Message *aMessage) in Free()
115 Buffer *MessagePool::NewBuffer(Message::Priority aPriority) in NewBuffer()
146 void MessagePool::FreeBuffers(Buffer *aBuffer) in FreeBuffers()
164 Error MessagePool::ReclaimBuffers(Message::Priority aPriority) { return Get<MeshForwarder>().EvictM… in ReclaimBuffers()
166 uint16_t MessagePool::GetFreeBufferCount(void) const in GetFreeBufferCount()
185 uint16_t MessagePool::GetTotalBufferCount(void) const in GetTotalBufferCount()
|
| D | instance.cpp | 405 aInfo.mTotalBuffers = Get<MessagePool>().GetTotalBufferCount(); in GetBufferInfo()
406 aInfo.mFreeBuffers = Get<MessagePool>().GetFreeBufferCount(); in GetBufferInfo()
407 aInfo.mMaxUsedBuffers = Get<MessagePool>().GetMaxUsedBufferCount(); in GetBufferInfo()
433 void Instance::ResetBufferInfo(void) { Get<MessagePool>().ResetMaxUsedBufferCount(); } in ResetBufferInfo()
|
| D | message.hpp | 149 class MessagePool;
192 MessagePool *mMessagePool; // Message pool for this message.
269 friend class MessagePool;
1404 MessagePool *GetMessagePool(void) const { return GetMetadata().mMessagePool; } in GetMessagePool()
1405 …void SetMessagePool(MessagePool *aMessagePool) { GetMetadata().mMessagePool = aMessagePool… in SetMessagePool()
1543 friend class MessagePool;
1686 class MessagePool : public InstanceLocator, private NonCopyable class
1697 explicit MessagePool(Instance &aInstance);
|
| D | instance.hpp | 419 MessagePool mMessagePool;
899 template <> inline MessagePool &Instance::Get(void) { return mMessagePool; } in Get()
|
| /openthread-3.4.0/src/core/meshcop/ |
| D | dataset_updater.cpp | 67 message = Get<MessagePool>().Allocate(Message::kTypeOther); in RequestUpdate()
|
| D | joiner_router.cpp | 210 Message *message = Get<MessagePool>().Allocate(Message::kTypeOther); in DelaySendingJoinerEntrust()
|
| /openthread-3.4.0/src/core/thread/ |
| D | child_supervision.cpp | 75 message = Get<MessagePool>().Allocate(Message::kTypeSupervision, sizeof(uint8_t)); in SendMessage()
|
| D | mesh_forwarder.cpp | 1546 …aMessage = Get<MessagePool>().Allocate(Message::kTypeIp6, /* aReserveHeader */ 0, Message::Setting… in FrameToMessage()
1653 message = Get<MessagePool>().Allocate(Message::kTypeMacEmptyData); in SendEmptyMessage()
|
| D | mesh_forwarder_ftd.cpp | 701 …Get<MessagePool>().Allocate(Message::kType6lowpan, /* aReserveHeader */ 0, Message::Settings(prior… in HandleMesh()
|
| /openthread-3.4.0/src/core/coap/ |
| D | coap_secure.cpp | 183 …VerifyOrExit((message = Get<MessagePool>().Allocate(Message::kTypeIp6, Message::GetHelpDataReserve… in HandleDtlsReceive()
|
| /openthread-3.4.0/src/core/net/ |
| D | ip6.cpp | 90 return Get<MessagePool>().Allocate( in NewMessage()
108 message = Get<MessagePool>().Allocate(Message::kTypeIp6, /* aReserveHeader */ 0, settings); in NewMessageFromData()
|
| D | dns_dso.cpp | 157 return Get<MessagePool>().Allocate(Message::kTypeOther, sizeof(Dns::Header), in NewMessage()
|
| D | dns_client.cpp | 1036 aQuery = Get<MessagePool>().Allocate(Message::kTypeOther); in AllocateQuery()
|
