#include <PubSubSubspace.h>

Inheritance diagram for PubSubSubspaceResponsible:

Classes
class	IntermediateNode
Public Member Functions
	PubSubSubspaceResponsible (PubSubSubspaceId id)
void	setBackupNode (NodeHandle b)
const NodeHandle &	getBackupNode ()
void	setHeartbeatTimer (PubSubTimer *t)
PubSubTimer *	getHeartbeatTimer ()
int	getHeartbeatFailCount ()
void	incHeartbeatFailCount ()
void	resetHeartbeatFailCount ()
int	getTotalChildrenCount ()
void	fixTotalChildrenCount ()
int	getNumIntermediates ()
IntermediateNode *	getNextFreeIntermediate ()
virtual bool	addChild (NodeHandle node)
virtual IntermediateNode *	removeAnyChild (NodeHandle node)
Public Attributes
std::deque< IntermediateNode >	intermediateNodes
std::map< NodeHandle, bool >	cachedChildren
std::deque< PubSubMoveMessage * >	waitingMoveMessages
Static Public Attributes
static unsigned int	maxChildren
Protected Attributes
int	totalChildrenCount
NodeHandle	backupNode
PubSubTimer *	heartbeatTimer
int	heartbeatFailCount
Friends
std::ostream &	operator<< (std::ostream &o, const PubSubSubspaceResponsible &subspace)

Detailed Description

Definition at line 81 of file PubSubSubspace.h.

Constructor & Destructor Documentation

PubSubSubspaceResponsible::PubSubSubspaceResponsible ( PubSubSubspaceId id )

Definition at line 63 of file PubSubSubspace.cc.

    : PubSubSubspaceIntermediate( id )
{
    backupNode = NodeHandle::UNSPECIFIED_NODE;
    heartbeatTimer = NULL;
    heartbeatFailCount = 0;
    totalChildrenCount = 0;
}

Member Function Documentation

bool PubSubSubspaceResponsible::addChild ( NodeHandle node ) [virtual]

Reimplemented from PubSubSubspaceIntermediate.

Definition at line 72 of file PubSubSubspace.cc.

Referenced by PubSubMMOG::handleSubscriptionBackup().

{
    if( getNumChildren() + getNumIntermediates() < (int) maxChildren ) {
        // we still have room in our children list, add to our own
        if( PubSubSubspaceIntermediate::addChild( child ) ){
            ++totalChildrenCount;
        }
        return true;
    } else {
        // Child has to go to an intermediate
        if( cachedChildren.insert( make_pair(child, false) ).second ){
            ++totalChildrenCount;
        }
        return false;
    }
}

void PubSubSubspaceResponsible::fixTotalChildrenCount ( )

Definition at line 118 of file PubSubSubspace.cc.

Referenced by PubSubMMOG::handleAdoptChildResponse(), PubSubMMOG::handleHelpResponse(), PubSubMMOG::handleIntermediateResponse(), PubSubMMOG::handlePingCallTimeout(), PubSubMMOG::handleSubscriptionCall(), PubSubMMOG::takeOverSubspace(), and PubSubMMOG::unsubscribeChild().

{
    totalChildrenCount = children.size() + cachedChildren.size();
    std::deque<IntermediateNode>::iterator it;
    for( it = intermediateNodes.begin(); it != intermediateNodes.end(); ++it ){
        totalChildrenCount += it->children.size();
    }
}

const NodeHandle& PubSubSubspaceResponsible::getBackupNode ( ) [inline]

Definition at line 101 of file PubSubSubspace.h.

Referenced by PubSubMMOG::handleIntermediateResponse(), PubSubMMOG::handlePingCallTimeout(), PubSubMMOG::sendMessageToChildren(), and PubSubMMOG::unsubscribeChild().

{ return backupNode; }

int PubSubSubspaceResponsible::getHeartbeatFailCount ( ) [inline]

Definition at line 106 of file PubSubSubspace.h.

{ return heartbeatFailCount; }

PubSubTimer* PubSubSubspaceResponsible::getHeartbeatTimer ( ) [inline]

Definition at line 104 of file PubSubSubspace.h.

{ return heartbeatTimer; }

PubSubSubspaceResponsible::IntermediateNode * PubSubSubspaceResponsible::getNextFreeIntermediate ( )

Definition at line 106 of file PubSubSubspace.cc.

Referenced by PubSubMMOG::unsubscribeChild().

{
    std::deque<IntermediateNode>::iterator it;
    for( it = intermediateNodes.begin(); it != intermediateNodes.end(); ++it ){
        if( it->node.isUnspecified() ) continue;
        int childIntermediates = intermediateNodes.size() - (it - intermediateNodes.begin() +1 )* maxChildren;
        if( childIntermediates < 0 ) childIntermediates = 0;
        if( it->children.size() + it->waitingChildren + childIntermediates < maxChildren ) return &*it;
    }
    return NULL;
}

int PubSubSubspaceResponsible::getNumIntermediates ( ) [inline]

Definition at line 113 of file PubSubSubspace.h.

Referenced by addChild(), PubSubMMOG::handleUnsubscribeBackup(), and PubSubMMOG::unsubscribeChild().

{ return intermediateNodes.size(); }

int PubSubSubspaceResponsible::getTotalChildrenCount ( ) [inline]

Definition at line 110 of file PubSubSubspace.h.

Referenced by PubSubMMOG::handleAdoptChildResponse(), PubSubMMOG::handleHelpResponse(), PubSubMMOG::handlePingCallTimeout(), PubSubMMOG::handleSubscriptionCall(), and PubSubMMOG::unsubscribeChild().

{ return totalChildrenCount; }

void PubSubSubspaceResponsible::incHeartbeatFailCount ( ) [inline]

Definition at line 107 of file PubSubSubspace.h.

{ ++heartbeatFailCount; }

PubSubSubspaceResponsible::IntermediateNode * PubSubSubspaceResponsible::removeAnyChild ( NodeHandle node ) [virtual]

Definition at line 89 of file PubSubSubspace.cc.

Referenced by PubSubMMOG::unsubscribeChild().

{
    if( removeChild( child ) || cachedChildren.erase( child )){
        --totalChildrenCount;
        return NULL;
    } else {
        std::deque<IntermediateNode>::iterator it;
        for( it = intermediateNodes.begin(); it != intermediateNodes.end(); ++it ){
            if( it->children.erase( child ) ) {
                --totalChildrenCount;
                return &*it;
            }
        }
        return NULL;
    }
}

void PubSubSubspaceResponsible::resetHeartbeatFailCount ( ) [inline]

Definition at line 108 of file PubSubSubspace.h.

{ heartbeatFailCount = 0; }

void PubSubSubspaceResponsible::setBackupNode ( NodeHandle b ) [inline]

Definition at line 100 of file PubSubSubspace.h.

Referenced by PubSubMMOG::handleHelpResponse(), and PubSubMMOG::handlePingCallTimeout().

{ backupNode = b; }

void PubSubSubspaceResponsible::setHeartbeatTimer ( PubSubTimer * t ) [inline]

Definition at line 103 of file PubSubSubspace.h.

Referenced by PubSubMMOG::handleBackupCall().

{ heartbeatTimer = t; }

Friends And Related Function Documentation

std::ostream& operator<<	(	std::ostream &	o,
		const PubSubSubspaceResponsible &	subspace
	)			`[friend]`

Definition at line 127 of file PubSubSubspace.cc.

{
    o << dynamic_cast<const PubSubSubspaceIntermediate&>(subspace) << "  BackupNode: " << subspace.backupNode;
    o << "\n  cachedChildren:\n";
    map<NodeHandle, bool>::const_iterator iit;
    for( iit = subspace.cachedChildren.begin(); iit != subspace.cachedChildren.end(); ++iit ){
        o << "    " << iit->first << " waiting: " << iit->second << "\n";
    }
    o << "  totalChildrenCount: " << subspace.totalChildrenCount;
    o << "\n  IntermediateNodes:\n";
    std::deque<PubSubSubspaceResponsible::IntermediateNode>::const_iterator it;
    for( it = subspace.intermediateNodes.begin(); it != subspace.intermediateNodes.end(); ++it ){
        o << "    " << it->node;
            o << "\n    Children:\n";
        for( set<NodeHandle>::iterator iit = it->children.begin(); iit != it->children.end(); ++iit ){
            o << "      " << *iit << "\n";
        }
    }
    return o;
}