TAO_Notify::Standard_Event_Persistence_Factory Class Reference

Standard (i.e. default) implementation of Event_Persistence_Factory interface. More...

#include <Standard_Event_Persistence.h>

Inheritance diagram for TAO_Notify::Standard_Event_Persistence_Factory:

[legend]Collaboration diagram for TAO_Notify::Standard_Event_Persistence_Factory:

[legend]List of all members.

Public Member Functions
	Standard_Event_Persistence_Factory ()
	Constructor.
virtual	~Standard_Event_Persistence_Factory ()
	Destructor.
bool	open (const ACE_TCHAR *filename, ACE_UINT32 block_size=512)
virtual Routing_Slip_Persistence_Manager *	create_routing_slip_persistence_manager (Persistent_Callback *callback)
	Create a Persistence Manager.
virtual Routing_Slip_Persistence_Manager *	first_reload_manager ()
void	done_reloading (Persistent_Storage_Block *next_psb, ACE_UINT64 current_serial_number)
	reloading process complete. Where should the chain continue?
void	preallocate_next_record (ACE_UINT64 &current_serial_number, Persistent_Storage_Block *&current_psb, ACE_UINT64 &next_serial_number, ACE_UINT32 &next_block_number)
void	get_preallocated_pointer (ACE_UINT64 &next_serial_number, ACE_UINT32 &next_block_number)
Persistent_File_Allocator *	allocator ()
Routing_Slip_Persistence_Manager &	root ()
Public Attributes
TAO_SYNCH_MUTEX	lock
Private Attributes
Persistent_File_Allocator	allocator_
Routing_Slip_Persistence_Manager	root_
Persistent_Storage_Block *	psb_
ACE_UINT64	serial_number_
bool	is_reloading_

---

Detailed Description

Standard (i.e. default) implementation of Event_Persistence_Factory interface.

Definition at line 39 of file Standard_Event_Persistence.h.

---

Constructor & Destructor Documentation

TAO_Notify::Standard_Event_Persistence_Factory::Standard_Event_Persistence_Factory

(

)

Constructor.

Definition at line 115 of file Standard_Event_Persistence.cpp.

  : allocator_()
  , root_(this)
  , psb_(0)
  , serial_number_(ROUTING_SLIP_ROOT_SERIAL_NUMBER + 1)
  , is_reloading_ (false)
{
}

TAO_Notify::Standard_Event_Persistence_Factory::~Standard_Event_Persistence_Factory

(

)

[virtual]

Destructor.

Definition at line 143 of file Standard_Event_Persistence.cpp.

References ACE_DEBUG, ACE_TEXT(), allocator_, LM_DEBUG, psb_, TAO_Notify::Routing_Slip_Persistence_Manager::release_all(), root_, TAO_Notify::Persistent_File_Allocator::shutdown(), and TAO_debug_level.

{
  if (TAO_debug_level > 0)
  {
    ACE_DEBUG ((LM_DEBUG,
      ACE_TEXT ("(%P|%t) Standard_Event_Persistence_Factory::~Standard_Event_Persistence_Factory\n")
    ));
  }
  this->root_.release_all ();
  delete this->psb_;
  this->psb_ = 0;
  this->allocator_.shutdown();
}

---

Member Function Documentation

Persistent_File_Allocator * TAO_Notify::Standard_Event_Persistence_Factory::allocator

(

)

Accessor for file allocator. Intended for use only by the Routing Slip Persistence Manager

Definition at line 218 of file Standard_Event_Persistence.cpp.

References allocator_.

{
  return &this->allocator_;
}

Routing_Slip_Persistence_Manager * TAO_Notify::Standard_Event_Persistence_Factory::create_routing_slip_persistence_manager

(

Persistent_Callback *

callback

)

[virtual]

Create a Persistence Manager.

Implements TAO_Notify::Event_Persistence_Factory.

Definition at line 158 of file Standard_Event_Persistence.cpp.

References ACE_NEW_RETURN, and TAO_Notify::Routing_Slip_Persistence_Manager::set_callback().

{
  Routing_Slip_Persistence_Manager* rspm = 0;
  ACE_NEW_RETURN(rspm, Routing_Slip_Persistence_Manager(this), rspm);
  rspm->set_callback(callback);
  return rspm;
}

void TAO_Notify::Standard_Event_Persistence_Factory::done_reloading	(	Persistent_Storage_Block *	next_psb,
		ACE_UINT64	current_serial_number
	)

reloading process complete. Where should the chain continue?

Definition at line 179 of file Standard_Event_Persistence.cpp.

References ACE_ASSERT, is_reloading_, psb_, and serial_number_.

Referenced by TAO_Notify::Routing_Slip_Persistence_Manager::load_next().

{
  ACE_ASSERT (this->psb_ == 0);
  this->psb_ = next_psb;
  this->serial_number_ = current_serial_number;
  this->is_reloading_ = false;
}

Routing_Slip_Persistence_Manager * TAO_Notify::Standard_Event_Persistence_Factory::first_reload_manager

(

)

[virtual]

Begin the reload process by returning the first Routing_Slip_Persistence_Manager to continue call Routing_Slip_Persistence_Manager::load_next ()

Implements TAO_Notify::Event_Persistence_Factory.

Definition at line 168 of file Standard_Event_Persistence.cpp.

References TAO_Notify::Routing_Slip_Persistence_Manager::load_next(), and root_.

{
  Routing_Slip_Persistence_Manager * result = 0;
  if (this->is_reloading_)
  {
    result = this->root_.load_next();
  }
  return result;
}

void TAO_Notify::Standard_Event_Persistence_Factory::get_preallocated_pointer	(	ACE_UINT64 &	next_serial_number,
		ACE_UINT32 &	next_block_number
	)

Definition at line 206 of file Standard_Event_Persistence.cpp.

References TAO_Notify::Persistent_File_Allocator::allocate(), allocator_, TAO_Notify::Persistent_Storage_Block::block_number(), psb_, and serial_number_.

Referenced by preallocate_next_record(), and TAO_Notify::Routing_Slip_Persistence_Manager::store_root().

{
  ++this->serial_number_;
  this->psb_ = this->allocator_.allocate();

  next_serial_number = this->serial_number_;
  next_block_number = ACE_Utils::truncate_cast<ACE_UINT32> (this->psb_->block_number());
}

bool TAO_Notify::Standard_Event_Persistence_Factory::open	(	const ACE_TCHAR *	filename,
		ACE_UINT32	block_size = 512
	)

Open persistence file and initialize. /param filename the fully qualified path/name of the file to contain persistent information. /param block_size the size of a physical block on the device containing the file.

Definition at line 125 of file Standard_Event_Persistence.cpp.

References ACE_ASSERT, allocator_, TAO_Notify::Persistent_File_Allocator::open(), root_, TAO_Notify::ROUTING_SLIP_ROOT_BLOCK_NUMBER, TAO_Notify::ROUTING_SLIP_ROOT_SERIAL_NUMBER, and TAO_Notify::Routing_Slip_Persistence_Manager::store_root().

{
  bool result = false;
  if (allocator_.open (filename, block_size))
  {
    this->is_reloading_ = this->root_.load(ROUTING_SLIP_ROOT_BLOCK_NUMBER, ROUTING_SLIP_ROOT_SERIAL_NUMBER);
    if (! this->is_reloading_)
    {
      ACE_ASSERT (this->psb_ == 0);
//      this->psb_ = this->allocator_.allocate();
      this->root_.store_root();
    }
    result = true;
  }
  return result;
}

void TAO_Notify::Standard_Event_Persistence_Factory::preallocate_next_record	(	ACE_UINT64 &	current_serial_number,
		Persistent_Storage_Block *&	current_psb,
		ACE_UINT64 &	next_serial_number,
		ACE_UINT32 &	next_block_number
	)

return current serial # and a psb containing current record# allocate new serial # and record number, and return those, too.

Definition at line 190 of file Standard_Event_Persistence.cpp.

References get_preallocated_pointer(), psb_, serial_number_, TAO_Notify::Persistent_Storage_Block::set_allocator_owns(), and TAO_Notify::Persistent_Storage_Block::set_sync().

Referenced by TAO_Notify::Routing_Slip_Persistence_Manager::store_i().

{
  // return current serial number and
  // a psb containing current record number
  current_serial_number = this->serial_number_;
  this->psb_->set_allocator_owns(false); // give up ownership
  this->psb_->set_sync();
  current_psb = this->psb_;
  this->get_preallocated_pointer (next_serial_number, next_block_number);
}

Routing_Slip_Persistence_Manager & TAO_Notify::Standard_Event_Persistence_Factory::root

(

)

Access root record. Intended for use only by the Routing Slip Persistence Manager

Definition at line 224 of file Standard_Event_Persistence.cpp.

References root_.

{
  return this->root_;
}

---

Member Data Documentation

Persistent_File_Allocator TAO_Notify::Standard_Event_Persistence_Factory::allocator_ [private]

Definition at line 92 of file Standard_Event_Persistence.h.

Referenced by allocator(), get_preallocated_pointer(), open(), and ~Standard_Event_Persistence_Factory().

bool TAO_Notify::Standard_Event_Persistence_Factory::is_reloading_ [private]

Definition at line 96 of file Standard_Event_Persistence.h.

Referenced by done_reloading().

TAO_SYNCH_MUTEX TAO_Notify::Standard_Event_Persistence_Factory::lock

Definition at line 89 of file Standard_Event_Persistence.h.

Referenced by TAO_Notify::Routing_Slip_Persistence_Manager::remove(), and TAO_Notify::Routing_Slip_Persistence_Manager::store_i().

Persistent_Storage_Block* TAO_Notify::Standard_Event_Persistence_Factory::psb_ [private]

Definition at line 94 of file Standard_Event_Persistence.h.

Referenced by done_reloading(), get_preallocated_pointer(), preallocate_next_record(), and ~Standard_Event_Persistence_Factory().

Routing_Slip_Persistence_Manager TAO_Notify::Standard_Event_Persistence_Factory::root_ [private]

Definition at line 93 of file Standard_Event_Persistence.h.

Referenced by first_reload_manager(), open(), root(), and ~Standard_Event_Persistence_Factory().

ACE_UINT64 TAO_Notify::Standard_Event_Persistence_Factory::serial_number_ [private]

Definition at line 95 of file Standard_Event_Persistence.h.

Referenced by done_reloading(), get_preallocated_pointer(), and preallocate_next_record().

---

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

• Standard_Event_Persistence.h
• Standard_Event_Persistence.cpp

---