timestampaccum.cc

COPE the first practical network coding scheme which is developped on click

// -*- c-basic-offset: 4 -*-
/*
 * timestampaccum.{cc,hh} -- accumulate cycle counter deltas
 * Eddie Kohler
 *
 * Copyright (c) 2002 International Computer Science Institute
 *
 * 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 <click/config.h>
#include "timestampaccum.hh"
#include <click/glue.hh>
CLICK_DECLS

TimestampAccum::TimestampAccum()
    : Element(1, 1)
{
}

TimestampAccum::~TimestampAccum()
{
}

int
TimestampAccum::initialize(ErrorHandler *)
{
    _usec_accum = 0;
    _count = 0;
    return 0;
}

inline Packet *
TimestampAccum::simple_action(Packet *p)
{
    _usec_accum += (Timestamp::now() - p->timestamp_anno()).to_double();
    _count++;
    return p;
}

String
TimestampAccum::read_handler(Element *e, void *thunk)
{
    TimestampAccum *ta = static_cast<TimestampAccum *>(e);
    int which = reinterpret_cast<int>(thunk);
    switch (which) {
      case 0:
	return String(ta->_count) + "\n";
      case 1:
	return String(ta->_usec_accum) + "\n";
      case 2:
	return String(ta->_usec_accum / ta->_count) + "\n";
      default:
	return String();
    }
}

int
TimestampAccum::reset_handler(const String &, Element *e, void *, ErrorHandler *)
{
    TimestampAccum *ta = static_cast<TimestampAccum *>(e);
    ta->_usec_accum = 0;
    ta->_count = 0;
    return 0;
}

void
TimestampAccum::add_handlers()
{
    add_read_handler("count", read_handler, (void *)0);
    add_read_handler("time", read_handler, (void *)1);
    add_read_handler("average_time", read_handler, (void *)2);
    add_write_handler("reset_counts", reset_handler, (void *)0);
}

CLICK_ENDDECLS
ELEMENT_REQUIRES(userlevel)
EXPORT_ELEMENT(TimestampAccum)