Lines Matching refs:stream_p
52 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()
91 || ((flags & MP_STREAM_OP_READ) && stream_p->read == NULL) in mp_get_stream_raise()
92 || ((flags & MP_STREAM_OP_WRITE) && stream_p->write == NULL) in mp_get_stream_raise()
93 || ((flags & MP_STREAM_OP_IOCTL) && stream_p->ioctl == NULL)) { in mp_get_stream_raise()
97 return stream_p; in mp_get_stream_raise()
109 const mp_stream_p_t *stream_p = mp_get_stream(args[0]); in stream_read_generic() local
112 if (stream_p->is_text) { in stream_read_generic()
214 return mp_obj_new_str_from_vstr(STREAM_CONTENT_TYPE(stream_p), &vstr); in stream_read_generic()
304 const mp_stream_p_t *stream_p = mp_get_stream(self_in); in stream_readall() local
313 mp_uint_t out_sz = stream_p->read(self_in, p, current_read, &error); in stream_readall()
340 return mp_obj_new_str_from_vstr(STREAM_CONTENT_TYPE(stream_p), &vstr); in stream_readall()
345 const mp_stream_p_t *stream_p = mp_get_stream(args[0]); in stream_unbuffered_readline() local
362 mp_uint_t out_sz = stream_p->read(args[0], p, 1, &error); in stream_unbuffered_readline()
393 return mp_obj_new_str_from_vstr(STREAM_CONTENT_TYPE(stream_p), &vstr); in stream_unbuffered_readline()
420 const mp_stream_p_t *stream_p = mp_get_stream(stream); in mp_stream_close() local
422 mp_uint_t res = stream_p->ioctl(stream, MP_STREAM_CLOSE, 0, &error); in mp_stream_close()
444 const mp_stream_p_t *stream_p = mp_get_stream(args[0]); in stream_seek() local
446 mp_uint_t res = stream_p->ioctl(args[0], MP_STREAM_SEEK, (mp_uint_t)(uintptr_t)&seek_s, &error); in stream_seek()
465 const mp_stream_p_t *stream_p = mp_get_stream(self); in stream_flush() local
467 mp_uint_t res = stream_p->ioctl(self, MP_STREAM_FLUSH, 0, &error); in stream_flush()
486 const mp_stream_p_t *stream_p = mp_get_stream(args[0]); in stream_ioctl() local
488 mp_uint_t res = stream_p->ioctl(args[0], mp_obj_get_int(args[1]), val, &error); in stream_ioctl()
510 const mp_stream_p_t *stream_p = o->type->protocol; in mp_stream_posix_write() local
511 mp_uint_t out_sz = stream_p->write(MP_OBJ_FROM_PTR(stream), buf, len, &errno); in mp_stream_posix_write()
521 const mp_stream_p_t *stream_p = o->type->protocol; in mp_stream_posix_read() local
522 mp_uint_t out_sz = stream_p->read(MP_OBJ_FROM_PTR(stream), buf, len, &errno); in mp_stream_posix_read()
532 const mp_stream_p_t *stream_p = o->type->protocol; in mp_stream_posix_lseek() local
536 …mp_uint_t res = stream_p->ioctl(MP_OBJ_FROM_PTR(stream), MP_STREAM_SEEK, (mp_uint_t)(uintptr_t)&se… in mp_stream_posix_lseek()
545 const mp_stream_p_t *stream_p = o->type->protocol; in mp_stream_posix_fsync() local
546 mp_uint_t res = stream_p->ioctl(MP_OBJ_FROM_PTR(stream), MP_STREAM_FLUSH, 0, &errno); in mp_stream_posix_fsync()