WIP

Author: maciejbaczmanski

include/openthread/platform/radio.h

@@ -1014,6 +1014,14 @@ otError otPlatRadioEnergyScan(otInstance *aInstance, uint8_t aScanChannel, uint1
  */
 extern void otPlatRadioEnergyScanDone(otInstance *aInstance, int8_t aEnergyScanMaxRssi);
 
+/**
+ * The radio driver calls this method to notify OpenThread that the spinel bus latency has been updated.
+ *
+ * @param[in]  aInstance  The OpenThread instance structure.
+ *
+ */
+extern void otPlatRadioBusLatencyUpdated(otInstance *aInstance);
+
 /**
  * Enable/Disable source address match feature.
  *

include/openthread/thread_ftd.h

@@ -953,15 +953,6 @@ void otThreadGetNextHopAndPathCost(otInstance *aInstance,
                                    uint16_t   *aNextHopRloc16,
                                    uint8_t    *aPathCost);
 
-/**
- * Calculates and updates value of CSL Frame Request Ahead, based on bus speed, bus latency and
- * `OPENTHREAD_CONFIG_MAC_CSL_REQUEST_AHEAD_US`.
- *
- * @param[in] aInstance A pointer to an OpenThread instance.
- *
- */
-void otThreadUpdateFrameRequestAhead(otInstance *aInstance);
-
 /**
  * @}
  *

src/core/api/thread_ftd_api.cpp

@@ -428,12 +428,4 @@ void otThreadGetNextHopAndPathCost(otInstance *aInstance,
         (aPathCost != nullptr) ? *aPathCost : pathcost);
 }
 
-#if OPENTHREAD_CONFIG_MAC_CSL_TRANSMITTER_ENABLE
-void otThreadUpdateFrameRequestAhead(otInstance *aInstance)
-{
-    AsCoreType(aInstance).Get<CslTxScheduler>().UpdateFrameRequestAhead();
-}
-
-#endif // OPENTHREAD_CONFIG_MAC_CSL_TRANSMITTER_ENABLE
-
 #endif // OPENTHREAD_FTD

src/core/radio/radio.hpp

@@ -229,6 +229,12 @@ class Radio : public InstanceLocator, private NonCopyable
          */
         void HandleEnergyScanDone(int8_t aMaxRssi);
 
+        /**
+         * This callback method handles "Bus Latency Updated" event from radio platform.
+         *
+         */
+        void HandleBusLatencyUpdated(void);
+
 #if OPENTHREAD_CONFIG_DIAG_ENABLE
         /**
          * This callback method handles a "Receive Done" event from radio platform when diagnostics mode is enabled.

src/core/radio/radio_callbacks.cpp

@@ -58,6 +58,13 @@ void Radio::Callbacks::HandleTransmitDone(Mac::TxFrame &aFrame, Mac::RxFrame *aA
 
 void Radio::Callbacks::HandleEnergyScanDone(int8_t aMaxRssi) { Get<Mac::SubMac>().HandleEnergyScanDone(aMaxRssi); }
 
+void Radio::Callbacks::HandleBusLatencyUpdated(void)
+{
+#if OPENTHREAD_FTD && OPENTHREAD_CONFIG_MAC_CSL_TRANSMITTER_ENABLE
+    Get<CslTxScheduler>().UpdateFrameRequestAhead();
+#endif
+}
+
 #if OPENTHREAD_CONFIG_DIAG_ENABLE
 void Radio::Callbacks::HandleDiagsReceiveDone(Mac::RxFrame *aFrame, Error aError)
 {

src/core/radio/radio_platform.cpp

@@ -116,6 +116,17 @@ extern "C" void otPlatRadioEnergyScanDone(otInstance *aInstance, int8_t aEnergyS
     return;
 }
 
+extern "C" void otPlatRadioBusLatencyUpdated(otInstance *aInstance)
+{
+    Instance &instance = AsCoreType(aInstance);
+
+    VerifyOrExit(instance.IsInitialized());
+    instance.Get<Radio::Callbacks>().HandleBusLatencyUpdated();
+
+exit:
+    return;
+}
+
 #if OPENTHREAD_CONFIG_DIAG_ENABLE
 extern "C" void otPlatDiagRadioReceiveDone(otInstance *aInstance, otRadioFrame *aFrame, otError aError)
 {
@@ -153,6 +164,8 @@ extern "C" void otPlatRadioTxDone(otInstance *, otRadioFrame *, otRadioFrame *,
 
 extern "C" void otPlatRadioEnergyScanDone(otInstance *, int8_t) {}
 
+extern "C" void otPlatRadioBusLatencyUpdated(otInstance *) {}
+
 #if OPENTHREAD_CONFIG_DIAG_ENABLE
 extern "C" void otPlatDiagRadioReceiveDone(otInstance *, otRadioFrame *, otError) {}
 

src/lib/spinel/radio_spinel.cpp

@@ -39,7 +39,6 @@
 #include <stdlib.h>
 
 #include <openthread/logging.h>
-#include <openthread/thread_ftd.h>
 #include <openthread/platform/diag.h>
 #include <openthread/platform/time.h>
 
@@ -1946,12 +1945,11 @@ uint32_t RadioSpinel::GetBusLatency(void) const { return mBusLatency; }
 void RadioSpinel::SetBusLatency(uint32_t aBusLatency)
 {
     mBusLatency = aBusLatency;
-#if OPENTHREAD_CONFIG_MAC_CSL_TRANSMITTER_ENABLE
-    if (IsEnabled())
+
+    if (IsEnabled() && mCallbacks.mBusLatencyUpdated != nullptr)
     {
-        otThreadUpdateFrameRequestAhead(mInstance);
+        mCallbacks.mBusLatencyUpdated(mInstance);
     }
-#endif // OPENTHREAD_CONFIG_MAC_CSL_TRANSMITTER_ENABLE
 }
 
 void RadioSpinel::HandleRcpUnexpectedReset(spinel_status_t aStatus)

src/lib/spinel/radio_spinel.hpp

@@ -87,6 +87,14 @@ struct RadioSpinelCallbacks
      */
     void (*mEnergyScanDone)(otInstance *aInstance, int8_t aMaxRssi);
 
+    /**
+     * This callback notifies user of `RadioSpinel` that the bus latency has been updated.
+     *
+     * @param[in]  aInstance  The OpenThread instance structure.
+     *
+     */
+    void (*mBusLatencyUpdated)(otInstance *aInstance);
+
     /**
      * This callback notifies user of `RadioSpinel` that the transmission has started.
      *

src/posix/platform/radio.cpp

@@ -84,10 +84,11 @@ void Radio::Init(const char *aUrl)
     callbacks.mDiagReceiveDone  = otPlatDiagRadioReceiveDone;
     callbacks.mDiagTransmitDone = otPlatDiagRadioTransmitDone;
 #endif // OPENTHREAD_CONFIG_DIAG_ENABLE
-    callbacks.mEnergyScanDone = otPlatRadioEnergyScanDone;
-    callbacks.mReceiveDone    = otPlatRadioReceiveDone;
-    callbacks.mTransmitDone   = otPlatRadioTxDone;
-    callbacks.mTxStarted      = otPlatRadioTxStarted;
+    callbacks.mEnergyScanDone    = otPlatRadioEnergyScanDone;
+    callbacks.mBusLatencyUpdated = otPlatRadioBusLatencyUpdated;
+    callbacks.mReceiveDone       = otPlatRadioReceiveDone;
+    callbacks.mTransmitDone      = otPlatRadioTxDone;
+    callbacks.mTxStarted         = otPlatRadioTxStarted;
 
     resetRadio             = !mRadioUrl.HasParam("no-reset");
     skipCompatibilityCheck = mRadioUrl.HasParam("skip-rcp-compatibility-check");