QP/C: qa_usuba.c Source File

Go to the documentation of this file.
00001 /*****************************************************************************
00002 * Product: QF/C
00003 * Last Updated for Version: 4.4.00
00004 * Date of the Last Update:  Jan 14, 2012
00005 *
00006 *                    Q u a n t u m     L e a P s
00007 *                    ---------------------------
00008 *                    innovating embedded systems
00009 *
00010 * Copyright (C) 2002-2012 Quantum Leaps, LLC. All rights reserved.
00011 *
00012 * This software may be distributed and modified under the terms of the GNU
00013 * General Public License version 2 (GPL) as published by the Free Software
00014 * Foundation and appearing in the file GPL.TXT included in the packaging of
00015 * this file. Please note that GPL Section 2[b] requires that all works based
00016 * on this software must also be made publicly available under the terms of
00017 * the GPL ("Copyleft").
00018 *
00019 * Alternatively, this software may be distributed and modified under the
00020 * terms of Quantum Leaps commercial licenses, which expressly supersede
00021 * the GPL and are specifically designed for licensees interested in
00022 * retaining the proprietary status of their code.
00023 *
00024 * Contact information:
00025 * Quantum Leaps Web site:  http://www.quantum-leaps.com
00026 * e-mail:                  info@quantum-leaps.com
00027 *****************************************************************************/
00028 #include "qf_pkg.h"
00029 #include "qassert.h"
00030 
00031 Q_DEFINE_THIS_MODULE("qa_usuba")
00032 
00033 
00039 /*..........................................................................*/
00040 void QActive_unsubscribeAll(QActive const *me) {
00041     uint8_t p = me->prio;
00042     uint8_t i;
00043     QSignal sig;
00044 
00045     Q_REQUIRE(((uint8_t)0 < p) && (p <= (uint8_t)QF_MAX_ACTIVE)
00046               && (QF_active_[p] == me));
00047 
00048     i = QF_div8Lkup[p];
00049     for (sig = (QSignal)Q_USER_SIG; sig < QF_maxSignal_; ++sig) {
00050         QF_CRIT_STAT_
00051         QF_CRIT_ENTRY_();
00052         if ((QF_PTR_AT_(QF_subscrList_, sig).bits[i]
00053              & Q_ROM_BYTE(QF_pwr2Lkup[p])) != (uint8_t)0)
00054         {
00055 
00056             QS_BEGIN_NOCRIT_(QS_QF_ACTIVE_UNSUBSCRIBE, QS_aoObj_, me)
00057                 QS_TIME_();                                    /* timestamp */
00058                 QS_SIG_(sig);                   /* the signal of this event */
00059                 QS_OBJ_(me);                          /* this active object */
00060             QS_END_NOCRIT_()
00061                                                   /* clear the priority bit */
00062             QF_PTR_AT_(QF_subscrList_, sig).bits[i] &=
00063                 Q_ROM_BYTE(QF_invPwr2Lkup[p]);
00064         }
00065         QF_CRIT_EXIT_();
00066     }
00067 }