Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(11)

Side by Side Diff: mojo/system/dispatcher_unittest.cc

Issue 336313007: Mojo: Rename MOJO_WAIT_FLAG_... -> MOJO_HANDLE_SIGNAL_.... (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebased Created 6 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « mojo/system/data_pipe.cc ('k') | mojo/system/local_data_pipe.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 46 matching lines...) Expand 10 before | Expand all | Expand 10 after
57 d->EndWriteData(0)); 57 d->EndWriteData(0));
58 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 58 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
59 d->ReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE)); 59 d->ReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE));
60 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 60 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
61 d->BeginReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE)); 61 d->BeginReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE));
62 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 62 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
63 d->EndReadData(0)); 63 d->EndReadData(0));
64 Waiter w; 64 Waiter w;
65 w.Init(); 65 w.Init();
66 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, 66 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
67 d->AddWaiter(&w, MOJO_WAIT_FLAG_EVERYTHING, 0)); 67 d->AddWaiter(&w, ~MOJO_HANDLE_SIGNAL_NONE, 0));
68 // Okay to remove even if it wasn't added (or was already removed). 68 // Okay to remove even if it wasn't added (or was already removed).
69 d->RemoveWaiter(&w); 69 d->RemoveWaiter(&w);
70 d->RemoveWaiter(&w); 70 d->RemoveWaiter(&w);
71 71
72 EXPECT_EQ(MOJO_RESULT_OK, d->Close()); 72 EXPECT_EQ(MOJO_RESULT_OK, d->Close());
73 73
74 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 74 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
75 d->WriteMessage(NULL, 0, NULL, MOJO_WRITE_MESSAGE_FLAG_NONE)); 75 d->WriteMessage(NULL, 0, NULL, MOJO_WRITE_MESSAGE_FLAG_NONE));
76 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 76 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
77 d->ReadMessage(NULL, NULL, NULL, NULL, 77 d->ReadMessage(NULL, NULL, NULL, NULL,
78 MOJO_WRITE_MESSAGE_FLAG_NONE)); 78 MOJO_WRITE_MESSAGE_FLAG_NONE));
79 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 79 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
80 d->WriteData(NULL, NULL, MOJO_WRITE_DATA_FLAG_NONE)); 80 d->WriteData(NULL, NULL, MOJO_WRITE_DATA_FLAG_NONE));
81 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 81 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
82 d->BeginWriteData(NULL, NULL, MOJO_WRITE_DATA_FLAG_NONE)); 82 d->BeginWriteData(NULL, NULL, MOJO_WRITE_DATA_FLAG_NONE));
83 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 83 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
84 d->EndWriteData(0)); 84 d->EndWriteData(0));
85 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 85 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
86 d->ReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE)); 86 d->ReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE));
87 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 87 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
88 d->BeginReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE)); 88 d->BeginReadData(NULL, NULL, MOJO_READ_DATA_FLAG_NONE));
89 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 89 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
90 d->EndReadData(0)); 90 d->EndReadData(0));
91 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 91 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
92 d->AddWaiter(&w, MOJO_WAIT_FLAG_EVERYTHING, 0)); 92 d->AddWaiter(&w, ~MOJO_HANDLE_SIGNAL_NONE, 0));
93 d->RemoveWaiter(&w); 93 d->RemoveWaiter(&w);
94 } 94 }
95 95
96 class ThreadSafetyStressThread : public base::SimpleThread { 96 class ThreadSafetyStressThread : public base::SimpleThread {
97 public: 97 public:
98 enum DispatcherOp { 98 enum DispatcherOp {
99 CLOSE = 0, 99 CLOSE = 0,
100 WRITE_MESSAGE, 100 WRITE_MESSAGE,
101 READ_MESSAGE, 101 READ_MESSAGE,
102 WRITE_DATA, 102 WRITE_DATA,
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after
185 } 185 }
186 case MAP_BUFFER: { 186 case MAP_BUFFER: {
187 scoped_ptr<RawSharedBufferMapping> unused; 187 scoped_ptr<RawSharedBufferMapping> unused;
188 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 188 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
189 dispatcher_->MapBuffer(0u, 0u, MOJO_MAP_BUFFER_FLAG_NONE, 189 dispatcher_->MapBuffer(0u, 0u, MOJO_MAP_BUFFER_FLAG_NONE,
190 &unused)); 190 &unused));
191 break; 191 break;
192 } 192 }
193 case ADD_WAITER: { 193 case ADD_WAITER: {
194 MojoResult r = dispatcher_->AddWaiter(&waiter_, 194 MojoResult r = dispatcher_->AddWaiter(&waiter_,
195 MOJO_WAIT_FLAG_EVERYTHING, 0); 195 ~MOJO_HANDLE_SIGNAL_NONE, 0);
196 EXPECT_TRUE(r == MOJO_RESULT_FAILED_PRECONDITION || 196 EXPECT_TRUE(r == MOJO_RESULT_FAILED_PRECONDITION ||
197 r == MOJO_RESULT_INVALID_ARGUMENT); 197 r == MOJO_RESULT_INVALID_ARGUMENT);
198 break; 198 break;
199 } 199 }
200 case REMOVE_WAITER: 200 case REMOVE_WAITER:
201 dispatcher_->RemoveWaiter(&waiter_); 201 dispatcher_->RemoveWaiter(&waiter_);
202 break; 202 break;
203 default: 203 default:
204 NOTREACHED(); 204 NOTREACHED();
205 break; 205 break;
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after
265 event.Signal(); // Kicks off real work on the threads. 265 event.Signal(); // Kicks off real work on the threads.
266 } // Joins all the threads. 266 } // Joins all the threads.
267 267
268 EXPECT_EQ(MOJO_RESULT_OK, d->Close()); 268 EXPECT_EQ(MOJO_RESULT_OK, d->Close());
269 } 269 }
270 } 270 }
271 271
272 } // namespace 272 } // namespace
273 } // namespace system 273 } // namespace system
274 } // namespace mojo 274 } // namespace mojo
OLDNEW
« no previous file with comments | « mojo/system/data_pipe.cc ('k') | mojo/system/local_data_pipe.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698