1 // Copyright 2013 The Chromium Authors. All rights reserved. 2 // Use of this source code is governed by a BSD-style license that can be 3 // found in the LICENSE file. 4 5 #include "mojo/edk/system/waiter_test_utils.h" 6 7 namespace mojo { 8 namespace edk { 9 namespace test { 10 11 SimpleWaiterThread::SimpleWaiterThread(MojoResult* result, uintptr_t* context) 12 : base::SimpleThread("waiter_thread"), result_(result), context_(context) { 13 waiter_.Init(); 14 *result_ = 5420734; // Totally invalid result. 15 *context_ = 23489023; // "Random". 16 } 17 18 SimpleWaiterThread::~SimpleWaiterThread() { 19 Join(); 20 } 21 22 void SimpleWaiterThread::Run() { 23 *result_ = waiter_.Wait(MOJO_DEADLINE_INDEFINITE, context_); 24 } 25 26 WaiterThread::WaiterThread(scoped_refptr<Dispatcher> dispatcher, 27 MojoHandleSignals handle_signals, 28 MojoDeadline deadline, 29 uintptr_t context, 30 bool* did_wait_out, 31 MojoResult* result_out, 32 uintptr_t* context_out, 33 HandleSignalsState* signals_state_out) 34 : base::SimpleThread("waiter_thread"), 35 dispatcher_(dispatcher), 36 handle_signals_(handle_signals), 37 deadline_(deadline), 38 context_(context), 39 did_wait_out_(did_wait_out), 40 result_out_(result_out), 41 context_out_(context_out), 42 signals_state_out_(signals_state_out) { 43 *did_wait_out_ = false; 44 // Initialize these with invalid results (so that we'll be sure to catch any 45 // case where they're not set). 46 *result_out_ = 8542346; 47 *context_out_ = 89023444; 48 *signals_state_out_ = HandleSignalsState(~0u, ~0u); 49 } 50 51 WaiterThread::~WaiterThread() { 52 Join(); 53 } 54 55 void WaiterThread::Run() { 56 waiter_.Init(); 57 58 *result_out_ = dispatcher_->AddAwakable(&waiter_, handle_signals_, context_, 59 signals_state_out_); 60 if (*result_out_ != MOJO_RESULT_OK) 61 return; 62 63 *did_wait_out_ = true; 64 *result_out_ = waiter_.Wait(deadline_, context_out_); 65 dispatcher_->RemoveAwakable(&waiter_, signals_state_out_); 66 } 67 68 } // namespace test 69 } // namespace edk 70 } // namespace mojo 71
