From f5ee3a5e65a8c1bddae503e31a1aa51684931f00 Mon Sep 17 00:00:00 2001
From: Jiacheng Guo <gjc@google.com>
Date: Thu, 25 Apr 2019 07:06:39 +0800
Subject: [PATCH] [posix-app] timeout for rcp radio driver (#3749)

---
 src/posix/platform/radio_spinel.cpp | 36 +++++++++++++++++++++++++++--
 src/posix/platform/radio_spinel.hpp |  2 ++
 2 files changed, 36 insertions(+), 2 deletions(-)

diff --git a/src/posix/platform/radio_spinel.cpp b/src/posix/platform/radio_spinel.cpp
index 39f6351c7..ef9b7ee56 100644
--- a/src/posix/platform/radio_spinel.cpp
+++ b/src/posix/platform/radio_spinel.cpp
@@ -55,6 +55,10 @@
 #include <openthread/platform/diag.h>
 #include <openthread/platform/radio.h>
 
+#ifndef TX_WAIT_US
+#define TX_WAIT_US (5 * US_PER_S)
+#endif
+
 static ot::PosixApp::RadioSpinel sRadioSpinel;
 
 namespace ot {
@@ -176,6 +180,7 @@ RadioSpinel::RadioSpinel(void)
     , mDiagOutput(NULL)
     , mDiagOutputMaxLen(0)
 #endif
+    , mTxRadioEndUs(UINT64_MAX)
 {
     mVersion[0] = '\0';
 }
@@ -704,6 +709,26 @@ void RadioSpinel::UpdateFdSet(fd_set &aReadFdSet, fd_set &aWriteFdSet, int &aMax
     {
         FD_SET(sockFd, &aWriteFdSet);
     }
+    else if (mState == kStateTransmitting)
+    {
+        uint64_t now = otSysGetTime();
+
+        if (now < mTxRadioEndUs)
+        {
+            uint64_t remain = mTxRadioEndUs - now;
+
+            if (remain < static_cast<uint64_t>(aTimeout.tv_sec * US_PER_S + aTimeout.tv_usec))
+            {
+                aTimeout.tv_sec  = static_cast<time_t>(remain / US_PER_S);
+                aTimeout.tv_usec = static_cast<suseconds_t>(remain % US_PER_S);
+            }
+        }
+        else
+        {
+            aTimeout.tv_sec  = 0;
+            aTimeout.tv_usec = 0;
+        }
+    }
 
     if (mHdlcInterface.GetRxFrameBuffer().HasSavedFrame() || (mState == kStateTransmitDone))
     {
@@ -730,7 +755,8 @@ void RadioSpinel::Process(const fd_set &aReadFdSet, const fd_set &aWriteFdSet)
 
     if (mState == kStateTransmitDone)
     {
-        mState = kStateReceive;
+        mState        = kStateReceive;
+        mTxRadioEndUs = UINT64_MAX;
 
 #if OPENTHREAD_ENABLE_DIAG
         if (otPlatDiagModeGet())
@@ -744,6 +770,11 @@ void RadioSpinel::Process(const fd_set &aReadFdSet, const fd_set &aWriteFdSet)
                               mTxError);
         }
     }
+    else if (mState == kStateTransmitting && otSysGetTime() >= mTxRadioEndUs)
+    {
+        otLogCritPlat("radio tx timeout, exit");
+        exit(OT_EXIT_FAILURE);
+    }
 
     if (FD_ISSET(mHdlcInterface.GetSocket(), &aWriteFdSet))
     {
@@ -1075,7 +1106,8 @@ void RadioSpinel::RadioTransmit(void)
 
     if (error == OT_ERROR_NONE)
     {
-        mState = kStateTransmitting;
+        mTxRadioEndUs = otSysGetTime() + TX_WAIT_US;
+        mState        = kStateTransmitting;
     }
     else
     {
diff --git a/src/posix/platform/radio_spinel.hpp b/src/posix/platform/radio_spinel.hpp
index 8800363a4..f9053636e 100644
--- a/src/posix/platform/radio_spinel.hpp
+++ b/src/posix/platform/radio_spinel.hpp
@@ -622,6 +622,8 @@ private:
     char * mDiagOutput;
     size_t mDiagOutputMaxLen;
 #endif
+
+    uint64_t mTxRadioEndUs;
 };
 
 } // namespace PosixApp