| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 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 | 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 #include "mojo/system/dispatcher.h" | 5 #include "mojo/system/dispatcher.h" |
| 6 | 6 |
| 7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
| 8 #include "base/memory/ref_counted.h" | 8 #include "base/memory/ref_counted.h" |
| 9 #include "base/memory/scoped_vector.h" | 9 #include "base/memory/scoped_vector.h" |
| 10 #include "base/synchronization/waitable_event.h" | 10 #include "base/synchronization/waitable_event.h" |
| (...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 52 d->ReadMessage(NullUserPointer(), NullUserPointer(), NULL, NULL, | 52 d->ReadMessage(NullUserPointer(), NullUserPointer(), NULL, NULL, |
| 53 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 53 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 54 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 54 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 55 d->WriteData(NULL, NULL, MOJO_WRITE_DATA_FLAG_NONE)); | 55 d->WriteData(NULL, NULL, MOJO_WRITE_DATA_FLAG_NONE)); |
| 56 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 56 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 57 d->BeginWriteData(NullUserPointer(), NullUserPointer(), | 57 d->BeginWriteData(NullUserPointer(), NullUserPointer(), |
| 58 MOJO_WRITE_DATA_FLAG_NONE)); | 58 MOJO_WRITE_DATA_FLAG_NONE)); |
| 59 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 59 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 60 d->EndWriteData(0)); | 60 d->EndWriteData(0)); |
| 61 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 61 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 62 d->ReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE)); | 62 d->ReadData(NullUserPointer(), NullUserPointer(), |
| 63 MOJO_READ_DATA_FLAG_NONE)); |
| 63 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 64 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 64 d->BeginReadData(NullUserPointer(), NullUserPointer(), | 65 d->BeginReadData(NullUserPointer(), NullUserPointer(), |
| 65 MOJO_READ_DATA_FLAG_NONE)); | 66 MOJO_READ_DATA_FLAG_NONE)); |
| 66 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 67 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 67 d->EndReadData(0)); | 68 d->EndReadData(0)); |
| 68 Waiter w; | 69 Waiter w; |
| 69 w.Init(); | 70 w.Init(); |
| 70 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 71 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 71 d->AddWaiter(&w, ~MOJO_HANDLE_SIGNAL_NONE, 0)); | 72 d->AddWaiter(&w, ~MOJO_HANDLE_SIGNAL_NONE, 0)); |
| 72 // Okay to remove even if it wasn't added (or was already removed). | 73 // Okay to remove even if it wasn't added (or was already removed). |
| 73 d->RemoveWaiter(&w); | 74 d->RemoveWaiter(&w); |
| 74 d->RemoveWaiter(&w); | 75 d->RemoveWaiter(&w); |
| 75 | 76 |
| 76 EXPECT_EQ(MOJO_RESULT_OK, d->Close()); | 77 EXPECT_EQ(MOJO_RESULT_OK, d->Close()); |
| 77 | 78 |
| 78 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 79 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 79 d->WriteMessage(NullUserPointer(), 0, NULL, | 80 d->WriteMessage(NullUserPointer(), 0, NULL, |
| 80 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 81 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 81 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 82 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 82 d->ReadMessage(NullUserPointer(), NullUserPointer(), NULL, NULL, | 83 d->ReadMessage(NullUserPointer(), NullUserPointer(), NULL, NULL, |
| 83 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 84 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 84 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 85 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 85 d->WriteData(NULL, NULL, MOJO_WRITE_DATA_FLAG_NONE)); | 86 d->WriteData(NULL, NULL, MOJO_WRITE_DATA_FLAG_NONE)); |
| 86 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 87 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 87 d->BeginWriteData(NullUserPointer(), NullUserPointer(), | 88 d->BeginWriteData(NullUserPointer(), NullUserPointer(), |
| 88 MOJO_WRITE_DATA_FLAG_NONE)); | 89 MOJO_WRITE_DATA_FLAG_NONE)); |
| 89 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 90 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 90 d->EndWriteData(0)); | 91 d->EndWriteData(0)); |
| 91 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 92 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 92 d->ReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE)); | 93 d->ReadData(NullUserPointer(), NullUserPointer(), |
| 94 MOJO_READ_DATA_FLAG_NONE)); |
| 93 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 95 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 94 d->BeginReadData(NullUserPointer(), NullUserPointer(), | 96 d->BeginReadData(NullUserPointer(), NullUserPointer(), |
| 95 MOJO_READ_DATA_FLAG_NONE)); | 97 MOJO_READ_DATA_FLAG_NONE)); |
| 96 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 98 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 97 d->EndReadData(0)); | 99 d->EndReadData(0)); |
| 98 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 100 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 99 d->AddWaiter(&w, ~MOJO_HANDLE_SIGNAL_NONE, 0)); | 101 d->AddWaiter(&w, ~MOJO_HANDLE_SIGNAL_NONE, 0)); |
| 100 d->RemoveWaiter(&w); | 102 d->RemoveWaiter(&w); |
| 101 } | 103 } |
| 102 | 104 |
| (...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 168 dispatcher_->BeginWriteData(NullUserPointer(), | 170 dispatcher_->BeginWriteData(NullUserPointer(), |
| 169 NullUserPointer(), | 171 NullUserPointer(), |
| 170 MOJO_WRITE_DATA_FLAG_NONE)); | 172 MOJO_WRITE_DATA_FLAG_NONE)); |
| 171 break; | 173 break; |
| 172 case END_WRITE_DATA: | 174 case END_WRITE_DATA: |
| 173 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 175 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 174 dispatcher_->EndWriteData(0)); | 176 dispatcher_->EndWriteData(0)); |
| 175 break; | 177 break; |
| 176 case READ_DATA: | 178 case READ_DATA: |
| 177 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 179 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 178 dispatcher_->ReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE)); | 180 dispatcher_->ReadData(NullUserPointer(), NullUserPointer(), |
| 181 MOJO_READ_DATA_FLAG_NONE)); |
| 179 break; | 182 break; |
| 180 case BEGIN_READ_DATA: | 183 case BEGIN_READ_DATA: |
| 181 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 184 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 182 dispatcher_->BeginReadData(NullUserPointer(), | 185 dispatcher_->BeginReadData(NullUserPointer(), |
| 183 NullUserPointer(), | 186 NullUserPointer(), |
| 184 MOJO_READ_DATA_FLAG_NONE)); | 187 MOJO_READ_DATA_FLAG_NONE)); |
| 185 break; | 188 break; |
| 186 case END_READ_DATA: | 189 case END_READ_DATA: |
| 187 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 190 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 188 dispatcher_->EndReadData(0)); | 191 dispatcher_->EndReadData(0)); |
| (...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 275 event.Signal(); // Kicks off real work on the threads. | 278 event.Signal(); // Kicks off real work on the threads. |
| 276 } // Joins all the threads. | 279 } // Joins all the threads. |
| 277 | 280 |
| 278 EXPECT_EQ(MOJO_RESULT_OK, d->Close()); | 281 EXPECT_EQ(MOJO_RESULT_OK, d->Close()); |
| 279 } | 282 } |
| 280 } | 283 } |
| 281 | 284 |
| 282 } // namespace | 285 } // namespace |
| 283 } // namespace system | 286 } // namespace system |
| 284 } // namespace mojo | 287 } // namespace mojo |
| OLD | NEW |