Mercurial > ecos-v2_0-branch
annotate packages/kernel/current/include/mboxt2.hxx @ 494:cffb2601409c
* include/mqueue.hxx: Allow get/put to return time out.
* include mqueue.inl: Ditto.
| author | jlarmour |
|---|---|
| date | Mon, 13 Jan 2003 05:50:23 +0000 |
| parents | d2c90368aeef |
| children |
| rev | line source |
|---|---|
| 0 | 1 #ifndef CYGONCE_KERNEL_MBOXT2_HXX |
| 2 #define CYGONCE_KERNEL_MBOXT2_HXX | |
| 3 | |
| 4 //========================================================================== | |
| 5 // | |
| 2 | 6 // mboxt2.hxx |
| 0 | 7 // |
| 2 | 8 // Mboxt2 (Message Box/Mailbox) class declarations |
| 0 | 9 // |
| 10 //========================================================================== | |
|
208
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
11 //####ECOSGPLCOPYRIGHTBEGIN#### |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
12 // ------------------------------------------- |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
13 // This file is part of eCos, the Embedded Configurable Operating System. |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
14 // Copyright (C) 1998, 1999, 2000, 2001, 2002 Red Hat, Inc. |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
15 // |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
16 // eCos is free software; you can redistribute it and/or modify it under |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
17 // the terms of the GNU General Public License as published by the Free |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
18 // Software Foundation; either version 2 or (at your option) any later version. |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
19 // |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
20 // eCos is distributed in the hope that it will be useful, but WITHOUT ANY |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
21 // WARRANTY; without even the implied warranty of MERCHANTABILITY or |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
22 // FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
23 // for more details. |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
24 // |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
25 // You should have received a copy of the GNU General Public License along |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
26 // with eCos; if not, write to the Free Software Foundation, Inc., |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
27 // 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
28 // |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
29 // As a special exception, if other files instantiate templates or use macros |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
30 // or inline functions from this file, or you compile this file and link it |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
31 // with other works to produce a work based on this file, this file does not |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
32 // by itself cause the resulting work to be covered by the GNU General Public |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
33 // License. However the source code for this file must still be made available |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
34 // in accordance with section (3) of the GNU General Public License. |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
35 // |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
36 // This exception does not invalidate any other reasons why a work based on |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
37 // this file might be covered by the GNU General Public License. |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
38 // |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
39 // Alternative licenses for eCos may be arranged by contacting Red Hat, Inc. |
|
210
d2c90368aeef
Merge from eCos master repository on 2002-05-23-21:39:14-BST
jlarmour
parents:
208
diff
changeset
|
40 // at http://sources.redhat.com/ecos/ecos-license/ |
|
208
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
41 // ------------------------------------------- |
|
e0c0827131d1
Merge from eCos master repository on 2002-05-20-20:11:54-BST
jlarmour
parents:
66
diff
changeset
|
42 //####ECOSGPLCOPYRIGHTEND#### |
| 0 | 43 //========================================================================== |
| 44 //#####DESCRIPTIONBEGIN#### | |
| 45 // | |
| 2 | 46 // Author(s): hmt |
| 47 // Contributors: hmt | |
| 48 // Date: 1998-02-10 | |
| 49 // Purpose: Define Mboxt2 class interfaces | |
| 50 // Description: The classes defined here provide the APIs for mboxt2es. | |
| 51 // Usage: #include <cyg/kernel/mboxt2.hxx> | |
| 52 // #include <cyg/kernel/mboxt2.inl> | |
| 53 // | |
| 0 | 54 // |
| 55 //####DESCRIPTIONEND#### | |
| 56 // | |
| 57 //========================================================================== | |
| 58 | |
| 59 #include <cyg/kernel/ktypes.h> | |
| 60 #include <cyg/infra/cyg_ass.h> // assertion macros | |
| 61 #include <cyg/kernel/thread.hxx> | |
| 62 #include <cyg/kernel/thread.inl> | |
| 63 | |
| 64 // ------------------------------------------------------------------------- | |
| 65 // Message/Mail Box. This template implements a queue of T's. | |
| 66 // Implemented as a template for maximal flexibility; one would hope | |
| 67 // that only one, with T==(void *) and the same number of them, | |
| 68 // is ever used without very good reason. | |
| 69 | |
| 70 // Cyg_Mboxt2 has a fixed size array of T's; one size fits all. | |
| 71 | |
| 72 template <class T, cyg_count32 QUEUE_SIZE> | |
| 73 class Cyg_Mboxt2 | |
| 74 { | |
| 75 private: | |
| 76 cyg_count32 base; // index of first used slot | |
| 77 cyg_count32 count; // count of used slots | |
| 78 Cyg_ThreadQueue get_threadq; // Queue of waiting threads | |
| 79 #ifdef CYGMFN_KERNEL_SYNCH_MBOXT_PUT_CAN_WAIT | |
| 80 Cyg_ThreadQueue put_threadq; // Queue of waiting threads | |
| 81 #endif | |
| 82 static const | |
| 2 | 83 cyg_count32 size = QUEUE_SIZE; |
| 84 T itemqueue[ QUEUE_SIZE ]; | |
| 0 | 85 // queue of items |
| 86 // private utility functions | |
| 87 // wake up a thread from some queue | |
| 2 | 88 inline void wakeup_winner( const T &msg ); |
| 0 | 89 #ifdef CYGMFN_KERNEL_SYNCH_MBOXT_PUT_CAN_WAIT |
| 2 | 90 inline void wakeup_putter( void ); |
| 0 | 91 #endif |
| 92 | |
| 93 public: | |
| 94 | |
| 95 CYGDBG_DEFINE_CHECK_THIS | |
| 96 | |
| 97 Cyg_Mboxt2(); // Constructor | |
| 98 ~Cyg_Mboxt2(); // Destructor | |
| 99 | |
| 2 | 100 cyg_bool get( T &ritem ); // get an item; wait if none |
| 0 | 101 #ifdef CYGFUN_KERNEL_THREADS_TIMER |
| 2 | 102 cyg_bool get( T &ritem, cyg_tick_count abs_timeout ); |
| 0 | 103 #endif |
| 2 | 104 cyg_bool tryget( T &ritem ); // just one attempt |
| 0 | 105 |
| 2 | 106 cyg_bool peek_item( T &ritem ); // get next item without |
| 0 | 107 // removing it |
| 108 | |
| 109 #ifdef CYGMFN_KERNEL_SYNCH_MBOXT_PUT_CAN_WAIT | |
| 2 | 110 cyg_bool put( const T item ); // put an item; wait if full |
| 0 | 111 #ifdef CYGFUN_KERNEL_THREADS_TIMER |
| 2 | 112 cyg_bool put( const T item, cyg_tick_count abs_timeout ); |
| 0 | 113 #endif |
| 114 #endif | |
| 2 | 115 cyg_bool tryput( const T item ); // fails if Q full |
| 0 | 116 |
| 117 inline | |
| 118 cyg_count32 peek() // Get current count value | |
| 119 { | |
| 120 return count; | |
| 121 } | |
| 122 | |
| 123 inline | |
| 2 | 124 cyg_bool waiting_to_get() // Any threads waiting? |
| 0 | 125 { |
| 126 return ! get_threadq.empty(); | |
| 127 } | |
| 128 | |
| 129 inline | |
| 2 | 130 cyg_bool waiting_to_put() // Any threads waiting? |
| 0 | 131 { |
| 132 #ifdef CYGMFN_KERNEL_SYNCH_MBOXT_PUT_CAN_WAIT | |
| 133 return ! put_threadq.empty(); | |
| 134 #else | |
| 135 return false; | |
| 136 #endif | |
| 137 } | |
| 138 }; | |
| 139 | |
| 140 // ------------------------------------------------------------------------- | |
| 141 #endif // ifndef CYGONCE_KERNEL_MBOXT2_HXX | |
| 142 // EOF mboxt2.hxx |
