开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > MTK > 查看源码
Queue.c
资源名称：mmi.rar　[点击查看]
上传用户：lqx1163
上传日期：2014-08-13
资源大小：9183k
文件大小：28k
源码类别：

MTK

开发平台：

C/C++

Queue.c：源码内容
  1. /*****************************************************************************
  2. *  Copyright Statement:
  3. *  --------------------
  4. *  This software is protected by Copyright and the information contained
  5. *  herein is confidential. The software may not be copied and the information
  6. *  contained herein may not be used or disclosed except with the written
  7. *  permission of MediaTek Inc. (C) 2005
  8. *
  9. *  BY OPENING THIS FILE, BUYER HEREBY UNEQUIVOCALLY ACKNOWLEDGES AND AGREES
  10. *  THAT THE SOFTWARE/FIRMWARE AND ITS DOCUMENTATIONS ("MEDIATEK SOFTWARE")
  11. *  RECEIVED FROM MEDIATEK AND/OR ITS REPRESENTATIVES ARE PROVIDED TO BUYER ON
  12. *  AN "AS-IS" BASIS ONLY. MEDIATEK EXPRESSLY DISCLAIMS ANY AND ALL WARRANTIES,
  13. *  EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE IMPLIED WARRANTIES OF
  14. *  MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE OR NONINFRINGEMENT.
  15. *  NEITHER DOES MEDIATEK PROVIDE ANY WARRANTY WHATSOEVER WITH RESPECT TO THE
  16. *  SOFTWARE OF ANY THIRD PARTY WHICH MAY BE USED BY, INCORPORATED IN, OR
  17. *  SUPPLIED WITH THE MEDIATEK SOFTWARE, AND BUYER AGREES TO LOOK ONLY TO SUCH
  18. *  THIRD PARTY FOR ANY WARRANTY CLAIM RELATING THERETO. MEDIATEK SHALL ALSO
  19. *  NOT BE RESPONSIBLE FOR ANY MEDIATEK SOFTWARE RELEASES MADE TO BUYER'S
  20. *  SPECIFICATION OR TO CONFORM TO A PARTICULAR STANDARD OR OPEN FORUM.
  21. *
  22. *  BUYER'S SOLE AND EXCLUSIVE REMEDY AND MEDIATEK'S ENTIRE AND CUMULATIVE
  23. *  LIABILITY WITH RESPECT TO THE MEDIATEK SOFTWARE RELEASED HEREUNDER WILL BE,
  24. *  AT MEDIATEK'S OPTION, TO REVISE OR REPLACE THE MEDIATEK SOFTWARE AT ISSUE,
  25. *  OR REFUND ANY SOFTWARE LICENSE FEES OR SERVICE CHARGE PAID BY BUYER TO
  26. *  MEDIATEK FOR SUCH MEDIATEK SOFTWARE AT ISSUE. 
  27. *
  28. *  THE TRANSACTION CONTEMPLATED HEREUNDER SHALL BE CONSTRUED IN ACCORDANCE
  29. *  WITH THE LAWS OF THE STATE OF CALIFORNIA, USA, EXCLUDING ITS CONFLICT OF
  30. *  LAWS PRINCIPLES.  ANY DISPUTES, CONTROVERSIES OR CLAIMS ARISING THEREOF AND
  31. *  RELATED THERETO SHALL BE SETTLED BY ARBITRATION IN SAN FRANCISCO, CA, UNDER
  32. *  THE RULES OF THE INTERNATIONAL CHAMBER OF COMMERCE (ICC).
  33. *
  34. *****************************************************************************/
  36. /*******************************************************************************
  37.  * Filename:
  38.  * ---------
  39.  *  Queue.c
  40.  *
  41.  * Project:
  42.  * --------
  43.  *  MAUI
  44.  *
  45.  * Description:
  46.  * ------------
  47.  *  
  48.  *
  49.  * Author:
  50.  * -------
  51.  *  
  52.  *
  53.  *==============================================================================
  54.  *             HISTORY
  55.  * Below this line, this part is controlled by PVCS VM. DO NOT MODIFY!! 
  56.  *------------------------------------------------------------------------------
  57.  * removed!
  58.  *
  59.  * removed!
  60.  * removed!
  61.  * removed!
  62.  *
  63.  * removed!
  64.  * removed!
  65.  * removed!
  66.  *
  67.  * removed!
  68.  * removed!
  69.  * removed!
  70.  *
  71.  * removed!
  72.  * removed!
  73.  * removed!
  74.  *
  75.  * removed!
  76.  * removed!
  77.  * removed!
  78.  *
  79.  * removed!
  80.  * removed!
  81.  * removed!
  82.  *
  83.  * removed!
  84.  * removed!
  85.  * removed!
  86.  *
  87.  * removed!
  88.  * removed!
  89.  * removed!
  90.  *
  91.  * removed!
  92.  * removed!
  93.  * removed!
  94.  *
  95.  * removed!
  96.  * removed!
  97.  * removed!
  98.  *
  99.  * removed!
  100.  * removed!
  101.  * removed!
  102.  *
  103.  * removed!
  104.  * removed!
  105.  * removed!
  106.  *
  107.  * removed!
  108.  * removed!
  109.  * removed!
  110.  *
  111.  * removed!
  112.  * removed!
  113.  * removed!
  114.  *
  115.  * removed!
  116.  * removed!
  117.  * removed!
  118.  *
  119.  * removed!
  120.  * removed!
  121.  * removed!
  122.  *
  123.  * removed!
  124.  * removed!
  125.  * removed!
  126.  *
  127.  * removed!
  128.  * removed!
  129.  * removed!
  130.  *
  131.  *------------------------------------------------------------------------------
  132.  * Upper this line, this part is controlled by PVCS VM. DO NOT MODIFY!! 
  133.  *==============================================================================
  134.  *******************************************************************************/
  136. /**
  137.  * Copyright Notice
  138.  * ?2002 - 2003, Pixtel Communications, Inc., 1489 43rd Ave. W.,
  139.  * Vancouver, B.C. V6M 4K8 Canada. All Rights Reserved.
  140.  *  (It is illegal to remove this copyright notice from this software or any
  141.  *  portion of it)
  142.  */
  144. /**************************************************************
  146.    FILENAME : Queue.c
  148.    PURPOSE     : Task queue implementation functions 
  150.    REMARKS     : nil
  152.    AUTHOR      : Neeraj Sharma
  154.    DATE     : Dec' 28, 2002
  156. **************************************************************/
  158. // #define __NEWSIMULATOR
  159. #include "MMI_features.h"
  160. #include "stdc.h"
  161. // #include "L4Dr1.h"
  162. #include "OslMemory.h"
  163. #include "pixteldatatypes.h"
  164. #include "QueueGprot.h"
  165. #include "DebugInitDef.h"
  166. //#undef __NEWSIMULATOR 
  167. //#include "l4dr.h"
  168. //#include "MMI_trc.h"
  169. #ifndef __MTK_TARGET__
  170. #define __align(x)
  171. #endif 
  172. void *lastMemory;
  173. TSIZE *lastSize;
  174. MYQUEUE *qPtr;
  177. /*****************************************************************************
  178.  * FUNCTION
  179.  *  OslIntCreateMsgQ
  180.  * DESCRIPTION
  181.  *  Creates Message Queue
  182.  * PARAMETERS
  183.  *  queue_name          [IN]        
  184.  *  max_msg_size        [IN]        
  185.  *  max_msgs            [IN]        
  186.  * RETURNS
  187.  *  void
  188.  *****************************************************************************/
  189. oslMsgqid OslIntCreateMsgQ(PS8 queue_name, U32 max_msg_size, U32 max_msgs)
  190. {
  191. #ifdef MMI_ON_WIN32
  192.     /*----------------------------------------------------------------*/
  193.     /* Local Variables                                                */
  194.     /*----------------------------------------------------------------*/
  195.     win32_msgqid *msgqid;
  197.     /*----------------------------------------------------------------*/
  198.     /* Code Body                                                      */
  199.     /*----------------------------------------------------------------*/
  200.     msgqid = (win32_msgqid*) OslMalloc(sizeof(win32_msgqid));
  201.     strcpy(msgqid->q_name, queue_name);
  202.     msgqid->q_max_message_size = max_msg_size;
  203.     msgqid->q_max_messages = max_msgs;
  204.     msgqid->q_messages = 0;
  205.     msgqid->q_queue_size = msgqid->q_max_message_size * msgqid->q_max_messages;
  206.     msgqid->q_semaphore_read = CreateSemaphore(NULL, 0, 1000, NULL);
  207.     msgqid->q_semaphore_write = CreateSemaphore(NULL, 0, 1000, NULL);
  208.     msgqid->q_start = (PU32) OslMalloc(msgqid->q_queue_size);
  209.     msgqid->q_message_size = (PU32) OslMalloc(msgqid->q_max_messages * 4);
  210.     msgqid->q_read = 0;
  211.     msgqid->q_write = 0;
  212.     msgqid->q_tasks_waiting_read = 0;
  213.     msgqid->q_tasks_waiting_write = 0;
  214.     InitializeCriticalSection(&msgqid->q_cs);
  215.     return msgqid;
  216. #else /* MMI_ON_WIN32 */ 
  217.     return NULL;
  218. #endif /* MMI_ON_WIN32 */ 
  220. }
  223. /*****************************************************************************
  224.  * FUNCTION
  225.  *  OslIntDeleteMsgQ
  226.  * DESCRIPTION
  227.  *  Deletes Message Queue
  228.  * PARAMETERS
  229.  *  msgqid      [IN]        
  230.  * RETURNS
  231.  *  void
  232.  *****************************************************************************/
  233. void OslIntDeleteMsgQ(oslMsgqid msgqid)
  234. {
  235. #ifdef MMI_ON_WIN32
  236.     /*----------------------------------------------------------------*/
  237.     /* Local Variables                                                */
  238.     /*----------------------------------------------------------------*/
  240.     /*----------------------------------------------------------------*/
  241.     /* Code Body                                                      */
  242.     /*----------------------------------------------------------------*/
  243.     DeleteCriticalSection(&msgqid->q_cs);
  244.     CloseHandle(msgqid->q_semaphore_read);
  245.     CloseHandle(msgqid->q_semaphore_write);
  246.     OslMfree(msgqid->q_start);
  247.     OslMfree(msgqid->q_message_size);
  248.     OslMfree(msgqid);
  249. #endif /* MMI_ON_WIN32 */ 
  250. }
  253. /*****************************************************************************
  254.  * FUNCTION
  255.  *  OslIntWriteMsgQ
  256.  * DESCRIPTION
  257.  *  Writes to Message Queue
  258.  * PARAMETERS
  259.  *  msgqid          [IN]        
  260.  *  msgPtr          [?]         
  261.  *  msgSize         [IN]        
  262.  *  wait_mode       [IN]        
  263.  * RETURNS
  264.  *  void
  265.  *****************************************************************************/
  266. OSLSTATUS OslIntWriteMsgQ(oslMsgqid msgqid, void *msgPtr, U32 msgSize, OSLWAITMODE wait_mode)
  267. {
  268. #ifdef MMI_ON_WIN32
  269.     /*----------------------------------------------------------------*/
  270.     /* Local Variables                                                */
  271.     /*----------------------------------------------------------------*/
  272.     U32 index;
  273.     PU32 ptr;
  275.     /*----------------------------------------------------------------*/
  276.     /* Code Body                                                      */
  277.     /*----------------------------------------------------------------*/
  278.     EnterCriticalSection(&msgqid->q_cs);
  279.     if (msgSize > msgqid->q_max_message_size)
  280.     {
  281.         LeaveCriticalSection(&msgqid->q_cs);
  282.         return OSL_MESSAGE_TOO_BIG;
  283.     }
  284.     /* Check whether the queue is full) */
  285.     if (msgqid->q_messages == msgqid->q_max_messages)
  286.     {
  287.         if (wait_mode == OSL_INFINITE_WAIT)
  288.         {
  289.             ++msgqid->q_tasks_waiting_write;
  290.             LeaveCriticalSection(&msgqid->q_cs);
  291.             WaitForSingleObject(msgqid->q_semaphore_write, INFINITE);
  292.             EnterCriticalSection(&msgqid->q_cs);
  293.         }
  294.         else
  295.         {
  296.             LeaveCriticalSection(&msgqid->q_cs);
  297.             return OSL_Q_FULL;
  298.         }
  299.     }
  300.     msgqid->q_message_size[msgqid->q_write] = msgSize;
  301.     index = msgqid->q_write * (msgqid->q_max_message_size / 4);
  302.     ptr = msgqid->q_start + index;
  303.     memcpy(ptr, msgPtr, msgSize);
  304.     if (++msgqid->q_write == msgqid->q_max_messages)
  305.     {
  306.         msgqid->q_write = 0;
  307.     }
  308.     ++msgqid->q_messages;
  309.     if (msgqid->q_tasks_waiting_read != 0)
  310.     {
  311.         ReleaseSemaphore(msgqid->q_semaphore_read, 1, NULL);
  312.         msgqid->q_tasks_waiting_read -= 1;
  313.     }
  314.     LeaveCriticalSection(&msgqid->q_cs);
  315. #endif /* MMI_ON_WIN32 */ 
  316.     return OSL_SUCCESS;
  317. }
  320. /*****************************************************************************
  321.  * FUNCTION
  322.  *  OslIntReadMsgQ
  323.  * DESCRIPTION
  324.  *  Reades from Message Queue
  325.  * PARAMETERS
  326.  *  msgqid          [IN]        
  327.  *  msgPtr          [?]         
  328.  *  msgSize         [?]         
  329.  *  wait_mode       [IN]        
  330.  * RETURNS
  331.  *  void
  332.  *****************************************************************************/
  333. OSLSTATUS OslIntReadMsgQ(oslMsgqid msgqid, void *msgPtr, U32 *msgSize, OSLWAITMODE wait_mode)
  334. {
  335. #ifdef MMI_ON_WIN32
  336.     /*----------------------------------------------------------------*/
  337.     /* Local Variables                                                */
  338.     /*----------------------------------------------------------------*/
  340.     /*----------------------------------------------------------------*/
  341.     /* Code Body                                                      */
  342.     /*----------------------------------------------------------------*/
  343.     EnterCriticalSection(&msgqid->q_cs);
  345.     if ((msgqid->q_read == msgqid->q_write) && (msgqid->q_messages == 0))
  346.     {
  347.         if (wait_mode == OSL_INFINITE_WAIT)
  348.         {
  349.             ++msgqid->q_tasks_waiting_read;
  350.             LeaveCriticalSection(&msgqid->q_cs);
  351.             WaitForSingleObject(msgqid->q_semaphore_read, INFINITE);
  352.             EnterCriticalSection(&msgqid->q_cs);
  353.         }
  354.         else
  355.         {
  356.             LeaveCriticalSection(&msgqid->q_cs);
  357.             return OSL_Q_EMPTY;
  358.         }
  359.     }
  360.     *msgSize = msgqid->q_message_size[msgqid->q_read];
  361.     memcpy(msgPtr, msgqid->q_start + (msgqid->q_read * (msgqid->q_max_message_size / 4)), *msgSize);
  362.     if (++msgqid->q_read == msgqid->q_max_messages)
  363.     {
  364.         msgqid->q_read = 0;
  365.     }
  366.     --msgqid->q_messages;
  368.     if (msgqid->q_tasks_waiting_write != 0)
  369.     {
  370.         ReleaseSemaphore(msgqid->q_semaphore_write, 1, NULL);
  371.         --msgqid->q_tasks_waiting_write;
  372.     }
  373.     LeaveCriticalSection(&msgqid->q_cs);
  375. #endif /* MMI_ON_WIN32 */ 
  376.     return OSL_SUCCESS;
  377. }
  380. /*****************************************************************************
  381.  * FUNCTION
  382.  *  OslIntReceiveMsgExtQ
  383.  * DESCRIPTION
  384.  *  Reades from Task External Queue
  385.  * PARAMETERS
  386.  *  msgqid      [IN]        
  387.  *  Message     [?]         
  388.  * RETURNS
  389.  *  void
  390.  *****************************************************************************/
  391. U32 OslIntReceiveMsgExtQ(oslMsgqid msgqid, MYQUEUE *Message)
  392. {
  393.     /*----------------------------------------------------------------*/
  394.     /* Local Variables                                                */
  395.     /*----------------------------------------------------------------*/
  396.     U32 msgSize = 0;
  398.     /*----------------------------------------------------------------*/
  399.     /* Code Body                                                      */
  400.     /*----------------------------------------------------------------*/
  401.     OslIntReadMsgQ(msgqid, Message, &msgSize, OSL_INFINITE_WAIT);
  402.     return msgSize;
  403. }
  405. extern void CheckAndPrintMsgId(U16 Id);
  408. /*****************************************************************************
  409.  * FUNCTION
  410.  *  OslIntMsgSendExtQueue
  411.  * DESCRIPTION
  412.  *  Writes to Task External Queue
  413.  * PARAMETERS
  414.  *  Message     [?]     
  415.  * RETURNS
  416.  *  void
  417.  *****************************************************************************/
  418. void OslIntMsgSendExtQueue(MYQUEUE *Message)
  419. {
  420. #ifndef MMI_ON_WIN32
  421.     /*----------------------------------------------------------------*/
  422.     /* Local Variables                                                */
  423.     /*----------------------------------------------------------------*/
  424.     MYQUEUE *oslMessage;
  425.     U8 ref_count;
  426.     
  427.     /*----------------------------------------------------------------*/
  428.     /* Code Body                                                      */
  429.     /*----------------------------------------------------------------*/
  430.     
  431.     /* check ref_count of local para */
  432.     if (Message->local_para_ptr != NULL)
  433.     {
  434.         ref_count = Message->local_para_ptr->ref_count;              
  435.         EXT_ASSERT(ref_count != 0, (int)Message->src_mod_id, 
  436.                     (int)Message->dest_mod_id, (int)Message->msg_id);
  438.     }    
  439.     
  440.     oslMessage = allocate_ilm(Message->oslSrcId);
  441.     memcpy(oslMessage, Message, sizeof(MYQUEUE));
  442.     if (oslMessage->oslSrcId == MOD_MMI &&
  443.         oslMessage->oslDestId == MOD_L4C)
  444.     {
  445.         oslMessage->sap_id = MMI_L4C_SAP;
  446.     }
  447.     else if (oslMessage->oslSrcId == MOD_MMI &&
  448.              oslMessage->oslDestId == MOD_MMI)
  449.     {
  450.         oslMessage->sap_id = MMI_MMI_SAP;
  451.     }
  452. #ifdef __MMI_FILE_MANAGER__    
  453.     else if (oslMessage->oslSrcId == MOD_MMI &&
  454.              oslMessage->oslDestId == MOD_FMT)
  455.     {
  456.         oslMessage->sap_id = MMI_FMT_SAP;
  457.     }
  458. #endif
  459.     else if (oslMessage->oslSrcId == MOD_MMI &&
  460.              oslMessage->oslDestId == MOD_ABM)
  461.     {
  462.         oslMessage->sap_id = MMI_ABM_SAP;
  463.     }
  464.     else if (oslMessage->oslSrcId == MOD_MMI &&
  465.              oslMessage->oslDestId == MOD_J2ME)
  466.     {
  467.         oslMessage->sap_id = MMI_J2ME_SAP;
  468.     }
  469.     else if (oslMessage->oslSrcId == MOD_MMI &&
  470.              oslMessage->oslDestId == MOD_JASYN)
  471.     {
  472.         oslMessage->sap_id = MMI_JASYN_SAP;
  473.     }
  474.     else if (oslMessage->oslSrcId == MOD_MMI &&
  475.              oslMessage->oslDestId == MOD_SYNCML)
  476.     {
  477.         oslMessage->sap_id = MMI_SYNCML_SAP;
  478.     }
  479.     else if (oslMessage->oslSrcId == MOD_MMI &&
  480.              oslMessage->oslDestId == MOD_POC)
  481.     {
  482.         oslMessage->sap_id = MMI_POC_SAP;
  483.     }
  484.     else if (oslMessage->oslSrcId == MOD_MMI &&
  485.              oslMessage->oslDestId == MOD_WAP)
  486.     {
  487.         oslMessage->sap_id = MMI_WAP_SAP;
  488.     }
  489.     else if (oslMessage->oslSrcId == MOD_WAP &&
  490.              oslMessage->oslDestId == MOD_MMI)
  491.     {
  492.         oslMessage->sap_id = WAP_MMI_SAP;
  493.     }
  494.     else
  495.     {
  496.         oslMessage->sap_id = INVALID_SAP;
  497.     }
  498.     msg_send_ext_queue(oslMessage);
  499.     CheckAndPrintMsgId((U16) (Message->msg_id));
  500. #else /* MMI_ON_WIN32 */ 
  501.     if (Message->oslDestId == MOD_MMI)
  502.     {
  503.         Message->oslDestId = MOD_PRT;
  504.     }
  505.     if (Message->oslSrcId == MOD_MMI)
  506.     {
  507.         Message->oslSrcId = MOD_PRT;
  508.     }
  509.     if (Message->oslDestId == MOD_WAP)
  510.     {
  511.         Message->oslDestId = MOD_PRT;
  512.     }
  513.     
  514.     /* make sure destination module exists */
  515.     MMI_ASSERT( Message->oslDestId < TOTAL_TASKS );
  516.     
  517.     OslIntWriteMsgQ(task_info_g1[Message->oslDestId].task_ext_qid, Message, sizeof(MYQUEUE), OSL_INFINITE_WAIT);
  518. #endif /* MMI_ON_WIN32 */ 
  519. }
  522. /*****************************************************************************
  523.  * FUNCTION
  524.  *  OslIntConstructDataPtr
  525.  * DESCRIPTION
  526.  *  Constructs Data Ptr
  527.  *  
  528.  *  Not used now
  529.  * PARAMETERS
  530.  *  size        [IN]        
  531.  * RETURNS
  532.  *  void
  533.  *****************************************************************************/
  534. void *OslIntConstructDataPtr(U32 size)
  535. {
  536. #ifndef MMI_ON_WIN32
  537.     /*----------------------------------------------------------------*/
  538.     /* Local Variables                                                */
  539.     /*----------------------------------------------------------------*/
  541.     /*----------------------------------------------------------------*/
  542.     /* Code Body                                                      */
  543.     /*----------------------------------------------------------------*/
  544.     return (construct_local_para((kal_uint16) size, TD_CTRL));
  545. #else /* MMI_ON_WIN32 */ 
  546.     void *ptr;
  547.     TSIZE *temp, tempdata;
  549.     temp = OslMalloc(size + sizeof(tempdata));
  550.     assert(temp != NULL);
  552.     tempdata.s = size;
  553.     memcpy(temp, &tempdata, sizeof(tempdata));
  554.     ptr = (void*)((char*)temp + sizeof(tempdata));
  555.     return ptr;
  556. #endif /* MMI_ON_WIN32 */ 
  558. }
  561. /*****************************************************************************
  562.  * FUNCTION
  563.  *  OslIntFreeDataPtr
  564.  * DESCRIPTION
  565.  *  Frees Data Ptr
  566.  *  
  567.  *  Not used now
  568.  * PARAMETERS
  569.  *  ptr     [?]     
  570.  * RETURNS
  571.  *  void
  572.  *****************************************************************************/
  573. void OslIntFreeDataPtr(void *ptr)
  574. {
  575. #ifndef MMI_ON_WIN32
  576.     /*----------------------------------------------------------------*/
  577.     /* Local Variables                                                */
  578.     /*----------------------------------------------------------------*/
  580.     /*----------------------------------------------------------------*/
  581.     /* Code Body                                                      */
  582.     /*----------------------------------------------------------------*/
  583.     free_local_para(ptr);
  584. #else /* MMI_ON_WIN32 */ 
  585.     TSIZE *temp;
  587.     temp = (void*)((char*)ptr - sizeof(TSIZE));
  588.     OslMfree(temp);
  589. #endif /* MMI_ON_WIN32 */ 
  590. }
  593. /*****************************************************************************
  594.  * FUNCTION
  595.  *  OslIntSizeofDataPtr
  596.  * DESCRIPTION
  597.  *  Returns Size of Data Ptr
  598.  *  
  599.  *  Not used now
  600.  * PARAMETERS
  601.  *  ptr     [?]     
  602.  * RETURNS
  603.  *  void
  604.  *****************************************************************************/
  605. U32 OslIntSizeofDataPtr(void *ptr)
  606. {
  607. #ifndef MMI_ON_WIN32
  608.     /*----------------------------------------------------------------*/
  609.     /* Local Variables                                                */
  610.     /*----------------------------------------------------------------*/
  611.     struct tsize
  612.     {
  613.         U8 ref_count;
  614.         U16 size;
  616.         /*----------------------------------------------------------------*/
  617.         /* Code Body                                                      */
  618.         /*----------------------------------------------------------------*/
  619.     };
  621.     return 0;
  622. #else /* MMI_ON_WIN32 */ 
  623.     typedef struct tsize
  624.     {
  625.         U32 size;
  626.     } TSIZE;
  627.     TSIZE *temp;
  629.     if (ptr == NULL)
  630.     {
  631.         return 0;
  632.     }
  633.     temp = (void*)((char*)ptr - sizeof(TSIZE));
  634.     return (U32) temp->size;
  635. #endif /* MMI_ON_WIN32 */ 
  636. }
  639. /*****************************************************************************
  640.  * FUNCTION
  641.  *  OslIntFreeInterTaskMsg
  642.  * DESCRIPTION
  643.  *  Frees InterTask Mesg
  644.  *  
  645.  *  Not used now
  646.  * PARAMETERS
  647.  *  Message     [?]     
  648.  * RETURNS
  649.  *  void
  650.  *****************************************************************************/
  651. void OslIntFreeInterTaskMsg(void *Message)
  652. {
  653. #ifndef MMI_ON_WIN32
  654.     /*----------------------------------------------------------------*/
  655.     /* Local Variables                                                */
  656.     /*----------------------------------------------------------------*/
  658.     /*----------------------------------------------------------------*/
  659.     /* Code Body                                                      */
  660.     /*----------------------------------------------------------------*/
  661.     free_ilm(Message);
  662. #else /* MMI_ON_WIN32 */ 
  664.     MYQUEUE *ptr;
  666.     ptr = Message;
  667.     if (ptr->oslSrcId == MOD_L4C)
  668.     {
  669.         ptr->oslSrcId = MOD_MMI;
  670.         ptr->oslDestId = MOD_L4C;
  672.         ptr->oslMsgId = 0;
  673.         OslMsgSendExtQueue(ptr);
  674.     }
  675.     else
  676.     {
  677.         if (ptr->oslDataPtr != NULL)
  678.         {
  679.             OslIntFreeDataPtr(ptr->oslDataPtr);
  680.         }
  681.     }
  682. #endif /* MMI_ON_WIN32 */ 
  683. }
  685. #ifdef MMI_ON_WIN32
  688. /*****************************************************************************
  689.  * FUNCTION
  690.  *  OslNumOfQMsgs
  691.  * DESCRIPTION
  692.  *  Get the message number in MMI queue
  693.  * PARAMETERS
  694.  *  void
  695.  * RETURNS
  696.  *  message number
  697.  *****************************************************************************/
  698. U8 OslNumOfQMsgs(void)
  699. {
  700.     /*----------------------------------------------------------------*/
  701.     /* Local Variables                                                */
  702.     /*----------------------------------------------------------------*/
  703.     U8 num;
  704.     oslMsgqid msgqid = task_info_g1[MOD_PRT].task_ext_qid;
  706.     /*----------------------------------------------------------------*/
  707.     /* Code Body                                                      */
  708.     /*----------------------------------------------------------------*/
  709.     EnterCriticalSection(&msgqid->q_cs);
  710.     num = (U8) (msgqid->q_messages);
  711.     LeaveCriticalSection(&msgqid->q_cs);
  712.     return num;
  713. }
  715. #endif /* MMI_ON_WIN32 */ 
  716. #define CIRCQ_NODE_SIZE sizeof(MYQUEUE)
  718. /* 
  719.  * Because MMI task will receive extQ message into circular queue,
  720.  * we increase the circular queue size from 30 to 50
  721.  */
  722. #define CIRCQ_NO_OF_NODES 65
  724. __align(4)
  725.      U8 circq_array[CIRCQ_NODE_SIZE * CIRCQ_NO_OF_NODES];
  726.      U8 circq_read = 0, circq_write = 0, circq_messages = 0, max_circq_messages = 0;
  729. /*****************************************************************************
  730.  * FUNCTION
  731.  *  OslReadCircularQ
  732.  * DESCRIPTION
  733.  *  Reads from Circ Queue
  734.  *  
  735.  *  Not used now
  736.  * PARAMETERS
  737.  *  msgPtr      [?]     
  738.  * RETURNS
  739.  *  void
  740.  *****************************************************************************/
  741.      U8 OslReadCircularQ(void *msgPtr)
  742. {
  743.     /*----------------------------------------------------------------*/
  744.     /* Local Variables                                                */
  745.     /*----------------------------------------------------------------*/
  747.     /*----------------------------------------------------------------*/
  748.     /* Code Body                                                      */
  749.     /*----------------------------------------------------------------*/
  750.     PRINT_INFORMATION_2((MMI_TRACE_G1_FRM, "OslReadCircularQ: <#[%d], read:[%d], write:[%d]>", circq_messages,
  751.                          circq_read, circq_write));
  752.     if (circq_messages == 0)
  753.     {
  754.         return 0;
  755.     }
  756.     memcpy(msgPtr, circq_array + (circq_read * CIRCQ_NODE_SIZE), CIRCQ_NODE_SIZE);
  757.     if (++circq_read == CIRCQ_NO_OF_NODES)
  758.     {
  759.         circq_read = 0;
  760.     }
  761.     --circq_messages;
  762.     return 1;
  763. }
  766. /*****************************************************************************
  767.  * FUNCTION
  768.  *  OslLookUpLastCircularQMsg
  769.  * DESCRIPTION
  770.  *  Look up the last message in Circ Queue
  771.  *  
  772.  *  Not used now
  773.  * PARAMETERS
  774.  *  msgPtr      [?]     
  775.  * RETURNS
  776.  *  void
  777.  *****************************************************************************/
  778. U8 OslLookUpLastCircularQMsg(void *msgPtr)
  779. {
  780.     /*----------------------------------------------------------------*/
  781.     /* Local Variables                                                */
  782.     /*----------------------------------------------------------------*/
  783.     U16 last_read_index;
  785.     /*----------------------------------------------------------------*/
  786.     /* Code Body                                                      */
  787.     /*----------------------------------------------------------------*/
  788.     if (circq_messages > 0)
  789.     {
  790.         if (circq_write == 0)
  791.         {
  792.             last_read_index = CIRCQ_NO_OF_NODES;
  793.         }
  794.         else
  795.         {
  796.             last_read_index = circq_write - 1;
  797.         }
  798.         memcpy(msgPtr, circq_array + (last_read_index * CIRCQ_NODE_SIZE), CIRCQ_NODE_SIZE);
  799.         return 1;
  800.     }
  801.     else
  802.     {
  803.         memset(msgPtr, 0, CIRCQ_NODE_SIZE);
  804.         return 0;
  805.     }
  806. }
  809. /*****************************************************************************
  810.  * FUNCTION
  811.  *  OslWriteCircularQ
  812.  * DESCRIPTION
  813.  *  Writes to Circ Queue
  814.  *  
  815.  *  Not used now
  816.  * PARAMETERS
  817.  *  msgPtr      [?]     
  818.  * RETURNS
  819.  *  void
  820.  *****************************************************************************/
  821. U8 OslWriteCircularQ(void *msgPtr)
  822. {
  823.     /*----------------------------------------------------------------*/
  824.     /* Local Variables                                                */
  825.     /*----------------------------------------------------------------*/
  827.     /*----------------------------------------------------------------*/
  828.     /* Code Body                                                      */
  829.     /*----------------------------------------------------------------*/
  830.     PRINT_INFORMATION_2((MMI_TRACE_G1_FRM, "OslWriteCircularQ: <#[%d], read:[%d], write:[%d]>", circq_messages,
  831.                          circq_read, circq_write));
  832.     if (circq_messages == CIRCQ_NO_OF_NODES)
  833.     {
  834.         MMI_ASSERT(0);
  835.         return 0;
  836.     }
  837.     memcpy(circq_array + (circq_write * CIRCQ_NODE_SIZE), msgPtr, CIRCQ_NODE_SIZE);
  838.     if (++circq_write == CIRCQ_NO_OF_NODES)
  839.     {
  840.         circq_write = 0;
  841.     }
  842.     ++circq_messages;
  843.     if (max_circq_messages < circq_messages)
  844.     {
  845.         max_circq_messages = circq_messages;
  846.     }
  847.     return 1;
  848. }
  851. /*****************************************************************************
  852.  * FUNCTION
  853.  *  OslNumOfCircularQMsgs
  854.  * DESCRIPTION
  855.  *  Get the message number
  856.  *  
  857.  *  Not used now
  858.  * PARAMETERS
  859.  *  void
  860.  * RETURNS
  861.  *  void
  862.  *****************************************************************************/
  863. U8 OslNumOfCircularQMsgs(void)
  864. {
  865.     /*----------------------------------------------------------------*/
  866.     /* Local Variables                                                */
  867.     /*----------------------------------------------------------------*/
  869.     /*----------------------------------------------------------------*/
  870.     /* Code Body                                                      */
  871.     /*----------------------------------------------------------------*/
  872.     return circq_messages;
  873. }
  876. /*****************************************************************************
  877.  * FUNCTION
  878.  *  OslIsCircularQFull
  879.  * DESCRIPTION
  880.  *  Check if Circ Queue is full
  881.  *  
  882.  *  Not used now
  883.  * PARAMETERS
  884.  *  void
  885.  * RETURNS
  886.  *  void
  887.  *****************************************************************************/
  888. U8 OslIsCircularQFull(void)
  889. {
  890.     /*----------------------------------------------------------------*/
  891.     /* Local Variables                                                */
  892.     /*----------------------------------------------------------------*/
  894.     /*----------------------------------------------------------------*/
  895.     /* Code Body                                                      */
  896.     /*----------------------------------------------------------------*/
  897.     return (circq_messages == CIRCQ_NO_OF_NODES);
  898. }