LogFilter Class Reference

#include <log.hh>

Inheritance diagram for LogFilter:

[legend]Collaboration diagram for LogFilter:

[legend]List of all members.

Public Member Functions
	LogFilter (int argc, char **argv)
void	run ()
void	recv (Message *msg, handle h)
Protected Member Functions
handle	setupFilter ()
void	ProcessMessage (Message *msg)
void	usage (char *s)
void	parseCommandLine (int argc, char **argv)
Protected Attributes
handle	filter_handle_
LogFilterReceive *	filter_callback_
NR *	dr_
u_int16_t	diffusion_port_
char *	config_file_

---

Constructor & Destructor Documentation

LogFilter::LogFilter (  int  argc, char **  argv )

Definition at line 120 of file log.cc. References NR::createNR(), DEBUG_ALWAYS, and DiffPrint(). { // Create Diffusion Routing class #ifndef NS_DIFFUSION parseCommandLine(argc, argv); dr_ = NR::createNR(diffusion_port_); #endif // !NS_DIFFUSION filter_callback_ = new LogFilterReceive(this); #ifndef NS_DIFFUSION // Set up the filter filter_handle_ = setupFilter(); DiffPrint(DEBUG_ALWAYS, "Log filter subscribed to *, received handle %d\n", filter_handle_); DiffPrint(DEBUG_ALWAYS, "Log filter initialized !\n"); #endif // !NS_DIFFUSION }

Here is the call graph for this function:

---

Member Function Documentation

void DiffApp::parseCommandLine (  int  argc, char **  argv )  [protected, inherited]

Definition at line 59 of file diffapp.cc. References DiffApp::config_file_, DEBUG_ALWAYS, DEFAULT_DIFFUSION_PORT, DiffPrint(), DiffApp::diffusion_port_, global_debug_level, optarg, u_int16_t, and DiffApp::usage(). Referenced by GeoRoutingFilter::GeoRoutingFilter(), GradientFilter::GradientFilter(), PingSenderApp::PingSenderApp(), PushSenderApp::PushSenderApp(), and SrcRtFilter::SrcRtFilter(). { u_int16_t diff_port = DEFAULT_DIFFUSION_PORT; int debug_level; int opt; config_file_ = NULL; opterr = 0; while (1){ opt = getopt(argc, argv, "f:hd:p:"); switch (opt){ case 'p': diff_port = (u_int16_t) atoi(optarg); if ((diff_port < 1024) || (diff_port >= 65535)){ DiffPrint(DEBUG_ALWAYS, "Error: Diffusion port must be between 1024 and 65535 !\n"); exit(-1); } break; case 'h': usage(argv[0]); break; case 'd': debug_level = atoi(optarg); if (debug_level < 1 || debug_level > 10){ DiffPrint(DEBUG_ALWAYS, "Error: Debug level outside range or missing !\n"); usage(argv[0]); } global_debug_level = debug_level; break; case 'f': if (!strncasecmp(optarg, "-", 1)){ DiffPrint(DEBUG_ALWAYS, "Error: Parameter missing !\n"); usage(argv[0]); } config_file_ = strdup(optarg); break; case '?': DiffPrint(DEBUG_ALWAYS, "Error: %c isn't a valid option or its parameter is missing !\n", optopt); usage(argv[0]); break; case ':': DiffPrint(DEBUG_ALWAYS, "Parameter missing !\n"); usage(argv[0]); break; } if (opt == -1) break; } diffusion_port_ = diff_port; }

Here is the call graph for this function:

void LogFilter::ProcessMessage (  Message *  msg  )  [protected]

Definition at line 68 of file log.cc. References CalculateSize(), DEBUG_ALWAYS, DiffPrint(), Message::last_hop_, LOCALHOST_ADDR, Message::msg_attr_vec_, Message::msg_type_, msg_types, Message::new_message_, and Message::source_port_. Referenced by recv(). { DiffPrint(DEBUG_ALWAYS, "Received a"); if (msg->new_message_) DiffPrint(DEBUG_ALWAYS, " new "); else DiffPrint(DEBUG_ALWAYS, "n old "); if (msg->last_hop_ != LOCALHOST_ADDR) DiffPrint(DEBUG_ALWAYS, "%s message from node %d, %d bytes\n", msg_types[msg->msg_type_], msg->last_hop_, CalculateSize(msg->msg_attr_vec_)); else DiffPrint(DEBUG_ALWAYS, "%s message from agent %d, %d bytes\n", msg_types[msg->msg_type_], msg->source_port_, CalculateSize(msg->msg_attr_vec_)); }

Here is the call graph for this function:

void LogFilter::recv (  Message *  msg, handle  h )

Definition at line 55 of file log.cc. References DEBUG_ALWAYS, DiffPrint(), DiffApp::dr_, filter_handle_, and ProcessMessage(). Referenced by LogFilterReceive::recv(). { if (h != filter_handle_){ DiffPrint(DEBUG_ALWAYS, "Error: recv received message for handle %d when subscribing to handle %d !\n", h, filter_handle_); return; } ProcessMessage(msg); ((DiffusionRouting *)dr_)->sendMessage(msg, h); }

Here is the call graph for this function:

void LogFilter::run (   )  [virtual]

Implements DiffApp. Definition at line 102 of file log.cc. References DEBUG_ALWAYS, DiffPrint(), filter_handle_, and setupFilter(). Referenced by main(). { #ifdef NS_DIFFUSION filter_handle_ = setupFilter(); DiffPrint(DEBUG_ALWAYS, "Log filter subscribed to *, received handle %d\n", filter_handle_); DiffPrint(DEBUG_ALWAYS, "Log filter initialized !\n"); #else // Doesn't do anything while (1){ sleep(1000); } #endif // NS_DIFFUSION }

Here is the call graph for this function:

handle LogFilter::setupFilter (   )  [protected]

Definition at line 87 of file log.cc. References ClearAttrs(), DiffApp::dr_, filter_callback_, handle, NRAttribute::INTEREST_CLASS, NRAttribute::IS, LOG_FILTER_PRIORITY, and NRClassAttr. Referenced by run(). { NRAttrVec attrs; handle h; // This is a dummy attribute for filtering that matches everything attrs.push_back(NRClassAttr.make(NRAttribute::IS, NRAttribute::INTEREST_CLASS)); h = ((DiffusionRouting *)dr_)->addFilter(&attrs, LOG_FILTER_PRIORITY, filter_callback_); ClearAttrs(&attrs); return h; }

Here is the call graph for this function:

void DiffApp::usage (  char *  s  )  [protected, inherited]

Definition at line 49 of file diffapp.cc. References DEBUG_ALWAYS, and DiffPrint(). Referenced by DiffApp::parseCommandLine(). { DiffPrint(DEBUG_ALWAYS, "Usage: %s [-d debug] [-p port] [-f file] [-h]\n\n", s); DiffPrint(DEBUG_ALWAYS, "\t-d - Sets debug level (0-10)\n"); DiffPrint(DEBUG_ALWAYS, "\t-p - Uses port 'port' to talk to diffusion\n"); DiffPrint(DEBUG_ALWAYS, "\t-f - Specifies a config file\n"); DiffPrint(DEBUG_ALWAYS, "\t-h - Prints this information\n"); DiffPrint(DEBUG_ALWAYS, "\n"); exit(0); }

Here is the call graph for this function:

---

Member Data Documentation

char* DiffApp::config_file_ [protected, inherited]

Definition at line 57 of file diffapp.hh. Referenced by DiffApp::parseCommandLine().

u_int16_t DiffApp::diffusion_port_ [protected, inherited]

Definition at line 56 of file diffapp.hh. Referenced by GeoRoutingFilter::GeoRoutingFilter(), GradientFilter::GradientFilter(), DiffApp::parseCommandLine(), PingSenderApp::PingSenderApp(), PushSenderApp::PushSenderApp(), and SrcRtFilter::SrcRtFilter().

NR* DiffApp::dr_ [protected, inherited]

Definition at line 55 of file diffapp.hh. Referenced by GeoRoutingFilter::beaconTimeout(), GeoRoutingFilter::broadcastHeuristicValue(), GradientFilter::forwardData(), GradientFilter::forwardExploratoryData(), GradientFilter::forwardPushExploratoryData(), GeoRoutingFilter::GeoRoutingFilter(), GeoRoutingFilter::getNodeLocation(), GradientFilter::GradientFilter(), GradientFilter::interestTimeout(), GradientFilter::messageTimeout(), GeoRoutingFilter::messageTimeout(), PingSenderApp::PingSenderApp(), GeoRoutingFilter::postProcessFilter(), GeoRoutingFilter::preProcessFilter(), SrcRtFilter::ProcessMessage(), GradientFilter::processNewMessage(), PushSenderApp::PushSenderApp(), TagFilter::recv(), SrcRtFilter::recv(), recv(), GradientFilter::reinforcementTimeout(), PushSenderApp::run(), PingSenderApp::run(), GeoRoutingFilter::run(), GradientFilter::sendInterest(), GeoRoutingFilter::sendNeighborRequest(), GradientFilter::sendPositiveReinforcement(), TagFilter::setupFilter(), SrcRtFilter::setupFilter(), setupFilter(), GradientFilter::setupFilter(), GeoRoutingFilter::setupPostFilter(), GeoRoutingFilter::setupPreFilter(), PushSenderApp::setupPublication(), PingSenderApp::setupPublication(), PushReceiverApp::setupSubscription(), PingSenderApp::setupSubscription(), PingReceiverApp::setupSubscription(), and SrcRtFilter::SrcRtFilter().

LogFilterReceive* LogFilter::filter_callback_ [protected]

Definition at line 61 of file log.hh. Referenced by setupFilter().

handle LogFilter::filter_handle_ [protected]

Definition at line 58 of file log.hh. Referenced by recv(), and run().

---

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

• log.hh
• log.cc

---