X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=utcp.c;h=d846fb1965bd4384bef7239ae0781e08fb257d8f;hb=e572986223f5a373e2873f916d55d7cc282da074;hp=c63def15cfc7845ce324d8b2ec36f6a0455ed280;hpb=2049874f3c436cc1d85bb8bcccb272a3b933f4a9;p=utcp

diff --git a/utcp.c b/utcp.c
index c63def1..d846fb1 100644
--- a/utcp.c
+++ b/utcp.c
@@ -1000,13 +1000,26 @@ int utcp_shutdown(struct utcp_connection *c, int dir) {
 		return -1;
 	}
 
-	// TODO: handle dir
-	// TODO: check that repeated calls with the same parameters should have no effect
+	if(!(dir == UTCP_SHUT_RD || dir == UTCP_SHUT_WR || dir == UTCP_SHUT_RDWR)) {
+		errno = EINVAL;
+		return -1;
+	}
+
+	// TCP does not have a provision for stopping incoming packets.
+	// The best we can do is to just ignore them.
+	if(dir == UTCP_SHUT_RD || dir == UTCP_SHUT_RDWR)
+		c->recv = NULL;
+
+	// The rest of the code deals with shutting down writes.
+	if(dir == UTCP_SHUT_RD)
+		return 0;
 
 	switch(c->state) {
 	case CLOSED:
-		return 0;
 	case LISTEN:
+		errno = ENOTCONN;
+		return -1;
+
 	case SYN_SENT:
 		set_state(c, CLOSED);
 		return 0;