df_MgrReader Class Reference
[IVD Data format.]

#include <df.h>

Collaboration diagram for df_MgrReader:

[legend]

List of all members.

---

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 266 of file df.h.

Public Member Functions
	df_MgrReader (df_BlockManager &a_mgr)
	~df_MgrReader ()
df_DataBlock *	GetFull ()
void	Release ()
UInt32_t	GetReaderIdx () const
void	SetError (ivd_Exception *a_err)
Private Attributes
	log_CLASSID_m
df_BlockManager &	m_mgr
UInt32_t	m_readerIdx
bool	m_reserved

---

Constructor & Destructor Documentation

df_MgrReader::df_MgrReader

(

df_BlockManager &

a_mgr

)

Definition at line 93 of file df_blockmanager.cpp.

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

  : m_mgr(a_mgr),
    m_reserved(false) {

    log_FUNC_m(df_MgrReader);

    m_readerIdx = m_mgr.RegisterReader();
}

Here is the call graph for this function:

df_MgrReader::~df_MgrReader

(

)

Definition at line 102 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().

                            {

    log_FUNC_m(~df_MgrReader);

    if (m_reserved) {
        log_DBG_m(dbg_NORM, "Releasing block.");
        Release();
    }

    m_mgr.ReaderFinished(m_readerIdx);
}

Here is the call graph for this function:

---

Member Function Documentation

df_DataBlock * df_MgrReader::GetFull

(

)

Definition at line 114 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:

void df_MgrReader::Release

(

)

Definition at line 122 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:

UInt32_t df_MgrReader::GetReaderIdx

(

)

const [inline]

Definition at line 274 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::SetError

(

ivd_Exception *

a_err

)

[inline]

Definition at line 278 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

df_MgrReader::log_CLASSID_m [private]

Definition at line 278 of file df.h.

df_BlockManager& df_MgrReader::m_mgr [private]

Definition at line 283 of file df.h.

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

UInt32_t df_MgrReader::m_readerIdx [private]

Definition at line 284 of file df.h.

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

bool df_MgrReader::m_reserved [private]

Definition at line 285 of file df.h.

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

---

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

• df.h
• df_blockmanager.cpp