diff --git a/libi2pd/Streaming.h b/libi2pd/Streaming.h index 9410df9d..a114844d 100644 --- a/libi2pd/Streaming.h +++ b/libi2pd/Streaming.h @@ -276,8 +276,8 @@ namespace stream /** set max connections per minute per destination */ void SetMaxConnsPerMinute(const uint32_t conns); - Packet * NewPacket () { return new Packet; } - void DeletePacket (Packet * p) { delete p; } + Packet * NewPacket () { return m_PacketsPool.Acquire(); } + void DeletePacket (Packet * p) { return m_PacketsPool.Release(p); } void AcceptOnceAcceptor (std::shared_ptr stream, Acceptor acceptor, Acceptor prev); @@ -315,7 +315,7 @@ namespace stream std::vector m_Banned; uint64_t m_LastBanClear; - //i2p::util::MemoryPool m_PacketsPool; + i2p::util::MemoryPool m_PacketsPool; bool m_EnableDrop; public: