Dining Philosophers Problem (DPP) example for the QP active object framework. Demonstrates: event-driven programming, hierarchical state machines in C++, modeling and graphical state machine design, code generation, preemptive multitasking, software tracing, power saving mode, direct event posting, publish-subscribe. More information available in the [[/users/QL/notebook|Quantum Leaps Notebook pages]]. See also [[http://www.state-machine.com|state-machine.com]].

Dependencies:   mbed qp

Committer:
QL
Date:
Sat Feb 12 23:22:47 2011 +0000
Revision:
0:efb9ac8d1a88
Child:
3:81ceb3127876

        

Who changed what in which revision?

UserRevisionLine numberNew contents of line
QL 0:efb9ac8d1a88 1 //////////////////////////////////////////////////////////////////////////////
QL 0:efb9ac8d1a88 2 // Product: DPP example
QL 0:efb9ac8d1a88 3 // Last Updated for Version: 4.0.00
QL 0:efb9ac8d1a88 4 // Date of the Last Update: May 28, 2008
QL 0:efb9ac8d1a88 5 //
QL 0:efb9ac8d1a88 6 // Q u a n t u m L e a P s
QL 0:efb9ac8d1a88 7 // ---------------------------
QL 0:efb9ac8d1a88 8 // innovating embedded systems
QL 0:efb9ac8d1a88 9 //
QL 0:efb9ac8d1a88 10 // Copyright (C) 2002-2008 Quantum Leaps, LLC. All rights reserved.
QL 0:efb9ac8d1a88 11 //
QL 0:efb9ac8d1a88 12 // This software may be distributed and modified under the terms of the GNU
QL 0:efb9ac8d1a88 13 // General Public License version 2 (GPL) as published by the Free Software
QL 0:efb9ac8d1a88 14 // Foundation and appearing in the file GPL.TXT included in the packaging of
QL 0:efb9ac8d1a88 15 // this file. Please note that GPL Section 2[b] requires that all works based
QL 0:efb9ac8d1a88 16 // on this software must also be made publicly available under the terms of
QL 0:efb9ac8d1a88 17 // the GPL ("Copyleft").
QL 0:efb9ac8d1a88 18 //
QL 0:efb9ac8d1a88 19 // Alternatively, this software may be distributed and modified under the
QL 0:efb9ac8d1a88 20 // terms of Quantum Leaps commercial licenses, which expressly supersede
QL 0:efb9ac8d1a88 21 // the GPL and are specifically designed for licensees interested in
QL 0:efb9ac8d1a88 22 // retaining the proprietary status of their code.
QL 0:efb9ac8d1a88 23 //
QL 0:efb9ac8d1a88 24 // Contact information:
QL 0:efb9ac8d1a88 25 // Quantum Leaps Web site: http://www.quantum-leaps.com
QL 0:efb9ac8d1a88 26 // e-mail: info@quantum-leaps.com
QL 0:efb9ac8d1a88 27 //////////////////////////////////////////////////////////////////////////////
QL 0:efb9ac8d1a88 28 #include "qp_port.h"
QL 0:efb9ac8d1a88 29 #include "dpp.h"
QL 0:efb9ac8d1a88 30 #include "bsp.h"
QL 0:efb9ac8d1a88 31
QL 0:efb9ac8d1a88 32 // Local-scope objects -------------------------------------------------------
QL 0:efb9ac8d1a88 33 static QEvent const *l_tableQueueSto[N_PHILO];
QL 0:efb9ac8d1a88 34 static QEvent const *l_philoQueueSto[N_PHILO][N_PHILO];
QL 0:efb9ac8d1a88 35 static QSubscrList l_subscrSto[MAX_PUB_SIG];
QL 0:efb9ac8d1a88 36
QL 0:efb9ac8d1a88 37 static union SmallEvents {
QL 0:efb9ac8d1a88 38 void *min_size;
QL 0:efb9ac8d1a88 39 TableEvt te;
QL 0:efb9ac8d1a88 40 // other event types to go into this pool
QL 0:efb9ac8d1a88 41 } l_smlPoolSto[2*N_PHILO]; // storage for the small event pool
QL 0:efb9ac8d1a88 42
QL 0:efb9ac8d1a88 43 //............................................................................
QL 0:efb9ac8d1a88 44 int main(void) {
QL 0:efb9ac8d1a88 45 BSP_init(); // initialize the BSP
QL 0:efb9ac8d1a88 46 QF::init(); // initialize the framework and the underlying RT kernel
QL 0:efb9ac8d1a88 47 // object dictionaries...
QL 0:efb9ac8d1a88 48 QS_OBJ_DICTIONARY(l_smlPoolSto);
QL 0:efb9ac8d1a88 49 QS_OBJ_DICTIONARY(l_tableQueueSto);
QL 0:efb9ac8d1a88 50 QS_OBJ_DICTIONARY(l_philoQueueSto[0]);
QL 0:efb9ac8d1a88 51 QS_OBJ_DICTIONARY(l_philoQueueSto[1]);
QL 0:efb9ac8d1a88 52 QS_OBJ_DICTIONARY(l_philoQueueSto[2]);
QL 0:efb9ac8d1a88 53 QS_OBJ_DICTIONARY(l_philoQueueSto[3]);
QL 0:efb9ac8d1a88 54 QS_OBJ_DICTIONARY(l_philoQueueSto[4]);
QL 0:efb9ac8d1a88 55
QL 0:efb9ac8d1a88 56 QF::psInit(l_subscrSto, Q_DIM(l_subscrSto)); // init publish-subscribe
QL 0:efb9ac8d1a88 57 // initialize event pools...
QL 0:efb9ac8d1a88 58 QF::poolInit(l_smlPoolSto, sizeof(l_smlPoolSto), sizeof(l_smlPoolSto[0]));
QL 0:efb9ac8d1a88 59
QL 0:efb9ac8d1a88 60 // start the active objects...
QL 0:efb9ac8d1a88 61 uint8_t n;
QL 0:efb9ac8d1a88 62 for (n = 0; n < N_PHILO; ++n) {
QL 0:efb9ac8d1a88 63 AO_Philo[n]->start((uint8_t)(n + 1),
QL 0:efb9ac8d1a88 64 l_philoQueueSto[n], Q_DIM(l_philoQueueSto[n]),
QL 0:efb9ac8d1a88 65 (void *)0, 0, (QEvent *)0);
QL 0:efb9ac8d1a88 66 }
QL 0:efb9ac8d1a88 67 AO_Table->start((uint8_t)(N_PHILO + 1),
QL 0:efb9ac8d1a88 68 l_tableQueueSto, Q_DIM(l_tableQueueSto),
QL 0:efb9ac8d1a88 69 (void *)0, 0, (QEvent *)0);
QL 0:efb9ac8d1a88 70
QL 0:efb9ac8d1a88 71 QF::run(); // run the QF application
QL 0:efb9ac8d1a88 72
QL 0:efb9ac8d1a88 73 return 0;
QL 0:efb9ac8d1a88 74 }
QL 0:efb9ac8d1a88 75