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).
void	Recycle (XrdCl::Buffer &&buffer)
	Give back a buffer to the poool.

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

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()

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();
      }