/**************************************************************************************
* *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 antibanish@gmail.com or b9229008@stmail.cgu.edu.tw                    			*
**************************************************************************************/#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_=1;}void BEAppTimer::expire(Event*){    t_->timeout();}void BEApp::start(){    running_ = 1;	double t = next();	timer_.sched(t);	//Setting packet type to BE.	agent_->set_pkttype(PT_BE);}void BEApp::stop(){    running_ = 0;}void BEApp::timeout(){    if (running_) {		//BE service using variable bit rate packet.		size_ = (int)Random::uniform(512, 1024);		agent_->size()=size_;		agent_->send(agent_->size());		/* reschedule the timer */		double t = next();		timer_.resched(t);		printf("---------- BE traffic t : %f\t",t);  		printf("size : %d ----------\n",size_); 	}}double BEApp::next(){	if (interval_ == 0)	    /* use tcplib */	    return tcplib_telnet_interarrival();	else	    return Random::exponential() * interval_;}