inet::Igmpv3::RouterGroupData Struct Reference

#include <Igmpv3.h>

Public Member Functions
	RouterGroupData (RouterInterfaceData *parent, Ipv4Address group)
virtual	~RouterGroupData ()
bool	hasSourceRecord (Ipv4Address source)
SourceRecord *	createSourceRecord (Ipv4Address source)
SourceRecord *	getOrCreateSourceRecord (Ipv4Address source)
void	deleteSourceRecord (Ipv4Address source)
std::string	getStateInfo () const
void	collectForwardedSources (Ipv4MulticastSourceList &result) const

Public Attributes
RouterInterfaceData *	parent
Ipv4Address	groupAddr
FilterMode	filter
RouterGroupState	state
cMessage *	timer
SourceToSourceRecordMap	sources

Private Member Functions
void	printSourceList (std::ostream &out, bool withRunningTimer) const

Constructor & Destructor Documentation

RouterGroupData()

inet::Igmpv3::RouterGroupData::RouterGroupData	(	RouterInterfaceData *	parent,
		Ipv4Address	group
	)

    : parent(parent), groupAddr(group), filter(IGMPV3_FM_INCLUDE), state(IGMPV3_RGS_NO_MEMBERS_PRESENT)
{
    ASSERT(parent);
    ASSERT(groupAddr.isMulticast());
 
    timer = new cMessage("Igmpv3 router group timer", IGMPV3_R_GROUP_TIMER);
    timer->setContextPointer(this);
}

~RouterGroupData()

inet::Igmpv3::RouterGroupData::~RouterGroupData ( )

virtual

{
    parent->owner->cancelAndDelete(timer);
}

Member Function Documentation

collectForwardedSources()

void inet::Igmpv3::RouterGroupData::collectForwardedSources

(

Ipv4MulticastSourceList &

result

)

const

{
    switch (filter) {
        case IGMPV3_FM_INCLUDE:
            result.filterMode = MCAST_INCLUDE_SOURCES;
            result.sources.clear();
            for (const auto& elem : sources) {
                if (elem.second->sourceTimer && elem.second->sourceTimer->isScheduled())
                    result.sources.push_back(elem.first);
            }
            break;
 
        case IGMPV3_FM_EXCLUDE:
            result.filterMode = MCAST_EXCLUDE_SOURCES;
            result.sources.clear();
            for (const auto& elem : sources) {
                if (!elem.second->sourceTimer || !elem.second->sourceTimer->isScheduled())
                    result.sources.push_back(elem.first);
            }
            break;
    }
}

Referenced by inet::Igmpv3::processReport().

createSourceRecord()

Igmpv3::SourceRecord * inet::Igmpv3::RouterGroupData::createSourceRecord

(

Ipv4Address

source

)

{
    ASSERT(!containsKey(sources, source));
    SourceRecord *record = new SourceRecord(this, source);
    sources[source] = record;
    return record;
}

Referenced by inet::Igmpv3::processReport().

deleteSourceRecord()

void inet::Igmpv3::RouterGroupData::deleteSourceRecord

(

Ipv4Address

source

)

{
    auto it = sources.find(source);
    if (it != sources.end()) {
        SourceRecord *record = it->second;
        sources.erase(it);
        delete record;
    }
}

Referenced by inet::Igmpv3::processReport(), inet::Igmpv3::processRouterGroupTimer(), and inet::Igmpv3::processRouterSourceTimer().

getOrCreateSourceRecord()

Igmpv3::SourceRecord * inet::Igmpv3::RouterGroupData::getOrCreateSourceRecord

(

Ipv4Address

source

)

{
    auto it = sources.find(source);
    if (it != sources.end())
        return it->second;
    return createSourceRecord(source);
}

Referenced by inet::Igmpv3::processReport().

getStateInfo()

string inet::Igmpv3::RouterGroupData::getStateInfo

(

)

const

{
    ostringstream out;
    switch (filter) {
        case IGMPV3_FM_INCLUDE:
            out << "INCLUDE(";
            printSourceList(out, true);
            out << ")";
            break;
 
        case IGMPV3_FM_EXCLUDE:
            out << "EXCLUDE(";
            printSourceList(out, true);
            out << ";";
            printSourceList(out, false);
            out << ")";
            break;
    }
    return out.str();
}

Referenced by inet::Igmpv3::processReport(), and inet::Igmpv3::processRouterGroupTimer().

hasSourceRecord()

bool inet::Igmpv3::RouterGroupData::hasSourceRecord ( Ipv4Address  source )

inline

{ return containsKey(sources, source); }

Referenced by inet::Igmpv3::processReport().

printSourceList()

void inet::Igmpv3::RouterGroupData::printSourceList ( std::ostream &  out, bool  withRunningTimer  ) const

private

{
    bool first = true;
    for (const auto& elem : sources) {
        bool timerIsRunning = elem.second->sourceTimer && elem.second->sourceTimer->isScheduled();
        if (withRunningTimer == timerIsRunning) {
            if (!first)
                out << ",";
            first = false;
            out << elem.first;
        }
    }
}

Member Data Documentation

filter

FilterMode inet::Igmpv3::RouterGroupData::filter

Referenced by inet::Igmpv3::processReport(), inet::Igmpv3::processRouterGroupTimer(), and inet::Igmpv3::processRouterSourceTimer().

groupAddr

Ipv4Address inet::Igmpv3::RouterGroupData::groupAddr

Referenced by inet::Igmpv3::processReport(), inet::Igmpv3::processRouterGroupTimer(), inet::Igmpv3::processRouterSourceTimer(), RouterGroupData(), inet::Igmpv3::sendGroupAndSourceSpecificQuery(), and inet::Igmpv3::sendGroupSpecificQuery().

parent

RouterInterfaceData* inet::Igmpv3::RouterGroupData::parent

Referenced by inet::Igmpv3::processRouterGroupTimer(), inet::Igmpv3::processRouterSourceTimer(), RouterGroupData(), inet::Igmpv3::sendGroupAndSourceSpecificQuery(), and inet::Igmpv3::sendGroupSpecificQuery().

sources

SourceToSourceRecordMap inet::Igmpv3::RouterGroupData::sources

Referenced by inet::Igmpv3::processReport(), inet::Igmpv3::processRouterGroupTimer(), and inet::Igmpv3::processRouterSourceTimer().

state

RouterGroupState inet::Igmpv3::RouterGroupData::state

Referenced by inet::Igmpv3::processQuery().

timer

cMessage* inet::Igmpv3::RouterGroupData::timer

Referenced by inet::Igmpv3::processQuery(), inet::Igmpv3::processReport(), RouterGroupData(), and inet::Igmpv3::sendGroupSpecificQuery().

---

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

• Igmpv3.h
• Igmpv3.cc