summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJeff Hatch <jhatch@multitech.com>2020-06-05 10:34:19 -0500
committerJeff Hatch <jhatch@multitech.com>2020-06-05 10:34:19 -0500
commitc34ebcd0df9c5bdbeb5638e9a5498cbee6bab628 (patch)
tree727ca1ecf1b91033dacd37447f6d70040c94eff4
parentb3a9a71afdb0d6f4f104543cedba89d011ca68df (diff)
parentc9b6389ac4e53315e7d543091c821ea4b9771ed3 (diff)
downloadlibmts-io-c34ebcd0df9c5bdbeb5638e9a5498cbee6bab628.tar.gz
libmts-io-c34ebcd0df9c5bdbeb5638e9a5498cbee6bab628.tar.bz2
libmts-io-c34ebcd0df9c5bdbeb5638e9a5498cbee6bab628.zip
Merge branch 'sk/quectel-oma-dm' into 'mpower-5.2-lna7'
[GP-651] LNA7: Allow to start the OMA DM procedure when it is required See merge request !22
-rw-r--r--include/mts/MTS_IO_CellularRadio.h1
-rw-r--r--include/mts/MTS_IO_ICellularRadio.h3
-rw-r--r--include/mts/MTS_IO_QuectelRadio.h1
-rw-r--r--src/MTS_IO_CellularRadio.cpp6
-rw-r--r--src/MTS_IO_QuectelRadio.cpp92
5 files changed, 103 insertions, 0 deletions
diff --git a/include/mts/MTS_IO_CellularRadio.h b/include/mts/MTS_IO_CellularRadio.h
index 56506af..7f4ed2b 100644
--- a/include/mts/MTS_IO_CellularRadio.h
+++ b/include/mts/MTS_IO_CellularRadio.h
@@ -100,6 +100,7 @@ namespace MTS {
CODE updateFumo(const Json::Value& jArgs, UpdateCb& stepCb) override;
CODE resetHfa(const Json::Value& jArgs, UpdateCb& stepCb) override;
CODE activate(const Json::Value& jArgs, UpdateCb& stepCb) override;
+ CODE startOmaDm(UpdateCb& stepCb) override;
CODE setActiveFirmware(const Json::Value& jArgs) override;
CODE getActiveFirmware(std::string& sFwId) override;
CODE getEcho(bool& bEnabled) override;
diff --git a/include/mts/MTS_IO_ICellularRadio.h b/include/mts/MTS_IO_ICellularRadio.h
index 58d5076..c301191 100644
--- a/include/mts/MTS_IO_ICellularRadio.h
+++ b/include/mts/MTS_IO_ICellularRadio.h
@@ -431,6 +431,9 @@ namespace MTS {
* "fwid" : "Firmware Image To Be Enabled: STRING"
* }
*/
+
+ virtual CODE startOmaDm(UpdateCb& stepCb) = 0;
+
virtual CODE setActiveFirmware(const Json::Value& jArgs) = 0;
virtual CODE getActiveFirmware(std::string& sFwId) = 0;
diff --git a/include/mts/MTS_IO_QuectelRadio.h b/include/mts/MTS_IO_QuectelRadio.h
index df3b5b5..1dc45cd 100644
--- a/include/mts/MTS_IO_QuectelRadio.h
+++ b/include/mts/MTS_IO_QuectelRadio.h
@@ -41,6 +41,7 @@ namespace MTS {
CODE convertdBmToSignalStrength(const int32_t& dBm, int32_t& iRssi) override;
CODE setMdn(const Json::Value& jArgs) override;
+ CODE startOmaDm(ICellularRadio::UpdateCb& stepCb) override;
protected:
QuectelRadio(const std::string& sName, const std::string& sRadioPort);
diff --git a/src/MTS_IO_CellularRadio.cpp b/src/MTS_IO_CellularRadio.cpp
index 50fdf5c..648894f 100644
--- a/src/MTS_IO_CellularRadio.cpp
+++ b/src/MTS_IO_CellularRadio.cpp
@@ -1020,6 +1020,12 @@ ICellularRadio::CODE CellularRadio::activate(const Json::Value&, UpdateCb&) {
return NOT_APPLICABLE;
}
+ICellularRadio::CODE CellularRadio::startOmaDm(ICellularRadio::UpdateCb&) {
+ printTrace("%s| Start OMA DM procedure: not applicable", m_sName.c_str());
+
+ return NOT_APPLICABLE;
+}
+
ICellularRadio::CODE CellularRadio::setActiveFirmware(const Json::Value&) {
printTrace("%s| Set Active Firmware Image Number: not applicable", m_sName.c_str());
diff --git a/src/MTS_IO_QuectelRadio.cpp b/src/MTS_IO_QuectelRadio.cpp
index c4bdc56..4498919 100644
--- a/src/MTS_IO_QuectelRadio.cpp
+++ b/src/MTS_IO_QuectelRadio.cpp
@@ -436,6 +436,98 @@ ICellularRadio::CODE QuectelRadio::setMdn(const Json::Value& jArgs) {
return NOT_APPLICABLE;
}
+ICellularRadio::CODE QuectelRadio::startOmaDm(ICellularRadio::UpdateCb& stepCb) {
+ printTrace("%s| Start OMA DM procedure", getName().c_str());
+
+ // TODO: All the timeout values below are empirically defined.
+ // Feel free to update them if you get any verified information.
+ const int32_t iTimeoutOk = 3 * 1000; // 3 seconds
+ const int32_t iTimeoutStart = 5 * 1000; // 5 seconds
+ const int32_t iTimeoutEnd = 160 * 1000; // 2 minutes 40 seconds
+ const int32_t iTimeoutAbort = 3 * 1000; // 3 seconds
+
+ const std::string sCmdOdmStart = "AT+QODM=\"dme\",2,\"ui\"";
+ const std::string sCmdOdmAbort = "AT+QODM=\"dme\",2,\"kill\"";
+
+ const std::string sOdmStarted = "DM Start";
+ const std::string sOdmFinished = "DM End";
+ const std::string sOdmAbnormal = "DME Abnormal";
+
+ const std::vector<std::string> vOdmStartedStrings{ sOdmStarted };
+ const std::vector<std::string> vOdmFinishedStrings{ sOdmFinished, sOdmAbnormal };
+
+ CODE eCode;
+
+ do {
+
+ // Send command and expect "OK" in iTimeoutOk milliseconds
+ eCode = sendBasicCommand(sCmdOdmStart, iTimeoutOk);
+ if (eCode != SUCCESS) {
+ printError("%s| OMA DM procedure can not be started", getName().c_str());
+ if (stepCb) {
+ stepCb(Json::Value("OMA DM Error: OMA DM can not be started"));
+ }
+ break;
+ }
+
+ // Wait for the "Start" response
+ std::string sResponse = sendCommand("", vOdmStartedStrings, iTimeoutStart, 0x00);
+ printDebug("%s| Radio returned: [%s]", getName().c_str(), sResponse.c_str());
+
+ // Received something unexpected or nothing at all?
+ if (sResponse.find(sOdmStarted) == std::string::npos) {
+ printError("%s| OMA DM procedure failed due to timeout", getName().c_str());
+ if (stepCb) {
+ stepCb(Json::Value("OMA DM Error: OMA DM failed due to timeout"));
+ }
+ eCode = FAILURE;
+ break;
+ }
+
+ // Got "DM Started" message from the radio
+ printTrace("%s| OMA DM started", getName().c_str());
+ if (stepCb) {
+ stepCb(Json::Value("OMA DM Info: OMA DM started"));
+ }
+
+ // Wait for the "End" or "Abnormal" response
+ sResponse = sendCommand("", vOdmFinishedStrings, iTimeoutEnd, 0x00);
+ printDebug("%s| Radio returned: [%s]", getName().c_str(), sResponse.c_str());
+
+ // Received "Abnormal"?
+ if (sResponse.find(sOdmAbnormal) != std::string::npos) {
+ printError("%s| OMA DM procedure failed due to internal error: [%s]", getName().c_str(), sResponse.c_str());
+ if (stepCb) {
+ stepCb(Json::Value("OMA DM Error: OMA DM failed due to internal error"));
+ }
+ eCode = FAILURE;
+ break;
+ }
+
+ // Received something unexpected or nothing at all?
+ if (sResponse.find(sOdmFinished) == std::string::npos) {
+ printError("%s| OMA DM procedure failed due to timeout", getName().c_str());
+ if (stepCb) {
+ stepCb(Json::Value("OMA DM Error: OMA DM failed due to timeout"));
+ }
+ sendBasicCommand(sCmdOdmAbort, iTimeoutAbort); // abort the procedure
+ eCode = FAILURE;
+ break;
+ }
+
+ // Got "DM End" message from the radio
+ printTrace("%s| OMA DM finished", getName().c_str());
+ if (stepCb) {
+ stepCb(Json::Value("OMA DM Info: OMA DM finished"));
+ }
+
+ eCode = SUCCESS;
+
+ } while (false);
+
+ return eCode;
+}
+
ICellularRadio::CODE QuectelRadio::getServiceDomain(ICellularRadio::SERVICEDOMAIN& sd) {
printTrace("%s| Get Service Domain", getName().c_str());