EventFramework library allows the creation of an event-driven infrastructure in which small "threads" can handle events in a multithreaded execution context. The EventFramework can be configured to act as a cooperative or a fully-preemptive kernel with fixed-priority scheduling. Furthermore, this kernel matches run-to-completion semantics, and hence a single-stack configuration is enough to keep running this multithreaded execution environment. As running threads shares global stack, a huge quantity of RAM is saved in contrast with traditional RTOSes.
Event/Event.cpp@1:ec12f2e32faf, 2012-10-03 (annotated)
- Committer:
- raulMrello
- Date:
- Wed Oct 03 21:02:16 2012 +0000
- Revision:
- 1:ec12f2e32faf
- Parent:
- 0:9d09acc8f9d9
Nesting correction on RestoreContext interface.; Erase invalid comment-block
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
raulMrello | 0:9d09acc8f9d9 | 1 | /* mbed EventFramework Library |
raulMrello | 0:9d09acc8f9d9 | 2 | * Copyright (c) 2012 raulMrello |
raulMrello | 0:9d09acc8f9d9 | 3 | * |
raulMrello | 0:9d09acc8f9d9 | 4 | * Permission is hereby granted, free of charge, to any person obtaining a copy |
raulMrello | 0:9d09acc8f9d9 | 5 | * of this software and associated documentation files (the "Software"), to deal |
raulMrello | 0:9d09acc8f9d9 | 6 | * in the Software without restriction, including without limitation the rights |
raulMrello | 0:9d09acc8f9d9 | 7 | * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell |
raulMrello | 0:9d09acc8f9d9 | 8 | * copies of the Software, and to permit persons to whom the Software is |
raulMrello | 0:9d09acc8f9d9 | 9 | * furnished to do so, subject to the following conditions: |
raulMrello | 0:9d09acc8f9d9 | 10 | * |
raulMrello | 0:9d09acc8f9d9 | 11 | * The above copyright notice and this permission notice shall be included in |
raulMrello | 0:9d09acc8f9d9 | 12 | * all copies or substantial portions of the Software. |
raulMrello | 0:9d09acc8f9d9 | 13 | * |
raulMrello | 0:9d09acc8f9d9 | 14 | * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR |
raulMrello | 0:9d09acc8f9d9 | 15 | * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, |
raulMrello | 0:9d09acc8f9d9 | 16 | * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE |
raulMrello | 0:9d09acc8f9d9 | 17 | * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER |
raulMrello | 0:9d09acc8f9d9 | 18 | * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, |
raulMrello | 0:9d09acc8f9d9 | 19 | * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN |
raulMrello | 0:9d09acc8f9d9 | 20 | * THE SOFTWARE. |
raulMrello | 0:9d09acc8f9d9 | 21 | */ |
raulMrello | 0:9d09acc8f9d9 | 22 | |
raulMrello | 0:9d09acc8f9d9 | 23 | #include "Event.h" |
raulMrello | 0:9d09acc8f9d9 | 24 | |
raulMrello | 0:9d09acc8f9d9 | 25 | Event::Event(uint16_t prio){ |
raulMrello | 0:9d09acc8f9d9 | 26 | this->prio = prio; |
raulMrello | 0:9d09acc8f9d9 | 27 | base = NULL; |
raulMrello | 0:9d09acc8f9d9 | 28 | data = NULL; |
raulMrello | 0:9d09acc8f9d9 | 29 | hlist = NULL; |
raulMrello | 0:9d09acc8f9d9 | 30 | } |
raulMrello | 0:9d09acc8f9d9 | 31 | |
raulMrello | 0:9d09acc8f9d9 | 32 | Event::~Event(void){ |
raulMrello | 0:9d09acc8f9d9 | 33 | prio = 0; |
raulMrello | 0:9d09acc8f9d9 | 34 | data = NULL; |
raulMrello | 0:9d09acc8f9d9 | 35 | base = NULL; |
raulMrello | 0:9d09acc8f9d9 | 36 | if(hlist){ |
raulMrello | 0:9d09acc8f9d9 | 37 | delete hlist; |
raulMrello | 0:9d09acc8f9d9 | 38 | } |
raulMrello | 0:9d09acc8f9d9 | 39 | } |
raulMrello | 0:9d09acc8f9d9 | 40 | |
raulMrello | 0:9d09acc8f9d9 | 41 | void Event::SetData(void* data){ |
raulMrello | 0:9d09acc8f9d9 | 42 | this->data = data; |
raulMrello | 0:9d09acc8f9d9 | 43 | } |
raulMrello | 0:9d09acc8f9d9 | 44 | |
raulMrello | 0:9d09acc8f9d9 | 45 | void Event::SetBase(Event* ev){ |
raulMrello | 0:9d09acc8f9d9 | 46 | base = ev; |
raulMrello | 0:9d09acc8f9d9 | 47 | } |
raulMrello | 0:9d09acc8f9d9 | 48 | |
raulMrello | 0:9d09acc8f9d9 | 49 | void* Event::GetData(void){ |
raulMrello | 0:9d09acc8f9d9 | 50 | return data; |
raulMrello | 0:9d09acc8f9d9 | 51 | } |
raulMrello | 0:9d09acc8f9d9 | 52 | |
raulMrello | 0:9d09acc8f9d9 | 53 | Event* Event::GetBase(void){ |
raulMrello | 0:9d09acc8f9d9 | 54 | return base; |
raulMrello | 0:9d09acc8f9d9 | 55 | } |
raulMrello | 0:9d09acc8f9d9 | 56 | |
raulMrello | 0:9d09acc8f9d9 | 57 | List* Event::GetList(void){ |
raulMrello | 0:9d09acc8f9d9 | 58 | return hlist; |
raulMrello | 0:9d09acc8f9d9 | 59 | } |
raulMrello | 0:9d09acc8f9d9 | 60 | |
raulMrello | 0:9d09acc8f9d9 | 61 | uint16_t Event::GetPrio(void){ |
raulMrello | 0:9d09acc8f9d9 | 62 | return prio; |
raulMrello | 0:9d09acc8f9d9 | 63 | } |
raulMrello | 0:9d09acc8f9d9 | 64 | |
raulMrello | 0:9d09acc8f9d9 | 65 | void Event::Subscribe(EventHandler * hnd){ |
raulMrello | 0:9d09acc8f9d9 | 66 | // if EventHandler list is not created yet, then creates and add handler |
raulMrello | 0:9d09acc8f9d9 | 67 | if(!hlist){ |
raulMrello | 0:9d09acc8f9d9 | 68 | hlist = new List(hnd); |
raulMrello | 0:9d09acc8f9d9 | 69 | return; |
raulMrello | 0:9d09acc8f9d9 | 70 | } |
raulMrello | 0:9d09acc8f9d9 | 71 | // else insert the handler according with its priority |
raulMrello | 0:9d09acc8f9d9 | 72 | Node* node = hlist->GetFirstNode(); |
raulMrello | 0:9d09acc8f9d9 | 73 | EventHandler* data = (EventHandler*)node->GetData(); |
raulMrello | 0:9d09acc8f9d9 | 74 | while(data->GetPrio() <= hnd->GetPrio()){ |
raulMrello | 0:9d09acc8f9d9 | 75 | Node* next = node->GetNext(); |
raulMrello | 0:9d09acc8f9d9 | 76 | if(!next){ |
raulMrello | 0:9d09acc8f9d9 | 77 | hlist->AddAfter(node, hnd); |
raulMrello | 0:9d09acc8f9d9 | 78 | return; |
raulMrello | 0:9d09acc8f9d9 | 79 | } |
raulMrello | 0:9d09acc8f9d9 | 80 | data = (EventHandler*)next->GetData(); |
raulMrello | 0:9d09acc8f9d9 | 81 | } |
raulMrello | 0:9d09acc8f9d9 | 82 | Node* newHead = hlist->AddBefore(node, hnd); |
raulMrello | 0:9d09acc8f9d9 | 83 | if(newHead){ |
raulMrello | 0:9d09acc8f9d9 | 84 | hlist->SetFirstNode(newHead); |
raulMrello | 0:9d09acc8f9d9 | 85 | } |
raulMrello | 0:9d09acc8f9d9 | 86 | } |
raulMrello | 0:9d09acc8f9d9 | 87 | |
raulMrello | 0:9d09acc8f9d9 | 88 | void Event::Unsubscribe(EventHandler* hnd){ |
raulMrello | 0:9d09acc8f9d9 | 89 | hlist->RemoveItem(hnd); |
raulMrello | 0:9d09acc8f9d9 | 90 | } |