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

Side by Side Diff: extensions/browser/mojo/stash_backend_unittest.cc

Issue 830593003: Update mojo sdk to rev 9fbbc4f0fef1187312316c0ed992342474e139f1 (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: cherry-pick mojo 9d3b8dd17f12d20035a14737fdc38dd926890ff8 Created 5 years, 11 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
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 "base/bind.h" 5 #include "base/bind.h"
6 #include "base/message_loop/message_loop.h" 6 #include "base/message_loop/message_loop.h"
7 #include "base/run_loop.h" 7 #include "base/run_loop.h"
8 #include "extensions/browser/mojo/stash_backend.h" 8 #include "extensions/browser/mojo/stash_backend.h"
9 #include "testing/gtest/include/gtest/gtest.h" 9 #include "testing/gtest/include/gtest/gtest.h"
10 10
(...skipping 112 matching lines...) Expand 10 before | Expand all | Expand 10 after
123 stashed_objects.push_back(stashed_object.Pass()); 123 stashed_objects.push_back(stashed_object.Pass());
124 stash_service_->AddToStash(stashed_objects.Pass()); 124 stash_service_->AddToStash(stashed_objects.Pass());
125 stashed_objects = RetrieveStash(); 125 stashed_objects = RetrieveStash();
126 ASSERT_EQ(1u, stashed_objects.size()); 126 ASSERT_EQ(1u, stashed_objects.size());
127 EXPECT_EQ("test type", stashed_objects[0]->id); 127 EXPECT_EQ("test type", stashed_objects[0]->id);
128 ASSERT_EQ(2u, stashed_objects[0]->stashed_handles.size()); 128 ASSERT_EQ(2u, stashed_objects[0]->stashed_handles.size());
129 129
130 consumer = mojo::ScopedDataPipeConsumerHandle::From( 130 consumer = mojo::ScopedDataPipeConsumerHandle::From(
131 stashed_objects[0]->stashed_handles[1].Pass()); 131 stashed_objects[0]->stashed_handles[1].Pass());
132 result = mojo::Wait( 132 result = mojo::Wait(
133 consumer.get(), MOJO_HANDLE_SIGNAL_READABLE, MOJO_DEADLINE_INDEFINITE); 133 consumer.get(), MOJO_HANDLE_SIGNAL_READABLE, MOJO_DEADLINE_INDEFINITE,
134 nullptr);
134 ASSERT_EQ(MOJO_RESULT_OK, result); 135 ASSERT_EQ(MOJO_RESULT_OK, result);
135 char data = '\0'; 136 char data = '\0';
136 result = mojo::ReadDataRaw( 137 result = mojo::ReadDataRaw(
137 consumer.get(), &data, &num_bytes, MOJO_READ_DATA_FLAG_ALL_OR_NONE); 138 consumer.get(), &data, &num_bytes, MOJO_READ_DATA_FLAG_ALL_OR_NONE);
138 ASSERT_EQ(MOJO_RESULT_OK, result); 139 ASSERT_EQ(MOJO_RESULT_OK, result);
139 ASSERT_EQ(1u, num_bytes); 140 ASSERT_EQ(1u, num_bytes);
140 EXPECT_EQ('1', data); 141 EXPECT_EQ('1', data);
141 } 142 }
142 143
143 TEST_F(StashServiceTest, RetrieveWithoutStashing) { 144 TEST_F(StashServiceTest, RetrieveWithoutStashing) {
(...skipping 16 matching lines...) Expand all
160 stashed_object->stashed_handles.push_back( 161 stashed_object->stashed_handles.push_back(
161 mojo::ScopedHandle::From(message_pipe.handle0.Pass())); 162 mojo::ScopedHandle::From(message_pipe.handle0.Pass()));
162 stashed_objects.push_back(stashed_object.Pass()); 163 stashed_objects.push_back(stashed_object.Pass());
163 stash_service_->AddToStash(stashed_objects.Pass()); 164 stash_service_->AddToStash(stashed_objects.Pass());
164 stashed_objects = RetrieveStash(); 165 stashed_objects = RetrieveStash();
165 ASSERT_EQ(0u, stashed_objects.size()); 166 ASSERT_EQ(0u, stashed_objects.size());
166 // Check that the stashed handle has been closed. 167 // Check that the stashed handle has been closed.
167 MojoResult result = 168 MojoResult result =
168 mojo::Wait(message_pipe.handle1.get(), 169 mojo::Wait(message_pipe.handle1.get(),
169 MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_READABLE, 170 MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_READABLE,
170 MOJO_DEADLINE_INDEFINITE); 171 MOJO_DEADLINE_INDEFINITE, nullptr);
171 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, result); 172 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, result);
172 } 173 }
173 174
174 } // namespace extensions 175 } // namespace extensions
OLDNEW
« no previous file with comments | « build/android/findbugs_filter/findbugs_known_bugs.txt ('k') | ipc/mojo/async_handle_waiter_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698