diff --git a/py/obj.h b/py/obj.h index e800addade..fc99055b6e 100644 --- a/py/obj.h +++ b/py/obj.h @@ -229,7 +229,7 @@ struct _mp_obj_type_t { // in mp_obj_type_t at the expense of extra pointer and extra dereference // when actually used. mp_buffer_p_t buffer_p; - mp_stream_p_t stream_p; + const mp_stream_p_t *stream_p; // these are for dynamically created types (classes) mp_obj_t bases_tuple; diff --git a/py/qstrdefs.h b/py/qstrdefs.h index 2271941a05..85f69861b2 100644 --- a/py/qstrdefs.h +++ b/py/qstrdefs.h @@ -111,6 +111,7 @@ Q(max) Q(min) Q(namedtuple) Q(next) +Q(open) Q(ord) Q(path) Q(pow) diff --git a/py/stream.c b/py/stream.c index 56f475a0c8..52e5f6d4b2 100644 --- a/py/stream.c +++ b/py/stream.c @@ -14,7 +14,7 @@ STATIC mp_obj_t stream_readall(mp_obj_t self_in); STATIC mp_obj_t stream_read(uint n_args, const mp_obj_t *args) { struct _mp_obj_base_t *o = (struct _mp_obj_base_t *)args[0]; - if (o->type->stream_p.read == NULL) { + if (o->type->stream_p == NULL || o->type->stream_p->read == NULL) { // CPython: io.UnsupportedOperation, OSError subclass nlr_raise(mp_obj_new_exception_msg(&mp_type_OSError, "Operation not supported")); } @@ -25,7 +25,7 @@ STATIC mp_obj_t stream_read(uint n_args, const mp_obj_t *args) { } byte *buf = m_new(byte, sz); int error; - machine_int_t out_sz = o->type->stream_p.read(o, buf, sz, &error); + machine_int_t out_sz = o->type->stream_p->read(o, buf, sz, &error); if (out_sz == -1) { nlr_raise(mp_obj_new_exception_msg_varg(&mp_type_OSError, "[Errno %d]", error)); } else { @@ -37,7 +37,7 @@ STATIC mp_obj_t stream_read(uint n_args, const mp_obj_t *args) { STATIC mp_obj_t stream_write(mp_obj_t self_in, mp_obj_t arg) { struct _mp_obj_base_t *o = (struct _mp_obj_base_t *)self_in; - if (o->type->stream_p.write == NULL) { + if (o->type->stream_p == NULL || o->type->stream_p->write == NULL) { // CPython: io.UnsupportedOperation, OSError subclass nlr_raise(mp_obj_new_exception_msg(&mp_type_OSError, "Operation not supported")); } @@ -45,7 +45,7 @@ STATIC mp_obj_t stream_write(mp_obj_t self_in, mp_obj_t arg) { uint sz; const char *buf = mp_obj_str_get_data(arg, &sz); int error; - machine_int_t out_sz = o->type->stream_p.write(self_in, buf, sz, &error); + machine_int_t out_sz = o->type->stream_p->write(self_in, buf, sz, &error); if (out_sz == -1) { nlr_raise(mp_obj_new_exception_msg_varg(&mp_type_OSError, "[Errno %d]", error)); } else { @@ -60,7 +60,7 @@ STATIC mp_obj_t stream_write(mp_obj_t self_in, mp_obj_t arg) { #define READ_SIZE 256 STATIC mp_obj_t stream_readall(mp_obj_t self_in) { struct _mp_obj_base_t *o = (struct _mp_obj_base_t *)self_in; - if (o->type->stream_p.read == NULL) { + if (o->type->stream_p == NULL || o->type->stream_p->read == NULL) { // CPython: io.UnsupportedOperation, OSError subclass nlr_raise(mp_obj_new_exception_msg(&mp_type_OSError, "Operation not supported")); } @@ -72,7 +72,7 @@ STATIC mp_obj_t stream_readall(mp_obj_t self_in) { int error; int current_read = READ_SIZE; while (true) { - machine_int_t out_sz = o->type->stream_p.read(self_in, p, current_read, &error); + machine_int_t out_sz = o->type->stream_p->read(self_in, p, current_read, &error); if (out_sz == -1) { nlr_raise(mp_obj_new_exception_msg_varg(&mp_type_OSError, "[Errno %d]", error)); } @@ -101,7 +101,7 @@ STATIC mp_obj_t stream_readall(mp_obj_t self_in) { // Unbuffered, inefficient implementation of readline() for raw I/O files. STATIC mp_obj_t stream_unbuffered_readline(uint n_args, const mp_obj_t *args) { struct _mp_obj_base_t *o = (struct _mp_obj_base_t *)args[0]; - if (o->type->stream_p.read == NULL) { + if (o->type->stream_p == NULL || o->type->stream_p->read == NULL) { // CPython: io.UnsupportedOperation, OSError subclass nlr_raise(mp_obj_new_exception_msg(&mp_type_OSError, "Operation not supported")); } @@ -126,7 +126,7 @@ STATIC mp_obj_t stream_unbuffered_readline(uint n_args, const mp_obj_t *args) { nlr_raise(mp_obj_new_exception_msg_varg(&mp_type_OSError/*&mp_type_RuntimeError*/, "Out of memory")); } - machine_int_t out_sz = o->type->stream_p.read(o, p, 1, &error); + machine_int_t out_sz = o->type->stream_p->read(o, p, 1, &error); if (out_sz == -1) { nlr_raise(mp_obj_new_exception_msg_varg(&mp_type_OSError, "[Errno %d]", error)); } diff --git a/stm/qstrdefsport.h b/stm/qstrdefsport.h index ea2681f18e..5fba03eb9f 100644 --- a/stm/qstrdefsport.h +++ b/stm/qstrdefsport.h @@ -36,7 +36,6 @@ Q(Usart) Q(ADC) Q(ADC_all) Q(Audio) -Q(open) Q(File) // Entries for sys.path Q(0:/) diff --git a/stmhal/file.c b/stmhal/file.c index a78c58d4f9..6d743a0c8c 100644 --- a/stmhal/file.c +++ b/stmhal/file.c @@ -61,17 +61,20 @@ STATIC const mp_map_elem_t file_locals_dict_table[] = { STATIC MP_DEFINE_CONST_DICT(file_locals_dict, file_locals_dict_table); STATIC mp_obj_t file_obj_make_new(mp_obj_t type_in, uint n_args, uint n_kw, const mp_obj_t *args); -static const mp_obj_type_t file_obj_type = { + +STATIC const mp_stream_p_t file_obj_stream_p = { + .read = file_read, + .write = file_write, +}; + +STATIC const mp_obj_type_t file_obj_type = { { &mp_type_type }, .name = MP_QSTR_File, .make_new = file_obj_make_new, .print = file_obj_print, .getiter = mp_identity, .iternext = mp_stream_unbuffered_iter, - .stream_p = { - .read = file_read, - .write = file_write, - }, + .stream_p = &file_obj_stream_p, .locals_dict = (mp_obj_t)&file_locals_dict, }; diff --git a/stmhal/qstrdefsport.h b/stmhal/qstrdefsport.h index 3212de85b3..c846adc198 100644 --- a/stmhal/qstrdefsport.h +++ b/stmhal/qstrdefsport.h @@ -33,7 +33,6 @@ Q(SDcard) Q(gpio) Q(gpio_in) Q(gpio_out) -Q(open) Q(File) // Entries for sys.path Q(0:/) diff --git a/unix/file.c b/unix/file.c index 780e84718d..2cc17dfd34 100644 --- a/unix/file.c +++ b/unix/file.c @@ -123,6 +123,11 @@ STATIC const mp_map_elem_t rawfile_locals_dict_table[] = { STATIC MP_DEFINE_CONST_DICT(rawfile_locals_dict, rawfile_locals_dict_table); +STATIC const mp_stream_p_t rawfile_stream_p = { + .read = fdfile_read, + .write = fdfile_write, +}; + STATIC const mp_obj_type_t rawfile_type = { { &mp_type_type }, .name = MP_QSTR_io_dot_FileIO, @@ -130,10 +135,7 @@ STATIC const mp_obj_type_t rawfile_type = { .make_new = fdfile_make_new, .getiter = mp_identity, .iternext = mp_stream_unbuffered_iter, - .stream_p = { - .read = fdfile_read, - .write = fdfile_write, - }, + .stream_p = &rawfile_stream_p, .locals_dict = (mp_obj_t)&rawfile_locals_dict, }; diff --git a/unix/modsocket.c b/unix/modsocket.c index 6bdbc889d6..62f10300f8 100644 --- a/unix/modsocket.c +++ b/unix/modsocket.c @@ -240,6 +240,11 @@ STATIC const mp_map_elem_t microsocket_locals_dict_table[] = { STATIC MP_DEFINE_CONST_DICT(microsocket_locals_dict, microsocket_locals_dict_table); +STATIC const mp_stream_p_t microsocket_stream_p = { + .read = socket_read, + .write = socket_write, +}; + STATIC const mp_obj_type_t microsocket_type = { { &mp_type_type }, .name = MP_QSTR_socket, @@ -247,10 +252,7 @@ STATIC const mp_obj_type_t microsocket_type = { .make_new = socket_make_new, .getiter = NULL, .iternext = NULL, - .stream_p = { - .read = socket_read, - .write = socket_write, - }, + .stream_p = µsocket_stream_p, .locals_dict = (mp_obj_t)µsocket_locals_dict, }; diff --git a/unix/mpconfigport.h b/unix/mpconfigport.h index 3798f88b58..e2f2a69e11 100644 --- a/unix/mpconfigport.h +++ b/unix/mpconfigport.h @@ -31,7 +31,6 @@ typedef unsigned int machine_uint_t; // must be pointer size typedef void *machine_ptr_t; // must be of pointer size typedef const void *machine_const_ptr_t; // must be of pointer size -struct _mp_obj_fun_native_t; extern const struct _mp_obj_fun_native_t mp_builtin_open_obj; #define MICROPY_EXTRA_BUILTINS \ { MP_OBJ_NEW_QSTR(MP_QSTR_open), (mp_obj_t)&mp_builtin_open_obj }, diff --git a/unix/qstrdefsport.h b/unix/qstrdefsport.h index bfef9eb0da..fd259f327c 100644 --- a/unix/qstrdefsport.h +++ b/unix/qstrdefsport.h @@ -3,7 +3,6 @@ Q(Test) Q(argv) -Q(open) Q(stdin) Q(stdout) Q(stderr)