Mercurial > flash_v2
annotate packages/kernel/current/include/mboxt.hxx @ 128:0c2b7be0d798 ecos-sw-2000-10-12
Merge from eCos master repository on 2000-10-12-08:46:24-BST
| author | jlarmour |
|---|---|
| date | Thu, 12 Oct 2000 20:31:43 +0000 |
| parents | bf00f99aec69 |
| children | e0c0827131d1 |
| rev | line source |
|---|---|
| 0 | 1 #ifndef CYGONCE_KERNEL_MBOXT_HXX |
| 2 #define CYGONCE_KERNEL_MBOXT_HXX | |
| 3 | |
| 4 //========================================================================== | |
| 5 // | |
| 2 | 6 // mboxt.hxx |
| 0 | 7 // |
| 2 | 8 // Mboxt (Message Box/Mailbox) class declarations |
| 0 | 9 // |
| 10 //========================================================================== | |
| 11 //####COPYRIGHTBEGIN#### | |
|
64
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
12 // |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
13 // ------------------------------------------- |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
14 // The contents of this file are subject to the Red Hat eCos Public License |
|
66
bf00f99aec69
Merge from eCos master repository on 2000-02-02-19:16:44-GMT
jlarmour
parents:
64
diff
changeset
|
15 // Version 1.1 (the "License"); you may not use this file except in |
|
64
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
16 // compliance with the License. You may obtain a copy of the License at |
|
66
bf00f99aec69
Merge from eCos master repository on 2000-02-02-19:16:44-GMT
jlarmour
parents:
64
diff
changeset
|
17 // http://www.redhat.com/ |
|
64
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
18 // |
|
66
bf00f99aec69
Merge from eCos master repository on 2000-02-02-19:16:44-GMT
jlarmour
parents:
64
diff
changeset
|
19 // Software distributed under the License is distributed on an "AS IS" |
|
64
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
20 // basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
21 // License for the specific language governing rights and limitations under |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
22 // the License. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
23 // |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
24 // The Original Code is eCos - Embedded Configurable Operating System, |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
25 // released September 30, 1998. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
26 // |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
27 // The Initial Developer of the Original Code is Red Hat. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
28 // Portions created by Red Hat are |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
29 // Copyright (C) 1998, 1999, 2000 Red Hat, Inc. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
30 // All Rights Reserved. |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
31 // ------------------------------------------- |
|
c38311975d4f
Merge from eCos master repository on 2000-01-28-04:28:11-GMT
jlarmour
parents:
2
diff
changeset
|
32 // |
| 0 | 33 //####COPYRIGHTEND#### |
| 34 //========================================================================== | |
| 35 //#####DESCRIPTIONBEGIN#### | |
| 36 // | |
| 2 | 37 // Author(s): hmt |
| 38 // Contributors: hmt | |
| 39 // Date: 1998-02-10 | |
| 40 // Purpose: Define Mboxt class interfaces | |
| 41 // Description: The classes defined here provide the APIs for mboxtes. | |
| 42 // Usage: #include <cyg/kernel/mboxt.hxx> | |
| 43 // #include <cyg/kernel/mboxt.inl> | |
| 44 // | |
| 0 | 45 // |
| 46 //####DESCRIPTIONEND#### | |
| 47 // | |
| 48 //========================================================================== | |
| 49 | |
| 50 #include <cyg/kernel/ktypes.h> | |
| 51 #include <cyg/infra/cyg_ass.h> // assertion macros | |
| 52 #include <cyg/kernel/thread.hxx> | |
| 53 | |
| 54 // ------------------------------------------------------------------------- | |
| 55 // Message/Mail Box. This template implements a queue of T's. | |
| 56 // Implemented as a template for maximal flexibility; one would hope | |
| 57 // that only one, with T==(void *) and the same number of them, | |
| 58 // is ever used without very good reason. | |
| 59 | |
| 60 // Cyg_Mboxt has a fixed size array of T's; one size fits all. | |
| 61 | |
| 62 template <class T, cyg_count32 QUEUE_SIZE> | |
| 63 class Cyg_Mboxt | |
| 64 { | |
| 65 private: | |
| 66 cyg_count32 base; // index of first used slot | |
| 67 cyg_count32 count; // count of used slots | |
| 68 Cyg_ThreadQueue get_threadq; // Queue of waiting threads | |
| 69 #ifdef CYGMFN_KERNEL_SYNCH_MBOXT_PUT_CAN_WAIT | |
| 70 Cyg_ThreadQueue put_threadq; // Queue of waiting threads | |
| 71 #endif | |
| 72 static const | |
| 2 | 73 cyg_count32 size = QUEUE_SIZE; |
| 74 T itemqueue[ QUEUE_SIZE ]; | |
| 0 | 75 // queue of items |
| 76 // private utility functions | |
| 77 // wake up a thread from some queue | |
| 2 | 78 inline void wakeup_waiter( Cyg_ThreadQueue &q ); |
| 0 | 79 |
| 80 public: | |
| 81 | |
| 82 CYGDBG_DEFINE_CHECK_THIS | |
| 83 | |
| 84 Cyg_Mboxt(); // Constructor | |
| 85 ~Cyg_Mboxt(); // Destructor | |
| 86 | |
| 2 | 87 cyg_bool get( T &ritem ); // get an item; wait if none |
| 0 | 88 #ifdef CYGFUN_KERNEL_THREADS_TIMER |
| 2 | 89 cyg_bool get( T &ritem, cyg_tick_count abs_timeout ); |
| 0 | 90 #endif |
| 2 | 91 cyg_bool tryget( T &ritem ); // just one attempt |
| 0 | 92 |
| 2 | 93 cyg_bool peek_item( T &ritem ); // get next item without |
| 0 | 94 // removing it |
| 95 | |
| 96 #ifdef CYGMFN_KERNEL_SYNCH_MBOXT_PUT_CAN_WAIT | |
| 2 | 97 cyg_bool put( const T item ); // put an item; wait if full |
| 0 | 98 #ifdef CYGFUN_KERNEL_THREADS_TIMER |
| 2 | 99 cyg_bool put( const T item, cyg_tick_count abs_timeout ); |
| 0 | 100 #endif |
| 101 #endif | |
| 2 | 102 cyg_bool tryput( const T item ); // fails if Q full |
| 0 | 103 |
| 104 inline | |
| 105 cyg_count32 peek() // Get current count value | |
| 106 { | |
| 107 return count; | |
| 108 } | |
| 109 | |
| 110 inline | |
| 2 | 111 cyg_bool waiting_to_get() // Any threads waiting? |
| 0 | 112 { |
| 113 return ! get_threadq.empty(); | |
| 114 } | |
| 115 | |
| 116 inline | |
| 2 | 117 cyg_bool waiting_to_put() // Any threads waiting? |
| 0 | 118 { |
| 119 #ifdef CYGMFN_KERNEL_SYNCH_MBOXT_PUT_CAN_WAIT | |
| 120 return ! put_threadq.empty(); | |
| 121 #else | |
| 122 return false; | |
| 123 #endif | |
| 124 } | |
| 125 }; | |
| 126 | |
| 127 // ------------------------------------------------------------------------- | |
| 128 #endif // ifndef CYGONCE_KERNEL_MBOXT_HXX | |
| 129 // EOF mboxt.hxx |
