Signed-off-by: Alexander Chuprov <a.chuprov@yadro.com>

@@ -0,0 +12,4 @@
+}
+
+func NewBufferPool(poolSliseMaxSize int) BufferPool {
+	pool := sync.Pool{

@@ -0,0 +11,4 @@
+	buffersPool      *sync.Pool
+}
+
+func NewBufferPool(poolSliseMaxSize int) BufferPool {

@@ -0,0 +27,4 @@
+	return pool.NewBufferFromPool(size), true
+}
+
+func (pool BufferPool) NewBufferFromPool(size int, capacity ...int) *Buffer {

@@ -0,0 +17,4 @@
+func NewBufferPool(poolSliceMaxSize uint32) BufferPool {
+	pool := sync.Pool{
+		New: func() any {
+			return new(Buffer)

@@ -0,0 +23,4 @@
+	return BufferPool{poolSliceMaxSize: poolSliceMaxSize, buffersPool: &pool}
+}
+
+func (pool BufferPool) TryGetNewBufferFromPool(size uint32) (*Buffer, bool) {

@@ -0,0 +30,4 @@
+	return pool.NewBufferFromPool(size), true
+}
+
+func (pool BufferPool) NewBufferFromPool(size uint32, capacity ...uint32) *Buffer {

@@ -0,0 +4,4 @@
+	"sync"
+)
+
+type Buffer struct {

@@ -0,0 +42,4 @@
+	pool.buffersPool.Put(buf)
+}
+
+func (pool BufferPool) GetPoolSliceMaxSize() uint32 {

@@ -39,2 +43,2 @@
-	if ok {
-		defer returnBufferToPool(buffer)
+	buffer := buffersPool.Get(uint32(src.SignedDataSize()))
+	if src.SignedDataSize() < int(buffersPool.GetPoolSliceMaxSize()) {

@@ -0,0 +38,4 @@
+	return result
+}
+
+// Put returns a Buffer to the pool if its capacity is greater than or equal to the poolSliceSize.