From 5f27a7e81135f7a7c0c75ee551fe0c6103048046 Mon Sep 17 00:00:00 2001 From: Damien George Date: Thu, 31 Jul 2014 10:29:56 +0100 Subject: [PATCH 1/4] py: Add mp_obj_str_builder_end_with_len. This allows to create str's with a smaller length than initially asked for. --- py/obj.h | 1 + py/objstr.c | 10 ++++++++++ 2 files changed, 11 insertions(+) diff --git a/py/obj.h b/py/obj.h index c391611c10..64ed061c8b 100644 --- a/py/obj.h +++ b/py/obj.h @@ -460,6 +460,7 @@ void mp_init_emergency_exception_buf(void); // str mp_obj_t mp_obj_str_builder_start(const mp_obj_type_t *type, uint len, byte **data); mp_obj_t mp_obj_str_builder_end(mp_obj_t o_in); +mp_obj_t mp_obj_str_builder_end_with_len(mp_obj_t o_in, mp_uint_t len); bool mp_obj_str_equal(mp_obj_t s1, mp_obj_t s2); uint mp_obj_str_get_hash(mp_obj_t self_in); uint mp_obj_str_get_len(mp_obj_t self_in); diff --git a/py/objstr.c b/py/objstr.c index 63d394e0a9..321340eea3 100644 --- a/py/objstr.c +++ b/py/objstr.c @@ -1744,6 +1744,16 @@ mp_obj_t mp_obj_str_builder_end(mp_obj_t o_in) { return o; } +mp_obj_t mp_obj_str_builder_end_with_len(mp_obj_t o_in, mp_uint_t len) { + mp_obj_str_t *o = o_in; + o->data = m_renew(byte, (byte*)o->data, o->len + 1, len + 1); + o->len = len; + o->hash = qstr_compute_hash(o->data, o->len); + byte *p = (byte*)o->data; + p[o->len] = '\0'; // for now we add null for compatibility with C ASCIIZ strings + return o; +} + mp_obj_t mp_obj_new_str_of_type(const mp_obj_type_t *type, const byte* data, uint len) { mp_obj_str_t *o = m_new_obj(mp_obj_str_t); o->base.type = type; From 3c4db9f91c01211aed47afe3efdd11477badc0bc Mon Sep 17 00:00:00 2001 From: Damien George Date: Thu, 31 Jul 2014 10:30:42 +0100 Subject: [PATCH 2/4] stmhal: Add USB_VCP class/object, for direct USB VCP control. Before, pyb.stdin/pyb.stdout allowed some kind of access to the USB VCP device, but it was basic access. This patch adds a proper USB_VCP class and object with much more control over the USB VCP device. Create an object with pyb.USB_VCP(), then use this object as if it were a UART object. It has send, recv, read, write, and other methods. send and recv allow a timeout to be specified. Addresses issue 774. --- stmhal/modpyb.c | 1 + stmhal/pybstdio.c | 6 +- stmhal/qstrdefsport.h | 6 ++ stmhal/usb.c | 158 +++++++++++++++++++++++++++++++++--- stmhal/usb.h | 5 +- stmhal/usbd_cdc_interface.c | 69 +++++++++++++--- stmhal/usbd_cdc_interface.h | 11 ++- 7 files changed, 227 insertions(+), 29 deletions(-) diff --git a/stmhal/modpyb.c b/stmhal/modpyb.c index 38a680da24..ace0020f77 100644 --- a/stmhal/modpyb.c +++ b/stmhal/modpyb.c @@ -367,6 +367,7 @@ STATIC const mp_map_elem_t pyb_module_globals_table[] = { { MP_OBJ_NEW_QSTR(MP_QSTR_have_cdc), (mp_obj_t)&pyb_have_cdc_obj }, { MP_OBJ_NEW_QSTR(MP_QSTR_repl_uart), (mp_obj_t)&pyb_repl_uart_obj }, { MP_OBJ_NEW_QSTR(MP_QSTR_hid), (mp_obj_t)&pyb_hid_send_report_obj }, + { MP_OBJ_NEW_QSTR(MP_QSTR_USB_VCP), (mp_obj_t)&pyb_usb_vcp_type }, { MP_OBJ_NEW_QSTR(MP_QSTR_millis), (mp_obj_t)&pyb_millis_obj }, { MP_OBJ_NEW_QSTR(MP_QSTR_delay), (mp_obj_t)&pyb_delay_obj }, diff --git a/stmhal/pybstdio.c b/stmhal/pybstdio.c index 88f47d1b44..2121a6cbb7 100644 --- a/stmhal/pybstdio.c +++ b/stmhal/pybstdio.c @@ -84,8 +84,10 @@ int stdin_rx_chr(void) { } #endif #endif - if (usb_vcp_rx_num() != 0) { - return usb_vcp_rx_get(); + + byte c; + if (usb_vcp_recv_byte(&c) != 0) { + return c; } else if (pyb_stdio_uart != PYB_UART_NONE && uart_rx_any(pyb_stdio_uart)) { return uart_rx_char(pyb_stdio_uart); } diff --git a/stmhal/qstrdefsport.h b/stmhal/qstrdefsport.h index b5b4a4e4a0..f1f84999f5 100644 --- a/stmhal/qstrdefsport.h +++ b/stmhal/qstrdefsport.h @@ -71,6 +71,12 @@ Q(millis) Q(seek) Q(tell) +// for USB VCP class +Q(USB_VCP) +Q(send) +Q(recv) +Q(timeout) + // for RTC class Q(RTC) Q(info) diff --git a/stmhal/usb.c b/stmhal/usb.c index 85dd2b4eaf..a7c3add53c 100644 --- a/stmhal/usb.c +++ b/stmhal/usb.c @@ -32,10 +32,13 @@ #include "usbd_cdc_interface.h" #include "usbd_msc_storage.h" -#include "misc.h" #include "mpconfig.h" +#include "misc.h" #include "qstr.h" #include "obj.h" +#include "runtime.h" +#include "stream.h" +#include "bufhelper.h" #include "usb.h" #ifdef USE_DEVICE_MODE @@ -99,18 +102,14 @@ void usb_vcp_set_interrupt_char(int c) { } } -int usb_vcp_rx_num(void) { - return USBD_CDC_RxNum(); -} - -char usb_vcp_rx_get(void) { - return USBD_CDC_RxGet(); +int usb_vcp_recv_byte(uint8_t *c) { + return USBD_CDC_Rx(c, 1, 0); } void usb_vcp_send_strn(const char *str, int len) { #ifdef USE_DEVICE_MODE if (dev_is_enabled) { - USBD_CDC_Tx(str, len); + USBD_CDC_TxAlways((const uint8_t*)str, len); } #endif } @@ -120,9 +119,9 @@ void usb_vcp_send_strn_cooked(const char *str, int len) { if (dev_is_enabled) { for (const char *top = str + len; str < top; str++) { if (*str == '\n') { - USBD_CDC_Tx("\r\n", 2); + USBD_CDC_TxAlways((const uint8_t*)"\r\n", 2); } else { - USBD_CDC_Tx(str, 1); + USBD_CDC_TxAlways((const uint8_t*)str, 1); } } } @@ -135,6 +134,145 @@ void usb_hid_send_report(uint8_t *buf) { #endif } +/******************************************************************************/ +// Micro Python bindings for USB VCP + +typedef struct _pyb_usb_vcp_obj_t { + mp_obj_base_t base; +} pyb_usb_vcp_obj_t; + +STATIC const pyb_usb_vcp_obj_t pyb_usb_vcp_obj = {{&pyb_usb_vcp_type}}; + +STATIC void pyb_usb_vcp_print(void (*print)(void *env, const char *fmt, ...), void *env, mp_obj_t self_in, mp_print_kind_t kind) { + print(env, "USB_VCP()"); +} + +STATIC mp_obj_t pyb_usb_vcp_make_new(mp_obj_t type_in, uint n_args, uint n_kw, const mp_obj_t *args) { + // check arguments + mp_arg_check_num(n_args, n_kw, 0, 0, false); + + // return the USB VCP object + return (mp_obj_t)&pyb_usb_vcp_obj; +} + +/// \method any() +/// Return `True` if any characters waiting, else `False`. +STATIC mp_obj_t pyb_usb_vcp_any(mp_obj_t self_in) { + if (USBD_CDC_RxNum() > 0) { + return mp_const_true; + } else { + return mp_const_false; + } +} +STATIC MP_DEFINE_CONST_FUN_OBJ_1(pyb_usb_vcp_any_obj, pyb_usb_vcp_any); + +/// \method send(data, *, timeout=5000) +/// Send data over the USB VCP: +/// +/// - `data` is the data to send (an integer to send, or a buffer object). +/// - `timeout` is the timeout in milliseconds to wait for the send. +/// +/// Return value: number of bytes sent. +STATIC const mp_arg_t pyb_usb_vcp_send_args[] = { + { MP_QSTR_data, MP_ARG_REQUIRED | MP_ARG_OBJ, {.u_obj = MP_OBJ_NULL} }, + { MP_QSTR_timeout, MP_ARG_KW_ONLY | MP_ARG_INT, {.u_int = 5000} }, +}; +#define PYB_USB_VCP_SEND_NUM_ARGS MP_ARRAY_SIZE(pyb_usb_vcp_send_args) + +STATIC mp_obj_t pyb_usb_vcp_send(uint n_args, const mp_obj_t *args, mp_map_t *kw_args) { + // parse args + mp_arg_val_t vals[PYB_USB_VCP_SEND_NUM_ARGS]; + mp_arg_parse_all(n_args - 1, args + 1, kw_args, PYB_USB_VCP_SEND_NUM_ARGS, pyb_usb_vcp_send_args, vals); + + // get the buffer to send from + mp_buffer_info_t bufinfo; + uint8_t data[1]; + pyb_buf_get_for_send(vals[0].u_obj, &bufinfo, data); + + // send the data + int ret = USBD_CDC_Tx(bufinfo.buf, bufinfo.len, vals[1].u_int); + + return mp_obj_new_int(ret); +} +STATIC MP_DEFINE_CONST_FUN_OBJ_KW(pyb_usb_vcp_send_obj, 1, pyb_usb_vcp_send); + +/// \method recv(data, *, timeout=5000) +/// +/// Receive data on the bus: +/// +/// - `data` can be an integer, which is the number of bytes to receive, +/// or a mutable buffer, which will be filled with received bytes. +/// - `timeout` is the timeout in milliseconds to wait for the receive. +/// +/// Return value: if `data` is an integer then a new buffer of the bytes received, +/// otherwise the number of bytes read into `data` is returned. +STATIC mp_obj_t pyb_usb_vcp_recv(uint n_args, const mp_obj_t *args, mp_map_t *kw_args) { + // parse args + mp_arg_val_t vals[PYB_USB_VCP_SEND_NUM_ARGS]; + mp_arg_parse_all(n_args - 1, args + 1, kw_args, PYB_USB_VCP_SEND_NUM_ARGS, pyb_usb_vcp_send_args, vals); + + // get the buffer to receive into + mp_buffer_info_t bufinfo; + mp_obj_t o_ret = pyb_buf_get_for_recv(vals[0].u_obj, &bufinfo); + + // receive the data + int ret = USBD_CDC_Rx(bufinfo.buf, bufinfo.len, vals[1].u_int); + + // return the received data + if (o_ret == MP_OBJ_NULL) { + return mp_obj_new_int(ret); // number of bytes read into given buffer + } else { + return mp_obj_str_builder_end_with_len(o_ret, ret); // create a new buffer + } +} +STATIC MP_DEFINE_CONST_FUN_OBJ_KW(pyb_usb_vcp_recv_obj, 1, pyb_usb_vcp_recv); + +STATIC mp_uint_t pyb_usb_vcp_read(mp_obj_t self_in, void *buf, mp_uint_t size, int *errcode) { + int ret = USBD_CDC_Rx((byte*)buf, size, -1); + return ret; +} + +STATIC mp_uint_t pyb_usb_vcp_write(mp_obj_t self_in, const void *buf, mp_uint_t size, int *errcode) { + int ret = USBD_CDC_Tx((const byte*)buf, size, -1); + return ret; +} + +mp_obj_t pyb_usb_vcp___exit__(uint n_args, const mp_obj_t *args) { + return mp_const_none; +} +STATIC MP_DEFINE_CONST_FUN_OBJ_VAR_BETWEEN(pyb_usb_vcp___exit___obj, 4, 4, pyb_usb_vcp___exit__); + +STATIC const mp_map_elem_t pyb_usb_vcp_locals_dict_table[] = { + { MP_OBJ_NEW_QSTR(MP_QSTR_send), (mp_obj_t)&pyb_usb_vcp_send_obj }, + { MP_OBJ_NEW_QSTR(MP_QSTR_recv), (mp_obj_t)&pyb_usb_vcp_recv_obj }, + { MP_OBJ_NEW_QSTR(MP_QSTR_read), (mp_obj_t)&mp_stream_read_obj }, + { MP_OBJ_NEW_QSTR(MP_QSTR_readall), (mp_obj_t)&mp_stream_readall_obj }, + { MP_OBJ_NEW_QSTR(MP_QSTR_readline), (mp_obj_t)&mp_stream_unbuffered_readline_obj}, + { MP_OBJ_NEW_QSTR(MP_QSTR_write), (mp_obj_t)&mp_stream_write_obj }, + { MP_OBJ_NEW_QSTR(MP_QSTR_close), (mp_obj_t)&mp_identity_obj }, + { MP_OBJ_NEW_QSTR(MP_QSTR___del__), (mp_obj_t)&mp_identity_obj }, + { MP_OBJ_NEW_QSTR(MP_QSTR___enter__), (mp_obj_t)&mp_identity_obj }, + { MP_OBJ_NEW_QSTR(MP_QSTR___exit__), (mp_obj_t)&pyb_usb_vcp___exit___obj }, +}; + +STATIC MP_DEFINE_CONST_DICT(pyb_usb_vcp_locals_dict, pyb_usb_vcp_locals_dict_table); + +STATIC const mp_stream_p_t pyb_usb_vcp_stream_p = { + .read = pyb_usb_vcp_read, + .write = pyb_usb_vcp_write, +}; + +const mp_obj_type_t pyb_usb_vcp_type = { + { &mp_type_type }, + .name = MP_QSTR_USB_VCP, + .print = pyb_usb_vcp_print, + .make_new = pyb_usb_vcp_make_new, + .getiter = mp_identity, + .iternext = mp_stream_unbuffered_iter, + .stream_p = &pyb_usb_vcp_stream_p, + .locals_dict = (mp_obj_t)&pyb_usb_vcp_locals_dict, +}; + /******************************************************************************/ // code for experimental USB OTG support diff --git a/stmhal/usb.h b/stmhal/usb.h index 4eb29c9dee..5153cb5fab 100644 --- a/stmhal/usb.h +++ b/stmhal/usb.h @@ -41,13 +41,14 @@ typedef enum { USB_STORAGE_MEDIUM_SDCARD, } usb_storage_medium_t; +const mp_obj_type_t pyb_usb_vcp_type; + void pyb_usb_dev_init(usb_device_mode_t mode, usb_storage_medium_t medium); void pyb_usb_dev_stop(void); bool usb_vcp_is_enabled(void); bool usb_vcp_is_connected(void); void usb_vcp_set_interrupt_char(int c); -int usb_vcp_rx_num(void); -char usb_vcp_rx_get(void); +int usb_vcp_recv_byte(uint8_t *c); void usb_vcp_send_strn(const char* str, int len); void usb_vcp_send_strn_cooked(const char *str, int len); void usb_hid_send_report(uint8_t *buf); // 4 bytes for mouse: ?, x, y, ? diff --git a/stmhal/usbd_cdc_interface.c b/stmhal/usbd_cdc_interface.c index 323ca74382..d437955508 100644 --- a/stmhal/usbd_cdc_interface.c +++ b/stmhal/usbd_cdc_interface.c @@ -33,11 +33,18 @@ */ /* Includes ------------------------------------------------------------------*/ + #include + #include "stm32f4xx_hal.h" #include "usbd_cdc_msc_hid.h" #include "usbd_cdc_interface.h" #include "pendsv.h" + +#include "mpconfig.h" +#include "misc.h" +#include "qstr.h" +#include "obj.h" #include "usb.h" // CDC control commands @@ -59,7 +66,7 @@ /* Private macro -------------------------------------------------------------*/ /* Private variables ---------------------------------------------------------*/ -static uint8_t dev_is_connected = 0; // indicates if we are connected +static __IO uint8_t dev_is_connected = 0; // indicates if we are connected static uint8_t UserRxBuffer[APP_RX_DATA_SIZE]; // received data from USB OUT endpoint is stored in this buffer static uint16_t UserRxBufCur = 0; // points to next available character in UserRxBuffer @@ -399,7 +406,34 @@ void USBD_CDC_SetInterrupt(int chr, void *data) { user_interrupt_data = data; } -void USBD_CDC_Tx(const char *str, uint32_t len) { +// timout in milliseconds. +// Returns number of bytes written to the device. +int USBD_CDC_Tx(const uint8_t *buf, uint32_t len, uint32_t timeout) { + for (uint32_t i = 0; i < len; i++) { + // Wait until the device is connected and the buffer has space, with a given timeout + uint32_t start = HAL_GetTick(); + while (!dev_is_connected || ((UserTxBufPtrIn + 1) & (APP_TX_DATA_SIZE - 1)) == UserTxBufPtrOut) { + // Wraparound of tick is taken care of by 2's complement arithmetic. + if (HAL_GetTick() - start >= timeout) { + // timeout + return i; + } + __WFI(); // enter sleep mode, waiting for interrupt + } + + // Write data to device buffer + UserTxBuffer[UserTxBufPtrIn] = buf[i]; + UserTxBufPtrIn = (UserTxBufPtrIn + 1) & (APP_TX_DATA_SIZE - 1); + } + + // Success, return number of bytes read + return len; +} + +// Always write all of the data to the device tx buffer, even if the +// device is not connected, or if the buffer is full. Has a small timeout +// to wait for the buffer to be drained, in the case the device is connected. +void USBD_CDC_TxAlways(const uint8_t *buf, uint32_t len) { for (int i = 0; i < len; i++) { // If the CDC device is not connected to the host then we don't have anyone to receive our data. // The device may become connected in the future, so we should at least try to fill the buffer @@ -433,23 +467,36 @@ void USBD_CDC_Tx(const char *str, uint32_t len) { */ } - UserTxBuffer[UserTxBufPtrIn] = str[i]; + UserTxBuffer[UserTxBufPtrIn] = buf[i]; UserTxBufPtrIn = (UserTxBufPtrIn + 1) & (APP_TX_DATA_SIZE - 1); } } +// Returns number of bytes in the rx buffer. int USBD_CDC_RxNum(void) { return UserRxBufLen - UserRxBufCur; } -int USBD_CDC_RxGet(void) { - // wait for buffer to have at least 1 character in it - while (USBD_CDC_RxNum() == 0) { - __WFI(); +// timout in milliseconds. +// Returns number of bytes read from the device. +int USBD_CDC_Rx(uint8_t *buf, uint32_t len, uint32_t timeout) { + // loop to read bytes + for (uint32_t i = 0; i < len; i++) { + // Wait until we have at least 1 byte to read + uint32_t start = HAL_GetTick(); + while (!dev_is_connected || UserRxBufLen == UserRxBufCur) { + // Wraparound of tick is taken care of by 2's complement arithmetic. + if (HAL_GetTick() - start >= timeout) { + // timeout + return i; + } + __WFI(); // enter sleep mode, waiting for interrupt + } + + // Copy byte from device to user buffer + buf[i] = UserRxBuffer[UserRxBufCur++]; } - // get next character - int c = UserRxBuffer[UserRxBufCur++]; - - return c; + // Success, return number of bytes read + return len; } diff --git a/stmhal/usbd_cdc_interface.h b/stmhal/usbd_cdc_interface.h index c1fa54020b..f312682fbf 100644 --- a/stmhal/usbd_cdc_interface.h +++ b/stmhal/usbd_cdc_interface.h @@ -20,8 +20,8 @@ * * http://www.st.com/software_license_agreement_liberty_v2 * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. @@ -36,6 +36,9 @@ void USBD_CDC_HAL_TIM_PeriodElapsedCallback(void); int USBD_CDC_IsConnected(void); void USBD_CDC_SetInterrupt(int chr, void *data); -void USBD_CDC_Tx(const char *str, uint32_t len); + +int USBD_CDC_Tx(const uint8_t *buf, uint32_t len, uint32_t timeout); +void USBD_CDC_TxAlways(const uint8_t *buf, uint32_t len); + int USBD_CDC_RxNum(void); -int USBD_CDC_RxGet(void); +int USBD_CDC_Rx(uint8_t *buf, uint32_t len, uint32_t timeout); From fa1ecda3fdaecd89b86bb63930a6521c8f63fe90 Mon Sep 17 00:00:00 2001 From: Damien George Date: Thu, 31 Jul 2014 10:39:52 +0100 Subject: [PATCH 3/4] stmhal, accel: Increase start-up times to 30ms; add extra 30ms delay. For accel to start-up reliably, need to wait 30ms between on/off, and 30ms for it to enter active mode. With this fix the accel can be read immediately after initialising it. Addresses issue #763. --- stmhal/accel.c | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/stmhal/accel.c b/stmhal/accel.c index cfc80f9d3c..e846ca4e77 100644 --- a/stmhal/accel.c +++ b/stmhal/accel.c @@ -83,11 +83,11 @@ STATIC void accel_start(void) { I2CHandle1.Init.OwnAddress2 = 0xfe; // unused i2c_init(&I2CHandle1); - // turn off AVDD, wait 20ms, turn on AVDD, wait 20ms again + // turn off AVDD, wait 30ms, turn on AVDD, wait 30ms again GPIOB->BSRRH = GPIO_PIN_5; // turn off - HAL_Delay(20); + HAL_Delay(30); GPIOB->BSRRL = GPIO_PIN_5; // turn on - HAL_Delay(20); + HAL_Delay(30); HAL_StatusTypeDef status; @@ -100,11 +100,12 @@ STATIC void accel_start(void) { } } - //printf("MemWrite\n"); - uint8_t data[1]; - data[0] = 1; // active mode + // set MMA to active mode + uint8_t data[1] = {1}; // active mode status = HAL_I2C_Mem_Write(&I2CHandle1, MMA_ADDR, MMA_REG_MODE, I2C_MEMADD_SIZE_8BIT, data, 1, 200); - //printf(" got %d\n", status); + + // wait for MMA to become active + HAL_Delay(30); } /******************************************************************************/ From bb4c6f35c627ab3487cdd6bafb4588cc633cd6a4 Mon Sep 17 00:00:00 2001 From: Damien George Date: Thu, 31 Jul 2014 10:49:14 +0100 Subject: [PATCH 4/4] py: Make MP_OBJ_NEW_SMALL_INT cast arg to mp_int_t itself. Addresses issue #724. --- extmod/moductypes.c | 8 ++++---- py/modgc.c | 6 +++--- py/modmicropython.c | 6 +++--- py/obj.c | 2 +- py/obj.h | 4 ++-- py/objbool.c | 2 +- py/objdict.c | 2 +- py/objint.c | 2 +- py/objset.c | 2 +- py/objstr.c | 4 ++-- py/objstrunicode.c | 2 +- stmhal/file.c | 2 +- stmhal/pin.c | 4 ++-- unix/file.c | 4 ++-- unix/modffi.c | 6 +++--- unix/modos.c | 14 +++++++------- unix/modsocket.c | 18 +++++++++--------- 17 files changed, 44 insertions(+), 44 deletions(-) diff --git a/extmod/moductypes.c b/extmod/moductypes.c index dd78102aee..3fffd98e4f 100644 --- a/extmod/moductypes.c +++ b/extmod/moductypes.c @@ -296,13 +296,13 @@ static inline void set_aligned_basic(uint val_type, void *p, mp_uint_t v) { STATIC mp_obj_t get_aligned(uint val_type, void *p, mp_int_t index) { switch (val_type) { case UINT8: - return MP_OBJ_NEW_SMALL_INT((mp_int_t)((uint8_t*)p)[index]); + return MP_OBJ_NEW_SMALL_INT(((uint8_t*)p)[index]); case INT8: - return MP_OBJ_NEW_SMALL_INT((mp_int_t)((int8_t*)p)[index]); + return MP_OBJ_NEW_SMALL_INT(((int8_t*)p)[index]); case UINT16: - return MP_OBJ_NEW_SMALL_INT((mp_int_t)((uint16_t*)p)[index]); + return MP_OBJ_NEW_SMALL_INT(((uint16_t*)p)[index]); case INT16: - return MP_OBJ_NEW_SMALL_INT((mp_int_t)((int16_t*)p)[index]); + return MP_OBJ_NEW_SMALL_INT(((int16_t*)p)[index]); case UINT32: return mp_obj_new_int_from_uint(((uint32_t*)p)[index]); case INT32: diff --git a/py/modgc.c b/py/modgc.c index 045563cd98..5fed2d8861 100644 --- a/py/modgc.c +++ b/py/modgc.c @@ -42,7 +42,7 @@ extern uint gc_collected; STATIC mp_obj_t py_gc_collect(void) { gc_collect(); #if MICROPY_PY_GC_COLLECT_RETVAL - return MP_OBJ_NEW_SMALL_INT((mp_uint_t)gc_collected); + return MP_OBJ_NEW_SMALL_INT(gc_collected); #else return mp_const_none; #endif @@ -64,14 +64,14 @@ MP_DEFINE_CONST_FUN_OBJ_0(gc_enable_obj, gc_enable); STATIC mp_obj_t gc_mem_free(void) { gc_info_t info; gc_info(&info); - return MP_OBJ_NEW_SMALL_INT((mp_uint_t)info.free); + return MP_OBJ_NEW_SMALL_INT(info.free); } MP_DEFINE_CONST_FUN_OBJ_0(gc_mem_free_obj, gc_mem_free); STATIC mp_obj_t gc_mem_alloc(void) { gc_info_t info; gc_info(&info); - return MP_OBJ_NEW_SMALL_INT((mp_uint_t)info.used); + return MP_OBJ_NEW_SMALL_INT(info.used); } MP_DEFINE_CONST_FUN_OBJ_0(gc_mem_alloc_obj, gc_mem_alloc); diff --git a/py/modmicropython.c b/py/modmicropython.c index 78beb88afa..87bab0a33e 100644 --- a/py/modmicropython.c +++ b/py/modmicropython.c @@ -35,15 +35,15 @@ #if MICROPY_MEM_STATS STATIC mp_obj_t mp_micropython_mem_total() { - return MP_OBJ_NEW_SMALL_INT((mp_int_t)m_get_total_bytes_allocated()); + return MP_OBJ_NEW_SMALL_INT(m_get_total_bytes_allocated()); } STATIC mp_obj_t mp_micropython_mem_current() { - return MP_OBJ_NEW_SMALL_INT((mp_int_t)m_get_current_bytes_allocated()); + return MP_OBJ_NEW_SMALL_INT(m_get_current_bytes_allocated()); } STATIC mp_obj_t mp_micropython_mem_peak() { - return MP_OBJ_NEW_SMALL_INT((mp_int_t)m_get_peak_bytes_allocated()); + return MP_OBJ_NEW_SMALL_INT(m_get_peak_bytes_allocated()); } STATIC MP_DEFINE_CONST_FUN_OBJ_0(mp_micropython_mem_total_obj, mp_micropython_mem_total); diff --git a/py/obj.c b/py/obj.c index 755da02750..ae20db4354 100644 --- a/py/obj.c +++ b/py/obj.c @@ -368,7 +368,7 @@ mp_obj_t mp_obj_len_maybe(mp_obj_t o_in) { MP_OBJ_IS_STR(o_in) || #endif MP_OBJ_IS_TYPE(o_in, &mp_type_bytes)) { - return MP_OBJ_NEW_SMALL_INT((mp_int_t)mp_obj_str_get_len(o_in)); + return MP_OBJ_NEW_SMALL_INT(mp_obj_str_get_len(o_in)); } else { mp_obj_type_t *type = mp_obj_get_type(o_in); if (type->unary_op != NULL) { diff --git a/py/obj.h b/py/obj.h index 64ed061c8b..fa42428fad 100644 --- a/py/obj.h +++ b/py/obj.h @@ -76,10 +76,10 @@ typedef struct _mp_obj_base_t mp_obj_base_t; #define MP_OBJ_IS_STR(o) (MP_OBJ_IS_QSTR(o) || MP_OBJ_IS_TYPE(o, &mp_type_str)) #define MP_OBJ_SMALL_INT_VALUE(o) (((mp_int_t)(o)) >> 1) -#define MP_OBJ_NEW_SMALL_INT(small_int) ((mp_obj_t)(((small_int) << 1) | 1)) +#define MP_OBJ_NEW_SMALL_INT(small_int) ((mp_obj_t)((((mp_int_t)(small_int)) << 1) | 1)) #define MP_OBJ_QSTR_VALUE(o) (((mp_int_t)(o)) >> 2) -#define MP_OBJ_NEW_QSTR(qstr) ((mp_obj_t)((((mp_uint_t)qstr) << 2) | 2)) +#define MP_OBJ_NEW_QSTR(qstr) ((mp_obj_t)((((mp_uint_t)(qstr)) << 2) | 2)) // These macros are used to declare and define constant function objects // You can put "static" in front of the definitions to make them local diff --git a/py/objbool.c b/py/objbool.c index 9bf30d4236..72535b2972 100644 --- a/py/objbool.c +++ b/py/objbool.c @@ -74,7 +74,7 @@ STATIC mp_obj_t bool_unary_op(int op, mp_obj_t o_in) { STATIC mp_obj_t bool_binary_op(int op, mp_obj_t lhs_in, mp_obj_t rhs_in) { if (MP_BINARY_OP_OR <= op && op <= MP_BINARY_OP_NOT_EQUAL) { - return mp_binary_op(op, MP_OBJ_NEW_SMALL_INT((mp_int_t)mp_obj_is_true(lhs_in)), rhs_in); + return mp_binary_op(op, MP_OBJ_NEW_SMALL_INT(mp_obj_is_true(lhs_in)), rhs_in); } return MP_OBJ_NULL; // op not supported } diff --git a/py/objdict.c b/py/objdict.c index 9b4133f83b..f09065b102 100644 --- a/py/objdict.c +++ b/py/objdict.c @@ -75,7 +75,7 @@ STATIC mp_obj_t dict_unary_op(int op, mp_obj_t self_in) { mp_obj_dict_t *self = self_in; switch (op) { case MP_UNARY_OP_BOOL: return MP_BOOL(self->map.used != 0); - case MP_UNARY_OP_LEN: return MP_OBJ_NEW_SMALL_INT((mp_int_t)self->map.used); + case MP_UNARY_OP_LEN: return MP_OBJ_NEW_SMALL_INT(self->map.used); default: return MP_OBJ_NULL; // op not supported } } diff --git a/py/objint.c b/py/objint.c index e351c3f394..c08bf7da6c 100644 --- a/py/objint.c +++ b/py/objint.c @@ -64,7 +64,7 @@ STATIC mp_obj_t mp_obj_int_make_new(mp_obj_t type_in, uint n_args, uint n_kw, co return mp_parse_num_integer(s, l, 0); #if MICROPY_PY_BUILTINS_FLOAT } else if (MP_OBJ_IS_TYPE(args[0], &mp_type_float)) { - return MP_OBJ_NEW_SMALL_INT((mp_int_t)(MICROPY_FLOAT_C_FUN(trunc)(mp_obj_float_get(args[0])))); + return MP_OBJ_NEW_SMALL_INT((MICROPY_FLOAT_C_FUN(trunc)(mp_obj_float_get(args[0])))); #endif } else { // try to convert to small int (eg from bool) diff --git a/py/objset.c b/py/objset.c index 48d037ffc2..f17628d53e 100644 --- a/py/objset.c +++ b/py/objset.c @@ -476,7 +476,7 @@ STATIC mp_obj_t set_unary_op(int op, mp_obj_t self_in) { mp_obj_set_t *self = self_in; switch (op) { case MP_UNARY_OP_BOOL: return MP_BOOL(self->set.used != 0); - case MP_UNARY_OP_LEN: return MP_OBJ_NEW_SMALL_INT((mp_int_t)self->set.used); + case MP_UNARY_OP_LEN: return MP_OBJ_NEW_SMALL_INT(self->set.used); default: return MP_OBJ_NULL; // op not supported } } diff --git a/py/objstr.c b/py/objstr.c index 321340eea3..6ec997f4bf 100644 --- a/py/objstr.c +++ b/py/objstr.c @@ -370,7 +370,7 @@ STATIC mp_obj_t str_subscr(mp_obj_t self_in, mp_obj_t index, mp_obj_t value) { #endif const byte *p = str_index_to_ptr(type, self_data, self_len, index, false); if (type == &mp_type_bytes) { - return MP_OBJ_NEW_SMALL_INT((mp_int_t)*p); + return MP_OBJ_NEW_SMALL_INT(*p); } else { return mp_obj_new_str((char*)p, 1, true); } @@ -1917,7 +1917,7 @@ STATIC mp_obj_t bytes_it_iternext(mp_obj_t self_in) { mp_obj_str_it_t *self = self_in; GET_STR_DATA_LEN(self->str, str, len); if (self->cur < len) { - mp_obj_t o_out = MP_OBJ_NEW_SMALL_INT((mp_int_t)str[self->cur]); + mp_obj_t o_out = MP_OBJ_NEW_SMALL_INT(str[self->cur]); self->cur += 1; return o_out; } else { diff --git a/py/objstrunicode.c b/py/objstrunicode.c index 873b4fc58e..848005c545 100644 --- a/py/objstrunicode.c +++ b/py/objstrunicode.c @@ -257,7 +257,7 @@ STATIC mp_obj_t str_subscr(mp_obj_t self_in, mp_obj_t index, mp_obj_t value) { #endif if (type == &mp_type_bytes) { uint index_val = mp_get_index(type, self_len, index, false); - return MP_OBJ_NEW_SMALL_INT((mp_int_t)self_data[index_val]); + return MP_OBJ_NEW_SMALL_INT(self_data[index_val]); } const byte *s = str_index_to_ptr(type, self_data, self_len, index, false); int len = 1; diff --git a/stmhal/file.c b/stmhal/file.c index db6d08e5e5..7ce8ef43f6 100644 --- a/stmhal/file.c +++ b/stmhal/file.c @@ -206,7 +206,7 @@ STATIC mp_obj_t file_obj_make_new(mp_obj_t type, uint n_args, uint n_kw, const m FRESULT res = f_open(&o->fp, fname, mode); if (res != FR_OK) { m_del_obj(pyb_file_obj_t, o); - nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT((mp_int_t)fresult_to_errno_table[res]))); + nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT(fresult_to_errno_table[res]))); } // for 'a' mode, we must begin at the end of the file diff --git a/stmhal/pin.c b/stmhal/pin.c index 56f179f40c..20661cfceb 100644 --- a/stmhal/pin.c +++ b/stmhal/pin.c @@ -352,7 +352,7 @@ STATIC MP_DEFINE_CONST_FUN_OBJ_1(pin_name_obj, pin_name); /// Get the pin port. STATIC mp_obj_t pin_port(mp_obj_t self_in) { pin_obj_t *self = self_in; - return MP_OBJ_NEW_SMALL_INT((mp_int_t)self->port); + return MP_OBJ_NEW_SMALL_INT(self->port); } STATIC MP_DEFINE_CONST_FUN_OBJ_1(pin_port_obj, pin_port); @@ -360,7 +360,7 @@ STATIC MP_DEFINE_CONST_FUN_OBJ_1(pin_port_obj, pin_port); /// Get the pin number. STATIC mp_obj_t pin_pin(mp_obj_t self_in) { pin_obj_t *self = self_in; - return MP_OBJ_NEW_SMALL_INT((mp_int_t)self->pin); + return MP_OBJ_NEW_SMALL_INT(self->pin); } STATIC MP_DEFINE_CONST_FUN_OBJ_1(pin_pin_obj, pin_pin); diff --git a/unix/file.c b/unix/file.c index cdec1ad1af..76a44e187c 100644 --- a/unix/file.c +++ b/unix/file.c @@ -114,7 +114,7 @@ STATIC MP_DEFINE_CONST_FUN_OBJ_VAR_BETWEEN(fdfile___exit___obj, 4, 4, fdfile___e STATIC mp_obj_t fdfile_fileno(mp_obj_t self_in) { mp_obj_fdfile_t *self = self_in; check_fd_is_open(self); - return MP_OBJ_NEW_SMALL_INT((mp_int_t)self->fd); + return MP_OBJ_NEW_SMALL_INT(self->fd); } STATIC MP_DEFINE_CONST_FUN_OBJ_1(fdfile_fileno_obj, fdfile_fileno); @@ -167,7 +167,7 @@ STATIC mp_obj_t fdfile_make_new(mp_obj_t type_in, uint n_args, uint n_kw, const const char *fname = mp_obj_str_get_str(args[0]); int fd = open(fname, mode, 0644); if (fd == -1) { - nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT((mp_int_t)errno))); + nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT(errno))); } o->fd = fd; return o; diff --git a/unix/modffi.c b/unix/modffi.c index 796dec4199..842ed3370e 100644 --- a/unix/modffi.c +++ b/unix/modffi.c @@ -179,7 +179,7 @@ STATIC mp_obj_t ffimod_func(uint n_args, const mp_obj_t *args) { void *sym = dlsym(self->handle, symname); if (sym == NULL) { - nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT((mp_int_t)errno))); + nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT(errno))); } int nparams = MP_OBJ_SMALL_INT_VALUE(mp_obj_len_maybe(args[3])); mp_obj_ffifunc_t *o = m_new_obj_var(mp_obj_ffifunc_t, ffi_type*, nparams); @@ -253,7 +253,7 @@ STATIC mp_obj_t ffimod_var(mp_obj_t self_in, mp_obj_t vartype_in, mp_obj_t symna void *sym = dlsym(self->handle, symname); if (sym == NULL) { - nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT((mp_int_t)errno))); + nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT(errno))); } mp_obj_ffivar_t *o = m_new_obj(mp_obj_ffivar_t); o->base.type = &ffivar_type; @@ -269,7 +269,7 @@ STATIC mp_obj_t ffimod_make_new(mp_obj_t type_in, uint n_args, uint n_kw, const void *mod = dlopen(fname, RTLD_NOW | RTLD_LOCAL); if (mod == NULL) { - nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT((mp_int_t)errno))); + nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT(errno))); } mp_obj_ffimod_t *o = m_new_obj(mp_obj_ffimod_t); o->base.type = type_in; diff --git a/unix/modos.c b/unix/modos.c index 7ff3fbbb89..5cd78a99fb 100644 --- a/unix/modos.c +++ b/unix/modos.c @@ -40,7 +40,7 @@ #define RAISE_ERRNO(err_flag, error_val) \ { if (err_flag == -1) \ - { nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT((mp_int_t)error_val))); } } + { nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT(error_val))); } } STATIC mp_obj_t mod_os_stat(mp_obj_t path_in) { struct stat sb; @@ -51,12 +51,12 @@ STATIC mp_obj_t mod_os_stat(mp_obj_t path_in) { RAISE_ERRNO(res, errno); mp_obj_tuple_t *t = mp_obj_new_tuple(10, NULL); - t->items[0] = MP_OBJ_NEW_SMALL_INT((mp_int_t)sb.st_mode); - t->items[1] = MP_OBJ_NEW_SMALL_INT((mp_int_t)sb.st_ino); - t->items[2] = MP_OBJ_NEW_SMALL_INT((mp_int_t)sb.st_dev); - t->items[3] = MP_OBJ_NEW_SMALL_INT((mp_int_t)sb.st_nlink); - t->items[4] = MP_OBJ_NEW_SMALL_INT((mp_int_t)sb.st_uid); - t->items[5] = MP_OBJ_NEW_SMALL_INT((mp_int_t)sb.st_gid); + t->items[0] = MP_OBJ_NEW_SMALL_INT(sb.st_mode); + t->items[1] = MP_OBJ_NEW_SMALL_INT(sb.st_ino); + t->items[2] = MP_OBJ_NEW_SMALL_INT(sb.st_dev); + t->items[3] = MP_OBJ_NEW_SMALL_INT(sb.st_nlink); + t->items[4] = MP_OBJ_NEW_SMALL_INT(sb.st_uid); + t->items[5] = MP_OBJ_NEW_SMALL_INT(sb.st_gid); t->items[6] = MP_OBJ_NEW_SMALL_INT(sb.st_size); t->items[7] = MP_OBJ_NEW_SMALL_INT(sb.st_atime); t->items[8] = MP_OBJ_NEW_SMALL_INT(sb.st_mtime); diff --git a/unix/modsocket.c b/unix/modsocket.c index a3380fb89a..d5b8e11c24 100644 --- a/unix/modsocket.c +++ b/unix/modsocket.c @@ -76,7 +76,7 @@ STATIC const mp_obj_type_t microsocket_type; // Helper functions #define RAISE_ERRNO(err_flag, error_val) \ { if (err_flag == -1) \ - { nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT((mp_int_t)error_val))); } } + { nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT(error_val))); } } STATIC mp_obj_socket_t *socket_new(int fd) { mp_obj_socket_t *o = m_new_obj(mp_obj_socket_t); @@ -120,7 +120,7 @@ STATIC MP_DEFINE_CONST_FUN_OBJ_1(socket_close_obj, socket_close); STATIC mp_obj_t socket_fileno(mp_obj_t self_in) { mp_obj_socket_t *self = self_in; - return MP_OBJ_NEW_SMALL_INT((mp_int_t)self->fd); + return MP_OBJ_NEW_SMALL_INT(self->fd); } STATIC MP_DEFINE_CONST_FUN_OBJ_1(socket_fileno_obj, socket_fileno); @@ -205,7 +205,7 @@ STATIC mp_obj_t socket_send(uint n_args, const mp_obj_t *args) { int out_sz = send(self->fd, bufinfo.buf, bufinfo.len, flags); RAISE_ERRNO(out_sz, errno); - return MP_OBJ_NEW_SMALL_INT((mp_int_t)out_sz); + return MP_OBJ_NEW_SMALL_INT(out_sz); } STATIC MP_DEFINE_CONST_FUN_OBJ_VAR_BETWEEN(socket_send_obj, 2, 3, socket_send); @@ -255,7 +255,7 @@ STATIC mp_obj_t socket_makefile(uint n_args, const mp_obj_t *args) { mp_obj_socket_t *self = args[0]; mp_obj_t *new_args = alloca(n_args * sizeof(mp_obj_t)); memcpy(new_args + 1, args + 1, (n_args - 1) * sizeof(mp_obj_t)); - new_args[0] = MP_OBJ_NEW_SMALL_INT((mp_int_t)self->fd); + new_args[0] = MP_OBJ_NEW_SMALL_INT(self->fd); return mp_builtin_open(n_args, new_args); } STATIC MP_DEFINE_CONST_FUN_OBJ_VAR_BETWEEN(socket_makefile_obj, 1, 3, socket_makefile); @@ -321,7 +321,7 @@ STATIC const mp_obj_type_t microsocket_type = { #if MICROPY_SOCKET_EXTRA STATIC mp_obj_t mod_socket_htons(mp_obj_t arg) { - return MP_OBJ_NEW_SMALL_INT((mp_int_t)htons(MP_OBJ_SMALL_INT_VALUE(arg))); + return MP_OBJ_NEW_SMALL_INT(htons(MP_OBJ_SMALL_INT_VALUE(arg))); } STATIC MP_DEFINE_CONST_FUN_OBJ_1(mod_socket_htons_obj, mod_socket_htons); @@ -343,7 +343,7 @@ STATIC mp_obj_t mod_socket_gethostbyname(mp_obj_t arg) { struct hostent *h = gethostbyname(s); if (h == NULL) { // CPython: socket.herror - nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT((mp_int_t)h_errno))); + nlr_raise(mp_obj_new_exception_arg1(&mp_type_OSError, MP_OBJ_NEW_SMALL_INT(h_errno))); } assert(h->h_length == 4); return mp_obj_new_int(*(int*)*h->h_addr_list); @@ -397,9 +397,9 @@ STATIC mp_obj_t mod_socket_getaddrinfo(uint n_args, const mp_obj_t *args) { mp_obj_t list = mp_obj_new_list(0, NULL); for (struct addrinfo *addr = addr_list; addr; addr = addr->ai_next) { mp_obj_tuple_t *t = mp_obj_new_tuple(5, NULL); - t->items[0] = MP_OBJ_NEW_SMALL_INT((mp_int_t)addr->ai_family); - t->items[1] = MP_OBJ_NEW_SMALL_INT((mp_int_t)addr->ai_socktype); - t->items[2] = MP_OBJ_NEW_SMALL_INT((mp_int_t)addr->ai_protocol); + t->items[0] = MP_OBJ_NEW_SMALL_INT(addr->ai_family); + t->items[1] = MP_OBJ_NEW_SMALL_INT(addr->ai_socktype); + t->items[2] = MP_OBJ_NEW_SMALL_INT(addr->ai_protocol); // "canonname will be a string representing the canonical name of the host // if AI_CANONNAME is part of the flags argument; else canonname will be empty." ?? if (addr->ai_canonname) {