Skip to content

Commit 873f116

Browse files
committed
Returning and evaluating result of calling connectionCheck() directly instead of checking member variable _iotStatus
1 parent edbca65 commit 873f116

5 files changed

+13
-17
lines changed

src/ArduinoIoTCloud.h

+1-1
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ class ArduinoIoTCloudClass {
7878

7979
virtual int connected() = 0;
8080

81-
virtual void connectionCheck() = 0;
81+
virtual ArduinoIoTConnectionStatus connectionCheck() = 0;
8282

8383
virtual void printDebugInfo() = 0;
8484

src/ArduinoIoTCloudLPWAN.cpp

+5-7
Original file line numberDiff line numberDiff line change
@@ -60,11 +60,7 @@ void ArduinoIoTCloudLPWAN::update() {
6060
// Check if a primitive property wrapper is locally changed
6161
Thing.updateTimestampOnLocallyChangedProperties();
6262

63-
connectionCheck();
64-
65-
if (_iotStatus != ArduinoIoTConnectionStatus::CONNECTED) {
66-
return;
67-
}
63+
if(connectionCheck() != ArduinoIoTConnectionStatus::CONNECTED) return;
6864

6965
if (_connection->available()) {
7066
uint8_t msgBuf[DEFAULT_CBOR_LORA_MSG_SIZE];
@@ -86,7 +82,7 @@ void ArduinoIoTCloudLPWAN::update() {
8682

8783
}
8884

89-
void ArduinoIoTCloudLPWAN::connectionCheck() {
85+
ArduinoIoTConnectionStatus ArduinoIoTCloudLPWAN::connectionCheck() {
9086
if (_connection != NULL) {
9187

9288
_connection->check();
@@ -96,7 +92,7 @@ void ArduinoIoTCloudLPWAN::connectionCheck() {
9692
_iotStatus = ArduinoIoTConnectionStatus::DISCONNECTED;
9793
printConnectionStatus(_iotStatus);
9894
}
99-
return;
95+
return _iotStatus;
10096
}
10197
}
10298

@@ -147,6 +143,8 @@ void ArduinoIoTCloudLPWAN::connectionCheck() {
147143
}
148144
break;
149145
}
146+
147+
return _iotStatus;
150148
}
151149

152150
void ArduinoIoTCloudLPWAN::printDebugInfo() {

src/ArduinoIoTCloudLPWAN.h

+1-1
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ class ArduinoIoTCloudLPWAN : public ArduinoIoTCloudClass {
3131
bool disconnect();
3232
int connected();
3333
void update();
34-
void connectionCheck();
34+
ArduinoIoTConnectionStatus connectionCheck();
3535
void printDebugInfo();
3636
int begin(LPWANConnectionHandler& connection, bool retry = false);
3737
inline LPWANConnectionHandler* getConnection() {

src/ArduinoIoTCloudTCP.cpp

+5-7
Original file line numberDiff line numberDiff line change
@@ -201,11 +201,7 @@ void ArduinoIoTCloudTCP::update() {
201201
// Check if a primitive property wrapper is locally changed
202202
Thing.updateTimestampOnLocallyChangedProperties();
203203

204-
connectionCheck();
205-
206-
if (_iotStatus != ArduinoIoTConnectionStatus::CONNECTED) {
207-
return;
208-
}
204+
if(connectionCheck() != ArduinoIoTConnectionStatus::CONNECTED) return;
209205

210206
// MTTQClient connected!, poll() used to retrieve data from MQTT broker
211207
_mqttClient->poll();
@@ -337,7 +333,7 @@ void ArduinoIoTCloudTCP::requestLastValue() {
337333
writeShadowOut(CBOR_REQUEST_LAST_VALUE_MSG, sizeof(CBOR_REQUEST_LAST_VALUE_MSG));
338334
}
339335

340-
void ArduinoIoTCloudTCP::connectionCheck() {
336+
ArduinoIoTConnectionStatus ArduinoIoTCloudTCP::connectionCheck() {
341337

342338
if (_connection != NULL) {
343339

@@ -348,7 +344,7 @@ void ArduinoIoTCloudTCP::connectionCheck() {
348344
_iotStatus = ArduinoIoTConnectionStatus::DISCONNECTED;
349345
printConnectionStatus(_iotStatus);
350346
}
351-
return;
347+
return _iotStatus;
352348
}
353349
}
354350

@@ -403,6 +399,8 @@ void ArduinoIoTCloudTCP::connectionCheck() {
403399
}
404400
break;
405401
}
402+
403+
return _iotStatus;
406404
}
407405

408406
void ArduinoIoTCloudTCP::printDebugInfo() {

src/ArduinoIoTCloudTCP.h

+1-1
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ class ArduinoIoTCloudTCP: public ArduinoIoTCloudClass {
4444
bool disconnect();
4545
int connected();
4646
void update();
47-
void connectionCheck();
47+
ArduinoIoTConnectionStatus connectionCheck();
4848
void printDebugInfo();
4949
#ifdef BOARD_HAS_ECCX08
5050
int begin(TcpIpConnectionHandler & connection, String brokerAddress = DEFAULT_BROKER_ADDRESS_SECURE_AUTH, uint16_t brokerPort = DEFAULT_BROKER_PORT_SECURE_AUTH);

0 commit comments

Comments
 (0)