Compare commits

...

10 Commits
main ... 6.0.x

Author SHA1 Message Date
Dan Halbert
aecb8a53bd
Merge pull request #3990 from jepler/make-dependency-race
ports/unix: Fix parallel build problem
2021-01-14 14:53:39 -05:00
Jeff Epler
b204778385 ports/unix: Fix parallel build problem
This is the same as I added to mpy-cross at e666e86035, see #3074
2021-01-13 15:40:20 -06:00
Dan Halbert
eda1f811a1
Merge pull request #3872 from dhalbert/frequencyin-fix-6.0.x-to-6.0.x
Backport #3867 (FrequencyIn fix) to 6.0.x
2020-12-23 17:49:18 -05:00
Scott Shawcroft
baa053b8b2
Merge pull request #3870 from dhalbert/speedup_json-6.0.x
Speed up JSON parsing with readinto (#3728 for 6.0.x)
2020-12-23 12:56:19 -08:00
Dan Halbert
eb03e4ba59 FrequencyIn: do not raise in interrupt handler 2020-12-23 15:38:23 -05:00
Scott Shawcroft
fc1f47d0d2 Ignore size parameter 2020-12-23 13:49:11 -05:00
Scott Shawcroft
ebc765e1e0 Speed up JSON parsing with readinto
Get a chunk of data from readinto instead of a single byte. This
speeds up the parsing by reducing the number of function calls.

Fixes #3703
2020-12-23 13:49:05 -05:00
Scott Shawcroft
3266720f15
Merge pull request #3861 from dhalbert/ble-fixes-6.0.x
BLE fixes
2020-12-22 10:10:42 -08:00
Dan Halbert
078a799078 make translate 2020-12-21 23:48:49 -05:00
Dan Halbert
6fd9c4803b BLE fixes 2020-12-21 22:58:17 -05:00
8 changed files with 69 additions and 20 deletions

View File

@ -57,6 +57,8 @@ typedef struct _ujson_stream_t {
int errcode; int errcode;
mp_obj_t python_readinto[2 + 1]; mp_obj_t python_readinto[2 + 1];
mp_obj_array_t bytearray_obj; mp_obj_array_t bytearray_obj;
size_t start;
size_t end;
byte cur; byte cur;
} ujson_stream_t; } ujson_stream_t;
@ -77,28 +79,44 @@ STATIC byte ujson_stream_next(ujson_stream_t *s) {
return s->cur; return s->cur;
} }
// We read from an object's `readinto` method in chunks larger than the json
// parser needs to reduce the number of function calls done.
#define CIRCUITPY_JSON_READ_CHUNK_SIZE 64
STATIC mp_uint_t ujson_python_readinto(mp_obj_t obj, void *buf, mp_uint_t size, int *errcode) { STATIC mp_uint_t ujson_python_readinto(mp_obj_t obj, void *buf, mp_uint_t size, int *errcode) {
(void) size; // Ignore size because we know it's always 1.
ujson_stream_t* s = obj; ujson_stream_t* s = obj;
s->bytearray_obj.items = buf;
s->bytearray_obj.len = size; if (s->start == s->end) {
*errcode = 0; *errcode = 0;
mp_obj_t ret = mp_call_method_n_kw(1, 0, s->python_readinto); mp_obj_t ret = mp_call_method_n_kw(1, 0, s->python_readinto);
if (ret == mp_const_none) { if (ret == mp_const_none) {
*errcode = MP_EAGAIN; *errcode = MP_EAGAIN;
return MP_STREAM_ERROR; return MP_STREAM_ERROR;
}
s->start = 0;
s->end = mp_obj_get_int(ret);
} }
return mp_obj_get_int(ret);
*((uint8_t *)buf) = ((uint8_t*) s->bytearray_obj.items)[s->start];
s->start++;
return 1;
} }
STATIC mp_obj_t _mod_ujson_load(mp_obj_t stream_obj, bool return_first_json) { STATIC mp_obj_t _mod_ujson_load(mp_obj_t stream_obj, bool return_first_json) {
const mp_stream_p_t *stream_p = mp_proto_get(MP_QSTR_protocol_stream, stream_obj); const mp_stream_p_t *stream_p = mp_proto_get(MP_QSTR_protocol_stream, stream_obj);
ujson_stream_t s; ujson_stream_t s;
uint8_t character_buffer[CIRCUITPY_JSON_READ_CHUNK_SIZE];
if (stream_p == NULL) { if (stream_p == NULL) {
s.start = 0;
s.end = 0;
mp_load_method(stream_obj, MP_QSTR_readinto, s.python_readinto); mp_load_method(stream_obj, MP_QSTR_readinto, s.python_readinto);
s.bytearray_obj.base.type = &mp_type_bytearray; s.bytearray_obj.base.type = &mp_type_bytearray;
s.bytearray_obj.typecode = BYTEARRAY_TYPECODE; s.bytearray_obj.typecode = BYTEARRAY_TYPECODE;
s.bytearray_obj.len = CIRCUITPY_JSON_READ_CHUNK_SIZE;
s.bytearray_obj.free = 0; s.bytearray_obj.free = 0;
// len and items are set at read time s.bytearray_obj.items = character_buffer;
s.python_readinto[2] = MP_OBJ_FROM_PTR(&s.bytearray_obj); s.python_readinto[2] = MP_OBJ_FROM_PTR(&s.bytearray_obj);
s.stream_obj = &s; s.stream_obj = &s;
s.read = ujson_python_readinto; s.read = ujson_python_readinto;

View File

@ -8,7 +8,7 @@ msgid ""
msgstr "" msgstr ""
"Project-Id-Version: PACKAGE VERSION\n" "Project-Id-Version: PACKAGE VERSION\n"
"Report-Msgid-Bugs-To: \n" "Report-Msgid-Bugs-To: \n"
"POT-Creation-Date: 2020-11-04 21:18+0530\n" "POT-Creation-Date: 2020-12-21 23:48-0500\n"
"PO-Revision-Date: YEAR-MO-DA HO:MI+ZONE\n" "PO-Revision-Date: YEAR-MO-DA HO:MI+ZONE\n"
"Last-Translator: FULL NAME <EMAIL@ADDRESS>\n" "Last-Translator: FULL NAME <EMAIL@ADDRESS>\n"
"Language-Team: LANGUAGE <LL@li.org>\n" "Language-Team: LANGUAGE <LL@li.org>\n"
@ -2861,7 +2861,7 @@ msgid "max_length must be 0-%d when fixed_length is %s"
msgstr "" msgstr ""
#: shared-bindings/_bleio/Characteristic.c shared-bindings/_bleio/Descriptor.c #: shared-bindings/_bleio/Characteristic.c shared-bindings/_bleio/Descriptor.c
msgid "max_length must be > 0" msgid "max_length must be >= 0"
msgstr "" msgstr ""
#: py/runtime.c #: py/runtime.c
@ -2999,6 +2999,14 @@ msgstr ""
msgid "non-keyword arg after keyword arg" msgid "non-keyword arg after keyword arg"
msgstr "" msgstr ""
#: ports/nrf/common-hal/_bleio/Adapter.c
msgid "non-zero timeout must be > 0.01"
msgstr ""
#: shared-bindings/_bleio/Adapter.c
msgid "non-zero timeout must be >= interval"
msgstr ""
#: shared-bindings/_bleio/UUID.c #: shared-bindings/_bleio/UUID.c
msgid "not a 128-bit UUID" msgid "not a 128-bit UUID"
msgstr "" msgstr ""
@ -3400,6 +3408,10 @@ msgstr ""
msgid "timeout must be 0.0-100.0 seconds" msgid "timeout must be 0.0-100.0 seconds"
msgstr "" msgstr ""
#: ports/nrf/common-hal/_bleio/Adapter.c
msgid "timeout must be < 655.35 secs"
msgstr ""
#: shared-bindings/_bleio/CharacteristicBuffer.c #: shared-bindings/_bleio/CharacteristicBuffer.c
msgid "timeout must be >= 0.0" msgid "timeout must be >= 0.0"
msgstr "" msgstr ""

View File

@ -82,7 +82,8 @@ void frequencyin_emergency_cancel_capture(uint8_t index) {
#ifdef SAM_D5X_E5X #ifdef SAM_D5X_E5X
NVIC_EnableIRQ(EIC_0_IRQn + self->channel); NVIC_EnableIRQ(EIC_0_IRQn + self->channel);
#endif #endif
mp_raise_RuntimeError(translate("Frequency captured is above capability. Capture Paused.")); // Frequency captured is above capability. Capture paused.
// We can't raise an error here; we're in an interrupt handler.
} }
void frequencyin_interrupt_handler(uint8_t index) { void frequencyin_interrupt_handler(uint8_t index) {

View File

@ -470,7 +470,16 @@ mp_obj_t common_hal_bleio_adapter_start_scan(bleio_adapter_obj_t *self, uint8_t*
ble_drv_add_event_handler(scan_on_ble_evt, self->scan_results); ble_drv_add_event_handler(scan_on_ble_evt, self->scan_results);
uint32_t nrf_timeout = SEC_TO_UNITS(timeout, UNIT_10_MS); uint32_t nrf_timeout = SEC_TO_UNITS(timeout, UNIT_10_MS);
if (timeout <= 0.0001) { if (nrf_timeout > UINT16_MAX) {
// 0xffff / 100
mp_raise_ValueError(translate("timeout must be < 655.35 secs"));
}
if (nrf_timeout == 0 && timeout > 0.0f) {
// Make sure converted timeout is > 0 if original timeout is > 0.
mp_raise_ValueError(translate("non-zero timeout must be > 0.01"));
}
if (nrf_timeout) {
nrf_timeout = BLE_GAP_SCAN_TIMEOUT_UNLIMITED; nrf_timeout = BLE_GAP_SCAN_TIMEOUT_UNLIMITED;
} }

View File

@ -318,3 +318,5 @@ $(BUILD)/libaxtls.a: $(TOP)/lib/axtls/README | $(OBJ_DIRS)
$(TOP)/lib/axtls/README: $(TOP)/lib/axtls/README:
@echo "You cloned without --recursive, fetching submodules for you." @echo "You cloned without --recursive, fetching submodules for you."
(cd $(TOP); git submodule update --init --recursive) (cd $(TOP); git submodule update --init --recursive)
$(BUILD)/supervisor/shared/translate.o: $(HEADER_BUILD)/qstrdefs.generated.h

View File

@ -33,8 +33,8 @@
#include "shared-bindings/_bleio/Address.h" #include "shared-bindings/_bleio/Address.h"
#include "shared-bindings/_bleio/Adapter.h" #include "shared-bindings/_bleio/Adapter.h"
#define ADV_INTERVAL_MIN (0.0020f) #define ADV_INTERVAL_MIN (0.02001f)
#define ADV_INTERVAL_MIN_STRING "0.0020" #define ADV_INTERVAL_MIN_STRING "0.02001"
#define ADV_INTERVAL_MAX (10.24f) #define ADV_INTERVAL_MAX (10.24f)
#define ADV_INTERVAL_MAX_STRING "10.24" #define ADV_INTERVAL_MAX_STRING "10.24"
// 20ms is recommended by Apple // 20ms is recommended by Apple
@ -307,7 +307,7 @@ STATIC mp_obj_t bleio_adapter_start_scan(size_t n_args, const mp_obj_t *pos_args
mp_arg_val_t args[MP_ARRAY_SIZE(allowed_args)]; mp_arg_val_t args[MP_ARRAY_SIZE(allowed_args)];
mp_arg_parse_all(n_args - 1, pos_args + 1, kw_args, MP_ARRAY_SIZE(allowed_args), allowed_args, args); mp_arg_parse_all(n_args - 1, pos_args + 1, kw_args, MP_ARRAY_SIZE(allowed_args), allowed_args, args);
mp_float_t timeout = 0; mp_float_t timeout = 0.0f;
if (args[ARG_timeout].u_obj != mp_const_none) { if (args[ARG_timeout].u_obj != mp_const_none) {
timeout = mp_obj_get_float(args[ARG_timeout].u_obj); timeout = mp_obj_get_float(args[ARG_timeout].u_obj);
} }
@ -325,6 +325,13 @@ STATIC mp_obj_t bleio_adapter_start_scan(size_t n_args, const mp_obj_t *pos_args
mp_raise_ValueError_varg(translate("interval must be in range %s-%s"), INTERVAL_MIN_STRING, INTERVAL_MAX_STRING); mp_raise_ValueError_varg(translate("interval must be in range %s-%s"), INTERVAL_MIN_STRING, INTERVAL_MAX_STRING);
} }
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wfloat-equal"
if (timeout != 0.0f && timeout < interval) {
mp_raise_ValueError(translate("non-zero timeout must be >= interval"));
}
#pragma GCC diagnostic pop
const mp_float_t window = mp_obj_float_get(args[ARG_window].u_obj); const mp_float_t window = mp_obj_float_get(args[ARG_window].u_obj);
if (window > interval) { if (window > interval) {
mp_raise_ValueError(translate("window must be <= interval")); mp_raise_ValueError(translate("window must be <= interval"));

View File

@ -110,8 +110,8 @@ STATIC mp_obj_t bleio_characteristic_add_to_service(size_t n_args, const mp_obj_
common_hal_bleio_attribute_security_mode_check_valid(write_perm); common_hal_bleio_attribute_security_mode_check_valid(write_perm);
const mp_int_t max_length_int = args[ARG_max_length].u_int; const mp_int_t max_length_int = args[ARG_max_length].u_int;
if (max_length_int <= 0) { if (max_length_int < 0) {
mp_raise_ValueError(translate("max_length must be > 0")); mp_raise_ValueError(translate("max_length must be >= 0"));
} }
const size_t max_length = (size_t) max_length_int; const size_t max_length = (size_t) max_length_int;
const bool fixed_length = args[ARG_fixed_length].u_bool; const bool fixed_length = args[ARG_fixed_length].u_bool;

View File

@ -101,8 +101,8 @@ STATIC mp_obj_t bleio_descriptor_add_to_characteristic(size_t n_args, const mp_o
common_hal_bleio_attribute_security_mode_check_valid(write_perm); common_hal_bleio_attribute_security_mode_check_valid(write_perm);
const mp_int_t max_length_int = args[ARG_max_length].u_int; const mp_int_t max_length_int = args[ARG_max_length].u_int;
if (max_length_int <= 0) { if (max_length_int < 0) {
mp_raise_ValueError(translate("max_length must be > 0")); mp_raise_ValueError(translate("max_length must be >= 0"));
} }
const size_t max_length = (size_t) max_length_int; const size_t max_length = (size_t) max_length_int;
const bool fixed_length = args[ARG_fixed_length].u_bool; const bool fixed_length = args[ARG_fixed_length].u_bool;