riot-ci/RIOT
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

lwip_sock: re-issue receive events if there are still received messages

Browse Source 
... after `*_recv()` or `*_accept()` was called.

This prevents a client from needing to call `*_recv()` or `*_accept()`
in a loop.
This commit is contained in:
Martine S. Lenders 2020-05-12 14:17:32 +02:00
parent fcd36f7b77
commit ef1d458089
No known key found for this signature in database
GPG Key ID: CCD317364F63286F
2 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/lwip/contrib/sock/lwip_sock.c
View File

@ -548,6 +548,13 @@ int lwip_sock_recv(struct netconn *conn, uint32_t timeout, struct netbuf **buf)
/* unset flags */ /* unset flags */
#if LWIP_SO_RCVTIMEO #if LWIP_SO_RCVTIMEO
netconn_set_recvtimeout(conn, 0); netconn_set_recvtimeout(conn, 0);
#endif
#if IS_ACTIVE(SOCK_HAS_ASYNC)
lwip_sock_base_t *sock = netconn_get_callback_arg(conn);
if (sock && sock->async_cb.gen && cib_avail(&conn->recvmbox.mbox.cib)) {
sock->async_cb.gen(sock, SOCK_ASYNC_MSG_RECV, sock->async_cb_arg);
}
#endif #endif
return res; return res;
} }

7
pkg/lwip/contrib/sock/tcp/lwip_sock_tcp.c
View File

@ -254,6 +254,13 @@ int sock_tcp_accept(sock_tcp_queue_t *queue, sock_tcp_t **sock,
} }
#if LWIP_SO_RCVTIMEO #if LWIP_SO_RCVTIMEO
netconn_set_recvtimeout(queue->base.conn, 0); netconn_set_recvtimeout(queue->base.conn, 0);
#endif
#if IS_ACTIVE(SOCK_HAS_ASYNC)
if (queue->base.async_cb.gen &&
cib_avail(&queue->base.conn->acceptmbox.mbox.cib)) {
queue->base.async_cb.gen(&queue->base, SOCK_ASYNC_CONN_RECV,
queue->base.async_cb_arg);
}
#endif #endif
mutex_unlock(&queue->mutex); mutex_unlock(&queue->mutex);
return res; return res;