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

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);
}

inet::IGMPv3::RouterGroupData::~RouterGroupData ( )

virtual

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

Member Function Documentation

void inet::IGMPv3::RouterGroupData::collectForwardedSources

(

IPv4MulticastSourceList &

result

)

const

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

{
    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;
    }
}

IGMPv3::SourceRecord * inet::IGMPv3::RouterGroupData::createSourceRecord

(

IPv4Address

source

)

Referenced by getOrCreateSourceRecord(), and inet::IGMPv3::processReport().

{
    ASSERT(sources.find(source) == sources.end());
    SourceRecord *record = new SourceRecord(this, source);
    sources[source] = record;
    return record;
}

void inet::IGMPv3::RouterGroupData::deleteSourceRecord

(

IPv4Address

source

)

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

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

IGMPv3::SourceRecord * inet::IGMPv3::RouterGroupData::getOrCreateSourceRecord

(

IPv4Address

source

)

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

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

string inet::IGMPv3::RouterGroupData::getStateInfo

(

)

const

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

{
    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();
}

bool inet::IGMPv3::RouterGroupData::hasSourceRecord ( IPv4Address  source )

inline

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

{ return sources.find(source) != sources.end(); }

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

private

Referenced by getStateInfo().

{
    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

FilterMode inet::IGMPv3::RouterGroupData::filter

Referenced by collectForwardedSources(), getStateInfo(), inet::IGMPv3::processReport(), inet::IGMPv3::processRouterGroupTimer(), and inet::IGMPv3::processRouterSourceTimer().

IPv4Address inet::IGMPv3::RouterGroupData::groupAddr

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

RouterInterfaceData* inet::IGMPv3::RouterGroupData::parent

Referenced by inet::IGMPv3::processRouterGroupTimer(), inet::IGMPv3::processRouterSourceTimer(), inet::IGMPv3::sendGroupAndSourceSpecificQuery(), inet::IGMPv3::sendGroupSpecificQuery(), ~RouterGroupData(), and inet::IGMPv3::SourceRecord::~SourceRecord().

SourceToSourceRecordMap inet::IGMPv3::RouterGroupData::sources

Referenced by collectForwardedSources(), createSourceRecord(), deleteSourceRecord(), getOrCreateSourceRecord(), printSourceList(), inet::IGMPv3::processReport(), inet::IGMPv3::processRouterGroupTimer(), and inet::IGMPv3::processRouterSourceTimer().

RouterGroupState inet::IGMPv3::RouterGroupData::state

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

cMessage* inet::IGMPv3::RouterGroupData::timer

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

---

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

• IGMPv3.h
• IGMPv3.cc