OLD | NEW |
| (Empty) |
1 // Copyright (c) 2012 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/shell/domain_socket/test_completion_callback.h" | |
6 | |
7 #include "base/bind.h" | |
8 #include "base/bind_helpers.h" | |
9 #include "base/compiler_specific.h" | |
10 #include "base/message_loop/message_loop.h" | |
11 | |
12 namespace mojo { | |
13 namespace shell { | |
14 | |
15 namespace internal { | |
16 | |
17 void TestCompletionCallbackBaseInternal::DidSetResult() { | |
18 have_result_ = true; | |
19 if (waiting_for_result_) | |
20 base::MessageLoop::current()->Quit(); | |
21 } | |
22 | |
23 void TestCompletionCallbackBaseInternal::WaitForResult() { | |
24 DCHECK(!waiting_for_result_); | |
25 while (!have_result_) { | |
26 waiting_for_result_ = true; | |
27 base::MessageLoop::current()->Run(); | |
28 waiting_for_result_ = false; | |
29 } | |
30 have_result_ = false; // Auto-reset for next callback. | |
31 } | |
32 | |
33 TestCompletionCallbackBaseInternal::TestCompletionCallbackBaseInternal() | |
34 : have_result_(false), waiting_for_result_(false) { | |
35 } | |
36 | |
37 } // namespace internal | |
38 | |
39 TestCompletionCallback::TestCompletionCallback() | |
40 : callback_(base::Bind(&TestCompletionCallback::SetResult, | |
41 base::Unretained(this))) { | |
42 } | |
43 | |
44 TestCompletionCallback::~TestCompletionCallback() { | |
45 } | |
46 | |
47 TestInt64CompletionCallback::TestInt64CompletionCallback() | |
48 : callback_(base::Bind(&TestInt64CompletionCallback::SetResult, | |
49 base::Unretained(this))) { | |
50 } | |
51 | |
52 TestInt64CompletionCallback::~TestInt64CompletionCallback() { | |
53 } | |
54 | |
55 } // namespace net | |
56 } // namespace net | |
OLD | NEW |