summaryrefslogtreecommitdiffstatshomepage
diff options
context:
space:
mode:
authorPaul Sokolovsky <pfalcon@users.sourceforge.net>2016-05-20 21:18:25 +0300
committerPaul Sokolovsky <pfalcon@users.sourceforge.net>2016-05-20 21:18:49 +0300
commitccf4e5ab7baf54b35b1cc4918a38932d21c65424 (patch)
treef11daec106808e3fa665c43277f7617ba1719984
parent497660fcda77ae819f5ea1f6a92b8fb5006d8213 (diff)
downloadmicropython-ccf4e5ab7baf54b35b1cc4918a38932d21c65424.tar.gz
micropython-ccf4e5ab7baf54b35b1cc4918a38932d21c65424.zip
extmod/modwebsocket: Add close() method.
-rw-r--r--extmod/modwebsocket.c9
1 files changed, 9 insertions, 0 deletions
diff --git a/extmod/modwebsocket.c b/extmod/modwebsocket.c
index 949a5fed91..fc5e29a05e 100644
--- a/extmod/modwebsocket.c
+++ b/extmod/modwebsocket.c
@@ -272,10 +272,19 @@ STATIC mp_uint_t websocket_ioctl(mp_obj_t self_in, mp_uint_t request, uintptr_t
}
}
+STATIC mp_obj_t websocket_close(mp_obj_t self_in) {
+ mp_obj_websocket_t *self = MP_OBJ_TO_PTR(self_in);
+ // TODO: Send close signaling to the other side, otherwise it's
+ // abrupt close (connection abort).
+ return mp_stream_close(self->sock);
+}
+STATIC MP_DEFINE_CONST_FUN_OBJ_1(websocket_close_obj, websocket_close);
+
STATIC const mp_map_elem_t websocket_locals_dict_table[] = {
{ MP_OBJ_NEW_QSTR(MP_QSTR_read), (mp_obj_t)&mp_stream_read_obj },
{ MP_OBJ_NEW_QSTR(MP_QSTR_write), (mp_obj_t)&mp_stream_write_obj },
{ MP_OBJ_NEW_QSTR(MP_QSTR_ioctl), (mp_obj_t)&mp_stream_ioctl_obj },
+ { MP_OBJ_NEW_QSTR(MP_QSTR_close), (mp_obj_t)&websocket_close_obj },
};
STATIC MP_DEFINE_CONST_DICT(websocket_locals_dict, websocket_locals_dict_table);