be_traffic.cc

802.16 Qos仿真平台的c++实现

/**************************************************************************************
* *Copyright (c) 2006 Regents of the University of Chang Gung 						*
* *All rights reserved.													*
 *																*
 * Redistribution and use in source and binary forms, with or without						*
 * modification, are permitted provided that the following conditions					*
 * are met: 															*
 * 1. Redistributions of source code must retain the above copyright						*
 *    notice, this list of conditions and the following disclaimer.						*
 * 2. Redistributions in binary form must reproduce the above copyright					*
 *    notice, this list of conditions and the following disclaimer in the						*
 *    documentation and/or other materials provided with the distribution.					*
 * 3. All advertising materials mentioning features or use of this software					*
 *    must display the following acknowledgement:									*
 *	This product includes software developed by the Computer Systems					*
 *	Engineering Group at Lawrence Berkeley Laboratory.							*
 * 4. Neither the name of the University nor of the Laboratory may be used					*
 *    to endorse or promote products derived from this software without					*
 *    specific prior written permission.										*
 *5. If you have any problem about these codes, 									*
       please mail to [e-mail] or [e-mail]                    			*
**************************************************************************************/

#include "random.h"
#include "tcp.h"
#include "BE_traffic.h"

extern double tcplib_telnet_interarrival();

static class BEAppClass : public TclClass {
 public:
	BEAppClass() : TclClass("Application/BE") {}
	TclObject* create(int, const char*const*) {
		return (new BEApp);
	}
} class_app_BE;


BEApp::BEApp() : running_(0), timer_(this)
{
	//bind("interval_", &interval_);
	interval_ = 0.01;
}


void BEAppTimer::expire(Event*)
{
    t_->timeout();
}


void BEApp::start()
{
    running_ = 1;
	double t = next();
	timer_.sched(t);
}

void BEApp::stop()
{
    running_ = 0;
}

void BEApp::timeout()
{
    if (running_) {
		//BE service using variable bit rate packet.
		size_ = (int)Random::uniform(200, 1000);
		agent_->size() = size_;
		agent_->send(agent_->size());
		//Setting packet type to BE.
		agent_->set_pkttype(PT_BE);
		/* reschedule the timer */
		double t = next();
		timer_.resched(t);
	}
}

double BEApp::next()
{
	return interval_;
}