• Home
  • Raw
  • Download

Lines Matching full:thread

80   Waiter waiter_;  // Thread-safe.
98 // Awake immediately after thread start. in TEST()
100 WaitingThread thread(10 * test::EpsilonDeadline()); in TEST() local
101 thread.Start(); in TEST()
102 thread.waiter()->Awake(MOJO_RESULT_OK, 1); in TEST()
103 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
109 // Awake before after thread start. in TEST()
111 WaitingThread thread(10 * test::EpsilonDeadline()); in TEST() local
112 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 2); in TEST()
113 thread.Start(); in TEST()
114 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
120 // Awake some time after thread start. in TEST()
122 WaitingThread thread(10 * test::EpsilonDeadline()); in TEST() local
123 thread.Start(); in TEST()
125 thread.waiter()->Awake(1, 3); in TEST()
126 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
133 // Awake some longer time after thread start. in TEST()
135 WaitingThread thread(10 * test::EpsilonDeadline()); in TEST() local
136 thread.Start(); in TEST()
138 thread.waiter()->Awake(2, 4); in TEST()
139 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
146 // Don't awake -- time out (on another thread). in TEST()
148 WaitingThread thread(2 * test::EpsilonDeadline()); in TEST() local
149 thread.Start(); in TEST()
150 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
159 // Awake immediately after thread start. in TEST()
161 WaitingThread thread(MOJO_DEADLINE_INDEFINITE); in TEST() local
162 thread.Start(); in TEST()
163 thread.waiter()->Awake(MOJO_RESULT_OK, 5); in TEST()
164 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
170 // Awake before after thread start. in TEST()
172 WaitingThread thread(MOJO_DEADLINE_INDEFINITE); in TEST() local
173 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 6); in TEST()
174 thread.Start(); in TEST()
175 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
181 // Awake some time after thread start. in TEST()
183 WaitingThread thread(MOJO_DEADLINE_INDEFINITE); in TEST() local
184 thread.Start(); in TEST()
186 thread.waiter()->Awake(1, 7); in TEST()
187 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
194 // Awake some longer time after thread start. in TEST()
196 WaitingThread thread(MOJO_DEADLINE_INDEFINITE); in TEST() local
197 thread.Start(); in TEST()
199 thread.waiter()->Awake(2, 8); in TEST()
200 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
248 WaitingThread thread(MOJO_DEADLINE_INDEFINITE); in TEST() local
249 thread.Start(); in TEST()
250 thread.waiter()->Awake(MOJO_RESULT_OK, 1); in TEST()
251 thread.waiter()->Awake(1, 2); in TEST()
252 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
259 WaitingThread thread(MOJO_DEADLINE_INDEFINITE); in TEST() local
260 thread.waiter()->Awake(1, 3); in TEST()
261 thread.Start(); in TEST()
262 thread.waiter()->Awake(MOJO_RESULT_OK, 4); in TEST()
263 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
270 WaitingThread thread(MOJO_DEADLINE_INDEFINITE); in TEST() local
271 thread.Start(); in TEST()
272 thread.waiter()->Awake(10, 5); in TEST()
274 thread.waiter()->Awake(20, 6); in TEST()
275 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
282 WaitingThread thread(10 * test::EpsilonDeadline()); in TEST() local
283 thread.Start(); in TEST()
285 thread.waiter()->Awake(MOJO_RESULT_FAILED_PRECONDITION, 7); in TEST()
287 thread.waiter()->Awake(MOJO_RESULT_OK, 8); in TEST()
288 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()