Home
last modified time | relevance | path

Searched refs:stream_p (Results 1 – 7 of 7) sorted by relevance

/AliOS-Things-master/components/py_engine/engine/py/
A Dstream.c52 const mp_stream_p_t *stream_p = mp_get_stream(stream); in mp_stream_rw() local
54 io_func = (io_func_t)stream_p->write; in mp_stream_rw()
56 io_func = stream_p->read; in mp_stream_rw()
89 const mp_stream_p_t *stream_p = type->protocol; in mp_get_stream_raise() local
90 if (stream_p == NULL in mp_get_stream_raise()
97 return stream_p; in mp_get_stream_raise()
112 if (stream_p->is_text) { in stream_read_generic()
510 const mp_stream_p_t *stream_p = o->type->protocol; in mp_stream_posix_write() local
521 const mp_stream_p_t *stream_p = o->type->protocol; in mp_stream_posix_read() local
532 const mp_stream_p_t *stream_p = o->type->protocol; in mp_stream_posix_lseek() local
[all …]
/AliOS-Things-master/components/py_engine/engine/extmod/
A Duos_dupterm.c67 const mp_stream_p_t *stream_p = mp_get_stream(s); in mp_uos_dupterm_poll() local
70 ret = stream_p->ioctl(s, MP_STREAM_POLL, poll_flags, &errcode); in mp_uos_dupterm_poll()
76 ret = stream_p->ioctl(s, MP_STREAM_POLL, poll_flags, &errcode); in mp_uos_dupterm_poll()
105 const mp_stream_p_t *stream_p = mp_get_stream(MP_STATE_VM(dupterm_objs[idx])); in mp_uos_dupterm_rx_chr() local
106 mp_uint_t out_sz = stream_p->read(MP_STATE_VM(dupterm_objs[idx]), buf, 1, &errcode); in mp_uos_dupterm_rx_chr()
119 const mp_stream_p_t *stream_p = mp_get_stream(MP_STATE_VM(dupterm_objs[idx])); in mp_uos_dupterm_rx_chr() local
120 mp_uint_t out_sz = stream_p->read(MP_STATE_VM(dupterm_objs[idx]), buf, 1, &errcode); in mp_uos_dupterm_rx_chr()
159 const mp_stream_p_t *stream_p = mp_get_stream(MP_STATE_VM(dupterm_objs[idx])); in mp_uos_dupterm_tx_strn() local
160 stream_p->write(MP_STATE_VM(dupterm_objs[idx]), str, len, &errcode); in mp_uos_dupterm_tx_strn()
A Dmoduwebsocket.c79 const mp_stream_p_t *stream_p = mp_get_stream(self->sock); in websocket_read() local
82 … mp_uint_t out_sz = stream_p->read(self->sock, self->buf + self->buf_pos, self->to_recv, errcode); in websocket_read()
173 out_sz = stream_p->read(self->sock, buf, sz, errcode); in websocket_read()
A Dmodujson.c149 const mp_stream_p_t *stream_p = mp_get_stream_raise(stream_obj, MP_STREAM_OP_READ); in mod_ujson_load() local
150 ujson_stream_t s = {stream_obj, stream_p->read, 0, 0}; in mod_ujson_load()
A Dmoduselect.c55 const mp_stream_p_t *stream_p = mp_get_stream_raise(obj[i], MP_STREAM_OP_IOCTL); in poll_map_add() local
58 poll_obj->ioctl = stream_p->ioctl; in poll_map_add()
A Dmodwebrepl.c302 const mp_stream_p_t *stream_p = mp_get_stream(self->sock); in webrepl_write() local
303 return stream_p->write(self->sock, buf, size, errcode); in webrepl_write()
A Dmodlwip.c120 type->stream_p->write(MP_STATE_VM(lwip_slip_stream), &c, 1, &error); in sio_send()
126 mp_uint_t out_sz = type->stream_p->read(MP_STATE_VM(lwip_slip_stream), data, len, &error); in sio_tryread()

Completed in 12 milliseconds