📄 os_q.lst
字号:
553 1
554 1 #if OS_ARG_CHK_EN > 0
555 1 if (pevent == (OS_EVENT *)0) { /* Validate 'pevent' */
556 2 return (OS_ERR_PEVENT_NULL);
557 2 }
558 1 if (msg == (void *)0) { /* Make sure we are not posting a NULL pointer */
559 2 return (OS_ERR_POST_NULL_PTR);
560 2 }
561 1 if (pevent->OSEventType != OS_EVENT_TYPE_Q) { /* Validate event block type */
562 2 return (OS_ERR_EVENT_TYPE);
563 2 }
564 1 #endif
565 1 OS_ENTER_CRITICAL();
566 1 if (pevent->OSEventGrp != 0x00) { /* See if any task pending on queue */
567 2 if ((opt & OS_POST_OPT_BROADCAST) != 0x00) { /* Do we need to post msg to ALL waiting tasks ? */
568 3 while (pevent->OSEventGrp != 0x00) { /* Yes, Post to ALL tasks waiting on queue */
569 4 OS_EventTaskRdy(pevent, msg, OS_STAT_Q);
570 4 }
571 3 } else {
572 3 OS_EventTaskRdy(pevent, msg, OS_STAT_Q); /* No, Post to HPT waiting on queue */
573 3 }
574 2 OS_EXIT_CRITICAL();
575 2 OS_Sched(); /* Find highest priority task ready to run */
576 2 return (OS_NO_ERR);
577 2 }
578 1 pq = (OS_Q *)pevent->OSEventPtr; /* Point to queue control block */
579 1 if (pq->OSQEntries >= pq->OSQSize) { /* Make sure queue is not full */
580 2 OS_EXIT_CRITICAL();
581 2 return (OS_Q_FULL);
582 2 }
583 1 if ((opt & OS_POST_OPT_FRONT) != 0x00) { /* Do we post to the FRONT of the queue? */
584 2 if (pq->OSQOut == pq->OSQStart) { /* Yes, Post as LIFO, Wrap OUT pointer if we ... */
585 3 pq->OSQOut = pq->OSQEnd; /* ... are at the 1st queue entry */
586 3 }
587 2 pq->OSQOut--;
588 2 *pq->OSQOut = msg; /* Insert message into queue */
589 2 } else { /* No, Post as FIFO */
590 2 *pq->OSQIn++ = msg; /* Insert message into queue */
591 2 if (pq->OSQIn == pq->OSQEnd) { /* Wrap IN ptr if we are at end of queue */
592 3 pq->OSQIn = pq->OSQStart;
593 3 }
594 2 }
595 1 pq->OSQEntries++; /* Update the nbr of entries in the queue */
596 1 OS_EXIT_CRITICAL();
597 1 return (OS_NO_ERR);
598 1 }
599 #endif
600 /*$PAGE*/
601 /*
602 *********************************************************************************************************
603 * QUERY A MESSAGE QUEUE
604 *
605 * Description: This function obtains information about a message queue.
606 *
607 * Arguments : pevent is a pointer to the event control block associated with the desired queue
608 *
609 * pdata is a pointer to a structure that will contain information about the message
610 * queue.
611 *
612 * Returns : OS_NO_ERR The call was successful and the message was sent
613 * OS_ERR_EVENT_TYPE If you are attempting to obtain data from a non queue.
C51 COMPILER V6.23a OS_Q 12/09/2004 16:50:26 PAGE 11
614 * OS_ERR_PEVENT_NULL If 'pevent' is a NULL pointer
615 *********************************************************************************************************
616 */
617
618 #if OS_Q_QUERY_EN > 0
619 INT8U OSQQuery (OS_EVENT *pevent, OS_Q_DATA *pdata) KCREENTRANT
620 {
621 1 #if OS_CRITICAL_METHOD == 3 /* Allocate storage for CPU status register */
OS_CPU_SR cpu_sr;
#endif
624 1 OS_Q *pq;
625 1 INT8U *psrc;
626 1 INT8U *pdest;
627 1
628 1
629 1 #if OS_ARG_CHK_EN > 0
630 1 if (pevent == (OS_EVENT *)0) { /* Validate 'pevent' */
631 2 return (OS_ERR_PEVENT_NULL);
632 2 }
633 1 if (pevent->OSEventType != OS_EVENT_TYPE_Q) { /* Validate event block type */
634 2 return (OS_ERR_EVENT_TYPE);
635 2 }
636 1 #endif
637 1 OS_ENTER_CRITICAL();
638 1 pdata->OSEventGrp = pevent->OSEventGrp; /* Copy message queue wait list */
639 1 psrc = &pevent->OSEventTbl[0];
640 1 pdest = &pdata->OSEventTbl[0];
641 1 #if OS_EVENT_TBL_SIZE > 0
642 1 *pdest++ = *psrc++;
643 1 #endif
644 1
645 1 #if OS_EVENT_TBL_SIZE > 1
646 1 *pdest++ = *psrc++;
647 1 #endif
648 1
649 1 #if OS_EVENT_TBL_SIZE > 2
*pdest++ = *psrc++;
#endif
652 1
653 1 #if OS_EVENT_TBL_SIZE > 3
*pdest++ = *psrc++;
#endif
656 1
657 1 #if OS_EVENT_TBL_SIZE > 4
*pdest++ = *psrc++;
#endif
660 1
661 1 #if OS_EVENT_TBL_SIZE > 5
*pdest++ = *psrc++;
#endif
664 1
665 1 #if OS_EVENT_TBL_SIZE > 6
*pdest++ = *psrc++;
#endif
668 1
669 1 #if OS_EVENT_TBL_SIZE > 7
*pdest = *psrc;
#endif
672 1 pq = (OS_Q *)pevent->OSEventPtr;
673 1 if (pq->OSQEntries > 0) {
674 2 pdata->OSMsg = *pq->OSQOut; /* Get next message to return if available */
675 2 } else {
C51 COMPILER V6.23a OS_Q 12/09/2004 16:50:26 PAGE 12
676 2 pdata->OSMsg = (void *)0;
677 2 }
678 1 pdata->OSNMsgs = pq->OSQEntries;
679 1 pdata->OSQSize = pq->OSQSize;
680 1 OS_EXIT_CRITICAL();
681 1 return (OS_NO_ERR);
682 1 }
683 #endif /* OS_Q_QUERY_EN */
684
685 /*$PAGE*/
686 /*
687 *********************************************************************************************************
688 * QUEUE MODULE INITIALIZATION
689 *
690 * Description : This function is called by uC/OS-II to initialize the message queue module. Your
691 * application MUST NOT call this function.
692 *
693 * Arguments : none
694 *
695 * Returns : none
696 *
697 * Note(s) : This function is INTERNAL to uC/OS-II and your application should not call it.
698 *********************************************************************************************************
699 */
700
701 void OS_QInit (void) KCREENTRANT
702 {
703 1 #if OS_MAX_QS == 1
OSQFreeList = &OSQTbl[0]; /* Only ONE queue! */
OSQFreeList->OSQPtr = (OS_Q *)0;
#endif
707 1
708 1 #if OS_MAX_QS >= 2
709 1 INT16U i;
710 1 OS_Q *pq1;
711 1 OS_Q *pq2;
712 1
713 1
714 1 pq1 = &OSQTbl[0];
715 1 pq2 = &OSQTbl[1];
716 1 for (i = 0; i < (OS_MAX_QS - 1); i++) { /* Init. list of free QUEUE control blocks */
717 2 pq1->OSQPtr = pq2;
718 2 pq1++;
719 2 pq2++;
720 2 }
721 1 pq1->OSQPtr = (OS_Q *)0;
722 1 OSQFreeList = &OSQTbl[0];
723 1 #endif
724 1 }
725 #endif /* OS_Q_EN */
MODULE INFORMATION: STATIC OVERLAYABLE
CODE SIZE = 4828 ----
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)
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -