add retry

Author: fabik111

src/ArduinoIoTCloudLPWAN.cpp

@@ -52,10 +52,13 @@ int ArduinoIoTCloudLPWAN::connected()
 	return state;
 }
 
-int ArduinoIoTCloudLPWAN::begin(LPWANConnectionHandler& connection)
+int ArduinoIoTCloudLPWAN::begin(LPWANConnectionHandler& connection, bool retry)
 {
 	_connection = &connection;
 	_connection->init();
+	_retryEnable = retry;
+	_maxNumRetry = 5;
+	_intervalRetry = 1000;
 	Thing.begin();
 	return 1;
 }
@@ -166,18 +169,37 @@ void ArduinoIoTCloudLPWAN::printDebugInfo() {
 
 
 int ArduinoIoTCloudLPWAN::writeProperties(const byte data[], int length) {
-	_connection->write(data, length);
-
+	int retcode = _connection->write(data, length);
+	int i = 0;
+	while (_retryEnable && retcode < 0 && i < _maxNumRetry) {
+		delay(_intervalRetry);
+		retcode = _connection->write(data, length);
+		i++;
+	}
+	
 	return 1;
 }
 
 int ArduinoIoTCloudLPWAN::writeStdout(const byte data[], int length) {
-	_connection->write(data, length);
+	int retcode = _connection->write(data, length);
+	int i = 0;
+	while (_retryEnable && retcode < 0 && i < _maxNumRetry) {
+		delay(_intervalRetry);
+		retcode = _connection->write(data, length);
+		i++;
+	}
+
 	return 1;
 }
 
 int ArduinoIoTCloudLPWAN::writeShadowOut(const byte data[], int length) {
-	_connection->write(data, length);
+	int retcode = _connection->write(data, length);
+	int i = 0;
+	while (_retryEnable && retcode < 0 && i < _maxNumRetry) {
+		delay(_intervalRetry);
+		retcode = _connection->write(data, length);
+		i++;
+	}
 	return 1;
 }
 

src/ArduinoIoTCloudLPWAN.h

@@ -41,11 +41,33 @@ class ArduinoIoTCloudLPWAN : public ArduinoIoTCloudClass {
 		void update(CallbackFunc onSyncCompleteCallback) __attribute__((deprecated));
 		void connectionCheck();
 		void printDebugInfo();
-		int begin(LPWANConnectionHandler& connection);
+		int begin(LPWANConnectionHandler& connection, bool retry = false);
 		inline LPWANConnectionHandler* getConnection() {
 			return _connection;
 		}
+		bool isRetryEnabled() {
+			return _retryEnable;
+		}
+
+		void enableRetry(bool val) {
+			_retryEnable = val;
+		}
+
+		int getMaxRetry() {
+			return _maxNumRetry;
+		}
 
+		void setMaxRetry(int val) {
+			_maxNumRetry = val;
+		}
+
+		long getIntervalRetry() {
+			return _intervalRetry;
+		}
+
+		void setIntervalRetry(long val) {
+			_intervalRetry = val;
+		}
 
 	protected:
 		int writeStdout(const byte data[], int length);
@@ -55,6 +77,9 @@ class ArduinoIoTCloudLPWAN : public ArduinoIoTCloudClass {
 	private:
 		LPWANConnectionHandler* _connection;
 		void sendPropertiesToCloud();
+		bool _retryEnable;
+		int _maxNumRetry;
+		long _intervalRetry;
 
 };