ACE_RMCast::NRTM Struct Reference

#include <Protocol.h>

Inheritance diagram for ACE_RMCast::NRTM:

[legend]Collaboration diagram for ACE_RMCast::NRTM:

[legend]List of all members.

Public Member Functions
	map_ (10)
	map_ (10)
NRTM_ptr	clone ()
void	insert (Address const &addr, u64 sn)
u64	find (Address const &addr) const
bool	empty () const
virtual void	serialize_body (ostream &os) const
virtual void	serialize_body (sstream &ss) const
Static Public Member Functions
static u32	max_count (u32 max_size)
Public Attributes
	__pad0__: Profile (h)
	__pad1__: Profile (id)
Static Public Attributes
static u16 const	id = 0x0006
Protected Member Functions
virtual Profile_ptr	clone_ ()
i	done ()
i	advance ())
Protected Attributes
	__pad2__: Profile (nrtm) { for (Map::const_iterator i (nrtm.map_)
Private Types
typedef ACE_Hash_Map_Manager_Ex< Address, u64, AddressHasher, ACE_Equal_To< Address >, ACE_Null_Mutex >	Map
Private Attributes
Map	map_

---

Detailed Description

Definition at line 953 of file Protocol.h.

---

Member Typedef Documentation

typedef ACE_Hash_Map_Manager_Ex<Address, u64, AddressHasher, ACE_Equal_To<Address>, ACE_Null_Mutex> ACE_RMCast::NRTM::Map [private]

Definition at line 1113 of file Protocol.h.

---

Member Function Documentation

i ACE_RMCast::NRTM::advance

(

)

[inline, protected]

Definition at line 1009 of file Protocol.h.

References ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::bind(), and map_.

      {
        map_.bind ((*i).ext_id_, (*i).int_id_);
      }

NRTM_ptr ACE_RMCast::NRTM::clone

(

void

)

[inline]

Reimplemented from ACE_RMCast::Profile.

Definition at line 993 of file Protocol.h.

References clone_().

    {
      return NRTM_ptr (clone_ ());
    }

virtual Profile_ptr ACE_RMCast::NRTM::clone_

(

)

[inline, protected, virtual]

Implements ACE_RMCast::Profile.

Definition at line 1000 of file Protocol.h.

Referenced by clone().

    {
      Profile_ptr p (new NRTM (*this));
      return p;
    }

i ACE_RMCast::NRTM::done

(

)

[protected]

bool ACE_RMCast::NRTM::empty

(

void

)

const [inline]

Definition at line 1035 of file Protocol.h.

References ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::current_size(), and map_.

    {
      return map_.current_size () == 0;
    }

u64 ACE_RMCast::NRTM::find

(

Address const &

addr

)

const [inline]

Definition at line 1025 of file Protocol.h.

References ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::find(), and map_.

    {
      u64 sn;

      if (map_.find (addr, sn) == -1) return 0;

      return sn;
    }

void ACE_RMCast::NRTM::insert	(	Address const &	addr,
		u64	sn
	)			[inline]

Definition at line 1017 of file Protocol.h.

References ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::bind(), ACE_RMCast::Profile::calculate_size(), map_, and ACE_RMCast::Profile::size().

    {
      map_.bind (addr, sn);

      size (calculate_size ());
    }

ACE_RMCast::NRTM::map_

(

10

)

[inline]

Definition at line 987 of file Protocol.h.

References ACE_RMCast::Profile::calculate_size(), and ACE_RMCast::Profile::size().

        : Profile (id), map_ (10)
    {
      size (calculate_size ());
    }

ACE_RMCast::NRTM::map_

(

10

)

[inline]

Definition at line 959 of file Protocol.h.

References ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, HASH_KEY, COMPARE_KEYS, ACE_LOCK >::bind(), map_, and ACE_SizeCDR::total_length().

        : Profile (h), map_ (10)
    {
      u32 addr (0);
      u16 port (0);
      u64 sn (0);

      sstream ss;

      ss << sn;
      ss << addr;
      ss << port;

      size_t block_size (ss.total_length ());


      // num_of_blocks = size / block_size
      //
      for (size_t i (0); i < (h.size () / block_size); ++i)
      {
        is >> sn;
        is >> addr;
        is >> port;

        map_.bind (Address (port, addr), sn);
      }
    }

static u32 ACE_RMCast::NRTM::max_count

(

u32

max_size

)

[inline, static]

Definition at line 1045 of file Protocol.h.

References ACE_SizeCDR::total_length().

Referenced by ACE_RMCast::Acknowledge::send(), and ACE_RMCast::Acknowledge::track().

    {
      u32 n (0);

      sstream ss;

      Profile::Header hdr (0, 0);
      ss << hdr;

      while (true)
      {
        u32 addr (0);
        u16 port (0);
        u64 sn (0);

        ss << sn;
        ss << addr;
        ss << port;

        if (ss.total_length () <= max_size)
          ++n;

        if (ss.total_length () >= max_size)
          break;
      }

      return n;
    }

virtual void ACE_RMCast::NRTM::serialize_body

(

sstream &

ss

)

const [inline, virtual]

Implements ACE_RMCast::Profile.

Definition at line 1092 of file Protocol.h.

References map_.

    {
      for (Map::const_iterator i (map_), e (map_, 1); i != e; ++i)
      {
        u32 addr (0);
        u16 port (0);
        u64 sn (0);

        ss << sn;
        ss << addr;
        ss << port;
      }
    }

virtual void ACE_RMCast::NRTM::serialize_body

(

ostream &

os

)

const [inline, virtual]

Implements ACE_RMCast::Profile.

Definition at line 1076 of file Protocol.h.

References map_.

    {
      for (Map::const_iterator i (map_), e (map_, 1); i != e; ++i)
      {
        u32 addr ((*i).ext_id_.get_ip_address ());
        u16 port ((*i).ext_id_.get_port_number ());
        u64 sn ((*i).int_id_);

        os << sn;
        os << addr;
        os << port;

      }
    }

---

Member Data Documentation

ACE_RMCast::NRTM::__pad0__

Definition at line 959 of file Protocol.h.

ACE_RMCast::NRTM::__pad1__

Definition at line 987 of file Protocol.h.

ACE_RMCast::NRTM::__pad2__ [protected]

Definition at line 1009 of file Protocol.h.

u16 const ACE_RMCast::NRTM::id = 0x0006 [static]

Definition at line 955 of file Protocol.h.

Map ACE_RMCast::NRTM::map_ [private]

Definition at line 1115 of file Protocol.h.

Referenced by advance(), empty(), find(), insert(), map_(), and serialize_body().

---

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

• Protocol.h
• Protocol.cpp

---