Pool of buffer for caching writes. More...

#include <XrdEcWrtBuff.hh>

Collaboration diagram for XrdEc::BufferPool:

Public Member Functions
XrdCl::Buffer	Create (const ObjCfg &objcfg)
	Create now buffer (or recycle existing one) More...

void	Recycle (XrdCl::Buffer &&buffer)
	Give back a buffer to the poool. More...

Static Public Member Functions
static BufferPool &	Instance ()
	Singleton access to the object. More...

Detailed Description

Pool of buffer for caching writes.

Definition at line 48 of file XrdEcWrtBuff.hh.

Member Function Documentation

◆ Create()

XrdCl::Buffer XrdEc::BufferPool::Create ( const ObjCfg & objcfg )

inline

Create now buffer (or recycle existing one)

Definition at line 64 of file XrdEcWrtBuff.hh.

       {
         std::unique_lock<std::mutex> lck( mtx );
         //---------------------------------------------------------------------
         // If pool is not empty, recycle existing buffer
         //---------------------------------------------------------------------
         if( !pool.empty() )
         {
           XrdCl::Buffer buffer( std::move( pool.front() ) );
           pool.pop();
           return buffer;
         }
         //---------------------------------------------------------------------
         // Check if we can create a new buffer object without exceeding the
         // the maximum size of the pool
         //---------------------------------------------------------------------
         if( currentsize < totalsize )
         {
           XrdCl::Buffer buffer( objcfg.blksize );
           ++currentsize;
           return buffer;
         }
         //---------------------------------------------------------------------
         // If not, we have to wait until there is a buffer we can recycle
         //---------------------------------------------------------------------
         while( pool.empty() ) cv.wait( lck );
         XrdCl::Buffer buffer( std::move( pool.front() ) );
         pool.pop();
         return buffer;
       }

References XrdEc::ObjCfg::blksize.

◆ Instance()

static BufferPool& XrdEc::BufferPool::Instance ( )

inlinestatic

Singleton access to the object.

Definition at line 55 of file XrdEcWrtBuff.hh.

       {
         static BufferPool instance;
         return instance;
       }

Referenced by XrdEc::WrtBuff::~WrtBuff().

Here is the caller graph for this function:

◆ Recycle()

void XrdEc::BufferPool::Recycle ( XrdCl::Buffer && buffer )

inline

Give back a buffer to the poool.

Definition at line 98 of file XrdEcWrtBuff.hh.

       {
         if( !buffer.GetBuffer() ) return;
         std::unique_lock<std::mutex> lck( mtx );
         buffer.SetCursor( 0 );
         pool.emplace( std::move( buffer ) );
         cv.notify_all();
       }