#include <Protocol.h>
Inheritance diagram for ACE_RMCast::NRTM:
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 | |
u32 | max_count (u32 max_size) |
Public Attributes | |
__pad0__: Profile (h) | |
__pad1__: Profile (id) | |
Static Public Attributes | |
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_ |
|
Definition at line 1110 of file Protocol.h. |
|
Definition at line 1006 of file Protocol.h. References map_.
01007 : Profile (nrtm) 01008 { 01009 for (Map::const_iterator i (nrtm.map_); !i.done (); i.advance ()) |
|
Reimplemented from ACE_RMCast::Profile. Definition at line 990 of file Protocol.h.
00994 { |
|
Implements ACE_RMCast::Profile. Definition at line 997 of file Protocol.h. References ACE_RMCast::Profile_ptr.
00998 : 00999 virtual Profile_ptr 01000 clone_ () 01001 { Profile_ptr p (new NRTM (*this)); |
|
|
|
Definition at line 1032 of file Protocol.h.
01036 { |
|
Definition at line 1022 of file Protocol.h. Referenced by ACE_RMCast::Acknowledge::recv().
|
|
Definition at line 1014 of file Protocol.h. References ACE_RMCast::Address, ACE_RMCast::Profile::size(), and ACE_RMCast::u64.
|
|
Definition at line 984 of file Protocol.h.
|
|
Definition at line 956 of file Protocol.h. References ACE_RMCast::Address, ACE_RMCast::istream, ACE_RMCast::sstream, ACE_SizeCDR::total_length(), ACE_RMCast::u16, ACE_RMCast::u32, and ACE_RMCast::u64.
00957 : 00958 NRTM (Header const& h, istream& is) 00959 : Profile (h), map_ (10) 00960 { 00961 u32 addr (0); 00962 u16 port (0); 00963 u64 sn (0); 00964 00965 sstream ss; 00966 00967 ss << sn; 00968 ss << addr; 00969 ss << port; 00970 00971 size_t block_size (ss.total_length ()); 00972 00973 00974 // num_of_blocks = size / block_size 00975 // 00976 for (size_t i (0); i < (h.size () / block_size); ++i) 00977 { 00978 is >> sn; 00979 is >> addr; 00980 is >> port; 00981 map_.bind (Address (port, addr), sn); |
|
Definition at line 1042 of file Protocol.h. References ACE_RMCast::sstream, ACE_SizeCDR::total_length(), ACE_RMCast::u16, ACE_RMCast::u32, and ACE_RMCast::u64.
01046 { 01047 u32 n (0); 01048 01049 sstream ss; 01050 01051 Profile::Header hdr (0, 0); 01052 ss << hdr; 01053 01054 while (true) 01055 { 01056 u32 addr (0); 01057 u16 port (0); 01058 u64 sn (0); 01059 01060 ss << sn; 01061 ss << addr; 01062 ss << port; 01063 01064 if (ss.total_length () <= max_size) 01065 ++n; 01066 01067 if (ss.total_length () >= max_size) 01068 break; 01069 } |
|
Implements ACE_RMCast::Profile. Definition at line 1089 of file Protocol.h.
|
|
Implements ACE_RMCast::Profile. Definition at line 1073 of file Protocol.h. References ACE_RMCast::ostream, ACE_RMCast::u16, ACE_RMCast::u32, and ACE_RMCast::u64.
01074 : 01075 virtual void 01076 serialize_body (ostream& os) const 01077 { 01078 for (Map::const_iterator i (map_), e (map_, 1); i != e; ++i) 01079 { 01080 u32 addr ((*i).ext_id_.get_ip_address ()); 01081 u16 port ((*i).ext_id_.get_port_number ()); 01082 u64 sn ((*i).int_id_); 01083 01084 os << sn; 01085 os << addr; 01086 os << port; |
|
Definition at line 956 of file Protocol.h. |
|
Definition at line 984 of file Protocol.h. |
|
Definition at line 1006 of file Protocol.h. |
|
Definition at line 14 of file Protocol.cpp. |
|
Definition at line 1112 of file Protocol.h. Referenced by advance(). |