/* * ethercount.{cc,hh} -- sets wifi txrate annotation on a packet * John Bicket * * Copyright (c) 2003 Massachusetts Institute of Technology * * Permission is hereby granted, free of charge, to any person obtaining a * copy of this software and associated documentation files (the "Software"), * to deal in the Software without restriction, subject to the conditions * listed in the Click LICENSE file. These conditions include: you must * preserve this copyright notice, and you cannot mention the copyright * holders in advertising related to the Software without their permission. * The Software is provided WITHOUT ANY WARRANTY, EXPRESS OR IMPLIED. This * notice is a summary of the Click LICENSE file; the license in that file is * legally binding. */ #include #include #include #include #include #include #include #include #include "ethercount.hh" CLICK_DECLS EtherCount::EtherCount() { } EtherCount::~EtherCount() { } int EtherCount::configure(Vector &conf, ErrorHandler *errh) { if (cp_va_parse(conf, this, errh, cpKeywords, cpEnd) < 0) { return -1; } return 0; } Packet * EtherCount::simple_action(Packet *p_in) { click_ether *eh = (click_ether *) p_in->data(); EtherAddress src = EtherAddress(eh->ether_shost); DstInfo *nfo = _neighbors.findp(src); if (!nfo) { DstInfo foo = DstInfo(src); _neighbors.insert(src, foo); nfo = _neighbors.findp(src); } nfo->count++; return p_in; } enum {H_STATS, H_RESET}; static String EtherCount_read_param(Element *e, void *thunk) { EtherCount *td = (EtherCount *)e; switch ((uintptr_t) thunk) { case H_STATS: { struct timeval now; click_gettimeofday(&now); StringAccum sa; for (EtherCount::NIter iter = td->_neighbors.begin(); iter; iter++) { EtherCount::DstInfo n = iter.value(); sa << n._eth.s().c_str() << " " << n.count << "\n"; } return sa.take_string(); } default: return String(); } } static int EtherCount_write_param(const String &in_s, Element *e, void *vparam, ErrorHandler *) { EtherCount *f = (EtherCount *)e; String s = cp_uncomment(in_s); switch((intptr_t)vparam) { case H_RESET: f->_neighbors.clear(); return 0; } return 0; } void EtherCount::add_handlers() { add_read_handler("stats", EtherCount_read_param, (void *) H_STATS); add_write_handler("reset", EtherCount_write_param, (void *) H_RESET); } // generate Vector template instance #include #if EXPLICIT_TEMPLATE_INSTANCES template class HashMap; #endif CLICK_ENDDECLS EXPORT_ELEMENT(EtherCount)