diff gsm-fw/gpf/osl/os_com_ir.c @ 362:03d034db09fa

OSL: os_SendToQueue() reconstructed
author Michael Spacefalcon <msokolov@ivan.Harhan.ORG>
date Wed, 28 May 2014 19:54:10 +0000
parents 4a92b7261e23
children 28a2965df6aa
line wrap: on
line diff
--- a/gsm-fw/gpf/osl/os_com_ir.c	Thu May 15 11:44:36 2014 +0000
+++ b/gsm-fw/gpf/osl/os_com_ir.c	Wed May 28 19:54:10 2014 +0000
@@ -8,13 +8,13 @@
 #include <string.h>
 #include "gpfconf.h"	/* FreeCalypso addition */
 #include "../../nucleus/nucleus.h"
+#include "../../nucleus/tc_extr.h"	/* not seen in original, but needed */
 #include "typedefs.h"
 #include "os.h"
 #include "gdi.h"
 #include "os_types.h"
 #include "os_glob.h"
 
-extern TC_PROTECT TCD_System_Protect;
 extern T_OS_COM_TABLE_ENTRY ComTable[];
 extern unsigned os_tick_to_time_multiplier;
 
@@ -27,9 +27,33 @@
 		ULONG Suspend, OS_QDATA *Msg)
 {
 	T_OS_COM_TABLE_ENTRY *pTable;
-	T_QDATA_ELEMENT *pFreeElement, *pRet;
+	T_QDATA_ELEMENT *elem;
+	T_QUEUE *queue;
 	int ret;
 	NU_SEMAPHORE *CBPtr;
-
+	USHORT watmark;
 
+	if (ComHandle <= 0 || ComHandle > MaxCommunications)
+		return(OS_INVALID_QUEUE);
+	pTable = ComTable + ComHandle;
+	if (!pTable->Name[0])
+		return(OS_INVALID_QUEUE);
+	CBPtr = &pTable->FreeSemCB;
+	ret = ObtainSemaphoreCB(CBPtr, Suspend, 1);
+	if (ret == OS_ERROR || ret == OS_TIMEOUT)
+		return(ret);
+	TCT_System_Protect();
+	elem = pTable->pFreeElement;
+	pTable->pFreeElement = elem->pNext;
+	bcopy(Msg, &elem->Data, sizeof(OS_QDATA));
+	queue = &pTable->Queue[Priority - OS_MIN_PRIORITY];
+	*queue->pWrite++ = &elem->Data;
+	if (queue->pWrite - queue->pStart >= pTable->Entries + 1)
+		queue->pWrite = queue->pStart;
+	watmark = pTable->Entries - CBPtr->sm_semaphore_count;
+	if (pTable->MaxUsed < watmark)
+		pTable->MaxUsed = watmark;
+	TCT_System_Unprotect();
+	ReleaseSemaphoreCB(&pTable->UsedSemCB);
+	return(ret);
 }