summaryrefslogtreecommitdiffstatshomepage
diff options
context:
space:
mode:
authorPaul Sokolovsky <pfalcon@users.sourceforge.net>2016-04-08 20:07:11 +0300
committerPaul Sokolovsky <pfalcon@users.sourceforge.net>2016-04-08 20:26:54 +0300
commit7e9182f3aa16f0a7d80edd1362a383fe68f1509c (patch)
tree55dac6f3db002685c094a09741d6a6d1c1f5b0a0
parentb32b0d38fe2fa061aab30b9cd7b7189999d196a2 (diff)
downloadmicropython-7e9182f3aa16f0a7d80edd1362a383fe68f1509c.tar.gz
micropython-7e9182f3aa16f0a7d80edd1362a383fe68f1509c.zip
extmod/modwebsocket: Make sure to propagate EOF.
-rw-r--r--extmod/modwebsocket.c2
1 files changed, 1 insertions, 1 deletions
diff --git a/extmod/modwebsocket.c b/extmod/modwebsocket.c
index 00ec5ee980..9f4e5ee7e8 100644
--- a/extmod/modwebsocket.c
+++ b/extmod/modwebsocket.c
@@ -68,7 +68,7 @@ STATIC mp_uint_t websocket_read(mp_obj_t self_in, void *buf, mp_uint_t size, int
while (1) {
if (self->to_recv != 0) {
mp_uint_t out_sz = stream_p->read(self->sock, self->buf + self->buf_pos, self->to_recv, errcode);
- if (out_sz == MP_STREAM_ERROR) {
+ if (out_sz == 0 || out_sz == MP_STREAM_ERROR) {
return out_sz;
}
self->buf_pos += out_sz;