Process all currently queued tasklets in one shot. (#735)

examples/apps/cli/main.c

@@ -78,7 +78,7 @@ int main(int argc, char *argv[])
 
     while (1)
     {
-        otProcessNextTasklet(sInstance);
+        otProcessQueuedTasklets(sInstance);
         PlatformProcessDrivers(sInstance);
     }
 

examples/apps/ncp/main.c

@@ -78,7 +78,7 @@ int main(int argc, char *argv[])
 
     while (1)
     {
-        otProcessNextTasklet(sInstance);
+        otProcessQueuedTasklets(sInstance);
         PlatformProcessDrivers(sInstance);
     }
 

include/openthread.h

@@ -114,11 +114,11 @@ extern "C" {
  */
 
 /**
- * Run the next queued tasklet in OpenThread.
+ * Run all queued OpenThread tasklets at the time this is called.
  *
  * @param[in] aInstance A pointer to an OpenThread instance.
  */
-void otProcessNextTasklet(otInstance *aInstance);
+void otProcessQueuedTasklets(otInstance *aInstance);
 
 /**
  * Indicates whether or not OpenThread has tasklets pending.

src/core/common/tasklet.cpp

@@ -103,15 +103,20 @@ bool TaskletScheduler::AreTaskletsPending(void)
     return mHead != NULL;
 }
 
-void TaskletScheduler::RunNextTasklet(void)
+void TaskletScheduler::ProcessQueuedTasklets(void)
 {
-    Tasklet  *task;
+    Tasklet *tail = mTail;
+    Tasklet *cur;
 
-    task = PopTasklet();
-
-    if (task != NULL)
+    while ((cur = PopTasklet()) != NULL)
     {
-        task->RunTask();
+        cur->RunTask();
+
+        // only process tasklets that were queued at the time this method was called
+        if (cur == tail)
+        {
+            break;
+        }
     }
 }
 

src/core/common/tasklet.hpp

@@ -125,10 +125,10 @@ public:
     bool AreTaskletsPending(void);
 
     /**
-     * This method runs the next tasklet.
+     * This method processes all tasklets queued when this is called.
      *
      */
-    void RunNextTasklet(void);
+    void ProcessQueuedTasklets(void);
 
 private:
     Tasklet *PopTasklet(void);

src/core/openthread.cpp

@@ -98,9 +98,9 @@ static void *sEnergyScanCallbackContext = NULL;
 static otHandleActiveScanResult sDiscoverCallback = NULL;
 static void *sDiscoverCallbackContext = NULL;
 
-void otProcessNextTasklet(otInstance *)
+void otProcessQueuedTasklets(otInstance *)
 {
-    sIp6->mTaskletScheduler.RunNextTasklet();
+    sIp6->mTaskletScheduler.ProcessQueuedTasklets();
 }
 
 bool otAreTaskletsPending(otInstance *)