SrmNode Class Reference

#include <srm-topo.h>

Inheritance diagram for SrmNode:

[legend]Collaboration diagram for SrmNode:

[legend]List of all members.

Public Member Functions
	SrmNode ()
void	id (int i)
void	handle (Event *)
void	send (SRM_Event *)
void	append (SRM_Event *)
void	remove (int, int)
Protected Member Functions
void	sched_nack (int)
void	dump_packet (SRM_Event *e)
Protected Attributes
int	id_
int	expected_
SRM_Request *	pending_

---

Constructor & Destructor Documentation

SrmNode::SrmNode (   )  [inline]

Definition at line 88 of file srm-topo.h. References expected_, id_, and pending_. : id_(0), expected_(0), pending_(0) {}

---

Member Function Documentation

void SrmNode::append (  SRM_Event *   )

Definition at line 411 of file srm-topo.cc. References pending_, and req. Referenced by sched_nack(). { SRM_Request *req = new SRM_Request(e); req->next_ = pending_; pending_ = req; }

void SrmNode::dump_packet (  SRM_Event *  e  )  [protected]

Definition at line 306 of file srm-topo.cc. References id_, SRM_Event::iif(), tprintf, and SRM_Event::type(). { #ifdef SRM_DEBUG tprintf(("(type %d) (in %d) -- @ %d --> \n", e->type(), e->iif(), id_)); #endif }

Here is the call graph for this function:

void SrmNode::handle (  Event *   )  [virtual]

Implements Handler. Definition at line 353 of file srm-topo.cc. References expected_, id_, remove(), sched_nack(), send(), SRM_Event::seqno(), SRM_DATA, SRM_NO_SUPPRESS, SRM_PENDING_RREQ, SRM_RREQ, SRM_SUPPRESS, tprintf, and SRM_Event::type(). { SRM_Event *srm_event = (SRM_Event *) event; int type = srm_event->type(); int seqno = srm_event->seqno(); //int iif = srm_event->iif(); //Scheduler& s = Scheduler::instance(); switch (type) { case SRM_DATA : if (seqno != expected_) sched_nack(seqno); expected_ = seqno; break; case SRM_PENDING_RREQ : tprintf(("Fired RREQ (node %d)\n", id_)); remove(seqno, SRM_NO_SUPPRESS); srm_event->type(SRM_RREQ); break; case SRM_RREQ : remove(seqno, SRM_SUPPRESS); break; default : tprintf(("panic: node(%d) Unexpected type %d\n", id_, type)); return; } #ifdef SRM_STAR if (type == SRM_RREQ || type == SRM_DATA) { delete srm_event; return; } #endif send(srm_event); return; }

Here is the call graph for this function:

void SrmNode::id (  int  i  )  [inline]

Definition at line 89 of file srm-topo.h. References id_. Referenced by Topology::Topology(). { id_ = i; }

void SrmNode::remove (  int  , int  )

Definition at line 419 of file srm-topo.cc. References SRM_Request::cancel_timer(), SRM_Request::event_, SRM_Request::next_, pending_, SRM_Event::seqno(), and SRM_SUPPRESS. Referenced by handle(). { SRM_Request *curr, *prev; SRM_Event *ev; if (!pending_) return; for (curr=pending_, prev=0; curr; curr=curr->next_) { ev = curr->event_; if (ev->seqno() == seqno) { if (!prev) pending_ = curr->next_; else { prev->next_ = curr->next_; prev = curr; } if (flag == SRM_SUPPRESS) { curr->cancel_timer(); } delete curr; } } }

Here is the call graph for this function:

void SrmNode::sched_nack (  int   )  [protected]

Definition at line 397 of file srm-topo.cc. References append(), Topology::backoff(), Scheduler::clock(), id_, Scheduler::instance(), Scheduler::schedule(), SRM_NOIF, SRM_PENDING_RREQ, and topology. Referenced by handle(). { double backoff, time; Scheduler& s = Scheduler::instance(); SRM_Event *event = new SRM_Event(seqno, SRM_PENDING_RREQ, SRM_NOIF); append(event); backoff = topology->backoff(id_); time = backoff + s.clock(); // tprintf(("node(%d) schd rrq after %f s\n", id_, backoff)); s.schedule(this, event, backoff); }

Here is the call graph for this function:

void SrmNode::send (  SRM_Event *   )

Definition at line 316 of file srm-topo.cc. References Topology::delay(), Interface_List::head_, id_, SRM_Event::iif(), Interface::in_, Scheduler::instance(), Interface::next_, Topology::node(), Topology::oif(), Scheduler::schedule(), SRM_Event::seqno(), topology, and SRM_Event::type(). Referenced by Star::flood(), BTree::flood(), Line::flood(), and handle(). { /* * Copy the packet and send it over to * all the outbound interfaces */ int nn; Scheduler& s = Scheduler::instance(); SRM_Event *copy; Interface *p; Interface_List *ilist = topology->oif(id_, e->iif()); if (e->iif() < 0) e->iif(id_); if (ilist) { for (p=ilist->head_; p; p=p->next_) { nn = p->in_; int t = e->type(); //int i = id_; int snum = e->seqno(); SrmNode *next = topology->node(nn); if (next) { copy = new SRM_Event(snum, t, id_); s.schedule(next, copy, topology->delay(id_, nn)); } } } delete ilist; delete e; }

Here is the call graph for this function:

---

Member Data Documentation

int SrmNode::expected_ [protected]

Definition at line 102 of file srm-topo.h. Referenced by handle(), and SrmNode().

int SrmNode::id_ [protected]

Definition at line 101 of file srm-topo.h. Referenced by dump_packet(), handle(), id(), sched_nack(), send(), and SrmNode().

SRM_Request* SrmNode::pending_ [protected]

Definition at line 103 of file srm-topo.h. Referenced by append(), remove(), and SrmNode().

---

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

• srm-topo.h
• srm-topo.cc

---