X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=utcp.c;h=db775a9e8a5b37cc3e15c2ff06bf8cc4236c4260;hb=2ae2f9bbb7502589f279c329815d55ec526baffd;hp=a79304ca8114b717028e9f8d5e3ede76948e6ccf;hpb=62454c16e18ba9ed03b5bc55ea59d28d666d8a48;p=utcp

diff --git a/utcp.c b/utcp.c
index a79304c..db775a9 100644
--- a/utcp.c
+++ b/utcp.c
@@ -587,12 +587,13 @@ ssize_t utcp_recv(struct utcp *utcp, const void *data, size_t len) {
 #endif
 
 	if(!acceptable) {
-		debug("Packet not acceptable, %u  <= %u + %zu < %u\n", c->rcv.nxt, hdr.seq, len, c->rcv.nxt + c->rcv.wnd);
+		debug("Packet not acceptable, %u <= %u + %zu < %u\n", c->rcv.nxt, hdr.seq, len, c->rcv.nxt + c->rcv.wnd);
 		// Ignore unacceptable RST packets.
 		if(hdr.ctl & RST)
 			return 0;
 		// Otherwise, send an ACK back in the hope things improve.
-		goto ack;
+		ack(c, true);
+		return 0;
 	}
 
 	c->snd.wnd = hdr.wnd; // TODO: move below
@@ -930,6 +931,8 @@ int utcp_shutdown(struct utcp_connection *c, int dir) {
 int utcp_close(struct utcp_connection *c) {
 	if(utcp_shutdown(c, SHUT_RDWR))
 		return -1;
+	c->recv = NULL;
+	c->poll = NULL;
 	c->reapable = true;
 	return 0;
 }
@@ -946,6 +949,8 @@ int utcp_abort(struct utcp_connection *c) {
 		return -1;
 	}
 
+	c->recv = NULL;
+	c->poll = NULL;
 	c->reapable = true;
 
 	switch(c->state) {
@@ -1057,7 +1062,7 @@ static void retransmit(struct utcp_connection *c) {
  * The return value is the time to the next timeout in milliseconds,
  * or maybe a negative value if the timeout is infinite.
  */
-int utcp_timeout(struct utcp *utcp) {
+struct timeval utcp_timeout(struct utcp *utcp) {
 	struct timeval now;
 	gettimeofday(&now, NULL);
 	struct timeval next = {now.tv_sec + 3600, now.tv_usec};
@@ -1107,9 +1112,7 @@ int utcp_timeout(struct utcp *utcp) {
 
 	struct timeval diff;
 	timersub(&next, &now, &diff);
-	if(diff.tv_sec < 0)
-		return 0;
-	return diff.tv_sec * 1000 + diff.tv_usec / 1000;
+	return diff;
 }
 
 struct utcp *utcp_init(utcp_accept_t accept, utcp_pre_accept_t pre_accept, utcp_send_t send, void *priv) {