os_q.lst

基于51单片机来实现UCOS用一个串口来看到实现阶段

                      OS_EXIT_CRITICAL();                      /* ... can't PEND from an ISR                         */
                      *err = OS_ERR_PEND_ISR;
                  } else {
                      OSTCBCur->OSTCBStat    |= OS_STAT_Q;     /* Task will have to pend for a message to be posted  */
                      OSTCBCur->OSTCBDly      = timeout;       /* Load timeout into TCB                              */
                      OSEventTaskWait(pevent);                 /* Suspend task until event or timeout occurs         */
                      OS_EXIT_CRITICAL();
                      OSSched();                               /* Find next highest priority task ready to run       */
                      OS_ENTER_CRITICAL();
                      if ((msg = OSTCBCur->OSTCBMsg) != (void *)0) {/* Did we get a message?                         */
                          OSTCBCur->OSTCBMsg      = (void *)0;      /* Extract message from TCB (Put there by QPost) */
                          OSTCBCur->OSTCBStat     = OS_STAT_RDY;
                          OSTCBCur->OSTCBEventPtr = (OS_EVENT *)0;  /* No longer waiting for event                   */
                          OS_EXIT_CRITICAL();
                          *err                    = OS_NO_ERR;
                      } else if (OSTCBCur->OSTCBStat & OS_STAT_Q) { /* Timed out if status indicates pending on Q    */
                          OSEventTO(pevent);
                          OS_EXIT_CRITICAL();
                          msg                     = (void *)0;      /* No message received                           */
                          *err                    = OS_TIMEOUT;     /* Indicate a timeout occured                    */
                      } else {
                          msg = *pq->OSQOut++;                      /* Extract message from queue                    */
                          pq->OSQEntries--;                         /* Update the number of entries in the queue     */
                          if (pq->OSQOut == pq->OSQEnd) {           /* Wrap OUT pointer if we are at the end of Q    */
                              pq->OSQOut = pq->OSQStart;
                          }
                          OSTCBCur->OSTCBEventPtr = (OS_EVENT *)0;
                          OS_EXIT_CRITICAL();
                          *err = OS_NO_ERR;
                      }
                  }                                                 
C51 COMPILER V7.50   OS_Q                                                                  10/31/2005 15:29:40 PAGE 4   

                return (msg);                                     /* Return message received (or NULL)             */
              }
              #endif
              
              //向消息队列中发送一个消息（FIFO）
              #if OS_Q_Post_EN
              INT8U OSQPost (OS_EVENT *pevent, void *msg)reentrant
              {
                  OS_Q   *pq;
              
                  OS_ENTER_CRITICAL();
                  if (pevent->OSEventType != OS_EVENT_TYPE_Q) {     /* Validate event block type                     */
                      OS_EXIT_CRITICAL();
                      return (OS_ERR_EVENT_TYPE);
                  }
                  if (pevent->OSEventGrp) {                         /* See if any task pending on queue              */
                      OSEventTaskRdy(pevent, msg, OS_STAT_Q);       /* Ready highest priority task waiting on event  */
                      OS_EXIT_CRITICAL();
                      OSSched();                                    /* Find highest priority task ready to run       */
                      return (OS_NO_ERR);
                  } else {
                      pq = pevent->OSEventPtr;                      /* Point to queue control block                  */
                      if (pq->OSQEntries >= pq->OSQSize) {          /* Make sure queue is not full                   */
                          OS_EXIT_CRITICAL();
                          return (OS_Q_FULL);
                      } else {
                          *pq->OSQIn++ = msg;                       /* Insert message into queue                     */
                          pq->OSQEntries++;                         /* Update the nbr of entries in the queue        */
                          if (pq->OSQIn == pq->OSQEnd) {            /* Wrap IN ptr if we are at end of queue         */
                              pq->OSQIn = pq->OSQStart;
                          }
                          OS_EXIT_CRITICAL();
                      }
                      return (OS_NO_ERR);
                  }
              }
              #endif
              
              //向消息队列中发送一个消息（LIFO）
              #if OS_Q_PostFront_EN                           
              INT8U OSQPostFront (OS_EVENT *pevent, void *msg)reentrant
              {
                  OS_Q   *pq;
              
              
                  OS_ENTER_CRITICAL();
                  if (pevent->OSEventType != OS_EVENT_TYPE_Q) {     /* Validate event block type                     */
                      OS_EXIT_CRITICAL();
                      return (OS_ERR_EVENT_TYPE);
                  }
                  if (pevent->OSEventGrp) {                         /* See if any task pending on queue              */
                      OSEventTaskRdy(pevent, msg, OS_STAT_Q);       /* Ready highest priority task waiting on event  */
                      OS_EXIT_CRITICAL();
                      OSSched();                                    /* Find highest priority task ready to run       */
                      return (OS_NO_ERR);
                  } else {
                      pq = pevent->OSEventPtr;                      /* Point to queue control block                  */
                      if (pq->OSQEntries >= pq->OSQSize) {          /* Make sure queue is not full                   */
                          OS_EXIT_CRITICAL();
                          return (OS_Q_FULL);
                      } else {
                          if (pq->OSQOut == pq->OSQStart) {         /* Wrap OUT ptr if we are at the 1st queue entry */
C51 COMPILER V7.50   OS_Q                                                                  10/31/2005 15:29:40 PAGE 5   

                              pq->OSQOut = pq->OSQEnd;
                          }
                          pq->OSQOut--;
                          *pq->OSQOut = msg;                        /* Insert message into queue                     */
                          pq->OSQEntries++;                         /* Update the nbr of entries in the queue        */
                          OS_EXIT_CRITICAL();
                      }
                      return (OS_NO_ERR);
                  }
              }
              #endif
              
              //查询一个消息队列状态
              #if OS_Q_Query_EN
              INT8U OSQQuery (OS_EVENT *pevent, OS_Q_DATA *dataptr)reentrant
              {
                  OS_Q   *pq;
                  INT8U   i;
                  INT8U  *psrc;
                  INT8U  *pdest;
                  
                  
                  OS_ENTER_CRITICAL();
                  if (pevent->OSEventType != OS_EVENT_TYPE_Q) {          /* Validate event block type                */
                      OS_EXIT_CRITICAL();
                      return (OS_ERR_EVENT_TYPE);
                  }
                  dataptr->OSEventGrp = pevent->OSEventGrp;                /* Copy message mailbox wait list           *
             -/
                  psrc              = &pevent->OSEventTbl[0];
                  pdest             = &dataptr->OSEventTbl[0];
                  for (i = 0; i < OS_EVENT_TBL_SIZE; i++) {
                      *pdest++ = *psrc++;   
                  }
                  pq = (OS_Q *)pevent->OSEventPtr;
                  if (pq->OSQEntries > 0) {
                      dataptr->OSMsg = pq->OSQOut;                         /* Get next message to return if available  *
             -/
                  } else {
                      dataptr->OSMsg = (void *)0;
                  }
                  dataptr->OSNMsgs = pq->OSQEntries;
                  dataptr->OSQSize = pq->OSQSize;
                  OS_EXIT_CRITICAL();
                  return (OS_NO_ERR);
              }
              #endif
              #endif


MODULE INFORMATION:   STATIC OVERLAYABLE
   CODE SIZE        =   ----    ----
   CONSTANT SIZE    =   ----    ----
   XDATA SIZE       =   ----    ----
   PDATA SIZE       =   ----    ----
   DATA SIZE        =   ----    ----
   IDATA SIZE       =   ----    ----
   BIT SIZE         =   ----    ----
END OF MODULE INFORMATION.


C51 COMPILATION COMPLETE.  0 WARNING(S),  0 ERROR(S)