Public Member Functions | Private Attributes

df_MgrReader Class Reference
[IVD Data format.]

This class is used on top of df_BlockManager to perform read operations from the buffer queue inside the df_BlockManager. More...

#include <df.h>

Collaboration diagram for df_MgrReader:
Collaboration graph
[legend]

List of all members.

Public Member Functions

 df_MgrReader (df_BlockManager &a_mgr)
 ~df_MgrReader ()
df_DataBlockGetFull ()
void Release ()
UInt32_t GetReaderIdx () const
void SetError (ivd_Exception *a_err)

Private Attributes

 log_CLASSID_m
df_BlockManagerm_mgr
UInt32_t m_readerIdx
bool m_reserved

Detailed Description

This class is used on top of df_BlockManager to perform read operations from the buffer queue inside the df_BlockManager.

Destructor automatically notifies that the reader went down.

Definition at line 280 of file df.h.


Constructor & Destructor Documentation

df_MgrReader::df_MgrReader ( df_BlockManager a_mgr  ) 

Definition at line 107 of file df_blockmanager.cpp.

References log_FUNC_m, m_mgr, m_readerIdx, and df_BlockManager::RegisterReader().

Here is the call graph for this function:

df_MgrReader::~df_MgrReader (  ) 

Definition at line 116 of file df_blockmanager.cpp.

References dbg_NORM, log_DBG_m, log_FUNC_m, m_mgr, m_readerIdx, m_reserved, df_BlockManager::ReaderFinished(), and Release().

Here is the call graph for this function:


Member Function Documentation

df_DataBlock * df_MgrReader::GetFull (  ) 

Definition at line 128 of file df_blockmanager.cpp.

References df_BlockManager::GetFull(), m_mgr, m_readerIdx, m_reserved, and NULL.

Referenced by bea_MigrationThread::Migrate(), blk_NetWriter::Run(), and blk_BufferWriter::Run().

                                    {
    df_DataBlock *blk_p = m_mgr.GetFull(m_readerIdx);
    if (blk_p != NULL) {
        m_reserved = true;
    }
    return blk_p;
}

Here is the call graph for this function:

Here is the caller graph for this function:

UInt32_t df_MgrReader::GetReaderIdx (  )  const [inline]

Definition at line 288 of file df.h.

Referenced by blk_NetWriter::Run(), and blk_BufferWriter::Run().

                                         {
        return m_readerIdx;
    }

Here is the caller graph for this function:

void df_MgrReader::Release (  ) 

Definition at line 136 of file df_blockmanager.cpp.

References m_mgr, m_readerIdx, m_reserved, and df_BlockManager::Release().

Referenced by bea_MigrationThread::Migrate(), blk_NetWriter::Run(), blk_BufferWriter::Run(), and ~df_MgrReader().

                           {

    if (m_reserved) {
        m_reserved = false;
        m_mgr.Release(m_readerIdx);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void df_MgrReader::SetError ( ivd_Exception a_err  )  [inline]

Definition at line 292 of file df.h.

Referenced by blk_NetWriter::Run(), and blk_BufferWriter::Run().

{ m_mgr.SetReaderError(a_err); };

Here is the caller graph for this function:


Member Data Documentation

Definition at line 292 of file df.h.

Definition at line 297 of file df.h.

Referenced by df_MgrReader(), GetFull(), Release(), and ~df_MgrReader().

Definition at line 298 of file df.h.

Referenced by df_MgrReader(), GetFull(), Release(), and ~df_MgrReader().

bool df_MgrReader::m_reserved [private]

Definition at line 299 of file df.h.

Referenced by GetFull(), Release(), and ~df_MgrReader().


The documentation for this class was generated from the following files: