thread locks seem to work in sim767x.py

Author: James Boulton

Examples/ex05_SIM767X.py

@@ -27,7 +27,7 @@
 config_dict = dashio.decode_cfg64(cfg64)
 device = dashio.Device("aDeviceType", "aDeviceID", "Fred", cfg_dict=config_dict)
 # lte_con = lte_767x_connection.Lte767xConnection("iot.gdsp.nz", "username", "password", 'dash.dashio.io', 8883, "/dev/tty.usbserial-143110", 115200, None)
-lte_con = lte_767x_connection.Lte767xConnection("iot.gdsp.nz", "craig", "ThingyThing", 'dash.dashio.io', 8883, "/dev/cu.usbmodem0000000000013", 115200, None)
+lte_con = lte_767x_connection.Lte767xConnection("iot.gdsp.nz", "", "", 'dash.dashio.io', 8883, "/dev/cu.usbmodem0000000000013", 115200, None)
 lte_con.add_device(device)
 
 tcp_con = dashio.TCPConnection()

dashio/sim767x.py

@@ -169,7 +169,7 @@ def __init__(self, serial_port: str, network: str, apn: str, baud_rate: int):
         self.start_serial()
         self._serial_at.flush()
         self._sched = Schedular("LTE Connection Schedular")
-        self._sched.add_timer(0.01, 0.0, self._run_processing)
+        self._sched.add_timer(0.001, 0.0, self._run_processing)
         self._sched.add_timer(1.0, 0.25, self._run_one_second_module_tasks)
         self._sched.add_timer(1.0, 0.5, self._run_one_second_mqtt_tasks)
         self._sched.add_timer(1.0, 0.75, self._run_one_second_gnss_tasks)
@@ -328,10 +328,9 @@ def _run_processing(self, cookie: Any):
                 if self._sub_topic:
                     self._mqtt_req_subscribe()
                 if self._messages_dict:
-                    with self._messages_dict_lock:
-                        d_topic = list(self._messages_dict.keys())[0]
-                        self._mqtt_request_publish(d_topic, self._messages_dict[d_topic])
-                        del self._messages_dict[d_topic]
+                    self._messages_dict_lock.acquire()
+                    d_topic = list(self._messages_dict.keys())[0]
+                    self._mqtt_request_publish(d_topic, self._messages_dict[d_topic])
         return True
 
     def _process_at_commands(self):
@@ -486,9 +485,9 @@ def _process_at_commands(self):
                                 if len(result_arr) >= 2:
                                     error = int(result_arr[1])
                                     if error == 0:
-                                        with self._messages_dict_lock:
-                                            if self._pub_topic in self._messages_dict:
-                                                del self._messages_dict[self._pub_topic]
+                                        if self._pub_topic in self._messages_dict:
+                                            del self._messages_dict[self._pub_topic]
+                                            self._messages_dict_lock.release()
                                         if self.mqtt_is_finished():
                                             self._pub_topic = ""
                                             self._tx_message = ""