Skip to content

Commit 936b75c

Browse files
pennampennam
committed
Replace architecture specific watchdog handling functions with an unique implementation that takes care of the different architectures
1 parent 1b4168f commit 936b75c

File tree

6 files changed

+52
-42
lines changed

6 files changed

+52
-42
lines changed

‎src/ArduinoIoTCloudTCP.cpp

+6-14
Original file line numberDiff line numberDiff line change
@@ -282,13 +282,9 @@ int ArduinoIoTCloudTCP::begin(bool const enable_watchdog, String brokerAddress,
282282
* call to ArduinoIoTCloudTCP::update() it is wise to
283283
* set a rather large timeout at first.
284284
*/
285-
#ifdef ARDUINO_ARCH_SAMD
286-
if (enable_watchdog) {
287-
samd_watchdog_enable();
288-
}
289-
#elif defined(ARDUINO_ARCH_MBED)
285+
#if defined (ARDUINO_ARCH_SAMD) || (ARDUINO_ARCH_MBED)
290286
if (enable_watchdog) {
291-
mbed_watchdog_enable();
287+
watchdog_enable();
292288
}
293289
#endif
294290

@@ -300,10 +296,8 @@ void ArduinoIoTCloudTCP::update()
300296
/* Feed the watchdog. If any of the functions called below
301297
* get stuck than we can at least reset and recover.
302298
*/
303-
#ifdef ARDUINO_ARCH_SAMD
304-
samd_watchdog_reset();
305-
#elif defined(ARDUINO_ARCH_MBED)
306-
mbed_watchdog_reset();
299+
#if defined (ARDUINO_ARCH_SAMD) || (ARDUINO_ARCH_MBED)
300+
watchdog_reset();
307301
#endif
308302

309303

@@ -324,10 +318,8 @@ void ArduinoIoTCloudTCP::update()
324318
* maximum watchdog window is 8389ms; despite this we feed it for all
325319
* supported ARCH to keep code aligned.
326320
*/
327-
#ifdef ARDUINO_ARCH_SAMD
328-
samd_watchdog_reset();
329-
#elif defined(ARDUINO_ARCH_MBED)
330-
mbed_watchdog_reset();
321+
#if defined (ARDUINO_ARCH_SAMD) || (ARDUINO_ARCH_MBED)
322+
watchdog_reset();
331323
#endif
332324

333325
/* Check for new data from the MQTT client. */

‎src/utility/ota/OTA-nano-rp2040.cpp

+10-10
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ void URI::parse(const string& url_s)
8484

8585
int rp2040_connect_onOTARequest(char const * ota_url)
8686
{
87-
mbed_watchdog_reset();
87+
watchdog_reset();
8888

8989
int err = -1;
9090
FlashIAPBlockDevice flash(XIP_BASE + 0xF00000, 0x100000);
@@ -94,11 +94,11 @@ int rp2040_connect_onOTARequest(char const * ota_url)
9494
return static_cast<int>(OTAError::RP2040_ErrorFlashInit);
9595
}
9696

97-
mbed_watchdog_reset();
97+
watchdog_reset();
9898

9999
flash.erase(XIP_BASE + 0xF00000, 0x100000);
100100

101-
mbed_watchdog_reset();
101+
watchdog_reset();
102102

103103
mbed::FATFileSystem fs("ota");
104104
if ((err = fs.reformat(&flash)) != 0)
@@ -107,7 +107,7 @@ int rp2040_connect_onOTARequest(char const * ota_url)
107107
return static_cast<int>(OTAError::RP2040_ErrorReformat);
108108
}
109109

110-
mbed_watchdog_reset();
110+
watchdog_reset();
111111

112112
FILE * file = fopen("/ota/UPDATE.BIN.LZSS", "wb");
113113
if (!file)
@@ -117,7 +117,7 @@ int rp2040_connect_onOTARequest(char const * ota_url)
117117
return static_cast<int>(OTAError::RP2040_ErrorOpenUpdateFile);
118118
}
119119

120-
mbed_watchdog_reset();
120+
watchdog_reset();
121121

122122
URI url(ota_url);
123123
Client * client = nullptr;
@@ -135,7 +135,7 @@ int rp2040_connect_onOTARequest(char const * ota_url)
135135
return static_cast<int>(OTAError::RP2040_UrlParseError);
136136
}
137137

138-
mbed_watchdog_reset();
138+
watchdog_reset();
139139

140140
if (!client->connect(url.host_.c_str(), port))
141141
{
@@ -144,14 +144,14 @@ int rp2040_connect_onOTARequest(char const * ota_url)
144144
return static_cast<int>(OTAError::RP2040_ServerConnectError);
145145
}
146146

147-
mbed_watchdog_reset();
147+
watchdog_reset();
148148

149149
client->println(String("GET ") + url.path_.c_str() + " HTTP/1.1");
150150
client->println(String("Host: ") + url.host_.c_str());
151151
client->println("Connection: close");
152152
client->println();
153153

154-
mbed_watchdog_reset();
154+
watchdog_reset();
155155

156156
/* Receive HTTP header. */
157157
String http_header;
@@ -162,7 +162,7 @@ int rp2040_connect_onOTARequest(char const * ota_url)
162162
is_http_header_timeout = (millis() - start) > AIOT_CONFIG_RP2040_OTA_HTTP_HEADER_RECEIVE_TIMEOUT_ms;
163163
if (is_http_header_timeout) break;
164164

165-
mbed_watchdog_reset();
165+
watchdog_reset();
166166

167167
if (client->available())
168168
{
@@ -208,7 +208,7 @@ int rp2040_connect_onOTARequest(char const * ota_url)
208208
is_http_data_timeout = (millis() - start) > AIOT_CONFIG_RP2040_OTA_HTTP_DATA_RECEIVE_TIMEOUT_ms;
209209
if (is_http_data_timeout) break;
210210

211-
mbed_watchdog_reset();
211+
watchdog_reset();
212212

213213
if (client->available())
214214
{

‎src/utility/ota/OTA-portenta-h7.cpp

+6-6
Original file line numberDiff line numberDiff line change
@@ -34,33 +34,33 @@
3434

3535
int portenta_h7_onOTARequest(char const * ota_url)
3636
{
37-
mbed_watchdog_reset();
37+
watchdog_reset();
3838

3939
Arduino_Portenta_OTA::Error ota_portenta_err = Arduino_Portenta_OTA::Error::None;
4040
/* Use 2nd partition of QSPI (1st partition contains WiFi firmware) */
4141
Arduino_Portenta_OTA_QSPI ota_portenta_qspi(QSPI_FLASH_FATFS_MBR, 2);
4242

43-
mbed_watchdog_reset();
43+
watchdog_reset();
4444

4545
/* Initialize the QSPI memory for OTA handling. */
4646
if((ota_portenta_err = ota_portenta_qspi.begin()) != Arduino_Portenta_OTA::Error::None) {
4747
DEBUG_ERROR("Arduino_Portenta_OTA_QSPI::begin() failed with %d", static_cast<int>(ota_portenta_err));
4848
return static_cast<int>(ota_portenta_err);
4949
}
5050

51-
mbed_watchdog_reset();
51+
watchdog_reset();
5252

5353
/* Just to be safe delete any remains from previous updates. */
5454
remove("/fs/UPDATE.BIN");
5555
remove("/fs/UPDATE.BIN.LZSS");
5656

57-
mbed_watchdog_reset();
57+
watchdog_reset();
5858

5959
/* Download the OTA file from the web storage location. */
6060
int const ota_portenta_qspi_download_ret_code = ota_portenta_qspi.download(ota_url, true /* is_https */);
6161
DEBUG_VERBOSE("Arduino_Portenta_OTA_QSPI::download(%s) returns %d", ota_url, ota_portenta_qspi_download_ret_code);
6262

63-
mbed_watchdog_reset();
63+
watchdog_reset();
6464

6565
/* Decompress the LZSS compressed OTA file. */
6666
int const ota_portenta_qspi_decompress_ret_code = ota_portenta_qspi.decompress();
@@ -71,7 +71,7 @@ int portenta_h7_onOTARequest(char const * ota_url)
7171
return ota_portenta_qspi_decompress_ret_code;
7272
}
7373

74-
mbed_watchdog_reset();
74+
watchdog_reset();
7575

7676
/* Schedule the firmware update. */
7777
if((ota_portenta_err = ota_portenta_qspi.update()) != Arduino_Portenta_OTA::Error::None) {

‎src/utility/ota/OTA-samd.cpp

+2-2
Original file line numberDiff line numberDiff line change
@@ -38,14 +38,14 @@
3838

3939
int samd_onOTARequest(char const * ota_url)
4040
{
41-
samd_watchdog_reset();
41+
watchdog_reset();
4242

4343
#if OTA_STORAGE_SNU
4444
/* Just to be safe delete any remains from previous updates. */
4545
WiFiStorage.remove("/fs/UPDATE.BIN.LZSS");
4646
WiFiStorage.remove("/fs/UPDATE.BIN.LZSS.TMP");
4747

48-
samd_watchdog_reset();
48+
watchdog_reset();
4949

5050
/* Trigger direct download to nina module. */
5151
uint8_t nina_ota_err_code = 0;

‎src/utility/watchdog/Watchdog.cpp

+24-4
Original file line numberDiff line numberDiff line change
@@ -49,13 +49,13 @@ static bool is_watchdog_enabled = false;
4949
******************************************************************************/
5050

5151
#ifdef ARDUINO_ARCH_SAMD
52-
void samd_watchdog_enable()
52+
static void samd_watchdog_enable()
5353
{
5454
is_watchdog_enabled = true;
5555
Watchdog.enable(SAMD_WATCHDOG_MAX_TIME_ms);
5656
}
5757

58-
void samd_watchdog_reset()
58+
static void samd_watchdog_reset()
5959
{
6060
if (is_watchdog_enabled) {
6161
Watchdog.reset();
@@ -85,7 +85,7 @@ void mkr_nb_feed_watchdog()
8585
#endif /* ARDUINO_ARCH_SAMD */
8686

8787
#ifdef ARDUINO_ARCH_MBED
88-
void mbed_watchdog_enable()
88+
static void mbed_watchdog_enable()
8989
{
9090
watchdog_config_t cfg;
9191
#if defined(ARDUINO_PORTENTA_H7_M7) || defined(ARDUINO_PORTENTA_H7_M4)
@@ -104,7 +104,7 @@ void mbed_watchdog_enable()
104104
}
105105
}
106106

107-
void mbed_watchdog_reset()
107+
static void mbed_watchdog_reset()
108108
{
109109
if (is_watchdog_enabled) {
110110
hal_watchdog_kick();
@@ -132,3 +132,23 @@ void mbed_watchdog_trigger_reset()
132132

133133
}
134134
#endif /* ARDUINO_ARCH_MBED */
135+
136+
#if defined (ARDUINO_ARCH_SAMD) || (ARDUINO_ARCH_MBED)
137+
void watchdog_enable()
138+
{
139+
#ifdef ARDUINO_ARCH_SAMD
140+
samd_watchdog_enable();
141+
#else
142+
mbed_watchdog_enable();
143+
#endif
144+
}
145+
146+
void watchdog_reset()
147+
{
148+
#ifdef ARDUINO_ARCH_SAMD
149+
samd_watchdog_reset();
150+
#else
151+
mbed_watchdog_reset();
152+
#endif
153+
}
154+
#endif /* (ARDUINO_ARCH_SAMD) || (ARDUINO_ARCH_MBED) */

‎src/utility/watchdog/Watchdog.h

+4-6
Original file line numberDiff line numberDiff line change
@@ -22,14 +22,12 @@
2222
* FUNCTION DECLARATION
2323
******************************************************************************/
2424

25-
#ifdef ARDUINO_ARCH_SAMD
26-
void samd_watchdog_enable();
27-
void samd_watchdog_reset();
28-
#endif /* ARDUINO_ARCH_SAMD */
25+
#if defined (ARDUINO_ARCH_SAMD) || (ARDUINO_ARCH_MBED)
26+
void watchdog_enable();
27+
void watchdog_reset();
28+
#endif /* (ARDUINO_ARCH_SAMD) || (ARDUINO_ARCH_MBED) */
2929

3030
#ifdef ARDUINO_ARCH_MBED
31-
void mbed_watchdog_enable();
32-
void mbed_watchdog_reset();
3331
void mbed_watchdog_trigger_reset();
3432
#endif /* ARDUINO_ARCH_MBED */
3533

0 commit comments

Comments
 (0)