Changed GateAll to GateHwi since GateAll does not work in SMP BIOS according to SDOCM...
authorvwan@ti.com <vwan@ti.com>
Thu, 25 Apr 2013 17:42:22 +0000 (10:42 -0700)
committerVW <vwan@ti.com>
Tue, 30 Apr 2013 17:28:06 +0000 (10:28 -0700)
packages/ti/ipc/family/omap54xx/VirtQueue.c
packages/ti/ipc/family/vayu/VirtQueue.c
packages/ti/ipc/rpmsg/RPMessage.c

index 2ed8ffd46b6f17b5dc66ae321c814177015ea1f7..77ce58f689401fc3ad608761e0890ee2e41740dd 100644 (file)
@@ -62,7 +62,7 @@
 
 #include <ti/sysbios/hal/Hwi.h>
 #include <ti/sysbios/knl/Clock.h>
-#include <ti/sysbios/gates/GateAll.h>
+#include <ti/sysbios/gates/GateHwi.h>
 #include <ti/sysbios/BIOS.h>
 #include <ti/sysbios/hal/Cache.h>
 
@@ -195,7 +195,7 @@ typedef struct VirtQueue_Object {
     UInt16                  procId;
 
     /* Gate to protect from multiple threads */
-    GateAll_Handle       gateH;
+    GateHwi_Handle       gateH;
 } VirtQueue_Object;
 
 static struct VirtQueue_Object *queueRegistry[NUM_QUEUES] = {NULL};
@@ -248,9 +248,9 @@ Int VirtQueue_addUsedBuf(VirtQueue_Handle vq, Int16 head, Int len)
     struct vring_used_elem *used;
     IArg key;
 
-    key = GateAll_enter(vq->gateH);
+    key = GateHwi_enter(vq->gateH);
     if ((head > vq->vring.num) || (head < 0)) {
-        GateAll_leave(vq->gateH, key);
+        GateHwi_leave(vq->gateH, key);
         Error_raise(NULL, Error_E_generic, 0, 0);
     }
 
@@ -263,7 +263,7 @@ Int VirtQueue_addUsedBuf(VirtQueue_Handle vq, Int16 head, Int len)
     used->len = len;
 
     vq->vring.used->idx++;
-    GateAll_leave(vq->gateH, key);
+    GateHwi_leave(vq->gateH, key);
 
     return (0);
 }
@@ -283,12 +283,12 @@ Int VirtQueue_addAvailBuf(VirtQueue_Object *vq, Void *buf)
 
     vq->num_free--;
 
-    key = GateAll_enter(vq->gateH);
+    key = GateHwi_enter(vq->gateH);
     avail =  vq->vring.avail->idx++ % vq->vring.num;
 
     vq->vring.desc[avail].addr = mapVAtoPA(buf);
     vq->vring.desc[avail].len = RP_MSG_BUF_SIZE;
-    GateAll_leave(vq->gateH, key);
+    GateHwi_leave(vq->gateH, key);
 
     return (vq->num_free);
 }
@@ -302,7 +302,7 @@ Void *VirtQueue_getUsedBuf(VirtQueue_Object *vq)
     Void *buf;
     IArg key;
 
-    key = GateAll_enter(vq->gateH);
+    key = GateHwi_enter(vq->gateH);
     /* There's nothing available? */
     if (vq->last_used_idx == vq->vring.used->idx) {
         buf = NULL;
@@ -313,7 +313,7 @@ Void *VirtQueue_getUsedBuf(VirtQueue_Object *vq)
 
         buf = mapPAtoVA(vq->vring.desc[head].addr);
     }
-    GateAll_leave(vq->gateH, key);
+    GateHwi_leave(vq->gateH, key);
 
     return (buf);
 }
@@ -326,7 +326,7 @@ Int16 VirtQueue_getAvailBuf(VirtQueue_Handle vq, Void **buf, Int *len)
     Int16 head;
     IArg key;
 
-    key = GateAll_enter(vq->gateH);
+    key = GateHwi_enter(vq->gateH);
     Log_print6(Diags_USER1, "getAvailBuf vq: 0x%x %d %d %d 0x%x 0x%x\n",
         (IArg)vq, vq->last_avail_idx, vq->vring.avail->idx, vq->vring.num,
         (IArg)&vq->vring.avail, (IArg)vq->vring.avail);
@@ -347,7 +347,7 @@ Int16 VirtQueue_getAvailBuf(VirtQueue_Handle vq, Void **buf, Int *len)
         *buf = mapPAtoVA(vq->vring.desc[head].addr);
         *len = vq->vring.desc[head].len;
     }
-    GateAll_leave(vq->gateH, key);
+    GateHwi_leave(vq->gateH, key);
 
     return (head);
 }
@@ -495,7 +495,7 @@ VirtQueue_Handle VirtQueue_create(UInt16 remoteProcId, VirtQueue_Params *params,
     }
 
     /* Create the thread protection gate */
-    vq->gateH = GateAll_create(NULL, eb);
+    vq->gateH = GateHwi_create(NULL, eb);
     if (Error_check(eb)) {
         Log_error0("VirtQueue_create: could not create gate object");
         Memory_free(NULL, vq, sizeof(VirtQueue_Object));
@@ -536,7 +536,7 @@ VirtQueue_Handle VirtQueue_create(UInt16 remoteProcId, VirtQueue_Params *params,
             break;
 #endif
         default:
-            GateAll_delete(&vq->gateH);
+            GateHwi_delete(&vq->gateH);
             Memory_free(NULL, vq, sizeof(VirtQueue_Object));
             return (NULL);
     }
index 438e1af4f4cc007e4d91d8b1ad2a837be37a3daf..b1bccc366f57112934c9e5d7188f57c32687d6bb 100644 (file)
@@ -62,7 +62,7 @@
 
 #include <ti/sysbios/hal/Hwi.h>
 #include <ti/sysbios/knl/Clock.h>
-#include <ti/sysbios/gates/GateAll.h>
+#include <ti/sysbios/gates/GateHwi.h>
 #include <ti/sysbios/BIOS.h>
 #include <ti/sysbios/hal/Cache.h>
 
@@ -200,7 +200,7 @@ typedef struct VirtQueue_Object {
     UInt16                  procId;
 
     /* Gate to protect from multiple threads */
-    GateAll_Handle       gateH;
+    GateHwi_Handle       gateH;
 } VirtQueue_Object;
 
 static struct VirtQueue_Object *queueRegistry[NUM_QUEUES] = {NULL};
@@ -256,9 +256,9 @@ Int VirtQueue_addUsedBuf(VirtQueue_Handle vq, Int16 head, Int len)
     struct vring_used_elem *used;
     IArg key;
 
-    key = GateAll_enter(vq->gateH);
+    key = GateHwi_enter(vq->gateH);
     if ((head > vq->vring.num) || (head < 0)) {
-        GateAll_leave(vq->gateH, key);
+        GateHwi_leave(vq->gateH, key);
         Error_raise(NULL, Error_E_generic, 0, 0);
     }
 
@@ -271,7 +271,7 @@ Int VirtQueue_addUsedBuf(VirtQueue_Handle vq, Int16 head, Int len)
     used->len = len;
 
     vq->vring.used->idx++;
-    GateAll_leave(vq->gateH, key);
+    GateHwi_leave(vq->gateH, key);
 
     return (0);
 }
@@ -291,12 +291,12 @@ Int VirtQueue_addAvailBuf(VirtQueue_Object *vq, Void *buf)
 
     vq->num_free--;
 
-    key = GateAll_enter(vq->gateH);
+    key = GateHwi_enter(vq->gateH);
     avail =  vq->vring.avail->idx++ % vq->vring.num;
 
     vq->vring.desc[avail].addr = mapVAtoPA(buf);
     vq->vring.desc[avail].len = RP_MSG_BUF_SIZE;
-    GateAll_leave(vq->gateH, key);
+    GateHwi_leave(vq->gateH, key);
 
     return (vq->num_free);
 }
@@ -310,7 +310,7 @@ Void *VirtQueue_getUsedBuf(VirtQueue_Object *vq)
     Void *buf;
     IArg key;
 
-    key = GateAll_enter(vq->gateH);
+    key = GateHwi_enter(vq->gateH);
     /* There's nothing available? */
     if (vq->last_used_idx == vq->vring.used->idx) {
         buf = NULL;
@@ -321,7 +321,7 @@ Void *VirtQueue_getUsedBuf(VirtQueue_Object *vq)
 
         buf = mapPAtoVA(vq->vring.desc[head].addr);
     }
-    GateAll_leave(vq->gateH, key);
+    GateHwi_leave(vq->gateH, key);
 
     return (buf);
 }
@@ -334,7 +334,7 @@ Int16 VirtQueue_getAvailBuf(VirtQueue_Handle vq, Void **buf, Int *len)
     Int16 head;
     IArg key;
 
-    key = GateAll_enter(vq->gateH);
+    key = GateHwi_enter(vq->gateH);
     Log_print6(Diags_USER1, "getAvailBuf vq: 0x%x %d %d %d 0x%x 0x%x\n",
         (IArg)vq, vq->last_avail_idx, vq->vring.avail->idx, vq->vring.num,
         (IArg)&vq->vring.avail, (IArg)vq->vring.avail);
@@ -355,7 +355,7 @@ Int16 VirtQueue_getAvailBuf(VirtQueue_Handle vq, Void **buf, Int *len)
         *buf = mapPAtoVA(vq->vring.desc[head].addr);
         *len = vq->vring.desc[head].len;
     }
-    GateAll_leave(vq->gateH, key);
+    GateHwi_leave(vq->gateH, key);
 
     return (head);
 }
@@ -504,7 +504,7 @@ VirtQueue_Handle VirtQueue_create(UInt16 remoteProcId, VirtQueue_Params *params,
     }
 
     /* Create the thread protection gate */
-    vq->gateH = GateAll_create(NULL, eb);
+    vq->gateH = GateHwi_create(NULL, eb);
     if (Error_check(eb)) {
         Log_error0("VirtQueue_create: could not create gate object");
         Memory_free(NULL, vq, sizeof(VirtQueue_Object));
@@ -545,7 +545,7 @@ VirtQueue_Handle VirtQueue_create(UInt16 remoteProcId, VirtQueue_Params *params,
             break;
 #endif
         default:
-            GateAll_delete(&vq->gateH);
+            GateHwi_delete(&vq->gateH);
             Memory_free(NULL, vq, sizeof(VirtQueue_Object));
             return (NULL);
     }
index e2529d1c34cd94961b89348009680e32a1f26923..894551596214faf20374ddb148309f4654df68b8 100644 (file)
@@ -88,7 +88,7 @@
 #include <ti/sysbios/knl/Swi.h>
 #include <ti/sysbios/knl/Semaphore.h>
 #include <ti/sysbios/heaps/HeapBuf.h>
-#include <ti/sysbios/gates/GateAll.h>
+#include <ti/sysbios/gates/GateHwi.h>
 
 #include <ti/sdo/utils/List.h>
 #include <ti/ipc/MultiProc.h>
@@ -137,7 +137,7 @@ typedef struct RPMessage_Object {
 /* Module_State */
 typedef struct RPMessage_Module {
     /* Instance gate: */
-    GateAll_Handle gateH;
+    GateHwi_Handle gateH;
     /* Array of messageQObjects in the system: */
     struct RPMessage_Object  *msgqObjects[MAXMESSAGEQOBJECTS];
     /* Heap from which to allocate free messages for copying: */
@@ -258,7 +258,7 @@ static Void callback_availBufReady(VirtQueue_Handle vq)
 #define FXNN "RPMessage_init"
 Void RPMessage_init(UInt16 remoteProcId)
 {
-    GateAll_Params gatePrms;
+    GateHwi_Params gatePrms;
     HeapBuf_Params prms;
     int     i;
     Registry_Result result;
@@ -280,8 +280,8 @@ Void RPMessage_init(UInt16 remoteProcId)
                 (IArg)remoteProcId);
 
     /* Gate to protect module object and lists: */
-    GateAll_Params_init(&gatePrms);
-    module.gateH = GateAll_create(&gatePrms, NULL);
+    GateHwi_Params_init(&gatePrms);
+    module.gateH = GateHwi_create(&gatePrms, NULL);
 
     /* Initialize Module State: */
     for (i = 0; i < MAXMESSAGEQOBJECTS; i++) {
@@ -352,7 +352,7 @@ Void RPMessage_finalize()
 
     Swi_delete(&(transport.swiHandle));
 
-    GateAll_delete(&module.gateH);
+    GateHwi_delete(&module.gateH);
 
 exit:
     Log_print0(Diags_EXIT, "<-- "FXNN);
@@ -380,7 +380,7 @@ RPMessage_Handle RPMessage_create(UInt32 reserved,
 
     Assert_isTrue((curInit > 0) , NULL);
 
-    key = GateAll_enter(module.gateH);
+    key = GateHwi_enter(module.gateH);
 
     if (reserved == RPMessage_ASSIGN_ANY)  {
        /* Search the array for a free slot above reserved: */
@@ -430,7 +430,7 @@ RPMessage_Handle RPMessage_create(UInt32 reserved,
        }
     }
 
-    GateAll_leave(module.gateH, key);
+    GateHwi_leave(module.gateH, key);
 
     Log_print1(Diags_EXIT, "<-- "FXNN": 0x%x", (IArg)obj);
     return (obj);
@@ -470,9 +470,9 @@ Int RPMessage_delete(RPMessage_Handle *handlePtr)
        }
 
        /* Null out our slot: */
-       key = GateAll_enter(module.gateH);
+       key = GateHwi_enter(module.gateH);
        module.msgqObjects[obj->queueId] = NULL;
-       GateAll_leave(module.gateH, key);
+       GateHwi_leave(module.gateH, key);
 
        Log_print1(Diags_LIFECYCLE, FXNN": endPt deleted: %d",
                         (IArg)obj->queueId);
@@ -595,9 +595,9 @@ Int RPMessage_send(UInt16 dstProc,
         /* Put on a Message queue on this processor: */
 
         /* Protect from RPMessage_delete */
-        key = GateAll_enter(module.gateH);
+        key = GateHwi_enter(module.gateH);
         obj = module.msgqObjects[dstEndpt];
-        GateAll_leave(module.gateH, key);
+        GateHwi_leave(module.gateH, key);
 
         if (obj == NULL) {
             Log_print1(Diags_STATUS, FXNN": no object for endpoint: %d",
@@ -618,9 +618,9 @@ Int RPMessage_send(UInt16 dstProc,
             size = len + sizeof(Queue_elem);
 
             /* HeapBuf_alloc() is non-blocking, so needs protection: */
-            key = GateAll_enter(module.gateH);
+            key = GateHwi_enter(module.gateH);
             payload = (Queue_elem *)HeapBuf_alloc(module.heap, size, 0, NULL);
-            GateAll_leave(module.gateH, key);
+            GateHwi_leave(module.gateH, key);
 
             if (payload != NULL)  {
                 memcpy(payload->data, data, len);