| /external/pigweed/pw_multisink/ |
| D | multisink_threaded_test.cc | 52 class MessagePool { class
54 static MessagePool& Instance() { in Instance()
55 static MessagePool instance; in Instance()
59 MessagePool(const MessagePool&) = delete;
60 MessagePool& operator=(const MessagePool&) = delete;
61 MessagePool(MessagePool&&) = delete;
62 MessagePool& operator=(MessagePool&&) = delete;
70 MessagePool() { in MessagePool() function in pw::multisink::MessagePool
202 const auto message_stack = MessagePool::Instance().GetMessages(log_count); in TEST_F()
226 const auto message_stack = MessagePool::Instance().GetMessages(log_count); in TEST_F()
[all …]
|
| /external/openthread/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 | 151 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestMacCommandFrame()
205 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestInPlaceAesCcmProcessing()
|
| D | test_message_queue.cpp | 46 static MessagePool *sMessagePool;
114 sMessagePool = &sInstance->Get<MessagePool>(); in TestMessageQueue()
|
| D | test_heap_string.cpp | 208 MessagePool *messagePool; in TestHeapData()
222 messagePool = &instance->Get<MessagePool>(); in TestHeapData()
|
| D | test_message.cpp | 47 MessagePool *messagePool; in TestMessage()
62 messagePool = &instance->Get<MessagePool>(); in TestMessage()
381 message = instance->Get<MessagePool>().Allocate(Message::kTypeIp6); in TestAppender()
|
| D | test_priority_queue.cpp | 173 MessagePool *messagePool; in TestPriorityQueue()
184 messagePool = &instance->Get<MessagePool>(); in TestPriorityQueue()
|
| D | test_dns.cpp | 69 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()
|
| D | test_offset_range.cpp | 147 message = instance->Get<MessagePool>().Allocate(Message::kTypeOther); in TestOffsetRange()
|
| 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()
966 sMessagePool = &sInstance->Get<MessagePool>(); in TestFuzzBuffer()
|
| D | test_lowpan.cpp | 125 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 | 233 VerifyOrQuit(sInstance->Get<MessagePool>().GetFreeBufferCount() == in FinalizeTest()
234 sInstance->Get<MessagePool>().GetTotalBufferCount()); in FinalizeTest()
|
| D | test_mdns.cpp | 1101 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()
|
| /external/openthread/src/core/common/ |
| D | message.cpp | 51 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()
|
| D | message.hpp | 147 class MessagePool;
233 MessagePool *mMessagePool; // Message pool for this message.
282 friend class MessagePool;
1549 MessagePool *GetMessagePool(void) const { return GetMetadata().mMessagePool; } in GetMessagePool()
1550 …void SetMessagePool(MessagePool *aMessagePool) { GetMetadata().mMessagePool = aMessagePool… in SetMessagePool()
1679 friend class MessagePool;
1809 class MessagePool : public InstanceLocator, private NonCopyable class
1819 explicit MessagePool(Instance &aInstance);
|
| /external/openthread/src/core/instance/ |
| D | instance.cpp | 480 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()
|
| D | instance.hpp | 499 MessagePool mMessagePool;
1038 template <> inline MessagePool &Instance::Get(void) { return mMessagePool; } in Get()
|
| /external/openthread/src/core/radio/ |
| D | ble_secure.cpp | 183 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()
|
| /external/openthread/src/core/coap/ |
| D | coap_secure.cpp | 128 …VerifyOrExit((message = Get<MessagePool>().Allocate(Message::kTypeIp6, Message::GetHelpDataReserve… in HandleDtlsReceive()
|
| /external/openthread/src/core/thread/ |
| D | child_supervision.cpp | 70 messagePtr.Reset(Get<MessagePool>().Allocate(Message::kTypeSupervision, sizeof(uint8_t))); in SendMessage()
|
| /external/openthread/src/core/meshcop/ |
| D | dataset_updater.cpp | 105 message = Get<MessagePool>().Allocate(Message::kTypeOther); in RequestUpdate()
|
| D | joiner_router.cpp | 199 Message *message = Get<MessagePool>().Allocate(Message::kTypeOther); in DelaySendingJoinerEntrust()
|
| /external/openthread/src/core/net/ |
| D | ip6.cpp | 75 return Get<MessagePool>().Allocate( in NewMessage()
93 message = Get<MessagePool>().Allocate(Message::kTypeIp6, /* aReserveHeader */ 0, settings); in NewMessageFromData()
|