diff options
author | Damien George <damien.p.george@gmail.com> | 2014-07-27 22:38:58 +0100 |
---|---|---|
committer | Damien George <damien.p.george@gmail.com> | 2014-07-27 22:38:58 +0100 |
commit | adf0f2ae1a3debf8465ece7e065ddba2d4032e8c (patch) | |
tree | 090c7544536b130b47e30f8834d7450272dfb54a /unix/modsocket.c | |
parent | 05c255f039b5c0fbdcb0754748fd5d36135acfd9 (diff) |
py: Change stream protocol API: fns return uint; is_text for text.
Diffstat (limited to 'unix/modsocket.c')
-rw-r--r-- | unix/modsocket.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/unix/modsocket.c b/unix/modsocket.c index 160a1dcc0..a3380fb89 100644 --- a/unix/modsocket.c +++ b/unix/modsocket.c @@ -91,20 +91,22 @@ STATIC void socket_print(void (*print)(void *env, const char *fmt, ...), void *e print(env, "<_socket %d>", self->fd); } -STATIC mp_int_t socket_read(mp_obj_t o_in, void *buf, mp_uint_t size, int *errcode) { +STATIC mp_uint_t socket_read(mp_obj_t o_in, void *buf, mp_uint_t size, int *errcode) { mp_obj_socket_t *o = o_in; mp_int_t r = read(o->fd, buf, size); if (r == -1) { *errcode = errno; + return MP_STREAM_ERROR; } return r; } -STATIC mp_int_t socket_write(mp_obj_t o_in, const void *buf, mp_uint_t size, int *errcode) { +STATIC mp_uint_t socket_write(mp_obj_t o_in, const void *buf, mp_uint_t size, int *errcode) { mp_obj_socket_t *o = o_in; mp_int_t r = write(o->fd, buf, size); if (r == -1) { *errcode = errno; + return MP_STREAM_ERROR; } return r; } |