Merge pull request #2 from scdwyer/master

Add support so one can terminate the worker thread

fatfsWrapper.c

@@ -51,6 +51,7 @@
  * @brief Enumeration of all possible actions depending on activated functions.
  */
 enum wrapper_action {
+    eTERMINATE,
 #if HAS_MOUNT
     eFMOUNT,
 #endif
@@ -295,7 +296,7 @@ static msg_t ThreadFatFSWorker(void *arg) {
   Thread* p;
 
   chRegSetThreadName("fatfsWorker");
-  while (TRUE) {
+  while (!chThdShouldTerminate()) {
 
     /* Wait for msg with work to do. */
     p = chMsgWait();
@@ -307,6 +308,10 @@ static msg_t ThreadFatFSWorker(void *arg) {
 
     switch(msg->action) {
 
+    case eTERMINATE: {
+      break;
+    }
+
 #if HAS_MOUNT
     case eFMOUNT: {
       const struct wrapper_msg_vBYTEpFATFS* exmsg = \
@@ -551,10 +556,23 @@ static msg_t ThreadFatFSWorker(void *arg) {
 }
 
 
-void wf_init (tprio_t priority) {
+Thread* wf_init (tprio_t priority) {
   workerThread = chThdCreateStatic(waFatFSWorkerThread,
                                    sizeof(waFatFSWorkerThread),
                                    priority, ThreadFatFSWorker, NULL);
+  return workerThread;
+}
+
+void wf_terminate (void) {
+  struct wrapper_msg_base msg;
+
+  if (workerThread) {
+    msg.action = eTERMINATE;
+
+    chThdTerminate(workerThread);
+    chMsgSend(workerThread, (msg_t) &msg);
+  }
+  return;
 }
 
 

fatfsWrapper.h

@@ -17,7 +17,8 @@
 extern "C" {
 #endif
 
-void wf_init (tprio_t priority);
+Thread* wf_init (tprio_t priority);
+void wf_terminate (void);
 
 FRESULT wf_mount (BYTE, FATFS*);                     /* Mount/Unmount a logical drive */
 FRESULT wf_open (FIL*, const TCHAR*, BYTE);          /* Open or create a file */