debug("%p new state: %s\n", c->utcp, strstate[state]);
}
+static bool fin_wanted(struct utcp_connection *c, uint32_t seq) {
+ if(seq != c->snd.last)
+ return false;
+ switch(c->state) {
+ case FIN_WAIT_1:
+ case CLOSING:
+ case LAST_ACK:
+ return true;
+ default:
+ return false;
+ }
+}
+
static inline void list_connections(struct utcp *utcp) {
debug("%p has %d connections:\n", utcp, utcp->nconnections);
for(int i = 0; i < utcp->nconnections; i++)
c->snd.nxt += seglen;
left -= seglen;
- if(c->state != ESTABLISHED && seglen && c->snd.nxt == c->snd.last) {
- switch(c->state) {
- case FIN_WAIT_1:
- case CLOSING:
- seglen--;
- pkt->hdr.ctl |= FIN;
- break;
- default:
- break;
- }
+ if(seglen && fin_wanted(c, c->snd.nxt)) {
+ seglen--;
+ pkt->hdr.ctl |= FIN;
}
print_packet(c->utcp, "send", pkt, sizeof pkt->hdr + seglen);
default:
// TODO: implement
+#ifdef UTCP_DEBUG
abort();
+#endif
+ break;
}
free(pkt);
case TIME_WAIT:
break;
default:
+#ifdef UTCP_DEBUG
abort();
+#endif
+ break;
}
// 1b. Drop packets with a sequence number not in our receive window.
set_state(c, CLOSED);
return 0;
default:
+#ifdef UTCP_DEBUG
abort();
+#endif
+ break;
}
}
// Ehm, no. We should never receive a second SYN.
goto reset;
default:
+#ifdef UTCP_DEBUG
abort();
+#endif
+ return 0;
}
// SYN counts as one sequence number
case SYN_SENT:
case SYN_RECEIVED:
// This should never happen.
+#ifdef UTCP_DEBUG
abort();
+#endif
+ return 0;
case ESTABLISHED:
case FIN_WAIT_1:
case FIN_WAIT_2:
// Ehm no, We should never receive more data after a FIN.
goto reset;
default:
+#ifdef UTCP_DEBUG
abort();
+#endif
+ return 0;
}
ssize_t rxd;
case SYN_SENT:
case SYN_RECEIVED:
// This should never happen.
+#ifdef UTCP_DEBUG
abort();
+#endif
+ break;
case ESTABLISHED:
set_state(c, CLOSE_WAIT);
break;
// Ehm, no. We should never receive a second FIN.
goto reset;
default:
+#ifdef UTCP_DEBUG
abort();
+#endif
+ break;
}
// FIN counts as one sequence number