| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef NET_BASE_TEST_COMPLETION_CALLBACK_H_ | 5 #ifndef NET_BASE_TEST_COMPLETION_CALLBACK_H_ |
| 6 #define NET_BASE_TEST_COMPLETION_CALLBACK_H_ | 6 #define NET_BASE_TEST_COMPLETION_CALLBACK_H_ |
| 7 | 7 |
| 8 #include "base/callback.h" | 8 #include "base/callback.h" |
| 9 #include "base/compiler_specific.h" | 9 #include "base/compiler_specific.h" |
| 10 #include "base/memory/scoped_ptr.h" |
| 10 #include "net/base/completion_callback.h" | 11 #include "net/base/completion_callback.h" |
| 11 #include "net/base/net_errors.h" | 12 #include "net/base/net_errors.h" |
| 12 | 13 |
| 13 //----------------------------------------------------------------------------- | 14 //----------------------------------------------------------------------------- |
| 14 // completion callback helper | 15 // completion callback helper |
| 15 | 16 |
| 16 // A helper class for completion callbacks, designed to make it easy to run | 17 // A helper class for completion callbacks, designed to make it easy to run |
| 17 // tests involving asynchronous operations. Just call WaitForResult to wait | 18 // tests involving asynchronous operations. Just call WaitForResult to wait |
| 18 // for the asynchronous operation to complete. | 19 // for the asynchronous operation to complete. Uses a RunLoop to spin the |
| 20 // current MessageLoop while waiting. The callback must be invoked on the same |
| 21 // thread WaitForResult is called on. |
| 19 // | 22 // |
| 20 // NOTE: Since this runs a message loop to wait for the completion callback, | 23 // NOTE: Since this runs a message loop to wait for the completion callback, |
| 21 // there could be other side-effects resulting from WaitForResult. For this | 24 // there could be other side-effects resulting from WaitForResult. For this |
| 22 // reason, this class is probably not ideal for a general application. | 25 // reason, this class is probably not ideal for a general application. |
| 23 // | 26 // |
| 27 namespace base { |
| 28 class RunLoop; |
| 29 } |
| 24 | 30 |
| 25 namespace net { | 31 namespace net { |
| 26 | 32 |
| 27 class IOBuffer; | 33 class IOBuffer; |
| 28 | 34 |
| 29 namespace internal { | 35 namespace internal { |
| 30 | 36 |
| 31 class TestCompletionCallbackBaseInternal { | 37 class TestCompletionCallbackBaseInternal { |
| 32 public: | 38 public: |
| 33 bool have_result() const { return have_result_; } | 39 bool have_result() const { return have_result_; } |
| 34 | 40 |
| 35 protected: | 41 protected: |
| 36 TestCompletionCallbackBaseInternal(); | 42 TestCompletionCallbackBaseInternal(); |
| 37 virtual ~TestCompletionCallbackBaseInternal(); | 43 virtual ~TestCompletionCallbackBaseInternal(); |
| 38 | 44 |
| 39 void DidSetResult(); | 45 void DidSetResult(); |
| 40 void WaitForResult(); | 46 void WaitForResult(); |
| 41 | 47 |
| 48 private: |
| 49 // RunLoop. Only non-NULL during the call to WaitForResult, so the class is |
| 50 // reusable. |
| 51 scoped_ptr<base::RunLoop> run_loop_; |
| 42 bool have_result_; | 52 bool have_result_; |
| 43 bool waiting_for_result_; | |
| 44 | 53 |
| 45 private: | |
| 46 DISALLOW_COPY_AND_ASSIGN(TestCompletionCallbackBaseInternal); | 54 DISALLOW_COPY_AND_ASSIGN(TestCompletionCallbackBaseInternal); |
| 47 }; | 55 }; |
| 48 | 56 |
| 49 template <typename R> | 57 template <typename R> |
| 50 class TestCompletionCallbackTemplate | 58 class TestCompletionCallbackTemplate |
| 51 : public TestCompletionCallbackBaseInternal { | 59 : public TestCompletionCallbackBaseInternal { |
| 52 public: | 60 public: |
| 53 virtual ~TestCompletionCallbackTemplate() override {} | 61 virtual ~TestCompletionCallbackTemplate() override {} |
| 54 | 62 |
| 55 R WaitForResult() { | 63 R WaitForResult() { |
| 56 TestCompletionCallbackBaseInternal::WaitForResult(); | 64 TestCompletionCallbackBaseInternal::WaitForResult(); |
| 57 return result_; | 65 return result_; |
| 58 } | 66 } |
| 59 | 67 |
| 60 R GetResult(R result) { | 68 R GetResult(R result) { |
| 61 if (ERR_IO_PENDING != result) | 69 if (ERR_IO_PENDING != result) |
| 62 return result; | 70 return result; |
| 63 return WaitForResult(); | 71 return WaitForResult(); |
| 64 } | 72 } |
| 65 | 73 |
| 66 protected: | 74 protected: |
| 75 TestCompletionCallbackTemplate() : result_(R()) {} |
| 76 |
| 67 // Override this method to gain control as the callback is running. | 77 // Override this method to gain control as the callback is running. |
| 68 virtual void SetResult(R result) { | 78 virtual void SetResult(R result) { |
| 69 result_ = result; | 79 result_ = result; |
| 70 DidSetResult(); | 80 DidSetResult(); |
| 71 } | 81 } |
| 72 | 82 |
| 73 TestCompletionCallbackTemplate() : result_(R()) {} | 83 private: |
| 74 R result_; | 84 R result_; |
| 75 | 85 |
| 76 private: | |
| 77 DISALLOW_COPY_AND_ASSIGN(TestCompletionCallbackTemplate); | 86 DISALLOW_COPY_AND_ASSIGN(TestCompletionCallbackTemplate); |
| 78 }; | 87 }; |
| 79 | 88 |
| 80 } // namespace internal | 89 } // namespace internal |
| 81 | 90 |
| 82 class TestClosure | 91 class TestClosure : public internal::TestCompletionCallbackBaseInternal { |
| 83 : public internal::TestCompletionCallbackBaseInternal { | |
| 84 public: | 92 public: |
| 85 using internal::TestCompletionCallbackBaseInternal::WaitForResult; | 93 using internal::TestCompletionCallbackBaseInternal::WaitForResult; |
| 86 | 94 |
| 87 TestClosure(); | 95 TestClosure(); |
| 88 ~TestClosure() override; | 96 ~TestClosure() override; |
| 89 | 97 |
| 90 const base::Closure& closure() const { return closure_; } | 98 const base::Closure& closure() const { return closure_; } |
| 91 | 99 |
| 92 private: | 100 private: |
| 93 const base::Closure closure_; | 101 const base::Closure closure_; |
| (...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 137 private: | 145 private: |
| 138 void SetResult(int result) override; | 146 void SetResult(int result) override; |
| 139 | 147 |
| 140 IOBuffer* buffer_; | 148 IOBuffer* buffer_; |
| 141 DISALLOW_COPY_AND_ASSIGN(ReleaseBufferCompletionCallback); | 149 DISALLOW_COPY_AND_ASSIGN(ReleaseBufferCompletionCallback); |
| 142 }; | 150 }; |
| 143 | 151 |
| 144 } // namespace net | 152 } // namespace net |
| 145 | 153 |
| 146 #endif // NET_BASE_TEST_COMPLETION_CALLBACK_H_ | 154 #endif // NET_BASE_TEST_COMPLETION_CALLBACK_H_ |
| OLD | NEW |