|
0
|
1 //========================================================================== |
|
|
2 // |
|
|
3 // flag1.cxx |
|
|
4 // |
|
|
5 // Flag test 1 |
|
|
6 // |
|
|
7 //========================================================================== |
|
|
8 //####COPYRIGHTBEGIN#### |
|
|
9 // |
|
|
10 // ------------------------------------------- |
|
|
11 // The contents of this file are subject to the Cygnus eCos Public License |
|
|
12 // Version 1.0 (the "License"); you may not use this file except in |
|
|
13 // compliance with the License. You may obtain a copy of the License at |
|
|
14 // http://sourceware.cygnus.com/ecos |
|
|
15 // |
|
|
16 // Software distributed under the License is distributed on an "AS IS" |
|
|
17 // basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the |
|
|
18 // License for the specific language governing rights and limitations under |
|
|
19 // the License. |
|
|
20 // |
|
|
21 // The Original Code is eCos - Embedded Cygnus Operating System, released |
|
|
22 // September 30, 1998. |
|
|
23 // |
|
|
24 // The Initial Developer of the Original Code is Cygnus. Portions created |
|
|
25 // by Cygnus are Copyright (C) 1998 Cygnus Solutions. All Rights Reserved. |
|
|
26 // ------------------------------------------- |
|
|
27 // |
|
|
28 //####COPYRIGHTEND#### |
|
|
29 //========================================================================== |
|
|
30 //#####DESCRIPTIONBEGIN#### |
|
|
31 // |
|
|
32 // Author: dsm |
|
|
33 // Contributors: dsm |
|
|
34 // Date: 1998-05-11 |
|
|
35 // Description: Tests basic flag functionality. |
|
|
36 //####DESCRIPTIONEND#### |
|
|
37 |
|
|
38 #include <pkgconf/kernel.h> |
|
|
39 |
|
|
40 #include <cyg/kernel/thread.hxx> // Cyg_Thread |
|
|
41 #include <cyg/kernel/thread.inl> |
|
|
42 #include <cyg/kernel/sched.hxx> // Cyg_Scheduler::start() |
|
|
43 |
|
|
44 #include <cyg/kernel/flag.hxx> |
|
|
45 |
|
|
46 #include <cyg/infra/testcase.h> |
|
|
47 |
|
|
48 #include <cyg/kernel/sched.inl> |
|
|
49 |
|
|
50 |
|
|
51 #define NTHREADS 3 |
|
|
52 #include "testaux.hxx" |
|
|
53 |
|
|
54 static Cyg_Flag f0, f1; |
|
|
55 #ifdef CYGFUN_KERNEL_THREADS_TIMER |
|
|
56 static Cyg_Flag f2; |
|
|
57 #endif |
|
|
58 |
|
|
59 static volatile cyg_atomic q = 0; |
|
|
60 |
|
|
61 static void entry0( CYG_ADDRWORD data ) |
|
|
62 { |
|
|
63 CYG_TEST_INFO("Testing setbits() and maskbits()"); |
|
|
64 CYG_TEST_CHECK(0==f0.peek(), "flag not initialized properly"); |
|
|
65 f0.setbits(0x1); |
|
|
66 CYG_TEST_CHECK(1==f0.peek(), "setbits"); |
|
|
67 f0.setbits(0x3); |
|
|
68 CYG_TEST_CHECK(3==f0.peek(), "setbits"); |
|
|
69 f0.maskbits(~0x5); |
|
|
70 CYG_TEST_CHECK(2==f0.peek(), "maskbits"); |
|
|
71 f0.setbits(); |
|
|
72 CYG_TEST_CHECK(~0u==f0.peek(), "setbits no arg"); |
|
|
73 f0.maskbits(); |
|
|
74 CYG_TEST_CHECK(0==f0.peek(), "maskbits no arg"); |
|
|
75 CYG_TEST_CHECK(0==q++, "bad synchronization"); |
|
|
76 |
|
|
77 CYG_TEST_INFO("Testing wait()"); |
|
|
78 f1.setbits(0x4); |
|
|
79 CYG_TEST_CHECK(0x4==f1.peek(), "maskbits no arg"); |
|
|
80 CYG_TEST_CHECK(1==q++, "bad synchronization"); |
|
|
81 f1.setbits(0x18); // wake t1 |
|
|
82 f1.wait(0x11, Cyg_Flag::AND | Cyg_Flag::CLR); |
|
|
83 CYG_TEST_CHECK(0==f1.peek(), "flag value wrong"); |
|
|
84 CYG_TEST_CHECK(3==q++, "bad synchronization"); |
|
|
85 f0.setbits(0x2); // wake t1 |
|
|
86 f1.wait(0x10, Cyg_Flag::AND ); |
|
|
87 f0.setbits(0x1); // wake t1 |
|
|
88 |
|
|
89 f1.wait(0x11, Cyg_Flag::AND | Cyg_Flag::CLR); |
|
|
90 |
|
|
91 #ifdef CYGFUN_KERNEL_THREADS_TIMER |
|
|
92 f2.wait(0x2, Cyg_Flag::OR); |
|
|
93 CYG_TEST_CHECK(20==q,"bad synchronization"); |
|
|
94 f2.wait(0x10, Cyg_Flag::AND, |
|
|
95 Cyg_Clock::real_time_clock->current_value()+20); |
|
|
96 CYG_TEST_CHECK(21==q++,"bad synchronization"); |
|
|
97 #endif |
|
|
98 f0.wait(1, Cyg_Flag::OR); |
|
|
99 |
|
|
100 CYG_TEST_FAIL_FINISH("Not reached"); |
|
|
101 } |
|
|
102 |
|
|
103 static void entry1( CYG_ADDRWORD data ) |
|
|
104 { |
|
|
105 f1.wait(0xc, Cyg_Flag::AND); |
|
|
106 CYG_TEST_CHECK(2==q++, "bad synchronization"); |
|
|
107 CYG_TEST_CHECK(0x1c==f1.peek(), "flag value wrong"); |
|
|
108 f1.setbits(0x1); // wake t0 |
|
|
109 f0.wait(0x3, Cyg_Flag::OR); |
|
|
110 CYG_TEST_CHECK(4==q++, "bad synchronization"); |
|
|
111 CYG_TEST_CHECK(2==f0.peek(), "flag value wrong"); |
|
|
112 |
|
|
113 f1.setbits(0xf0); // wake t0,t2 |
|
|
114 f0.wait(0x5, Cyg_Flag::AND | Cyg_Flag::CLR); // wait for t0 & t2 |
|
|
115 CYG_TEST_CHECK(0==f0.peek(), "flag value wrong"); |
|
|
116 CYG_TEST_CHECK(0xf0==f1.peek(), "flag value wrong"); |
|
|
117 CYG_TEST_CHECK(5==q++, "bad synchronization"); |
|
|
118 f1.maskbits(); |
|
|
119 CYG_TEST_CHECK(0==f1.peek(), "flag value wrong"); |
|
|
120 |
|
|
121 CYG_TEST_INFO("Testing poll()"); |
|
|
122 f0.setbits(0x55); |
|
|
123 CYG_TEST_CHECK(0x55==f0.peek(), "flag value wrong"); |
|
|
124 CYG_TEST_CHECK(0x55==f0.poll(0x3, Cyg_Flag::OR),"bad poll() return"); |
|
|
125 CYG_TEST_CHECK(0==f0.poll(0xf, Cyg_Flag::AND),"poll()"); |
|
|
126 CYG_TEST_CHECK(0==f0.poll(0xa, Cyg_Flag::OR),"poll()"); |
|
|
127 CYG_TEST_CHECK(0x55==f0.peek(), "flag value wrong"); |
|
|
128 CYG_TEST_CHECK(0x55==f0.poll(0xf, Cyg_Flag::OR | Cyg_Flag::CLR),"poll"); |
|
|
129 CYG_TEST_CHECK(0x0==f0.peek(), "flag value wrong"); |
|
|
130 f0.setbits(0x50); |
|
|
131 CYG_TEST_CHECK(0x50==f0.poll(0x10, Cyg_Flag::AND | Cyg_Flag::CLR),"poll"); |
|
|
132 CYG_TEST_CHECK(0x0==f0.peek(), "flag value wrong"); |
|
|
133 |
|
|
134 CYG_TEST_INFO("Testing waiting()"); |
|
|
135 f0.maskbits(); |
|
|
136 CYG_TEST_CHECK(!f0.waiting(), "waiting()"); |
|
|
137 |
|
|
138 #ifdef CYGFUN_KERNEL_THREADS_TIMER |
|
|
139 thread[1]->delay(10); // allow other threads to reach wait on f1 |
|
|
140 CYG_TEST_CHECK(f1.waiting(), "waiting() not true"); |
|
|
141 f1.setbits(); // wake one of t0,t2 |
|
|
142 CYG_TEST_CHECK(f1.waiting(), "waiting() not true"); |
|
|
143 #else |
|
|
144 f1.setbits(0x11); // wake one of t0,t2 |
|
|
145 #endif |
|
|
146 f1.setbits(0x11); // wake other of t0,t2 |
|
|
147 CYG_TEST_CHECK(!f1.waiting(), "waiting not false"); |
|
|
148 |
|
|
149 #ifdef CYGFUN_KERNEL_THREADS_TIMER |
|
|
150 CYG_TEST_INFO("Testing wait() with timeout"); |
|
|
151 q=20; |
|
|
152 f2.setbits(0x2); // synchronize with t0,t2 |
|
|
153 CYG_TEST_CHECK(20==q,"bad synchronization"); |
|
|
154 f2.wait(0x20, Cyg_Flag::AND, |
|
|
155 Cyg_Clock::real_time_clock->current_value()+10); |
|
|
156 CYG_TEST_CHECK(22==q++,"bad synchronization"); |
|
|
157 #endif |
|
|
158 |
|
|
159 CYG_TEST_PASS_FINISH("Flag 1 OK"); |
|
|
160 } |
|
|
161 |
|
|
162 static void entry2( CYG_ADDRWORD data ) |
|
|
163 { |
|
|
164 f1.wait(0x60, Cyg_Flag::OR); |
|
|
165 f0.setbits(0x4); |
|
|
166 |
|
|
167 f1.wait(0x11, Cyg_Flag::AND | Cyg_Flag::CLR); |
|
|
168 #ifdef CYGFUN_KERNEL_THREADS_TIMER |
|
|
169 f2.wait(0x2, Cyg_Flag::OR); |
|
|
170 CYG_TEST_CHECK(20==q,"bad synchronization"); |
|
|
171 CYG_TEST_CHECK(0==f2.wait(0x40, Cyg_Flag::AND, |
|
|
172 Cyg_Clock::real_time_clock->current_value()+5), |
|
|
173 "timed wait() wrong"); |
|
|
174 CYG_TEST_CHECK(20==q++,"bad synchronization"); |
|
|
175 // Now wake t0 before it times out |
|
|
176 f2.setbits(0x10); |
|
|
177 #endif |
|
|
178 f0.wait(1, Cyg_Flag::OR); |
|
|
179 |
|
|
180 CYG_TEST_FAIL_FINISH("Not reached"); |
|
|
181 } |
|
|
182 |
|
|
183 void flag1_main( void ) |
|
|
184 { |
|
|
185 CYG_TEST_INIT(); |
|
|
186 |
|
|
187 new_thread(entry0, 0); |
|
|
188 new_thread(entry1, 1); |
|
|
189 new_thread(entry2, 2); |
|
|
190 |
|
|
191 Cyg_Scheduler::start(); |
|
|
192 |
|
|
193 CYG_TEST_FAIL_FINISH("Not reached"); |
|
|
194 } |
|
|
195 |
|
|
196 externC void |
|
|
197 cyg_start( void ) |
|
|
198 { |
|
|
199 flag1_main(); |
|
|
200 } |
|
|
201 |
|
|
202 // EOF flag1.cxx |
