debug("rtt %u srtt %u rttvar %u rto %u\n", rtt, utcp->srtt, utcp->rttvar, utcp->rto);
}
+static void start_retransmit_timer(struct utcp_connection *c) {
+ gettimeofday(&c->rtrx_timeout, NULL);
+ c->rtrx_timeout.tv_usec += c->utcp->rto;
+ while(c->rtrx_timeout.tv_usec >= 1000000) {
+ c->rtrx_timeout.tv_usec -= 1000000;
+ c->rtrx_timeout.tv_sec++;
+ }
+ debug("timeout set to %lu.%06lu (%u)\n", c->rtrx_timeout.tv_sec, c->rtrx_timeout.tv_usec, c->utcp->rto);
+}
+
+static void stop_retransmit_timer(struct utcp_connection *c) {
+ timerclear(&c->rtrx_timeout);
+ debug("timeout cleared\n");
+}
+
struct utcp_connection *utcp_connect(struct utcp *utcp, uint16_t dst, utcp_recv_t recv, void *priv) {
struct utcp_connection *c = allocate_connection(utcp, 0, dst);
if(!c)
c->snd.last += len;
ack(c, false);
+ if(!timerisset(&c->rtrx_timeout))
+ start_retransmit_timer(c);
return len;
}
#ifdef UTCP_DEBUG
abort();
#endif
- timerclear(&c->rtrx_timeout);
- break;
+ stop_retransmit_timer(c);
+ goto cleanup;
}
+ start_retransmit_timer(c);
utcp->rto *= 2;
if(utcp->rto > MAX_RTO)
utcp->rto = MAX_RTO;
c->rtt_start.tv_sec = 0; // invalidate RTT timer
+
+cleanup:
free(pkt);
}
// ackno should not roll back, and it should also not be bigger than what we ever could have sent
// (= snd.una + c->sndbuf.used).
- if(hdr.ctl & ACK &&
- ((seqdiff(hdr.ack, c->snd.una + c->sndbuf.used) > 0 &&
- seqdiff(hdr.ack, c->snd.nxt) > 0) // TODO: simplify this if
- || seqdiff(hdr.ack, c->snd.una) < 0)) {
+ if(hdr.ctl & ACK && (seqdiff(hdr.ack, c->snd.last) > 0 || seqdiff(hdr.ack, c->snd.una) < 0)) {
debug("Packet ack seqno out of range, %u <= %u < %u\n", c->snd.una, hdr.ack, c->snd.una + c->sndbuf.used);
// Ignore unacceptable RST packets.
if(hdr.ctl & RST)
if(advanced) {
timerclear(&c->conn_timeout); // It will be set anew in utcp_timeout() if c->snd.una != c->snd.nxt.
- if(c->snd.una == c->snd.nxt)
- timerclear(&c->rtrx_timeout);
+ if(c->snd.una == c->snd.last)
+ stop_retransmit_timer(c);
+ else
+ start_retransmit_timer(c);
}
// 5. Process SYN stuff
// - or we got an ack, so we should maybe send a bit more data
// -> sendatleastone = false
-ack:
ack(c, prevrcvnxt != c->rcv.nxt);
return 0;
if(!c)
continue;
+ // delete connections that have been utcp_close()d.
if(c->state == CLOSED) {
if(c->reapable) {
debug("Reaping %p\n", c);
}
if(timerisset(&c->rtrx_timeout) && timercmp(&c->rtrx_timeout, &now, <)) {
+ debug("retransmit()\n");
retransmit(c);
}
if(timerisset(&c->conn_timeout) && timercmp(&c->conn_timeout, &next, <))
next = c->conn_timeout;
- if(c->snd.nxt != c->snd.una) {
- c->rtrx_timeout = now;
- c->rtrx_timeout.tv_sec++;
- } else {
- timerclear(&c->rtrx_timeout);
- }
-
if(timerisset(&c->rtrx_timeout) && timercmp(&c->rtrx_timeout, &next, <))
next = c->rtrx_timeout;
}