l2dct

diff -crbB ns-allinone-2.35/ns-2.35/queue/red.cc ns-2.35/queue/red.cc
*** ns-allinone-2.35/ns-2.35/queue/red.cc	2011-10-02 18:32:34.000000000 -0400
--- ns-2.35/queue/red.cc	2014-10-01 14:37:10.684908657 -0400
***************
*** 559,566 ****
edv_.count_bytes = 0;
hdr_flags* hf = hdr_flags::access(pickPacketForECN(pkt));
if (edp_.setbit && hf->ect() &&
!                      (!edp_.use_mark_p || edv_.v_prob1 < edp_.mark_p)) {
hf->ce() = 1; 	// mark Congestion Experienced bit
// Tell the queue monitor here - call emark(pkt)
return (0);	// no drop
} else {
--- 559,567 ----
edv_.count_bytes = 0;
hdr_flags* hf = hdr_flags::access(pickPacketForECN(pkt));
if (edp_.setbit && hf->ect() &&
! 		    (!edp_.use_mark_p || edv_.v_prob1 <= edp_.mark_p)) { // For DCTCP: '<' is changed to '<=' here
hf->ce() = 1; 	// mark Congestion Experienced bit
+ 			//fprintf(stdout,"DCTCP packet marked at time= %f\n", (double)Scheduler::instance().clock());
// Tell the queue monitor here - call emark(pkt)
return (0);	// no drop
} else {
Only in ns-2.35/queue: red.cc~
diff -crbB ns-allinone-2.35/ns-2.35/tcl/lib/ns-default.tcl ns-2.35/tcl/lib/ns-default.tcl
*** ns-allinone-2.35/ns-2.35/tcl/lib/ns-default.tcl	2010-07-03 18:45:45.000000000 -0400
--- ns-2.35/tcl/lib/ns-default.tcl	2012-07-21 21:35:04.000000000 -0400
***************
*** 916,922 ****
Agent/TCP set exitFastRetrans_ true ;	# Added 2003/7/28.
# For clean exits of Fast Retransmit.
# False for old buggy behavior.
! Agent/TCP set window_ 20
Agent/TCP set windowInit_ 2 ;		# default changed on 2001/5/26.
Agent/TCP set windowInitOption_ 1
Agent/TCP set syn_ true ;		# default changed on 2001/5/17.
--- 916,922 ----
Agent/TCP set exitFastRetrans_ true ;	# Added 2003/7/28.
# For clean exits of Fast Retransmit.
# False for old buggy behavior.
! Agent/TCP set window_ 20000000
Agent/TCP set windowInit_ 2 ;		# default changed on 2001/5/26.
Agent/TCP set windowInitOption_ 1
Agent/TCP set syn_ true ;		# default changed on 2001/5/17.
***************
*** 1026,1031 ****
--- 1026,1039 ----

Agent/TCP set SetCWRonRetransmit_ true ; # added on 2005/06/19.
# default changed on 2008/06/05.
+ # DCTCP
+ Agent/TCP set dctcp_ false;
+ Agent/TCP set dctcp_alpha_ 0.0;
+ Agent/TCP set dctcp_g_ 0.0625;
+
+ # D2TCP
+ Agent/TCP set flow_deadline 100000;
+ Agent/TCP set flow_size 10000000000;

# XXX Generate nam trace or plain old text trace for variables.
# When it's true, generate nam trace.
diff -crbB ns-allinone-2.35/ns-2.35/tcp/tcp.cc ns-2.35/tcp/tcp.cc
*** ns-allinone-2.35/ns-2.35/tcp/tcp.cc	2011-06-20 00:51:46.000000000 -0400
--- ns-2.35/tcp/tcp.cc	2014-10-01 14:55:29.020865582 -0400
***************
*** 47,52 ****
--- 47,56 ----
#include "basetrace.h"
#include "hdr_qs.h"

+ #define debug_dctcp 0
+ #define wmax 2.5 	//Max weight a flow can get
+ #define wmin 0.125	//Min weight a flow can get
+
int hdr_tcp::offset_;

static class TCPHeaderClass : public PacketHeaderClass {
***************
*** 76,82 ****
first_decrease_(1), fcnt_(0), nrexmit_(0), restart_bugfix_(1),
cong_action_(0), ecn_burst_(0), ecn_backoff_(0), ect_(0),
use_rtt_(0), qs_requested_(0), qs_approved_(0),
! 	  qs_window_(0), qs_cwnd_(0), frto_(0)
{
#ifdef TCP_DELAY_BIND_ALL
// defined since Dec 1999.
--- 80,86 ----
first_decrease_(1), fcnt_(0), nrexmit_(0), restart_bugfix_(1),
cong_action_(0), ecn_burst_(0), ecn_backoff_(0), ect_(0),
use_rtt_(0), qs_requested_(0), qs_approved_(0),
! 	  qs_window_(0), qs_cwnd_(0), frto_(0), dctcp_maxseq(0)
{
#ifdef TCP_DELAY_BIND_ALL
// defined since Dec 1999.
***************
*** 101,106 ****
--- 105,113 ----
bind("necnresponses_", &necnresponses_);
bind("ncwndcuts_", &ncwndcuts_);
bind("ncwndcuts1_", &ncwndcuts1_);
+ 	bind("dctcp_", &dctcp_);
+ 	bind("dctcp_alpha_", &dctcp_alpha_);
+ 	bind("dctcp_g_", &dctcp_g_);
#endif /* TCP_DELAY_BIND_ALL */

}
***************
*** 123,128 ****
--- 130,140 ----
delay_bind_init_one("overhead_");
delay_bind_init_one("tcpTick_");
delay_bind_init_one("ecn_");
+ 	// DCTCP
+ 	delay_bind_init_one("dctcp_");
+ 	delay_bind_init_one("dctcp_alpha_");
+ 	delay_bind_init_one("dctcp_g_");
+
delay_bind_init_one("SetCWRonRetransmit_");
delay_bind_init_one("old_ecn_");
delay_bind_init_one("bugfix_ss_");
***************
*** 234,239 ****
--- 246,255 ----
if (delay_bind(varName, localName, "overhead_", &overhead_, tracer)) return TCL_OK;
if (delay_bind(varName, localName, "tcpTick_", &tcp_tick_, tracer)) return TCL_OK;
if (delay_bind_bool(varName, localName, "ecn_", &ecn_, tracer)) return TCL_OK;
+ 	// Ali munir
+         if (delay_bind_bool(varName, localName, "dctcp_", &dctcp_, tracer)) return TCL_OK;
+ 	if (delay_bind(varName, localName, "dctcp_alpha_", &dctcp_alpha_ , tracer)) return TCL_OK;
+ 	if (delay_bind(varName, localName, "dctcp_g_", &dctcp_g_ , tracer)) return TCL_OK;
if (delay_bind_bool(varName, localName, "SetCWRonRetransmit_", &SetCWRonRetransmit_, tracer)) return TCL_OK;
if (delay_bind_bool(varName, localName, "old_ecn_", &old_ecn_ , tracer)) return TCL_OK;
if (delay_bind_bool(varName, localName, "bugfix_ss_", &bugfix_ss_ , tracer)) return TCL_OK;
***************
*** 719,724 ****
--- 735,743 ----
hf->ecnecho() = 1;
//			hf->cong_action() = 1;
hf->ect() = 0;
+ 		/* ali munir */
+ 		if (dctcp_)
+ 			hf->ect() = 1;
}
if (qs_enabled_) {
hdr_qs *qsh = hdr_qs::access(p);
***************
*** 775,780 ****
--- 794,807 ----
send(p, 0);
if (seqno == curseq_ && seqno > maxseq_)
idle();  // Tell application I have sent everything so far
+
+ 	/* ali munir: begins*/
+ 	if (dctcp_)
+ 	if (seqno > dctcp_maxseq)
+ 		dctcp_maxseq = seqno;
+
+
+
if (seqno > maxseq_) {
maxseq_ = seqno;
if (!rtt_active_) {
***************
*** 1119,1124 ****
--- 1146,1175 ----
void TcpAgent::opencwnd()
{
double increment;
+ 	double weight_c;	//Ali Munir
+ 	double mywnd_old;	//Ali Munir
+ 	double mywnd_new;	//Ali Munir
+
+ 	/* Ali Munir: Begin */
+ 	mywnd_old = cwnd_;
+
+ 	if (dctcp_) {
+
+ 	if (ndatapack_ <= 200)	weight_c = wmax;
+ 	if (ndatapack_ > 200)	weight_c = wmax - (wmax-wmin) * (ndatapack_ - 200) / 800;
+
+ 	if (weight_c < wmin) weight_c = wmin;
+ 	if (weight_c > wmax) weight_c = wmax;
+
+ 	increase_num_ = weight_c / wmax;
+
+ 	if(debug_dctcp)
+ 	printf("opencwnd: increase=%f\n", increase_num_);
+
+ 	}
+ 	/* Ali Munir: End */
+
+
if (cwnd_ < ssthresh_) {
/* slow-start (exponential) */
cwnd_ += 1;
***************
*** 1127,1136 ****
double f;
switch (wnd_option_) {
case 0:
! 			if (++count_ >= cwnd_) {
! 				count_ = 0;
! 				++cwnd_;
! 			}
break;

case 1:
--- 1178,1188 ----
double f;
switch (wnd_option_) {
case 0:
! 		// Begin
! 			increment = increase_num_ / cwnd_;
! 			cwnd_ += increment;
! 	if(debug_dctcp)
! 		printf("opencwnd: increase=%f, test print # 0\n", increase_num_);
break;

case 1:
***************
*** 1143,1148 ****
--- 1195,1202 ----
max_ssthresh_, increment);
}
cwnd_ += increment;
+ 		if(debug_dctcp)
+ 		printf("opencwnd: increase=%f, test print # 1\n", increase_num_);
break;

case 2:
***************
*** 1153,1158 ****
--- 1207,1214 ----
*  with Multiple Congested Gateways".
*  The window is increased by roughly
*  wnd_const_*RTT^2 packets per round-trip time.  */
+ 	if(debug_dctcp)
+ 		printf("opencwnd: increase=%f, test print # 2\n", increase_num_);
f = (t_srtt_ >> T_SRTT_BITS) * tcp_tick_;
f *= f;
f *= wnd_const_;
***************
*** 1178,1183 ****
--- 1234,1241 ----
++cwnd_;
} else
fcnt_ = f;
+ 	if(debug_dctcp)
+ 		printf("opencwnd: increase=%f, test print # 3\n", increase_num_);
break;

case 4:
***************
*** 1192,1197 ****
--- 1250,1257 ----
++cwnd_;
} else
fcnt_ = f;
+ 	if(debug_dctcp)
+ 		printf("opencwnd: increase=%f, test print # 4\n", increase_num_);
break;
case 5:
/* The window is increased by roughly wnd_const_*RTT
***************
*** 1206,1215 ****
--- 1266,1279 ----
++cwnd_;
} else
fcnt_ = f;
+ 	if(debug_dctcp)
+ 		printf("opencwnd: increase=%f, test print # 5\n", increase_num_);
break;
case 6:
/* binomial controls */
cwnd_ += increase_num_ / (cwnd_*pow(cwnd_,k_parameter_));
+ 	if(debug_dctcp)
+ 		printf("opencwnd: increase=%f, test print # 6\n", increase_num_);
break;
case 8:
/* high-speed TCP, RFC 3649 */
***************
*** 1221,1232 ****
--- 1285,1300 ----
max_ssthresh_, increment);
}
cwnd_ += increment;
+ 	if(debug_dctcp)
+ 		printf("opencwnd: increase=%f, test print # 8\n", increase_num_);
break;
default:
#ifdef notdef
/*XXX*/
error("illegal window option %d", wnd_option_);
#endif
+ 	if(debug_dctcp)
+ 		printf("opencwnd: increase=%f, test print # default\n", increase_num_);
abort();
}
}
***************
*** 1234,1239 ****
--- 1302,1311 ----
if (maxcwnd_ && (int(cwnd_) > maxcwnd_))
cwnd_ = maxcwnd_;

+ 	if(debug_dctcp){
+ 		mywnd_new = cwnd_;
+ 		printf("opencwnd: increase=%f, cwnd: old %f new %f\n", increase_num_, (double)windowd(), mywnd_new);
+ 		}
return;
}

***************
*** 1243,1248 ****
--- 1315,1322 ----
double decrease;  /* added for highspeed - sylvia */
double win, halfwin, decreasewin;
int slowstart = 0;
+ 	double b_;
+ 	double weight_c;
++ncwndcuts_;
if (!(how & TCP_IDLE) && !(how & NO_OUTSTANDING_DATA)){
++ncwndcuts1_;
***************
*** 1297,1302 ****
--- 1371,1381 ----
} else {
ssthresh_ = (int) decreasewin;
}
+ 	else if (how & CLOSE_SSTHRESH_DCTCP) {
+ 		ssthresh_ = (int) ((1 - dctcp_alpha_/2.0) * windowd());
+ 	if(debug_dctcp)
+ 		fprintf(stdout,"DCTCP backoff (ssthresh) applied (alpha=%f) at time= %f\n", (double)dctcp_alpha_, (double)Scheduler::instance().clock());
+ 	}
else if (how & THREE_QUARTER_SSTHRESH)
if (ssthresh_ < 3*cwnd_/4)
ssthresh_  = (int)(3*cwnd_/4);
***************
*** 1306,1311 ****
--- 1385,1407 ----
if (first_decrease_ == 1 || slowstart || decrease_num_ == 0.5) {
cwnd_ = halfwin;
} else cwnd_ = decreasewin;
+ 	else if (how & CLOSE_CWND_DCTCP){
+
+ 		/* Ali Munir: Begin */
+ 		if (ndatapack_ <= 200)	weight_c = wmax;
+ 		if (ndatapack_ > 200)	weight_c = wmax - (wmax-wmin) * (ndatapack_ - 200) / 800;
+
+
+ 		if (weight_c < wmin) weight_c = wmin;
+ 		if (weight_c > wmax) weight_c = wmax;
+
+ 		b_ = pow(dctcp_alpha_,weight_c);
+ 		cwnd_ = (1 - b_/2.0) * windowd();
+
+ 		if(debug_dctcp)
+ 			fprintf(stdout,"DCTCP backoff (cwnd down) applied (alpha=%f) at time= %f, weight=%f b=%f, cwnd %f, fid %d\n", (double)dctcp_alpha_, (double)Scheduler::instance().clock(), weight_c, b_, (double)windowd(), fid_);
+ 		/* Ali Munir: End */
+ 	}
else if (how & CWND_HALF_WITH_MIN) {
// We have not thought about how non-standard TCPs, with
// non-standard values of decrease_num_, should respond
***************
*** 1328,1334 ****
}
if (ssthresh_ < 2)
ssthresh_ = 2;
! 	if (how & (CLOSE_CWND_HALF|CLOSE_CWND_RESTART|CLOSE_CWND_INIT|CLOSE_CWND_ONE))
cong_action_ = TRUE;

fcnt_ = count_ = 0;
--- 1424,1432 ----
}
if (ssthresh_ < 2)
ssthresh_ = 2;
! 	if (cwnd_ < 1)
! 		cwnd_ = 1;
! 	if (how & (CLOSE_CWND_HALF|CLOSE_CWND_RESTART|CLOSE_CWND_INIT|CLOSE_CWND_ONE|CLOSE_CWND_DCTCP))
cong_action_ = TRUE;

fcnt_ = count_ = 0;
***************
*** 1429,1434 ****
--- 1527,1535 ----
rtt_backoff();
else ecn_backoff_ = 1;
} else ecn_backoff_ = 0;
+ 		if (dctcp_)
+ 			slowdown(CLOSE_CWND_DCTCP|CLOSE_SSTHRESH_DCTCP);
+ 		else
slowdown(CLOSE_CWND_HALF|CLOSE_SSTHRESH_HALF);
++necnresponses_ ;
// added by sylvia to count number of ecn responses
Only in ns-2.35/tcp: tcp.cc~
diff -crbB ns-allinone-2.35/ns-2.35/tcp/tcp.h ns-2.35/tcp/tcp.h
*** ns-allinone-2.35/ns-2.35/tcp/tcp.h	2011-08-26 15:29:57.000000000 -0400
--- ns-2.35/tcp/tcp.h	2012-07-11 06:07:18.000000000 -0400
***************
*** 104,110 ****
#define CWND_HALF_WITH_MIN	0x00000200
#define TCP_IDLE		0x00000400
#define NO_OUTSTANDING_DATA     0x00000800
!
/*
* tcp_tick_:
* default 0.1,
--- 104,111 ----
#define CWND_HALF_WITH_MIN	0x00000200
#define TCP_IDLE		0x00000400
#define NO_OUTSTANDING_DATA     0x00000800
! #define CLOSE_SSTHRESH_DCTCP   0x00001000
! #define CLOSE_CWND_DCTCP       0x00002000
/*
* tcp_tick_:
* default 0.1,
***************
*** 432,437 ****
--- 433,445 ----

/* Used for ECN */
int ecn_;		/* Explicit Congestion Notification */
+
+ 	/* Use for DCTCP */
+ 	int dctcp_;
+ 	double dctcp_alpha_;
+ 	double dctcp_g_;
+ 	int dctcp_maxseq;
+
int cong_action_;	/* Congestion Action.  True to indicate
that the sender responded to congestion. */
int ecn_burst_;		/* True when the previous ACK packet
diff -crbB ns-allinone-2.35/ns-2.35/tcp/tcp-sack1.cc ns-2.35/tcp/tcp-sack1.cc
*** ns-allinone-2.35/ns-2.35/tcp/tcp-sack1.cc	2006-12-24 12:04:44.000000000 -0500
--- ns-2.35/tcp/tcp-sack1.cc	2014-10-01 15:10:19.248830658 -0400
***************
*** 38,43 ****
--- 38,45 ----
#define RECOVER_TIMEOUT 2
#define RECOVER_QUENCH  3

+ #define debug_dctcp 0
+
class Sack1TcpAgent : public TcpAgent {
public:
Sack1TcpAgent();
***************
*** 53,58 ****
--- 55,67 ----
protected:
u_char timeout_;	/* boolean: sent pkt from timeout? */
u_char fastrecov_;	/* boolean: doing fast recovery? */
+ 	/* variables for DCTCP */
+ 	int dctcp_total;
+ 	int dctcp_marked;
+ 	int dctcp_alpha_update_seq;
+ //	int dctcp_maxseq;
+ 	int ce_transition;
+
int pipe_;		/* estimate of pipe size (fast recovery) */
int partial_ack_;	/* Set to "true" to ensure sending */
/*  a packet on a partial ACK.     */
***************
*** 61,66 ****
--- 70,76 ----
int firstpartial_;	/* First of a series of partial acks. */
ScoreBoard* scb_;
static const int SBSIZE=64; /* Initial scoreboard size */
+ 	void update_dctcp_alpha(Packet *); /* DCTCP alpha update */
};

static class Sack1TcpClass : public TclClass {
***************
*** 71,77 ****
}
} class_sack;

! Sack1TcpAgent::Sack1TcpAgent() : fastrecov_(FALSE), pipe_(-1), next_pkt_(0), firstpartial_(0)
{
bind_bool("partial_ack_", &partial_ack_);
/* Use the Reassembly Queue based scoreboard as
--- 81,88 ----
}
} class_sack;

! Sack1TcpAgent::Sack1TcpAgent() : fastrecov_(FALSE), pipe_(-1), next_pkt_(0), firstpartial_(0),
! 	        dctcp_total(0), dctcp_marked(0), dctcp_alpha_update_seq(0), ce_transition(0)
{
bind_bool("partial_ack_", &partial_ack_);
/* Use the Reassembly Queue based scoreboard as
***************
*** 116,121 ****
--- 127,139 ----
return;
}
++nackpack_;
+
+ 	/* ali munir */
+ 	if (dctcp_)
+ 		update_dctcp_alpha(pkt);
+
+
+
int ecnecho = hdr_flags::access(pkt)->ecnecho();
if (ecnecho && ecn_)
ecn(tcph->seqno());
***************
*** 284,289 ****
--- 304,315 ----

if (ecn_ && last_cwnd_action_ == CWND_ACTION_ECN) {
last_cwnd_action_ = CWND_ACTION_DUPACK;
+
+ 		/* ali  munir: cut window by half when we have 3 dup ack */
+ 		if (dctcp_)
+ 			slowdown(CLOSE_SSTHRESH_HALF|CLOSE_CWND_HALF);
+
+
/*
* What if there is a DUPACK action followed closely by ECN
* followed closely by a DUPACK action?
***************
*** 400,405 ****
--- 426,438 ----
* If DSACK and detection of premature retransmit
*  timeouts, then save some info here.
*/
+ 		/* begin: ali munir */
+ 		//dctcp_alpha_update_seq = tno; /* should be t_seqno_ */
+ 		dctcp_alpha_update_seq = t_seqno_;
+ 		dctcp_maxseq = dctcp_alpha_update_seq;
+
+ 		/* end: ali munir */
+
dupacks_ = 0;
fastrecov_ = FALSE;
timeout_ = TRUE;
***************
*** 419,424 ****
--- 453,507 ----
frto_ = 0;
}

+
+ /*
+  * Update dctcp alpha based on the ecn bit in the received packet.
+  * This procedure is called only when dctcp_ is 1.
+  */
+ void Sack1TcpAgent::update_dctcp_alpha(Packet *pkt)
+ {
+ 	int ecnbit = hdr_flags::access(pkt)->ecnecho();
+ 	int ackno = hdr_tcp::access(pkt)->ackno();
+ 	int seqno = hdr_tcp::access(pkt)->seqno();
+ 	int acked_bytes = seqno - highest_ack_;
+
+ 	if(debug_dctcp)
+ 		printf ("timeout. highest_ack: %i seqno: %i fid: %i seqnum: %i\n",
+ 			(int)highest_ack_, (int)t_seqno_, fid_, seqno);
+
+ 	if (acked_bytes <= 0)
+ //		acked_bytes = size_;	/* it should be one */
+ 		acked_bytes = 1;	/* it should be one */
+ 	dctcp_total += acked_bytes;
+ 	if (ecnbit) {
+ 		dctcp_marked += acked_bytes;
+ 	}
+
+ 	if(debug_dctcp)
+ 		fprintf(stdout,"DCTCP update_alpha 1: (ackno=%i), (dctcp_alpha_update=%f), (dctcp_maxseq=%f), (acked_bytes=%d)\n", (int)ackno, (double)dctcp_alpha_update_seq, (double)dctcp_maxseq, acked_bytes);
+ 	/* Check for barrier indicating its time to recalculate alpha.
+ 	 * This code basically updated alpha roughly once per RTT.
+ 	 */
+ 	if (seqno > dctcp_alpha_update_seq) {
+ 		double temp_alpha;
+ 		dctcp_alpha_update_seq = dctcp_maxseq;
+ 		if (dctcp_total > 0)
+ 			temp_alpha = ((double) dctcp_marked) / dctcp_total;
+ 		else
+ 			temp_alpha = 0.0;
+
+ //		temp_alpha = ((double) dctcp_marked) / 35.0;
+ 		dctcp_alpha_ = (1 - dctcp_g_) * dctcp_alpha_ + dctcp_g_ * temp_alpha;
+ 		dctcp_marked = 0;
+ 		dctcp_total = 0;
+ 	}
+
+ 	if(debug_dctcp)
+ 		fprintf(stdout,"DCTCP update_alpha: (dctcpseq=%d), (marked=%d), (total=%d), (alpha=%f) at time= %f\n", dctcp_maxseq, dctcp_marked, dctcp_total, (double)dctcp_alpha_, (double)Scheduler::instance().clock());
+ }
+
+
+
void Sack1TcpAgent::send_much(int force, int reason, int maxburst)
{
register int found, npacket = 0;
Only in ns-2.35/tcp: tcp-sack1.cc~