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

Side by Side Diff: mojo/public/c/system/tests/core_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
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 // This file tests the C API. 5 // This file tests the C API.
6 6
7 #include "mojo/public/c/system/core.h" 7 #include "mojo/public/c/system/core.h"
8 8
9 #include <string.h> 9 #include <string.h>
10 10
(...skipping 16 matching lines...) Expand all
27 char buffer[10] = { 0 }; 27 char buffer[10] = { 0 };
28 uint32_t buffer_size; 28 uint32_t buffer_size;
29 void* write_pointer; 29 void* write_pointer;
30 const void* read_pointer; 30 const void* read_pointer;
31 31
32 // Close: 32 // Close:
33 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, MojoClose(MOJO_HANDLE_INVALID)); 33 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, MojoClose(MOJO_HANDLE_INVALID));
34 34
35 // Wait: 35 // Wait:
36 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 36 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
37 MojoWait(MOJO_HANDLE_INVALID, MOJO_WAIT_FLAG_EVERYTHING, 1000000)); 37 MojoWait(MOJO_HANDLE_INVALID, ~MOJO_HANDLE_SIGNAL_NONE, 1000000));
38 h0 = MOJO_HANDLE_INVALID; 38 h0 = MOJO_HANDLE_INVALID;
39 sig = MOJO_WAIT_FLAG_EVERYTHING; 39 sig = ~MOJO_HANDLE_SIGNAL_NONE;
40 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 40 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
41 MojoWaitMany(&h0, &sig, 1, MOJO_DEADLINE_INDEFINITE)); 41 MojoWaitMany(&h0, &sig, 1, MOJO_DEADLINE_INDEFINITE));
42 42
43 // Message pipe: 43 // Message pipe:
44 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 44 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
45 MojoWriteMessage(h0, buffer, 3, NULL, 0, 45 MojoWriteMessage(h0, buffer, 3, NULL, 0,
46 MOJO_WRITE_MESSAGE_FLAG_NONE)); 46 MOJO_WRITE_MESSAGE_FLAG_NONE));
47 buffer_size = static_cast<uint32_t>(sizeof(buffer)); 47 buffer_size = static_cast<uint32_t>(sizeof(buffer));
48 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, 48 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
49 MojoReadMessage(h0, buffer, &buffer_size, NULL, NULL, 49 MojoReadMessage(h0, buffer, &buffer_size, NULL, NULL,
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
82 uint32_t buffer_size; 82 uint32_t buffer_size;
83 83
84 h0 = MOJO_HANDLE_INVALID; 84 h0 = MOJO_HANDLE_INVALID;
85 h1 = MOJO_HANDLE_INVALID; 85 h1 = MOJO_HANDLE_INVALID;
86 EXPECT_EQ(MOJO_RESULT_OK, MojoCreateMessagePipe(NULL, &h0, &h1)); 86 EXPECT_EQ(MOJO_RESULT_OK, MojoCreateMessagePipe(NULL, &h0, &h1));
87 EXPECT_NE(h0, MOJO_HANDLE_INVALID); 87 EXPECT_NE(h0, MOJO_HANDLE_INVALID);
88 EXPECT_NE(h1, MOJO_HANDLE_INVALID); 88 EXPECT_NE(h1, MOJO_HANDLE_INVALID);
89 89
90 // Shouldn't be readable. 90 // Shouldn't be readable.
91 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, 91 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED,
92 MojoWait(h0, MOJO_WAIT_FLAG_READABLE, 0)); 92 MojoWait(h0, MOJO_HANDLE_SIGNAL_READABLE, 0));
93 93
94 // Should be writable. 94 // Should be writable.
95 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(h0, MOJO_WAIT_FLAG_WRITABLE, 0)); 95 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(h0, MOJO_HANDLE_SIGNAL_WRITABLE, 0));
96 96
97 // Try to read. 97 // Try to read.
98 buffer_size = static_cast<uint32_t>(sizeof(buffer)); 98 buffer_size = static_cast<uint32_t>(sizeof(buffer));
99 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, 99 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT,
100 MojoReadMessage(h0, buffer, &buffer_size, NULL, NULL, 100 MojoReadMessage(h0, buffer, &buffer_size, NULL, NULL,
101 MOJO_READ_MESSAGE_FLAG_NONE)); 101 MOJO_READ_MESSAGE_FLAG_NONE));
102 102
103 // Write to |h1|. 103 // Write to |h1|.
104 static const char kHello[] = "hello"; 104 static const char kHello[] = "hello";
105 buffer_size = static_cast<uint32_t>(sizeof(kHello)); 105 buffer_size = static_cast<uint32_t>(sizeof(kHello));
106 EXPECT_EQ(MOJO_RESULT_OK, 106 EXPECT_EQ(MOJO_RESULT_OK,
107 MojoWriteMessage(h1, kHello, buffer_size, NULL, 0, 107 MojoWriteMessage(h1, kHello, buffer_size, NULL, 0,
108 MOJO_WRITE_MESSAGE_FLAG_NONE)); 108 MOJO_WRITE_MESSAGE_FLAG_NONE));
109 109
110 // |h0| should be readable. 110 // |h0| should be readable.
111 sig = MOJO_WAIT_FLAG_READABLE; 111 sig = MOJO_HANDLE_SIGNAL_READABLE;
112 EXPECT_EQ(MOJO_RESULT_OK, 112 EXPECT_EQ(MOJO_RESULT_OK,
113 MojoWaitMany(&h0, &sig, 1, MOJO_DEADLINE_INDEFINITE)); 113 MojoWaitMany(&h0, &sig, 1, MOJO_DEADLINE_INDEFINITE));
114 114
115 // Read from |h0|. 115 // Read from |h0|.
116 buffer_size = static_cast<uint32_t>(sizeof(buffer)); 116 buffer_size = static_cast<uint32_t>(sizeof(buffer));
117 EXPECT_EQ(MOJO_RESULT_OK, 117 EXPECT_EQ(MOJO_RESULT_OK,
118 MojoReadMessage(h0, buffer, &buffer_size, NULL, NULL, 118 MojoReadMessage(h0, buffer, &buffer_size, NULL, NULL,
119 MOJO_READ_MESSAGE_FLAG_NONE)); 119 MOJO_READ_MESSAGE_FLAG_NONE));
120 EXPECT_EQ(static_cast<uint32_t>(sizeof(kHello)), buffer_size); 120 EXPECT_EQ(static_cast<uint32_t>(sizeof(kHello)), buffer_size);
121 EXPECT_STREQ(kHello, buffer); 121 EXPECT_STREQ(kHello, buffer);
122 122
123 // |h0| should no longer be readable. 123 // |h0| should no longer be readable.
124 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, 124 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED,
125 MojoWait(h0, MOJO_WAIT_FLAG_READABLE, 10)); 125 MojoWait(h0, MOJO_HANDLE_SIGNAL_READABLE, 10));
126 126
127 // Close |h0|. 127 // Close |h0|.
128 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(h0)); 128 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(h0));
129 129
130 // |h1| should no longer be readable or writable. 130 // |h1| should no longer be readable or writable.
131 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, 131 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
132 MojoWait(h1, MOJO_WAIT_FLAG_READABLE | MOJO_WAIT_FLAG_WRITABLE, 132 MojoWait(h1,
133 MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE,
133 1000)); 134 1000));
134 135
135 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(h1)); 136 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(h1));
136 } 137 }
137 138
138 TEST(CoreTest, BasicDataPipe) { 139 TEST(CoreTest, BasicDataPipe) {
139 MojoHandle hp, hc; 140 MojoHandle hp, hc;
140 MojoHandleSignals sig; 141 MojoHandleSignals sig;
141 char buffer[20] = { 0 }; 142 char buffer[20] = { 0 };
142 uint32_t buffer_size; 143 uint32_t buffer_size;
143 void* write_pointer; 144 void* write_pointer;
144 const void* read_pointer; 145 const void* read_pointer;
145 146
146 hp = MOJO_HANDLE_INVALID; 147 hp = MOJO_HANDLE_INVALID;
147 hc = MOJO_HANDLE_INVALID; 148 hc = MOJO_HANDLE_INVALID;
148 EXPECT_EQ(MOJO_RESULT_OK, MojoCreateDataPipe(NULL, &hp, &hc)); 149 EXPECT_EQ(MOJO_RESULT_OK, MojoCreateDataPipe(NULL, &hp, &hc));
149 EXPECT_NE(hp, MOJO_HANDLE_INVALID); 150 EXPECT_NE(hp, MOJO_HANDLE_INVALID);
150 EXPECT_NE(hc, MOJO_HANDLE_INVALID); 151 EXPECT_NE(hc, MOJO_HANDLE_INVALID);
151 152
152 // The consumer |hc| shouldn't be readable. 153 // The consumer |hc| shouldn't be readable.
153 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, 154 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED,
154 MojoWait(hc, MOJO_WAIT_FLAG_READABLE, 0)); 155 MojoWait(hc, MOJO_HANDLE_SIGNAL_READABLE, 0));
155 156
156 // The producer |hp| should be writable. 157 // The producer |hp| should be writable.
157 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(hp, MOJO_WAIT_FLAG_WRITABLE, 0)); 158 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(hp, MOJO_HANDLE_SIGNAL_WRITABLE, 0));
158 159
159 // Try to read from |hc|. 160 // Try to read from |hc|.
160 buffer_size = static_cast<uint32_t>(sizeof(buffer)); 161 buffer_size = static_cast<uint32_t>(sizeof(buffer));
161 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, 162 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT,
162 MojoReadData(hc, buffer, &buffer_size, MOJO_READ_DATA_FLAG_NONE)); 163 MojoReadData(hc, buffer, &buffer_size, MOJO_READ_DATA_FLAG_NONE));
163 164
164 // Try to begin a two-phase read from |hc|. 165 // Try to begin a two-phase read from |hc|.
165 read_pointer = NULL; 166 read_pointer = NULL;
166 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, 167 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT,
167 MojoBeginReadData(hc, &read_pointer, &buffer_size, 168 MojoBeginReadData(hc, &read_pointer, &buffer_size,
168 MOJO_READ_DATA_FLAG_NONE)); 169 MOJO_READ_DATA_FLAG_NONE));
169 170
170 // Write to |hp|. 171 // Write to |hp|.
171 static const char kHello[] = "hello "; 172 static const char kHello[] = "hello ";
172 // Don't include terminating null. 173 // Don't include terminating null.
173 buffer_size = static_cast<uint32_t>(strlen(kHello)); 174 buffer_size = static_cast<uint32_t>(strlen(kHello));
174 EXPECT_EQ(MOJO_RESULT_OK, 175 EXPECT_EQ(MOJO_RESULT_OK,
175 MojoWriteData(hp, kHello, &buffer_size, 176 MojoWriteData(hp, kHello, &buffer_size,
176 MOJO_WRITE_MESSAGE_FLAG_NONE)); 177 MOJO_WRITE_MESSAGE_FLAG_NONE));
177 178
178 // |hc| should be(come) readable. 179 // |hc| should be(come) readable.
179 sig = MOJO_WAIT_FLAG_READABLE; 180 sig = MOJO_HANDLE_SIGNAL_READABLE;
180 EXPECT_EQ(MOJO_RESULT_OK, 181 EXPECT_EQ(MOJO_RESULT_OK,
181 MojoWaitMany(&hc, &sig, 1, MOJO_DEADLINE_INDEFINITE)); 182 MojoWaitMany(&hc, &sig, 1, MOJO_DEADLINE_INDEFINITE));
182 183
183 // Do a two-phase write to |hp|. 184 // Do a two-phase write to |hp|.
184 EXPECT_EQ(MOJO_RESULT_OK, 185 EXPECT_EQ(MOJO_RESULT_OK,
185 MojoBeginWriteData(hp, &write_pointer, &buffer_size, 186 MojoBeginWriteData(hp, &write_pointer, &buffer_size,
186 MOJO_WRITE_DATA_FLAG_NONE)); 187 MOJO_WRITE_DATA_FLAG_NONE));
187 static const char kWorld[] = "world"; 188 static const char kWorld[] = "world";
188 ASSERT_GE(buffer_size, sizeof(kWorld)); 189 ASSERT_GE(buffer_size, sizeof(kWorld));
189 // Include the terminating null. 190 // Include the terminating null.
190 memcpy(write_pointer, kWorld, sizeof(kWorld)); 191 memcpy(write_pointer, kWorld, sizeof(kWorld));
191 EXPECT_EQ(MOJO_RESULT_OK, 192 EXPECT_EQ(MOJO_RESULT_OK,
192 MojoEndWriteData(hp, static_cast<uint32_t>(sizeof(kWorld)))); 193 MojoEndWriteData(hp, static_cast<uint32_t>(sizeof(kWorld))));
193 194
194 // Read one character from |hc|. 195 // Read one character from |hc|.
195 memset(buffer, 0, sizeof(buffer)); 196 memset(buffer, 0, sizeof(buffer));
196 buffer_size = 1; 197 buffer_size = 1;
197 EXPECT_EQ(MOJO_RESULT_OK, 198 EXPECT_EQ(MOJO_RESULT_OK,
198 MojoReadData(hc, buffer, &buffer_size, MOJO_READ_DATA_FLAG_NONE)); 199 MojoReadData(hc, buffer, &buffer_size, MOJO_READ_DATA_FLAG_NONE));
199 200
200 // Close |hp|. 201 // Close |hp|.
201 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(hp)); 202 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(hp));
202 203
203 // |hc| should still be readable. 204 // |hc| should still be readable.
204 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(hc, MOJO_WAIT_FLAG_READABLE, 0)); 205 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(hc, MOJO_HANDLE_SIGNAL_READABLE, 0));
205 206
206 // Do a two-phase read from |hc|. 207 // Do a two-phase read from |hc|.
207 read_pointer = NULL; 208 read_pointer = NULL;
208 EXPECT_EQ(MOJO_RESULT_OK, 209 EXPECT_EQ(MOJO_RESULT_OK,
209 MojoBeginReadData(hc, &read_pointer, &buffer_size, 210 MojoBeginReadData(hc, &read_pointer, &buffer_size,
210 MOJO_READ_DATA_FLAG_NONE)); 211 MOJO_READ_DATA_FLAG_NONE));
211 ASSERT_LE(buffer_size, sizeof(buffer) - 1); 212 ASSERT_LE(buffer_size, sizeof(buffer) - 1);
212 memcpy(&buffer[1], read_pointer, buffer_size); 213 memcpy(&buffer[1], read_pointer, buffer_size);
213 EXPECT_EQ(MOJO_RESULT_OK, MojoEndReadData(hc, buffer_size)); 214 EXPECT_EQ(MOJO_RESULT_OK, MojoEndReadData(hc, buffer_size));
214 EXPECT_STREQ("hello world", buffer); 215 EXPECT_STREQ("hello world", buffer);
215 216
216 // |hc| should no longer be readable. 217 // |hc| should no longer be readable.
217 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, 218 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
218 MojoWait(hc, MOJO_WAIT_FLAG_READABLE, 1000)); 219 MojoWait(hc, MOJO_HANDLE_SIGNAL_READABLE, 1000));
219 220
220 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(hc)); 221 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(hc));
221 222
222 // TODO(vtl): Test the other way around -- closing the consumer should make 223 // TODO(vtl): Test the other way around -- closing the consumer should make
223 // the producer never-writable? 224 // the producer never-writable?
224 } 225 }
225 226
226 TEST(CoreTest, BasicSharedBuffer) { 227 TEST(CoreTest, BasicSharedBuffer) {
227 MojoHandle h0, h1; 228 MojoHandle h0, h1;
228 void* pointer; 229 void* pointer;
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after
275 // This checks that things actually work in C (not C++). 276 // This checks that things actually work in C (not C++).
276 TEST(CoreTest, MinimalCTest) { 277 TEST(CoreTest, MinimalCTest) {
277 const char* failure = MinimalCTest(); 278 const char* failure = MinimalCTest();
278 EXPECT_TRUE(failure == NULL) << failure; 279 EXPECT_TRUE(failure == NULL) << failure;
279 } 280 }
280 281
281 // TODO(vtl): Add multi-threaded tests. 282 // TODO(vtl): Add multi-threaded tests.
282 283
283 } // namespace 284 } // namespace
284 } // namespace mojo 285 } // namespace mojo
OLDNEW
« no previous file with comments | « mojo/public/c/system/tests/core_perftest.cc ('k') | mojo/public/c/system/tests/core_unittest_pure_c.c » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698