From 730529353dbae98be0122ea0843333cf0f931525 Mon Sep 17 00:00:00 2001 From: sg Date: Wed, 18 Feb 2015 22:21:26 +0100 Subject: [PATCH] fixed bug #37958 "netconn API doesn't handle correctly connections half-closed by peer" --- CHANGELOG | 4 ++++ src/api/api_lib.c | 18 ++++++++++++++++-- 2 files changed, 20 insertions(+), 2 deletions(-) diff --git a/CHANGELOG b/CHANGELOG index a412bad7..f5317891 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -6,6 +6,10 @@ HISTORY ++ New features: + 2015-02-18: Simon Goldschmidt + * api_lib.c: fixed bug #37958 "netconn API doesn't handle correctly + connections half-closed by peer" + 2015-02-18: Simon Goldschmidt * tcp.c: tcp_alloc() prefers killing CLOSING/LAST_ACK over active connections (see bug #39565) diff --git a/src/api/api_lib.c b/src/api/api_lib.c index 03b61bd6..ce793f13 100644 --- a/src/api/api_lib.c +++ b/src/api/api_lib.c @@ -61,6 +61,8 @@ #define API_MSG_VAR_ALLOC_DONTFAIL(name) API_VAR_ALLOC_DONTFAIL(struct api_msg, MEMP_API_MSG, name) #define API_MSG_VAR_FREE(name) API_VAR_FREE(MEMP_API_MSG, name) +static err_t netconn_close_shutdown(struct netconn *conn, u8_t how); + /** * Create a new netconn (of a specific type) that has a callback function. * The corresponding pcb is also created. @@ -415,6 +417,17 @@ netconn_recv_data(struct netconn *conn, void **new_buf) LWIP_ERROR("netconn_recv: invalid pointer", (new_buf != NULL), return ERR_ARG;); *new_buf = NULL; LWIP_ERROR("netconn_recv: invalid conn", (conn != NULL), return ERR_ARG;); +#if LWIP_TCP +#if (LWIP_UDP || LWIP_RAW) + if (NETCONNTYPE_GROUP(conn->type) == NETCONN_TCP) +#endif /* (LWIP_UDP || LWIP_RAW) */ + { + if (!sys_mbox_valid(&conn->recvmbox)) { + /* This happens when calling this function after receiving FIN */ + return sys_mbox_valid(&conn->acceptmbox) ? ERR_CONN : ERR_CLSD; + } + } +#endif /* LWIP_TCP */ LWIP_ERROR("netconn_recv: invalid recvmbox", sys_mbox_valid(&conn->recvmbox), return ERR_CONN;); err = conn->last_err; @@ -459,8 +472,9 @@ netconn_recv_data(struct netconn *conn, void **new_buf) /* If we are closed, we indicate that we no longer wish to use the socket */ if (buf == NULL) { API_EVENT(conn, NETCONN_EVT_RCVMINUS, 0); - /* Avoid to lose any previous error code */ - NETCONN_SET_SAFE_ERR(conn, ERR_CLSD); + /* RX side is closed, so deallocate the recvmbox */ + netconn_close_shutdown(conn, NETCONN_SHUT_RD); + /* Don' store ERR_CLSD as conn->err since we are only half-closed */ return ERR_CLSD; } len = ((struct pbuf *)buf)->tot_len;