|
a/src/DIF/EFCP/DTP/DTP.cc |
|
b/src/DIF/EFCP/DTP/DTP.cc |
|
... |
|
... |
108 |
|
108 |
|
109 |
}
|
109 |
}
|
110 |
}
|
110 |
}
|
111 |
unsigned int tmp = floor((alpha * state->getRtt()) + ((1 - alpha)* newRtt) * 1000000000);
|
111 |
unsigned int tmp = floor((alpha * state->getRtt()) + ((1 - alpha)* newRtt) * 1000000000);
|
112 |
state->setRtt((double)tmp/1000000000);
|
112 |
state->setRtt((double)tmp/1000000000);
|
|
|
113 |
EV << "Current RTT: " << state->getRtt() << endl;
|
113 |
/* End Default */
|
114 |
/* End Default */
|
114 |
}
|
115 |
}
|
115 |
|
116 |
|
116 |
}
|
117 |
}
|
117 |
|
118 |
|
|
... |
|
... |
1203 |
DataTransferPDU* dataPdu = new DataTransferPDU();
|
1204 |
DataTransferPDU* dataPdu = new DataTransferPDU();
|
1204 |
setPDUHeader(dataPdu);
|
1205 |
setPDUHeader(dataPdu);
|
1205 |
unsigned int seqNum = state->getNextSeqNumToSend();
|
1206 |
unsigned int seqNum = state->getNextSeqNumToSend();
|
1206 |
dataPdu->setSeqNum(seqNum);
|
1207 |
dataPdu->setSeqNum(seqNum);
|
1207 |
|
1208 |
|
|
|
1209 |
|
|
|
1210 |
|
1208 |
if(setDRFInPDU(false)){
|
1211 |
if(setDRFInPDU(false)){
|
1209 |
dataPdu->setFlags(dataPdu->getFlags() | DRF_FLAG);
|
1212 |
dataPdu->setFlags(dataPdu->getFlags() | DRF_FLAG);
|
1210 |
}
|
1213 |
}
|
1211 |
UserDataField* userData = new UserDataField();
|
1214 |
UserDataField* userData = new UserDataField();
|
1212 |
dataPdu->setUserDataField(userData);
|
1215 |
dataPdu->setUserDataField(userData);
|